models

Nov 3, 2022

Changes in this version

+ type Secret string

+ func (s Secret) GoString() string

+ func (s Secret) MarshalText() ([]byte, error)

+ func (s Secret) String() string

+ type SecretURL URL

+ func MustSecretURL(u string) *SecretURL

+ func NewSecretURL(u *URL) *SecretURL

+ func (s *SecretURL) GoString() string

+ func (s *SecretURL) MarshalText() ([]byte, error)

+ func (s *SecretURL) String() string

+ func (s *SecretURL) URL() *url.URL

+ func (s *SecretURL) UnmarshalText(text []byte) error

type URL

+ func MustParseURL(s string) *URL

+ func (u *URL) IsZero() bool

+ func (u *URL) String() string

+ func (u *URL) URL() *url.URL

Sep 30, 2022

Changes in this version

+ var EmptySha256Hash = new(Sha256Hash)

Jul 20, 2022

Changes in this version

type Duration

+ func MustNewDuration(d time.Duration) *Duration

+ func ParseDuration(s string) (Duration, error)

+ func (d *Duration) UnmarshalText(input []byte) error

+ func (d Duration) MarshalText() ([]byte, error)

type Sha256Hash

+ func (s *Sha256Hash) MarshalText() ([]byte, error)

+ type URL url.URL

+ func ParseURL(s string) (*URL, error)

+ func (u *URL) MarshalText() ([]byte, error)

+ func (u *URL) UnmarshalText(input []byte) error

Mar 3, 2022

Changes in this version

type Interval

+ func NewInterval(d time.Duration) *Interval

type SendEtherRequest

+ AllowHigherAmounts bool

Jan 25, 2022

Changes in this version

type Duration

+ func MakeDurationFromString(s string) (Duration, error)

type SendEtherRequest

+ EVMChainID *utils.Big

Oct 19, 2021

Changes in this version

type Interval

+ func (i Interval) Duration() time.Duration

Aug 9, 2021

Changes in this version

+ type ReplayBlocksRequest struct

+ BlockNumber int64

Jul 6, 2021

Changes in this version

type EthTx

+ Subject uuid.NullUUID

type Head

+ L1BlockNumber null.Int64

Jun 21, 2021

Changes in this version

+ type EthTxMetaV2 struct

+ JobID int32

+ RequestID common.Hash

+ RequestTxHash common.Hash

type JobID

+ func NewJobIDFromString(input string) (JobID, error)

+ func (id JobID) Hash() common.Hash

May 24, 2021

Changes in this version

type EthTx

+ Meta postgres.Jsonb

+ type EthTxMeta struct

+ RunRequestID *common.Hash

+ RunRequestTxHash *common.Hash

+ TaskRunID uuid.UUID

type RunInput

+ func (ri RunInput) JobRun() JobRun

May 10, 2021

Changes in this version

type Head

+ func (h Head) ChainHashes() []common.Hash

type JSON

+ func MergeExceptResult(inputs ...JSON) (JSON, error)

+ func MustParseJSON(b []byte) JSON

Apr 26, 2021

Changes in this version

+ func HexToInt64(input interface{}) int64

+ func MarshalBridgeMetaData(latestAnswer *big.Int, updatedAt *big.Int) (map[string]interface{}, error)

type BridgeMetaData

+ LatestAnswer *big.Int

+ UpdatedAt *big.Int

+ type BridgeMetaDataJSON struct

+ Meta BridgeMetaData

type Head

+ func (h Head) HashAtHeight(blockNum int64) common.Hash

Apr 12, 2021

Changes in this version

+ func BridgeMetaData(latestAnswer *big.Int, updatedAt *big.Int) (map[string]interface{}, error)

type InitiatorParams

+ JobIDTopicFilter JobID

+ type NodeVersion struct

+ CreatedAt time.Time

+ Version string

+ func NewNodeVersion(version string) NodeVersion

Mar 22, 2021

Changes in this version

+ func Int64ToHex(n int64) string

type Block

+ Hash common.Hash

+ ParentHash common.Hash

+ func (b *Block) UnmarshalJSON(data []byte) error

+ func (b Block) MarshalJSON() ([]byte, error)

type Head

+ func (h Head) IsInChain(blockHash common.Hash) bool

Feb 24, 2021

Changes in this version

+ var NilJobID = JobID

type JSON

+ func (JSON) GormDBDataType(db *gorm.DB, field *schema.Field) string

+ func (JSON) GormDataType() string

+ type JobID uuid.UUID

+ 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)

Feb 1, 2021

Changes in this version

type PeerID

+ func (p PeerID) Raw() string

Jan 18, 2021

Changes in this version

type EIP55Address

+ func EIP55AddressFromAddress(a common.Address) (EIP55Address, error)

Dec 14, 2020

Changes in this version

+ const EthRequestEventJobType

+ const ResultCollectionKey

+ const ResultKey

+ var OracleFulfillmentFunctionID2020 = utils.MustHash("fulfillOracleRequest2(bytes32,uint256,address,bytes4,uint256,bytes)").Hex()[:10]

+ func CoerceInterfaceMapToStringMap(in interface{}) (interface{}, error)

+ type CreateJobSpecRequest struct

+ TOML string

+ type EthRequestEventSpec struct

