Versions in this module Expand all Collapse all v0 v0.6.4 Jul 24, 2019 Changes in this version type RunRequest + BlockHash *common.Hash type TxReceipt + BlockHash common.Hash v0.6.3 Jul 9, 2019 v0.6.2 Jun 27, 2019 v0.6.1 Jun 26, 2019 Changes in this version type Head + ID uint64 v0.6.0 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
Go to main page