Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2021 Changes in this version + const EthTxAttemptBroadcast + const EthTxAttemptInProgress + const EthTxAttemptInsufficientEth + const EthTxConfirmed + const EthTxConfirmedMissingReceipt + const EthTxFatalError + const EthTxInProgress + const EthTxUnconfirmed + const EthTxUnstarted + const FunctionSelectorLength + const InitiatorCron + const InitiatorEthLog + const InitiatorExternal + const InitiatorFluxMonitor + const InitiatorRandomnessLog + const InitiatorRunAt + const InitiatorRunLog + const InitiatorServiceAgreementExecutionLog + const InitiatorWeb + const MaxBcryptPasswordLength + const RequestLogTopicJobID + const RequestLogTopicPayment + const RequestLogTopicRequester + const RequestLogTopicSignature + const ResultCollectionKey + const ResultKey + const RunStatusCancelled + const RunStatusCompleted + const RunStatusErrored + const RunStatusInProgress + const RunStatusPendingBridge + const RunStatusPendingConnection + const RunStatusPendingIncomingConfirmations + const RunStatusPendingOutgoingConfirmations + const RunStatusPendingSleep + const RunStatusUnstarted + const SignatureLength + var AdamoracleFulfilledTopic = utils.MustHash("AdamoracleFulfilled(bytes32)") + var CronParser cron.Parser + var LogBasedAdamoracleJobInitiators = []string + var NilJobID = JobID + var OracleFulfillmentFunctionID20190128withoutCast = utils.MustHash("fulfillOracleRequest(bytes32,uint256,address,bytes4,uint256,bytes32)").Hex()[:10] + var OracleFulfillmentFunctionID2020 = utils.MustHash("fulfillOracleRequest2(bytes32,uint256,address,bytes4,uint256,bytes)").Hex()[:10] + var RandomnessRequestLogTopic = VRFRandomnessRequestLogTopic() + var RunLogTopic20190207withoutIndexes = utils.MustHash(...) + var TopicsForInitiatorsWhichRequireJobSpecIDTopic = map[string][]common.Hash + var WeiPerEth = new(big.Int).Exp(big.NewInt(10), big.NewInt(18), nil) + func AuthenticateBridgeType(bt *BridgeType, token string) (bool, error) + func AuthenticateExternalInitiator(eia *auth.Token, ea *ExternalInitiator) (bool, error) + func AuthenticateUserByToken(token *auth.Token, user *User) (bool, error) + func CoerceInterfaceMapToStringMap(in interface{}) (interface{}, error) + func FilterQueryFactory(i Initiator, from *big.Int, addresses ...common.Address) (q ethereum.FilterQuery, err error) + func HexToInt64(input interface{}) int64 + func IDToHexTopic(id JobID) common.Hash + func IDToTopic(id JobID) common.Hash + func Int64ToHex(n int64) string + func JobSpecIDTopics(jsID JobID) []common.Hash + func MarshalBridgeMetaData(latestAnswer *big.Int, updatedAt *big.Int) (map[string]interface{}, error) + func MarshalToMap(input interface{}) (map[string]interface{}, error) + func NewBridgeType(btr *BridgeTypeRequest) (*BridgeTypeAuthentication, *BridgeType, error) + func NewDatabaseAccessError(msg string) error + func NewValidationError(msg string, values ...interface{}) error + func ReceiptIndicatesRunLogFulfillment(txr types.Receipt) bool + func ReceiptIsUnconfirmed(txr *types.Receipt) bool + func VRFCoordinatorABI() abi.ABI + func VRFFulfillMethod() abi.Method + func VRFFulfillSelector() string + func VRFRandomnessRequestLogTopic() common.Hash + func ValidateBulkDeleteRunRequest(request *BulkDeleteRunRequest) error + type AddressCollection []common.Address + func (r *AddressCollection) Scan(value interface{}) error + func (r AddressCollection) ToStrings() []string + func (r AddressCollection) Value() (driver.Value, error) + type AnyTime struct + Valid bool + func NewAnyTime(t time.Time) AnyTime + func (t *AnyTime) Scan(value interface{}) error + func (t *AnyTime) UnmarshalJSON(b []byte) error + func (t *AnyTime) UnmarshalText(text []byte) error + func (t AnyTime) MarshalJSON() ([]byte, error) + func (t AnyTime) MarshalText() ([]byte, error) + func (t AnyTime) Value() (driver.Value, error) + type Block struct + Hash common.Hash + Number int64 + ParentHash common.Hash + Transactions []types.Transaction + func (b *Block) UnmarshalJSON(data []byte) error + func (b Block) MarshalJSON() ([]byte, error) + type BridgeMetaData struct + LatestAnswer *big.Int + UpdatedAt *big.Int + type BridgeMetaDataJSON struct + Meta BridgeMetaData + type BridgeRunResult struct + AccessToken string + Data JSON + ErrorMessage null.String + ExternalPending bool + Status RunStatus + func (brr *BridgeRunResult) UnmarshalJSON(input []byte) error + func (brr BridgeRunResult) GetError() error + func (brr BridgeRunResult) HasError() bool + type BridgeType struct + Confirmations uint32 + CreatedAt time.Time + IncomingTokenHash string + MinimumContractPayment *assets.Adam + Name TaskType + OutgoingToken string + Salt string + URL WebURL + UpdatedAt time.Time + type BridgeTypeAuthentication struct + Confirmations uint32 + IncomingToken string + MinimumContractPayment *assets.Adam + Name TaskType + OutgoingToken string + URL WebURL + type BridgeTypeRequest struct + Confirmations uint32 + MinimumContractPayment *assets.Adam + Name TaskType + URL WebURL + func (bt *BridgeTypeRequest) SetID(value string) error + func (bt BridgeTypeRequest) GetID() string + func (bt BridgeTypeRequest) GetName() string + type BulkDeleteRunRequest struct + ID uint + Status RunStatusCollection + UpdatedBefore time.Time + type ChangeAuthTokenRequest struct + Password string + type Configuration struct + CreatedAt time.Time + DeletedAt *gorm.DeletedAt + ID int64 + Name string + UpdatedAt time.Time + Value string + type CreateJobSpecRequest struct + TOML string + type Cron string + func (c *Cron) UnmarshalJSON(b []byte) error + func (c Cron) String() string + type DatabaseAccessError struct + func (e *DatabaseAccessError) Error() string + type Duration struct + func MakeDuration(d time.Duration) (Duration, error) + func MustMakeDuration(d time.Duration) Duration + func (d *Duration) Scan(v interface{}) (err error) + func (d *Duration) UnmarshalJSON(input []byte) error + func (d Duration) Before(t time.Time) time.Time + func (d Duration) Duration() time.Duration + func (d Duration) IsInstant() bool + func (d Duration) MarshalJSON() ([]byte, error) + func (d Duration) Shorter(od Duration) bool + func (d Duration) String() string + func (d Duration) Value() (driver.Value, error) + type EIP55Address string + func EIP55AddressFromAddress(a common.Address) (EIP55Address, error) + func NewEIP55Address(s string) (EIP55Address, error) + func (a *EIP55Address) Scan(value interface{}) error + func (a *EIP55Address) UnmarshalJSON(input []byte) error + func (a *EIP55Address) UnmarshalText(input []byte) error + func (a EIP55Address) Address() common.Address + func (a EIP55Address) Big() *big.Int + func (a EIP55Address) Bytes() []byte + func (a EIP55Address) Format(s fmt.State, c rune) + func (a EIP55Address) Hash() common.Hash + func (a EIP55Address) Hex() string + func (a EIP55Address) String() string + func (a EIP55Address) Value() (driver.Value, error) + type EIP55AddressCollection []EIP55Address + func (c *EIP55AddressCollection) Scan(value interface{}) error + func (c EIP55AddressCollection) Value() (driver.Value, error) + type Encumbrance struct + AggFulfillSelector FunctionSelector + AggInitiateJobSelector FunctionSelector + Aggregator EIP55Address + CreatedAt time.Time + EndAt AnyTime + Expiration uint64 + ID int64 + Oracles EIP55AddressCollection + Payment *assets.Adam + UpdatedAt time.Time + func (e Encumbrance) ABI(digest common.Hash) ([]byte, error) + type EthLogEvent struct + type EthReceipt struct + BlockHash common.Hash + BlockNumber int64 + CreatedAt time.Time + ID int64 + Receipt []byte + TransactionIndex uint + TxHash common.Hash + type EthTaskRunTx struct + EthTx EthTx + EthTxID int64 + TaskRunID uuid.UUID + type EthTx struct + BroadcastAt *time.Time + CreatedAt time.Time + EncodedPayload []byte + Error *string + EthTxAttempts []EthTxAttempt + FromAddress common.Address + GasLimit uint64 + ID int64 + Nonce *int64 + State EthTxState + ToAddress common.Address + Value assets.Eth + func (e EthTx) GetError() error + func (e EthTx) GetID() string + type EthTxAttempt struct + BroadcastBeforeBlockNum *int64 + CreatedAt time.Time + EthReceipts []EthReceipt + EthTx EthTx + EthTxID int64 + GasPrice utils.Big + Hash common.Hash + ID int64 + SignedRawTx []byte + State EthTxAttemptState + func (a EthTxAttempt) GetSignedTx() (*types.Transaction, error) + type EthTxAttemptState string + type EthTxState string + type ExternalInitiator struct + AccessKey string + CreatedAt time.Time + HashedSecret string + ID int64 + Name string + OutgoingSecret string + OutgoingToken string + Salt string + URL *WebURL + UpdatedAt time.Time + func NewExternalInitiator(eia *auth.Token, eir *ExternalInitiatorRequest) (*ExternalInitiator, error) + type ExternalInitiatorRequest struct + Name string + URL *WebURL + type Feeds = JSON + type FluxMonitorRoundStats struct + Aggregator common.Address + ID uint64 + JobRunID uuid.NullUUID + NumNewRoundLogs uint64 + NumSubmissions uint64 + RoundID uint32 + type FunctionSelector [FunctionSelectorLength]byte + func BytesToFunctionSelector(b []byte) FunctionSelector + func HexToFunctionSelector(s string) FunctionSelector + func (f *FunctionSelector) Scan(value interface{}) error + func (f *FunctionSelector) SetBytes(b []byte) + func (f *FunctionSelector) UnmarshalJSON(input []byte) error + func (f FunctionSelector) Bytes() []byte + func (f FunctionSelector) MarshalJSON() ([]byte, error) + func (f FunctionSelector) String() string + func (f FunctionSelector) Value() (driver.Value, error) + type Head struct + CreatedAt time.Time + Hash common.Hash + ID uint64 + Number int64 + Parent *Head + ParentHash common.Hash + Timestamp time.Time + func NewHead(number *big.Int, blockHash common.Hash, parentHash common.Hash, ...) Head + func (h *Head) GreaterThan(r *Head) bool + func (h *Head) MarshalJSON() ([]byte, error) + func (h *Head) NextInt() *big.Int + func (h *Head) String() string + func (h *Head) ToInt() *big.Int + func (h *Head) UnmarshalJSON(bs []byte) error + func (h Head) ChainHashes() []common.Hash + func (h Head) ChainLength() uint32 + func (h Head) EarliestInChain() Head + func (h Head) HashAtHeight(blockNum int64) common.Hash + func (h Head) IsInChain(blockHash common.Hash) bool + type IdleTimerConfig struct + Disabled bool + Duration Duration + func (itc *IdleTimerConfig) Scan(value interface{}) error + func (itc IdleTimerConfig) Value() (driver.Value, error) + type Initiator struct + CreatedAt time.Time + DeletedAt gorm.DeletedAt + ID int64 + JobSpecID JobID + Type string + UpdatedAt time.Time + func NewInitiatorFromRequest(initr InitiatorRequest, jobSpec JobSpec) Initiator + func (i Initiator) IsLogInitiated() bool + type InitiatorLogEvent struct + Initiator Initiator + Log types.Log + func (le InitiatorLogEvent) BlockNumber() *big.Int + func (le InitiatorLogEvent) ForLogger(kvs ...interface{}) []interface{} + func (le InitiatorLogEvent) GetInitiator() Initiator + func (le InitiatorLogEvent) GetJobSpecID() JobID + func (le InitiatorLogEvent) GetLog() types.Log + func (le InitiatorLogEvent) JSON() (JSON, error) + func (le InitiatorLogEvent) LogRequest() LogRequest + func (le InitiatorLogEvent) RunRequest() (RunRequest, error) + func (le InitiatorLogEvent) ToDebug() + func (le InitiatorLogEvent) Validate() bool + func (le InitiatorLogEvent) ValidateRequester() error + type InitiatorParams struct + AbsoluteThreshold float32 + Address common.Address + Body *JSON + Feeds Feeds + FromBlock *utils.Big + IdleTimer IdleTimerConfig + JobIDTopicFilter JobID + Name string + PollTimer PollTimerConfig + Precision int32 + Ran bool + RequestData JSON + Requesters AddressCollection + Schedule Cron + Threshold float32 + Time AnyTime + ToBlock *utils.Big + Topics Topics + type InitiatorRequest struct + Type string + type Interval time.Duration + func (i *Interval) Scan(v interface{}) error + func (i *Interval) UnmarshalText(input []byte) error + func (i Interval) IsZero() bool + func (i Interval) MarshalText() ([]byte, error) + func (i Interval) Value() (driver.Value, error) + type JSON struct + func Merge(inputs ...JSON) (JSON, error) + func ParseCBOR(b []byte) (JSON, error) + func ParseJSON(b []byte) (JSON, error) + func ParseRunLog(log types.Log) (JSON, error) + func (JSON) GormDBDataType(db *gorm.DB, field *schema.Field) string + func (JSON) GormDataType() string + func (j *JSON) Scan(value interface{}) error + func (j *JSON) UnmarshalJSON(b []byte) error + func (j *JSON) UnmarshalTOML(val interface{}) error + func (j JSON) Add(insertKey string, insertValue interface{}) (JSON, error) + func (j JSON) AsMap() (map[string]interface{}, error) + func (j JSON) Bytes() []byte + func (j JSON) CBOR() ([]byte, error) + func (j JSON) Delete(key string) (JSON, error) + func (j JSON) MarshalJSON() ([]byte, error) + func (j JSON) MultiAdd(keyValues KV) (JSON, error) + func (j JSON) PrependAtArrayKey(insertKey string, insertValue interface{}) (JSON, error) + func (j JSON) Value() (driver.Value, error) + type JSONAPIError struct + Detail string + type JSONAPIErrors struct + Errors []JSONAPIError + func NewJSONAPIErrors() *JSONAPIErrors + func NewJSONAPIErrorsWith(detail string) *JSONAPIErrors + func (jae *JSONAPIErrors) Add(detail string) + func (jae *JSONAPIErrors) CoerceEmptyToNil() error + func (jae *JSONAPIErrors) Error() string + func (jae *JSONAPIErrors) Merge(e error) + type JobID uuid.UUID + func NewIDFromString(input string) (JobID, error) + func NewJobID() JobID + func (id *JobID) Scan(src interface{}) error + func (id *JobID) UnmarshalString(input string) error + func (id *JobID) UnmarshalText(input []byte) error + func (id JobID) IsZero() bool + func (id JobID) MarshalText() ([]byte, error) + func (id JobID) String() string + func (id JobID) UUID() uuid.UUID + func (id JobID) Value() (driver.Value, error) + type JobRun struct + CreatedAt time.Time + CreationHeight *utils.Big + DeletedAt gorm.DeletedAt + FinishedAt null.Time + ID uuid.UUID + Initiator Initiator + InitiatorID int64 + JobSpecID JobID + ObservedHeight *utils.Big + Payment *assets.Adam + Result RunResult + ResultID clnull.Int64 + RunRequest RunRequest + RunRequestID clnull.Int64 + Status RunStatus + TaskRuns []TaskRun + UpdatedAt time.Time + func MakeJobRun(job *JobSpec, now time.Time, initiator *Initiator, currentHeight *big.Int, ...) JobRun + func (jr *JobRun) ApplyBridgeRunResult(result BridgeRunResult) + func (jr *JobRun) ApplyOutput(result RunOutput) + func (jr *JobRun) Cancel() + func (jr *JobRun) ErrorString() string + func (jr *JobRun) GetStatus() RunStatus + func (jr *JobRun) NextTaskRun() *TaskRun + func (jr *JobRun) NextTaskRunIndex() (int, bool) + func (jr *JobRun) PreviousTaskRun() *TaskRun + func (jr *JobRun) SetError(err error) + func (jr *JobRun) SetID(value string) error + func (jr *JobRun) SetStatus(status RunStatus) + func (jr *JobRun) TasksRemain() bool + func (jr JobRun) ForLogger(kvs ...interface{}) []interface{} + func (jr JobRun) GetID() string + func (jr JobRun) GetName() string + func (jr JobRun) HasError() bool + type JobSpec struct + CreatedAt time.Time + DeletedAt gorm.DeletedAt + EndAt null.Time + Errors []JobSpecError + ID JobID + Initiators []Initiator + MinPayment *assets.Adam + Name string + StartAt null.Time + Tasks []TaskSpec + UpdatedAt time.Time + func NewJob() JobSpec + func NewJobFromRequest(jsr JobSpecRequest) JobSpec + func (j *JobSpec) SetID(value string) error + func (j JobSpec) Archived() bool + func (j JobSpec) Ended(t time.Time) bool + func (j JobSpec) GetID() string + func (j JobSpec) GetName() string + func (j JobSpec) InitiatorExternal(name string) *Initiator + func (j JobSpec) InitiatorsFor(types ...string) []Initiator + func (j JobSpec) IsLogInitiated() bool + func (j JobSpec) Started(t time.Time) bool + type JobSpecError struct + CreatedAt time.Time + Description string + ID int64 + JobSpecID JobID + Occurrences uint + UpdatedAt time.Time + func NewJobSpecError(jobSpecID JobID, description string) JobSpecError + type JobSpecRequest struct + EndAt null.Time + Initiators []InitiatorRequest + MinPayment *assets.Adam + Name string + StartAt null.Time + Tasks []TaskSpecRequest + type KV map[string]interface + type Key struct + Address EIP55Address + CreatedAt time.Time + DeletedAt gorm.DeletedAt + ID int32 + IsFunding bool + JSON JSON + LastUsed *time.Time + NextNonce int64 + UpdatedAt time.Time + func NewKeyFromFile(path string) (Key, error) + func (k *Key) WriteToDisk(path string) error + type LogCursor struct + BlockIndex int64 + Initialized bool + LogIndex int64 + Name string + type LogRequest interface + BlockNumber func() *big.Int + ForLogger func(kvs ...interface{}) []interface{} + GetInitiator func() Initiator + GetJobSpecID func() JobID + GetLog func() types.Log + JSON func() (JSON, error) + RunRequest func() (RunRequest, error) + ToDebug func() + Validate func() bool + ValidateRequester func() error + type NodeVersion struct + CreatedAt time.Time + Version string + func NewNodeVersion(version string) NodeVersion + type NullSigner struct + func (NullSigner) SignHash(common.Hash) (Signature, error) + type PeerID peer.ID + func (p *PeerID) Scan(value interface{}) error + func (p *PeerID) UnmarshalJSON(input []byte) error + func (p *PeerID) UnmarshalText(bs []byte) error + func (p PeerID) MarshalJSON() ([]byte, error) + func (p PeerID) Raw() string + func (p PeerID) String() string + func (p PeerID) Value() (driver.Value, error) + type PollTimerConfig struct + Disabled bool + Period Duration + func (ptc *PollTimerConfig) Scan(value interface{}) error + func (ptc PollTimerConfig) Value() (driver.Value, error) + type RandomnessLogEvent struct + func (le RandomnessLogEvent) JSON() (js JSON, err error) + func (le RandomnessLogEvent) Requester() common.Address + func (le RandomnessLogEvent) RunRequest() (RunRequest, error) + func (le RandomnessLogEvent) Validate() bool + func (le RandomnessLogEvent) ValidateRequester() error + type RandomnessRequestLog struct + Fee *assets.Adam + JobID common.Hash + KeyHash common.Hash + Raw RawRandomnessRequestLog + RequestID common.Hash + Seed *big.Int + Sender common.Address + func ParseRandomnessRequestLog(log types.Log) (*RandomnessRequestLog, error) + func RawRandomnessRequestLogToRandomnessRequestLog(l *RawRandomnessRequestLog) *RandomnessRequestLog + func (l *RandomnessRequestLog) ComputedRequestID() common.Hash + func (l *RandomnessRequestLog) Equal(ol RandomnessRequestLog) bool + func (l *RandomnessRequestLog) RawData() ([]byte, error) + type RawRandomnessRequestLog solidity_vrf_coordinator_interface.VRFCoordinatorRandomnessRequest + type RunInput struct + func NewRunInput(jobRunID uuid.UUID, taskRunID uuid.UUID, data JSON, status RunStatus) *RunInput + func NewRunInputWithResult(jobRunID uuid.UUID, taskRunID uuid.UUID, value interface{}, status RunStatus) *RunInput + func (ri RunInput) CloneWithData(data JSON) RunInput + func (ri RunInput) Data() JSON + func (ri RunInput) JobRunID() uuid.UUID + func (ri RunInput) Result() gjson.Result + func (ri RunInput) ResultCollection() gjson.Result + func (ri RunInput) ResultString() (string, error) + func (ri RunInput) Status() RunStatus + func (ri RunInput) TaskRunID() uuid.UUID + type RunLogEvent struct + func (le RunLogEvent) JSON() (JSON, error) + func (le RunLogEvent) Requester() (common.Address, error) + func (le RunLogEvent) RunRequest() (RunRequest, error) + func (le RunLogEvent) Validate() bool + func (le RunLogEvent) ValidateRequester() error + type RunOutput struct + func NewRunOutputComplete(data JSON) RunOutput + func NewRunOutputCompleteWithResult(resultVal interface{}, resultCollection gjson.Result) RunOutput + func NewRunOutputError(err error) RunOutput + func NewRunOutputInProgress(data JSON) RunOutput + func NewRunOutputPendingBridge() RunOutput + func NewRunOutputPendingConnection() RunOutput + func NewRunOutputPendingConnectionWithData(data JSON) RunOutput + func NewRunOutputPendingOutgoingConfirmationsWithData(data JSON) RunOutput + func (ro RunOutput) Data() JSON + func (ro RunOutput) Error() error + func (ro RunOutput) Get(path string) gjson.Result + func (ro RunOutput) HasError() bool + func (ro RunOutput) Result() gjson.Result + func (ro RunOutput) ResultCollection() gjson.Result + func (ro RunOutput) Status() RunStatus + type RunRequest struct + BlockHash *common.Hash + CreatedAt time.Time + ID int64 + Payment *assets.Adam + RequestID *common.Hash + RequestParams JSON + Requester *common.Address + TxHash *common.Hash + func NewRunRequest(requestParams JSON) *RunRequest + type RunResult struct + CreatedAt time.Time + Data JSON + ErrorMessage null.String + ID int64 + UpdatedAt time.Time + type RunStatus string + func (s *RunStatus) Scan(value interface{}) error + func (s RunStatus) Cancelled() bool + func (s RunStatus) Completed() bool + func (s RunStatus) Errored() bool + func (s RunStatus) Finished() bool + func (s RunStatus) Pending() bool + func (s RunStatus) PendingBridge() bool + func (s RunStatus) PendingConnection() bool + func (s RunStatus) PendingIncomingConfirmations() bool + func (s RunStatus) PendingOutgoingConfirmations() bool + func (s RunStatus) PendingSleep() bool + func (s RunStatus) Runnable() bool + func (s RunStatus) Unstarted() bool + func (s RunStatus) Value() (driver.Value, error) + type RunStatusCollection []RunStatus + func (r *RunStatusCollection) Scan(value interface{}) error + func (r RunStatusCollection) ToStrings() []string + func (r RunStatusCollection) Value() (driver.Value, error) + type SendEtherRequest struct + Amount assets.Eth + DestinationAddress common.Address + FromAddress common.Address + type ServiceAgreement struct + CreatedAt time.Time + Encumbrance Encumbrance + EncumbranceID int64 + ID string + JobSpec JobSpec + JobSpecID JobID + RequestBody string + Signature Signature + UpdatedAt time.Time + func BuildServiceAgreement(us UnsignedServiceAgreement, signer Signer) (ServiceAgreement, error) + func (sa *ServiceAgreement) SetID(value string) error + func (sa ServiceAgreement) GetID() string + func (sa ServiceAgreement) GetName() string + type ServiceAgreementRequest struct + AggFulfillSelector FunctionSelector + AggInitiateJobSelector FunctionSelector + Aggregator EIP55Address + EndAt AnyTime + Expiration uint64 + Initiators []InitiatorRequest + Oracles EIP55AddressCollection + Payment *assets.Adam + StartAt AnyTime + Tasks []TaskSpecRequest + type Session struct + CreatedAt time.Time + ID string + LastUsed time.Time + func NewSession() Session + type SessionRequest struct + Email string + Password string + type Sha256Hash [32]byte + func MustSha256HashFromHex(x string) Sha256Hash + func Sha256HashFromHex(x string) (Sha256Hash, error) + func (s *Sha256Hash) Scan(value interface{}) error + func (s *Sha256Hash) UnmarshalJSON(input []byte) error + func (s *Sha256Hash) UnmarshalText(bs []byte) error + func (s Sha256Hash) MarshalJSON() ([]byte, error) + func (s Sha256Hash) String() string + func (s Sha256Hash) Value() (driver.Value, error) + type Signature [SignatureLength]byte + func BytesToSignature(b []byte) Signature + func NewSignature(s string) (Signature, error) + func (s *Signature) Scan(value interface{}) error + func (s *Signature) SetBytes(b []byte) + func (s *Signature) UnmarshalJSON(input []byte) error + func (s *Signature) UnmarshalText(input []byte) error + func (s Signature) Big() *big.Int + func (s Signature) Bytes() []byte + func (s Signature) Format(state fmt.State, c rune) + func (s Signature) Hex() string + func (s Signature) MarshalJSON() ([]byte, error) + func (s Signature) MarshalText() ([]byte, error) + func (s Signature) String() string + func (s Signature) Value() (driver.Value, error) + type Signer interface + SignHash func(hash common.Hash) (Signature, error) + type SyncEvent struct + Body string + CreatedAt time.Time + ID int64 + UpdatedAt time.Time + type TaskRun struct + CreatedAt time.Time + ID uuid.UUID + JobRunID uuid.UUID + MinRequiredIncomingConfirmations clnull.Uint32 + ObservedIncomingConfirmations clnull.Uint32 + Result RunResult + ResultID clnull.Int64 + Status RunStatus + TaskSpec TaskSpec + TaskSpecID int64 + UpdatedAt time.Time + func (tr *TaskRun) ApplyBridgeRunResult(result BridgeRunResult) + func (tr *TaskRun) ApplyOutput(result RunOutput) + func (tr *TaskRun) SetError(err error) + func (tr TaskRun) String() string + type TaskSpec struct + CreatedAt time.Time + DeletedAt gorm.DeletedAt + ID int64 + JobSpecID JobID + MinRequiredIncomingConfirmations clnull.Uint32 + Params JSON + Type TaskType + UpdatedAt time.Time + type TaskSpecRequest struct + MinRequiredIncomingConfirmations clnull.Uint32 + Params JSON + Type TaskType + type TaskType string + func MustNewTaskType(val string) TaskType + func NewTaskType(val string) (TaskType, error) + func (t *TaskType) Scan(value interface{}) error + func (t *TaskType) UnmarshalJSON(input []byte) error + func (t TaskType) MarshalJSON() ([]byte, error) + func (t TaskType) String() string + func (t TaskType) Value() (driver.Value, error) + type Topics [][]common.Hash + func (t *Topics) Scan(value interface{}) error + func (t Topics) Value() (driver.Value, error) + type UnsignedServiceAgreement struct + Encumbrance Encumbrance + ID common.Hash + JobSpecRequest JobSpecRequest + RequestBody string + func NewUnsignedServiceAgreementFromRequest(reader io.Reader) (UnsignedServiceAgreement, error) + type UntrustedBytes []byte + func (ary UntrustedBytes) SafeByteSlice(start int, end int) ([]byte, error) + type User struct + CreatedAt time.Time + Email string + HashedPassword string + TokenHashedSecret string + TokenKey string + TokenSalt string + UpdatedAt time.Time + func NewUser(email, plainPwd string) (User, error) + func (u *User) DeleteAuthToken() + func (u *User) GenerateAuthToken() (*auth.Token, error) + func (u *User) SetAuthToken(token *auth.Token) error + type ValidationError struct + func (e *ValidationError) Error() string + type WebURL url.URL + func (w *WebURL) Scan(value interface{}) error + func (w *WebURL) UnmarshalJSON(j []byte) error + func (w WebURL) MarshalJSON() ([]byte, error) + func (w WebURL) String() string + func (w WebURL) Value() (driver.Value, error) + type WithdrawalRequest struct + Amount *assets.Adam + ContractAddress common.Address + DestinationAddress common.Address