+ ContractAddress EIP55Address

+ CreatedAt time.Time

+ UpdatedAt time.Time

+ func (EthRequestEventSpec) TableName() string

+ type IDEmbed struct

+ ID int32

+ func (id *IDEmbed) SetID(value string) error

+ func (id IDEmbed) GetID() string

type Interval

+ func (i Interval) IsZero() bool

type JSON

+ func (j JSON) PrependAtArrayKey(insertKey string, insertValue interface{}) (JSON, error)

type JobSpecV2

+ EthRequestEventSpec *EthRequestEventSpec

+ EthRequestEventSpecID *int32

+ MaxTaskDuration Interval

+ Name null.String

+ SchemaVersion uint32

+ Type string

+ type PipelineRun struct

+ ID int64

+ func (pr *PipelineRun) SetID(value string) error

+ func (pr PipelineRun) GetID() string

type RunInput

+ func (ri RunInput) ResultCollection() gjson.Result

type RunOutput

+ func (ro RunOutput) ResultCollection() gjson.Result

Nov 23, 2020

Changes in this version

+ type CreateOCRJobSpecRequest struct

+ TOML string

+ type JobSpecErrorV2 struct

+ CreatedAt time.Time

+ Description string

+ ID int64

+ JobID int32

+ Occurrences uint

+ UpdatedAt time.Time

+ func (JobSpecErrorV2) TableName() string

type JobSpecV2

+ JobSpecErrors []JobSpecErrorV2

+ PipelineSpec *PipelineSpec

+ func (js JobSpecV2) GetID() string

+ type NullSigner struct

+ func (NullSigner) SignHash(common.Hash) (Signature, error)

+ type OCRJobRun struct

+ ID int64

+ func (jr *OCRJobRun) SetID(value string) error

+ func (jr OCRJobRun) GetID() string

type OffchainReportingOracleSpec

+ func (s *OffchainReportingOracleSpec) SetID(value string) error

+ func (s OffchainReportingOracleSpec) GetID() string

+ type PipelineSpec struct

+ CreatedAt time.Time

+ DotDagSource string

+ ID int32

type Sha256Hash

+ func (s *Sha256Hash) UnmarshalJSON(input []byte) error

+ func (s Sha256Hash) MarshalJSON() ([]byte, error)

Nov 2, 2020

Changes in this version

+ type Interval time.Duration

+ func (i *Interval) Scan(v interface{}) error

+ func (i *Interval) UnmarshalText(input []byte) error

+ func (i Interval) MarshalText() ([]byte, error)

+ func (i Interval) Value() (driver.Value, error)

type JSON

+ func (j *JSON) UnmarshalTOML(val interface{}) error

+ type JobSpecV2 struct

+ ID int32

+ OffchainreportingOracleSpec *OffchainReportingOracleSpec

+ OffchainreportingOracleSpecID int32

+ PipelineSpecID int32

+ func (JobSpecV2) TableName() string

+ func (js *JobSpecV2) SetID(value string) error

type Key

+ DeletedAt null.Time

type LogConsumption

+ JobIDV2 *int32

+ type OffchainReportingOracleSpec struct

+ BlockchainTimeout Interval

+ ContractAddress EIP55Address

+ ContractConfigConfirmations uint16

+ ContractConfigTrackerPollInterval Interval

+ ContractConfigTrackerSubscribeInterval Interval

+ CreatedAt time.Time

+ EncryptedOCRKeyBundleID Sha256Hash

+ ID int32

+ IsBootstrapPeer bool

+ MonitoringEndpoint string

+ ObservationTimeout Interval

+ P2PBootstrapPeers pq.StringArray

+ P2PPeerID PeerID

+ TransmitterAddress EIP55Address

+ UpdatedAt time.Time

+ func (OffchainReportingOracleSpec) TableName() string

+ func (s *OffchainReportingOracleSpec) BeforeCreate() error

+ func (s *OffchainReportingOracleSpec) BeforeSave() 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) String() string

+ func (p PeerID) Value() (driver.Value, error)

+ 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) UnmarshalText(bs []byte) error

+ func (s Sha256Hash) String() string

+ func (s Sha256Hash) Value() (driver.Value, error)

Oct 12, 2020

Changes in this version

+ const EthTxConfirmedMissingReceipt

type JobSpec

+ Name string

type JobSpecRequest

+ Name string

type Key

+ IsFunding bool

+ type OffchainreportingOracleSpec struct

+ ID int

+ func (OffchainreportingOracleSpec) TableName() string

Sep 28, 2020

Changes in this version

+ func MarshalToMap(input interface{}) (map[string]interface{}, error)

Sep 15, 2020

Changes in this version

type LogConsumption

+ BlockNumber uint64

Sep 2, 2020

Changes in this version

+ const EthTxAttemptInsufficientEth

Aug 26, 2020

Changes in this version

+ func ReceiptIndicatesRunLogFulfillment(txr types.Receipt) bool

+ func ReceiptIsUnconfirmed(txr *types.Receipt) bool

type FluxMonitorRoundStats

+ JobRunID *ID

type Head

+ func (h *Head) MarshalJSON() ([]byte, error)

+ func (h *Head) UnmarshalJSON(bs []byte) error

type RandomnessRequestLog

+ func (l *RandomnessRequestLog) ComputedRequestID() common.Hash

Jul 27, 2020

Changes in this version

type EIP55Address

+ func (a EIP55Address) Hex() string

type Key

+ LastUsed *time.Time

Jul 13, 2020

Changes in this version

type JobSpec

+ Errors []JobSpecError

+ type JobSpecError struct

+ CreatedAt time.Time

+ Description string

+ ID int64

+ JobSpecID *ID

+ Occurrences uint

+ UpdatedAt time.Time

+ func NewJobSpecError(jobSpecID *ID, description string) JobSpecError

Jun 29, 2020

Changes in this version

+ var WeiPerEth = new(big.Int).Exp(big.NewInt(10), big.NewInt(18), nil)

+ func VRFCoordinatorABI() abi.ABI

+ func VRFFulfillMethod() abi.Method

+ func VRFFulfillSelector() string

+ func VRFRandomnessRequestLogTopic() common.Hash

+ type Block struct

+ Number hexutil.Uint64

+ Transactions []Transaction

type EthTx

+ func (e EthTx) GetID() string

type Head

+ func NewHeadFromBlockHeader(h types.Header) Head

type Log

+ func (l Log) Copy() Log

+ func (l Log) GetBlockHash() common.Hash

+ func (l Log) GetIndex() uint

+ func (l Log) GetTopic(idx uint) (common.Hash, error)

+ type RandomnessRequestLog struct

+ Fee *assets.Link

+ JobID common.Hash

+ KeyHash common.Hash

+ Raw RawRandomnessRequestLog

+ Seed *big.Int

+ Sender common.Address

+ func ParseRandomnessRequestLog(log Log) (*RandomnessRequestLog, error)

+ func RawRandomnessRequestLogToRandomnessRequestLog(l *RawRandomnessRequestLog) *RandomnessRequestLog

+ func (l *RandomnessRequestLog) Equal(ol RandomnessRequestLog) bool

+ func (l *RandomnessRequestLog) RawData() ([]byte, error)

+ func (l *RandomnessRequestLog) RequestID() common.Hash

+ type RawLog interface

+ GetBlockHash func() common.Hash

+ GetIndex func() uint

+ type RawRandomnessRequestLog solidity_vrf_coordinator_interface.VRFCoordinatorRandomnessRequest

+ type Transaction struct

+ GasPrice hexutil.Uint64

+ type UntrustedBytes []byte

+ func (ary UntrustedBytes) SafeByteSlice(start int, end int) ([]byte, error)

Jun 15, 2020

Changes in this version

+ const EthTxAttemptBroadcast

+ const EthTxAttemptInProgress

+ const EthTxConfirmed

+ const EthTxFatalError

+ const EthTxInProgress

+ const EthTxUnconfirmed

+ const EthTxUnstarted

+ 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

+ 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 Head

+ func (h Head) ChainLength() uint32

+ func (h Head) EarliestInChain() Head

type ID

+ func (id ID) UUID() uuid.UUID

type Key

+ ID int32

+ NextNonce int64

Jun 11, 2020

Changes in this version

+ type FluxMonitorRoundStats struct

+ Aggregator common.Address

+ ID uint64

+ NumNewRoundLogs uint64

+ NumSubmissions uint64

+ RoundID uint32

Jun 1, 2020

Changes in this version

type Configuration

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ ID int64

+ UpdatedAt time.Time

type ExternalInitiator

+ ID int64

type Head

+ CreatedAt time.Time

+ Parent *Head

+ ParentHash common.Hash

+ Timestamp time.Time

type RunInput

+ func (ri RunInput) CloneWithData(data JSON) RunInput

+ func (ri RunInput) TaskRunID() ID

type TaskSpec

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ ID int64

+ UpdatedAt time.Time

May 18, 2020

Changes in this version

+ const RunStatusPendingIncomingConfirmations

+ const RunStatusPendingOutgoingConfirmations

type BridgeType

+ CreatedAt time.Time

+ UpdatedAt time.Time

type Encumbrance

+ CreatedAt time.Time

+ UpdatedAt time.Time

+ type IdleTimerConfig struct

+ Disabled bool

+ Duration Duration

+ func (itc *IdleTimerConfig) Scan(value interface{}) error

+ func (itc IdleTimerConfig) Value() (driver.Value, error)

type Initiator

+ UpdatedAt time.Time

type InitiatorParams

+ AbsoluteThreshold float32

+ IdleTimer IdleTimerConfig

+ PollTimer PollTimerConfig

type JobSpec

+ UpdatedAt time.Time

type Key

+ CreatedAt time.Time

+ UpdatedAt time.Time

+ type PollTimerConfig struct

+ Disabled bool

+ Period Duration

+ func (ptc *PollTimerConfig) Scan(value interface{}) error

+ func (ptc PollTimerConfig) Value() (driver.Value, error)

type RunOutput

+ func NewRunOutputPendingOutgoingConfirmationsWithData(data JSON) RunOutput

type RunResult

+ CreatedAt time.Time

+ UpdatedAt time.Time

type RunStatus

+ func (s RunStatus) PendingIncomingConfirmations() bool

+ func (s RunStatus) PendingOutgoingConfirmations() bool

type ServiceAgreement

+ UpdatedAt time.Time

type TaskRun

+ MinRequiredIncomingConfirmations clnull.Uint32

+ ObservedIncomingConfirmations clnull.Uint32

+ UpdatedAt time.Time

type TaskSpec

+ MinRequiredIncomingConfirmations clnull.Uint32

type TaskSpecRequest

+ MinRequiredIncomingConfirmations clnull.Uint32

type Tx

+ CreatedAt time.Time

+ UpdatedAt time.Time

type TxAttempt

+ UpdatedAt time.Time

type User

+ UpdatedAt time.Time

May 4, 2020

Changes in this version

+ var CronParser cron.Parser

type Duration

+ func MakeDuration(d time.Duration) (Duration, error)

+ func MustMakeDuration(d time.Duration) Duration

+ func (d *Duration) Scan(v interface{}) (err error)

+ func (d Duration) Before(t time.Time) time.Time

+ func (d Duration) IsInstant() bool

+ func (d Duration) Shorter(od Duration) bool

+ func (d Duration) Value() (driver.Value, error)

+ type LogConsumption struct

+ BlockHash common.Hash

+ CreatedAt time.Time

+ ID uint

+ JobID *ID

+ LogIndex uint

+ func NewLogConsumption(log eth.RawLog, jobID *ID) LogConsumption

Apr 20, 2020

Changes in this version

+ const InitiatorFluxMonitor

+ const InitiatorRandomnessLog

+ const MaxBcryptPasswordLength

+ const RunStatusCancelled

+ var FluxMonitorDefaultInitiatorParams = InitiatorParams

+ var LogBasedChainlinkJobInitiators = []string

+ var RandomnessRequestLogTopic = vrf.RandomnessRequestLogTopic()

+ var TopicsForInitiatorsWhichRequireJobSpecIDTopic = map[string][]common.Hash

+ func AuthenticateUserByToken(token *auth.Token, user *User) (bool, error)

+ func JobSpecIDTopics(jsID *ID) []common.Hash

type BridgeRunResult

+ Data JSON

+ ErrorMessage null.String

+ Status RunStatus

+ func (brr BridgeRunResult) GetError() error

+ func (brr BridgeRunResult) HasError() bool

+ type ChangeAuthTokenRequest struct

+ Password string

+ type Duration time.Duration

+ func (d *Duration) UnmarshalJSON(input []byte) error

+ func (d Duration) Duration() time.Duration

+ func (d Duration) MarshalJSON() ([]byte, error)

+ func (d Duration) String() string

+ type EncryptedSecretVRFKey = vrfkey.EncryptedSecretKey

type ExternalInitiator

+ CreatedAt time.Time

+ UpdatedAt time.Time

+ type Feeds = JSON

type InitiatorLogEvent

+ func (le InitiatorLogEvent) GetJobSpecID() *ID

type InitiatorParams

+ Body *JSON

+ Feeds Feeds

+ IdleThreshold Duration

+ PollingInterval Duration

+ Precision int32

+ RequestData JSON

+ Threshold float32

+ func (i *InitiatorParams) SetDefaultValues(typ string)

type JSON

+ func Merge(inputs ...JSON) (JSON, error)

+ func (j JSON) AsMap() (map[string]interface{}, error)

+ func (j JSON) MultiAdd(keyValues KV) (JSON, error)

type JobRun

+ 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) SetStatus(status RunStatus)

+ func (jr JobRun) HasError() bool

type JobSpec

+ func (j JobSpec) Archived() bool

+ type KV map[string]interface

+ type LogCursor struct

+ BlockIndex uint64

+ Initialized bool

+ LogIndex uint64

+ Name string

type LogRequest

+ GetJobSpecID func() *ID

+ type PublicKey = vrfkey.PublicKey

+ 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 RunInput struct

+ func NewRunInput(jobRunID *ID, data JSON, status RunStatus) *RunInput

+ func NewRunInputWithResult(jobRunID *ID, value interface{}, status RunStatus) *RunInput

+ func (ri RunInput) Data() JSON

+ func (ri RunInput) JobRunID() *ID

+ func (ri RunInput) Result() gjson.Result

+ func (ri RunInput) ResultString() (string, error)

+ func (ri RunInput) Status() RunStatus

+ type RunOutput struct

+ func NewRunOutputComplete(data JSON) RunOutput

+ func NewRunOutputCompleteWithResult(resultVal interface{}) RunOutput

+ func NewRunOutputError(err error) RunOutput

+ func NewRunOutputInProgress(data JSON) RunOutput

+ func NewRunOutputPendingBridge() RunOutput

+ func NewRunOutputPendingConfirmationsWithData(data JSON) RunOutput

+ func NewRunOutputPendingConnection() RunOutput

+ func NewRunOutputPendingConnectionWithData(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) Status() RunStatus

type RunRequest

+ RequestParams JSON

type RunStatus

+ func (s RunStatus) Cancelled() bool

type TaskRun

+ func (tr *TaskRun) ApplyBridgeRunResult(result BridgeRunResult)

+ func (tr *TaskRun) ApplyOutput(result RunOutput)

type User

+ TokenHashedSecret string

+ TokenKey string

+ TokenSalt string

+ func (u *User) DeleteAuthToken()

+ func (u *User) GenerateAuthToken() (*auth.Token, error)

+ func (u *User) SetAuthToken(token *auth.Token) error

Nov 13, 2019

Changes in this version

type InitiatorParams

+ FromBlock *Big

+ Params string

+ ToBlock *Big

+ Topics Topics

type InitiatorRequest

+ func (i *InitiatorRequest) UnmarshalJSON(buf []byte) error

type RunResult

+ func RunResultComplete(resultVal interface{}) RunResult

+ func RunResultError(err error) RunResult

+ type ServiceAgreementRequest struct

+ AggFulfillSelector FunctionSelector

+ AggInitiateJobSelector FunctionSelector

+ Aggregator EIP55Address

+ EndAt AnyTime

+ Expiration uint64

+ Initiators []InitiatorRequest

+ Oracles EIP55AddressCollection

+ Payment *assets.Link

+ StartAt AnyTime

+ Tasks []TaskSpecRequest

type Signer

+ SignHash func(hash common.Hash) (Signature, error)

+ type Topics [][]common.Hash

+ func (t Topics) Scan(value interface{}) error

+ func (t Topics) Value() (driver.Value, error)

type TxAttempt

+ func HighestPricedTxAttemptPerTx(items []TxAttempt) []TxAttempt

Oct 3, 2019

Changes in this version

type InitiatorRequest

+ Name string

Sep 19, 2019

Changes in this version

type Encumbrance

+ AggFulfillSelector FunctionSelector

+ AggInitiateJobSelector FunctionSelector

+ Aggregator EIP55Address

type FunctionSelector

+ func (f FunctionSelector) MarshalJSON() ([]byte, error)

+ func (f FunctionSelector) Scan(value interface{}) error

+ func (f FunctionSelector) Value() (driver.Value, error)

type Initiator

+ func NewInitiatorFromRequest(initr InitiatorRequest, jobSpec JobSpec) Initiator

Sep 11, 2019

Changes in this version

+ const InitiatorExternal

type InitiatorParams

+ Name string

type JobSpec

+ func (j JobSpec) InitiatorExternal(name string) *Initiator

Sep 9, 2019

Changes in this version

+ func IDToHexTopic(id *ID) common.Hash

+ func IDToTopic(id *ID) common.Hash

+ type Configuration struct

+ Name string

+ Value string

type ExternalInitiator

+ Name string

+ OutgoingSecret string

+ OutgoingToken string

+ URL WebURL

+ type ExternalInitiatorRequest struct

+ Name string

+ URL WebURL

type Head

+ func (h Head) AfterCreate(scope *gorm.Scope) (err error)

+ type ID uuid.UUID

+ func NewID() *ID

+ func NewIDFromString(input string) (*ID, error)

+ func (id *ID) Bytes() []byte

+ func (id *ID) MarshalText() ([]byte, error)

+ func (id *ID) Scan(value interface{}) error

+ func (id *ID) String() string

+ func (id *ID) UnmarshalString(input string) error

+ func (id *ID) UnmarshalText(input []byte) error

+ func (id *ID) Value() (driver.Value, error)

type JobRun

+ Payment *assets.Link

type JobSpec

+ MinPayment *assets.Link

type JobSpecRequest

+ MinPayment *assets.Link

+ type LinkEarned struct

+ Earned *assets.Link

+ EarnedAt time.Time

+ ID uint64

+ JobRunID *ID

+ func NewLinkEarned(jrunid *ID, ear *assets.Link) LinkEarned

+ func (LinkEarned) TableName() string

type RunRequest

+ Payment *assets.Link

Jul 24, 2019

Changes in this version

type RunRequest

+ BlockHash *common.Hash

type TxReceipt

+ BlockHash common.Hash

Jun 26, 2019

Changes in this version

type Head

+ ID uint64

Jun 25, 2019

Changes in this version

+ const BulkTaskStatusCompleted

+ const BulkTaskStatusErrored

+ const BulkTaskStatusInProgress

+ const FunctionSelectorLength

+ const InitiatorCron

+ const InitiatorEthLog

+ const InitiatorRunAt

+ const InitiatorRunLog

+ const InitiatorServiceAgreementExecutionLog

+ const InitiatorWeb

+ const RequestLogTopicJobID

+ const RequestLogTopicPayment

+ const RequestLogTopicRequester

+ const RequestLogTopicSignature

+ const RunStatusCompleted

+ const RunStatusErrored

+ const RunStatusInProgress

+ const RunStatusPendingBridge

+ const RunStatusPendingConfirmations

+ const RunStatusPendingConnection

+ const RunStatusPendingSleep

+ const RunStatusUnstarted

+ const SignatureLength

+ var ChainlinkFulfilledTopic = utils.MustHash("ChainlinkFulfilled(bytes32)")

+ var ErrorCannotMergeNonObject = errors.New("Cannot merge, expected object '{}'")

+ var OracleFulfillmentFunctionID20190123withFulfillmentParams = utils.MustHash("fulfillData(uint256,uint256,address,bytes4,uint256,bytes32)").Hex()[:10]

+ var OracleFulfillmentFunctionID20190128withoutCast = utils.MustHash("fulfillOracleRequest(bytes32,uint256,address,bytes4,uint256,bytes32)").Hex()[:10]

+ var OracleFullfillmentFunctionID0original = utils.MustHash("fulfillData(uint256,bytes32)").Hex()[:10]

+ var RunLogTopic0original = utils.MustHash("RunRequest(bytes32,address,uint256,uint256,uint256,bytes)")

+ var RunLogTopic20190123withFullfillmentParams = utils.MustHash(...)

+ var RunLogTopic20190207withoutIndexes = utils.MustHash(...)

+ var ServiceAgreementExecutionLogTopic = utils.MustHash("ServiceAgreementExecution(bytes32,address,uint256,uint256,uint256,bytes)")

+ func AuthenticateBridgeType(bt *BridgeType, token string) (bool, error)

+ func AuthenticateExternalInitiator(eia *ExternalInitiatorAuthentication, ea *ExternalInitiator) (bool, error)

+ func FilterQueryFactory(i Initiator, from *big.Int) (ethereum.FilterQuery, error)

+ func HashedSecret(eia *ExternalInitiatorAuthentication, salt string) (string, error)

+ func NewBridgeType(btr *BridgeTypeRequest) (*BridgeTypeAuthentication, *BridgeType, error)

+ func NewDatabaseAccessError(msg string) error

+ func NewSecret() string

+ func NewValidationError(msg string, values ...interface{}) error

+ func TopicFiltersForRunLog(logTopics []common.Hash, jobID string) ([][]common.Hash, error)

+ 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 AnyTimeFromNull(t null.Time) AnyTime

+ 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 Big big.Int

+ func NewBig(i *big.Int) *Big

+ func (b *Big) Hex() string

+ func (b *Big) MarshalJSON() ([]byte, error)

+ func (b *Big) MarshalText() ([]byte, error)

+ func (b *Big) Scan(value interface{}) error

+ func (b *Big) String() string

+ func (b *Big) ToInt() *big.Int

+ func (b *Big) UnmarshalJSON(input []byte) error

+ func (b *Big) UnmarshalText(input []byte) error

+ func (b Big) Value() (driver.Value, error)

+ type BlockHeader struct

+ Bloom types.Bloom

+ Coinbase common.Address

+ Difficulty hexutil.Big

+ Extra hexutil.Bytes

+ GasLimit hexutil.Uint64

+ GasUsed hexutil.Uint64

+ GethHash common.Hash

+ Nonce types.BlockNonce

+ Number hexutil.Big

+ ParentHash common.Hash

+ ParityHash common.Hash

+ ReceiptHash common.Hash

+ Root common.Hash

+ Time hexutil.Big

+ TxHash common.Hash

+ UncleHash common.Hash

+ func (h BlockHeader) Hash() common.Hash

+ func (h BlockHeader) ToHead() *Head

+ type BridgeRunResult struct

+ AccessToken string

+ ExternalPending bool

+ func (brr *BridgeRunResult) UnmarshalJSON(input []byte) error

+ type BridgeType struct

+ Confirmations uint32

+ IncomingTokenHash string

+ MinimumContractPayment *assets.Link

+ Name TaskType

+ OutgoingToken string

+ Salt string

+ URL WebURL

+ func (bt *BridgeType) SetID(value string) error

+ func (bt BridgeType) GetID() string

+ func (bt BridgeType) GetName() string

+ type BridgeTypeAuthentication struct

+ Confirmations uint32

+ IncomingToken string

+ MinimumContractPayment *assets.Link

+ Name TaskType

+ OutgoingToken string

+ URL WebURL

+ func (bt *BridgeTypeAuthentication) SetID(value string) error

+ func (bt BridgeTypeAuthentication) GetID() string

+ func (bt BridgeTypeAuthentication) GetName() string

+ type BridgeTypeRequest struct

+ Confirmations uint32

+ MinimumContractPayment *assets.Link

+ 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 BulkTaskStatus string

+ func (t *BulkTaskStatus) Scan(value interface{}) error

+ func (t BulkTaskStatus) Value() (driver.Value, error)

+ type ChangePasswordRequest struct

+ NewPassword string

+ OldPassword string

+ type CreateKeyRequest struct

+ CurrentPassword 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 EIP55Address string

+ 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) 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

+ EndAt AnyTime

+ Expiration uint64

+ ID uint

+ Oracles EIP55AddressCollection

+ Payment *assets.Link

+ func (e Encumbrance) ABI() ([]byte, error)

+ type EthLogEvent struct

+ type EthSubscription interface

+ Err func() <-chan error

+ Unsubscribe func()

+ type ExternalInitiator struct

+ AccessKey string

+ HashedSecret string

+ Salt string

+ func NewExternalInitiator(eia *ExternalInitiatorAuthentication) (*ExternalInitiator, error)

+ type ExternalInitiatorAuthentication struct

+ AccessKey string

+ Secret string

+ func NewExternalInitiatorAuthentication() *ExternalInitiatorAuthentication

+ func (eia *ExternalInitiatorAuthentication) GetID() string

+ func (eia *ExternalInitiatorAuthentication) GetName() string

+ func (eia *ExternalInitiatorAuthentication) SetID(id string) error

+ type FunctionSelector [FunctionSelectorLength]byte

+ func BytesToFunctionSelector(b []byte) FunctionSelector

+ func HexToFunctionSelector(s string) FunctionSelector

+ func (f *FunctionSelector) SetBytes(b []byte)

+ func (f *FunctionSelector) UnmarshalJSON(input []byte) error

+ func (f FunctionSelector) Bytes() []byte

+ func (f FunctionSelector) String() string

+ func (f FunctionSelector) WithoutPrefix() string

+ type Head struct

+ HashRaw string

+ Number int64

+ func NewHead(bigint *big.Int, hash common.Hash) *Head

+ func (l *Head) GreaterThan(r *Head) bool

+ func (l *Head) Hash() common.Hash

+ func (l *Head) NextInt() *big.Int

+ func (l *Head) String() string

+ func (l *Head) ToInt() *big.Int

+ type Initiator struct

+ CreatedAt time.Time

+ DeletedAt null.Time

+ ID uint

+ JobSpecID string

+ Type string

+ func (i *Initiator) UnmarshalJSON(input []byte) error

+ func (i Initiator) IsLogInitiated() bool

+ type InitiatorLogEvent struct

+ Initiator Initiator

+ JobSpec JobSpec

+ Log Log

+ func (le InitiatorLogEvent) BlockNumber() *big.Int

+ func (le InitiatorLogEvent) ContractPayment() (*assets.Link, error)

+ func (le InitiatorLogEvent) ForLogger(kvs ...interface{}) []interface{}

+ func (le InitiatorLogEvent) GetInitiator() Initiator

+ func (le InitiatorLogEvent) GetJobSpec() JobSpec

+ func (le InitiatorLogEvent) GetLog() 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

+ Address common.Address

+ Ran bool

+ Requesters AddressCollection

+ Schedule Cron

+ Time AnyTime

+ type InitiatorRequest struct

+ Type string

+ type JSON struct

+ func ParseCBOR(b []byte) (JSON, error)

+ func ParseJSON(b []byte) (JSON, error)

+ func ParseRunLog(log Log) (JSON, error)

+ func (j *JSON) Scan(value interface{}) error

+ func (j *JSON) UnmarshalJSON(b []byte) error

+ func (j JSON) Add(key string, val interface{}) (JSON, error)

+ func (j JSON) Bytes() []byte

+ func (j JSON) CBOR() ([]byte, error)

+ func (j JSON) Delete(key string) (JSON, error)

+ func (j JSON) Empty() bool

+ func (j JSON) MarshalJSON() ([]byte, error)

+ func (j JSON) Merge(j2 JSON) (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 JobRun struct

+ CreatedAt time.Time

+ CreationHeight *Big

+ DeletedAt null.Time

+ FinishedAt null.Time

+ ID string

+ Initiator Initiator

+ InitiatorID uint

+ JobSpecID string

+ ObservedHeight *Big

+ Overrides RunResult

+ OverridesID uint

+ Result RunResult

+ ResultID uint

+ RunRequest RunRequest

+ RunRequestID uint

+ Status RunStatus

+ TaskRuns []TaskRun

+ UpdatedAt time.Time

+ func JobRunsWithStatus(runs []JobRun, status RunStatus) []JobRun

+ func (jr *JobRun) ApplyResult(result RunResult)

+ 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) SetFinishedAt()

+ func (jr *JobRun) SetID(value string) error

+ func (jr *JobRun) TasksRemain() bool

+ func (jr JobRun) ForLogger(kvs ...interface{}) []interface{}

+ func (jr JobRun) GetID() string

+ func (jr JobRun) GetName() string

+ type JobSpec struct

+ CreatedAt time.Time

+ DeletedAt null.Time

+ EndAt null.Time

+ ID string

+ Initiators []Initiator

+ StartAt null.Time

+ Tasks []TaskSpec

+ func NewJob() JobSpec

+ func NewJobFromRequest(jsr JobSpecRequest) JobSpec

+ func (j *JobSpec) SetID(value string) error

+ func (j JobSpec) Ended(t time.Time) bool

+ func (j JobSpec) GetID() string

+ func (j JobSpec) GetName() string

+ func (j JobSpec) InitiatorsFor(types ...string) []Initiator

+ func (j JobSpec) IsLogInitiated() bool

+ func (j JobSpec) NewRun(i Initiator) JobRun

+ func (j JobSpec) Started(t time.Time) bool

+ func (j JobSpec) WebAuthorized() bool

+ type JobSpecRequest struct

+ EndAt null.Time

+ Initiators []InitiatorRequest

+ StartAt null.Time

+ Tasks []TaskSpecRequest

+ type Key struct

+ Address EIP55Address

+ JSON JSON

+ func NewKeyFromFile(path string) (*Key, error)

+ func (k *Key) WriteToDisk(path string) error

+ type Log struct

+ Address common.Address

+ BlockHash common.Hash

+ BlockNumber uint64

+ Data []byte

+ Index uint

+ Removed bool

+ Topics []common.Hash

+ TxHash common.Hash

+ TxIndex uint

+ func (l *Log) UnmarshalJSON(input []byte) error

+ func (l Log) MarshalJSON() ([]byte, error)

+ type LogRequest interface

+ BlockNumber func() *big.Int

+ ContractPayment func() (*assets.Link, error)

+ ForLogger func(kvs ...interface{}) []interface{}

+ GetInitiator func() Initiator

+ GetJobSpec func() JobSpec

+ GetLog func() Log

+ JSON func() (JSON, error)

+ RunRequest func() (RunRequest, error)

+ ToDebug func()

+ Validate func() bool

+ ValidateRequester func() error

+ type RunLogEvent struct

+ func (le RunLogEvent) ContractPayment() (*assets.Link, error)

+ func (le RunLogEvent) JSON() (JSON, error)

+ func (le RunLogEvent) Requester() common.Address

+ func (le RunLogEvent) RunRequest() (RunRequest, error)

+ func (le RunLogEvent) Validate() bool

+ func (le RunLogEvent) ValidateRequester() error

+ type RunRequest struct

+ CreatedAt time.Time

+ ID uint

+ RequestID *string

+ Requester *common.Address

+ TxHash *common.Hash

+ func NewRunRequest() RunRequest

+ type RunResult struct

+ Amount *assets.Link

+ CachedJobRunID string

+ CachedTaskRunID string

+ Data JSON

+ ErrorMessage null.String

+ ID uint

+ Status RunStatus

+ func (rr *RunResult) Add(key string, result interface{})

+ func (rr *RunResult) ApplyResult(val interface{})

+ func (rr *RunResult) CompleteWithResult(val interface{})

+ func (rr *RunResult) Error() string

+ func (rr *RunResult) Get(path string) gjson.Result

+ func (rr *RunResult) GetError() error

+ func (rr *RunResult) HasError() bool

+ func (rr *RunResult) MarkPendingBridge()

+ func (rr *RunResult) MarkPendingConfirmations()

+ func (rr *RunResult) MarkPendingConnection()

+ func (rr *RunResult) Merge(in RunResult) error

+ func (rr *RunResult) Result() gjson.Result

+ func (rr *RunResult) ResultString() (string, error)

+ func (rr *RunResult) SetError(err error)

+ type RunStatus string

+ func (s *RunStatus) Scan(value interface{}) error

+ func (s RunStatus) CanStart() 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) PendingConfirmations() bool

+ func (s RunStatus) PendingConnection() 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 uint

+ ID string

+ JobSpec JobSpec

+ JobSpecID string

+ RequestBody string

+ Signature Signature

+ 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 Session struct

+ CreatedAt time.Time

+ ID string

+ LastUsed time.Time

+ func NewSession() Session

+ type SessionRequest struct

+ Email string

+ Password string

+ 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

+ Sign func(input []byte) (Signature, error)

+ type SyncEvent struct

+ Body string

+ CreatedAt time.Time

+ ID uint

+ UpdatedAt time.Time

+ type TaskRun struct

+ Confirmations clnull.Uint32

+ CreatedAt time.Time

+ ID string

+ JobRunID string

+ MinimumConfirmations clnull.Uint32

+ Result RunResult

+ ResultID uint

+ Status RunStatus

+ TaskSpec TaskSpec

+ TaskSpecID uint

+ func (tr *TaskRun) ApplyResult(result RunResult)

+ func (tr *TaskRun) ForLogger(kvs ...interface{}) []interface{}

+ func (tr *TaskRun) MarkPendingConfirmations()

+ func (tr *TaskRun) SetError(err error)

+ func (tr TaskRun) String() string

+ type TaskSpec struct

+ Confirmations clnull.Uint32

+ JobSpecID string

+ Params JSON

+ Type TaskType

+ type TaskSpecRequest struct

+ Confirmations 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 Tx struct

+ Attempts []*TxAttempt

+ Confirmed bool

+ Data []byte

+ From common.Address

+ GasLimit uint64

+ GasPrice *Big

+ Hash common.Hash

+ ID uint64

+ Nonce uint64

+ SentAt uint64

+ SignedRawTx string

+ SurrogateID null.String

+ To common.Address

+ Value *Big

+ func (tx *Tx) String() string

+ func (tx Tx) EthTx(gasPriceWei *big.Int) *types.Transaction

+ type TxAttempt struct

+ Confirmed bool

+ CreatedAt time.Time

+ GasPrice *Big

+ Hash common.Hash

+ ID uint64

+ SentAt uint64

+ SignedRawTx string

+ Tx *Tx

+ TxID uint64

+ func (txa *TxAttempt) SetID(value string) error

+ func (txa *TxAttempt) String() string

+ func (txa TxAttempt) GetID() string

+ func (txa TxAttempt) GetName() string

+ type TxReceipt struct

+ BlockNumber *Big

+ Hash common.Hash

+ Logs []Log

+ func (txr *TxReceipt) Unconfirmed() bool

+ func (txr TxReceipt) FulfilledRunLog() bool

+ type UnsignedServiceAgreement struct

+ Encumbrance Encumbrance

+ ID common.Hash

+ JobSpecRequest JobSpecRequest

+ RequestBody string

+ func NewUnsignedServiceAgreementFromRequest(reader io.Reader) (UnsignedServiceAgreement, error)

+ type User struct

+ CreatedAt time.Time

+ Email string

+ HashedPassword string

+ func NewUser(email, plainPwd string) (User, 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.Link

+ ContractAddress common.Address

+ DestinationAddress common.Address