Versions in this module Expand all Collapse all v0 v0.0.2 Mar 12, 2021 Changes in this version + type AdvisoryLocker struct + func (_m *AdvisoryLocker) Close() error + func (_m *AdvisoryLocker) Unlock(ctx context.Context, classID int32, objectID int32) error + func (_m *AdvisoryLocker) WithAdvisoryLock(ctx context.Context, classID int32, objectID int32, f func() error) error + type AfterNower struct + func (_m *AfterNower) After(d time.Duration) <-chan time.Time + func (_m *AfterNower) Now() time.Time + type Application struct + func (_m *Application) AddJob(_a0 models.JobSpec) error + func (_m *Application) AddJobV2(ctx context.Context, _a1 job.SpecDB, name null.String) (int32, error) + func (_m *Application) AddServiceAgreement(_a0 *models.ServiceAgreement) error + func (_m *Application) ArchiveJob(_a0 models.JobID) error + func (_m *Application) AwaitRun(ctx context.Context, runID int64) error + func (_m *Application) Cancel(runID uuid.UUID) (*models.JobRun, error) + func (_m *Application) Create(jobSpecID models.JobID, initiator *models.Initiator, creationHeight *big.Int, ...) (*models.JobRun, error) + func (_m *Application) CreateErrored(jobSpecID models.JobID, initiator models.Initiator, err error) (*models.JobRun, error) + func (_m *Application) DeleteJobV2(ctx context.Context, jobID int32) error + func (_m *Application) GetExternalInitiatorManager() seerlink.ExternalInitiatorManager + func (_m *Application) GetJobORM() job.ORM + func (_m *Application) GetStatsPusher() synchronization.StatsPusher + func (_m *Application) GetStore() *store.Store + func (_m *Application) NewBox() packr.Box + func (_m *Application) ResumeAllInProgress() error + func (_m *Application) ResumeAllPendingConnection() error + func (_m *Application) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error + func (_m *Application) ResumePendingBridge(runID uuid.UUID, input models.BridgeRunResult) error + func (_m *Application) RunJobV2(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error) + func (_m *Application) Start() error + func (_m *Application) Stop() error + func (_m *Application) WakeSessionReaper() + type Client struct + func (_m *Client) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error) + func (_m *Client) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error + func (_m *Client) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error) + func (_m *Client) Call(result interface{}, method string, args ...interface{}) error + func (_m *Client) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error + func (_m *Client) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error) + func (_m *Client) ChainID(ctx context.Context) (*big.Int, error) + func (_m *Client) Close() + func (_m *Client) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error) + func (_m *Client) Dial(ctx context.Context) error + func (_m *Client) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error) + func (_m *Client) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error) + func (_m *Client) GetERC20Balance(address common.Address, contractAddress common.Address) (*big.Int, error) + func (_m *Client) GetEthBalance(ctx context.Context, account common.Address, blockNumber *big.Int) (*assets.Eth, error) + func (_m *Client) GetLINKBalance(linkAddress common.Address, address common.Address) (*assets.Link, error) + func (_m *Client) HeaderByNumber(ctx context.Context, n *big.Int) (*models.Head, error) + func (_m *Client) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error) + func (_m *Client) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error) + func (_m *Client) SendRawTx(bytes []byte) (common.Hash, error) + func (_m *Client) SendTransaction(ctx context.Context, tx *types.Transaction) error + func (_m *Client) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error) + func (_m *Client) SubscribeNewHead(ctx context.Context, ch chan<- *models.Head) (ethereum.Subscription, error) + func (_m *Client) SuggestGasPrice(ctx context.Context) (*big.Int, error) + func (_m *Client) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error) + type DeviationChecker struct + func (_m *DeviationChecker) Start() + func (_m *DeviationChecker) Stop() + type DeviationCheckerFactory struct + func (_m *DeviationCheckerFactory) New(_a0 models.Initiator, _a1 *assets.Link, _a2 fluxmonitor.RunManager, ...) (fluxmonitor.DeviationChecker, error) + type ExternalInitiatorManager struct + func (_m *ExternalInitiatorManager) DeleteJob(db *gorm.DB, jobID models.JobID) error + func (_m *ExternalInitiatorManager) Notify(_a0 models.JobSpec, _a1 *store.Store) error + type Fetcher struct + func (_m *Fetcher) Fetch(_a0 context.Context, _a1 map[string]interface{}) (decimal.Decimal, error) + type FluxAggregator struct + func (_m *FluxAggregator) AcceptAdmin(opts *bind.TransactOpts, _oracle common.Address) (*types.Transaction, error) + func (_m *FluxAggregator) AcceptOwnership(opts *bind.TransactOpts) (*types.Transaction, error) + func (_m *FluxAggregator) Address() common.Address + func (_m *FluxAggregator) AllocatedFunds(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) AvailableFunds(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) ChangeOracles(opts *bind.TransactOpts, _removed []common.Address, _added []common.Address, ...) (*types.Transaction, error) + func (_m *FluxAggregator) Decimals(opts *bind.CallOpts) (uint8, error) + func (_m *FluxAggregator) Description(opts *bind.CallOpts) (string, error) + func (_m *FluxAggregator) FilterAnswerUpdated(opts *bind.FilterOpts, current []*big.Int, roundId []*big.Int) (*flux_aggregator_wrapper.FluxAggregatorAnswerUpdatedIterator, error) + func (_m *FluxAggregator) FilterAvailableFundsUpdated(opts *bind.FilterOpts, amount []*big.Int) (*flux_aggregator_wrapper.FluxAggregatorAvailableFundsUpdatedIterator, error) + func (_m *FluxAggregator) FilterNewRound(opts *bind.FilterOpts, roundId []*big.Int, startedBy []common.Address) (*flux_aggregator_wrapper.FluxAggregatorNewRoundIterator, error) + func (_m *FluxAggregator) FilterOracleAdminUpdateRequested(opts *bind.FilterOpts, oracle []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdateRequestedIterator, ...) + func (_m *FluxAggregator) FilterOracleAdminUpdated(opts *bind.FilterOpts, oracle []common.Address, newAdmin []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdatedIterator, error) + func (_m *FluxAggregator) FilterOraclePermissionsUpdated(opts *bind.FilterOpts, oracle []common.Address, whitelisted []bool) (*flux_aggregator_wrapper.FluxAggregatorOraclePermissionsUpdatedIterator, error) + func (_m *FluxAggregator) FilterOwnershipTransferRequested(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferRequestedIterator, ...) + func (_m *FluxAggregator) FilterOwnershipTransferred(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferredIterator, error) + func (_m *FluxAggregator) FilterRequesterPermissionsSet(opts *bind.FilterOpts, requester []common.Address) (*flux_aggregator_wrapper.FluxAggregatorRequesterPermissionsSetIterator, error) + func (_m *FluxAggregator) FilterRoundDetailsUpdated(opts *bind.FilterOpts, paymentAmount []*big.Int, minSubmissionCount []uint32, ...) (*flux_aggregator_wrapper.FluxAggregatorRoundDetailsUpdatedIterator, error) + func (_m *FluxAggregator) FilterSubmissionReceived(opts *bind.FilterOpts, submission []*big.Int, round []uint32, ...) (*flux_aggregator_wrapper.FluxAggregatorSubmissionReceivedIterator, error) + func (_m *FluxAggregator) FilterValidatorUpdated(opts *bind.FilterOpts, previous []common.Address, current []common.Address) (*flux_aggregator_wrapper.FluxAggregatorValidatorUpdatedIterator, error) + func (_m *FluxAggregator) GetAdmin(opts *bind.CallOpts, _oracle common.Address) (common.Address, error) + func (_m *FluxAggregator) GetAnswer(opts *bind.CallOpts, _roundId *big.Int) (*big.Int, error) + func (_m *FluxAggregator) GetOracles(opts *bind.CallOpts) ([]common.Address, error) + func (_m *FluxAggregator) GetRoundData(opts *bind.CallOpts, _roundId *big.Int) (flux_aggregator_wrapper.GetRoundData, error) + func (_m *FluxAggregator) GetTimestamp(opts *bind.CallOpts, _roundId *big.Int) (*big.Int, error) + func (_m *FluxAggregator) LatestAnswer(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) LatestRound(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) LatestRoundData(opts *bind.CallOpts) (flux_aggregator_wrapper.LatestRoundData, error) + func (_m *FluxAggregator) LatestTimestamp(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) LinkToken(opts *bind.CallOpts) (common.Address, error) + func (_m *FluxAggregator) MaxSubmissionCount(opts *bind.CallOpts) (uint32, error) + func (_m *FluxAggregator) MaxSubmissionValue(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) MinSubmissionCount(opts *bind.CallOpts) (uint32, error) + func (_m *FluxAggregator) MinSubmissionValue(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) OnTokenTransfer(opts *bind.TransactOpts, arg0 common.Address, arg1 *big.Int, _data []byte) (*types.Transaction, error) + func (_m *FluxAggregator) OracleCount(opts *bind.CallOpts) (uint8, error) + func (_m *FluxAggregator) OracleRoundState(opts *bind.CallOpts, _oracle common.Address, _queriedRoundId uint32) (flux_aggregator_wrapper.OracleRoundState, error) + func (_m *FluxAggregator) Owner(opts *bind.CallOpts) (common.Address, error) + func (_m *FluxAggregator) ParseAnswerUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorAnswerUpdated, error) + func (_m *FluxAggregator) ParseAvailableFundsUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorAvailableFundsUpdated, error) + func (_m *FluxAggregator) ParseNewRound(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorNewRound, error) + func (_m *FluxAggregator) ParseOracleAdminUpdateRequested(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdateRequested, error) + func (_m *FluxAggregator) ParseOracleAdminUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdated, error) + func (_m *FluxAggregator) ParseOraclePermissionsUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOraclePermissionsUpdated, error) + func (_m *FluxAggregator) ParseOwnershipTransferRequested(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferRequested, error) + func (_m *FluxAggregator) ParseOwnershipTransferred(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferred, error) + func (_m *FluxAggregator) ParseRequesterPermissionsSet(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorRequesterPermissionsSet, error) + func (_m *FluxAggregator) ParseRoundDetailsUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorRoundDetailsUpdated, error) + func (_m *FluxAggregator) ParseSubmissionReceived(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorSubmissionReceived, error) + func (_m *FluxAggregator) ParseValidatorUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorValidatorUpdated, error) + func (_m *FluxAggregator) PaymentAmount(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) RequestNewRound(opts *bind.TransactOpts) (*types.Transaction, error) + func (_m *FluxAggregator) RestartDelay(opts *bind.CallOpts) (uint32, error) + func (_m *FluxAggregator) SetRequesterPermissions(opts *bind.TransactOpts, _requester common.Address, _authorized bool, ...) (*types.Transaction, error) + func (_m *FluxAggregator) SetValidator(opts *bind.TransactOpts, _newValidator common.Address) (*types.Transaction, error) + func (_m *FluxAggregator) Submit(opts *bind.TransactOpts, _roundId *big.Int, _submission *big.Int) (*types.Transaction, error) + func (_m *FluxAggregator) Timeout(opts *bind.CallOpts) (uint32, error) + func (_m *FluxAggregator) TransferAdmin(opts *bind.TransactOpts, _oracle common.Address, _newAdmin common.Address) (*types.Transaction, error) + func (_m *FluxAggregator) TransferOwnership(opts *bind.TransactOpts, _to common.Address) (*types.Transaction, error) + func (_m *FluxAggregator) UnpackLog(out interface{}, _a1 string, log types.Log) error + func (_m *FluxAggregator) UpdateAvailableFunds(opts *bind.TransactOpts) (*types.Transaction, error) + func (_m *FluxAggregator) UpdateFutureRounds(opts *bind.TransactOpts, _paymentAmount *big.Int, _minSubmissions uint32, ...) (*types.Transaction, error) + func (_m *FluxAggregator) Validator(opts *bind.CallOpts) (common.Address, error) + func (_m *FluxAggregator) Version(opts *bind.CallOpts) (*big.Int, error) + func (_m *FluxAggregator) WatchAnswerUpdated(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchAvailableFundsUpdated(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchNewRound(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchOracleAdminUpdateRequested(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchOracleAdminUpdated(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchOraclePermissionsUpdated(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchOwnershipTransferRequested(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchOwnershipTransferred(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchRequesterPermissionsSet(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchRoundDetailsUpdated(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchSubmissionReceived(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WatchValidatorUpdated(opts *bind.WatchOpts, ...) (event.Subscription, error) + func (_m *FluxAggregator) WithdrawFunds(opts *bind.TransactOpts, _recipient common.Address, _amount *big.Int) (*types.Transaction, error) + func (_m *FluxAggregator) WithdrawPayment(opts *bind.TransactOpts, _oracle common.Address, _recipient common.Address, ...) (*types.Transaction, error) + func (_m *FluxAggregator) WithdrawablePayment(opts *bind.CallOpts, _oracle common.Address) (*big.Int, error) + type FluxMonitor struct + func (_m *FluxMonitor) AddJob(_a0 models.JobSpec) error + func (_m *FluxMonitor) Connect(_a0 *models.Head) error + func (_m *FluxMonitor) Disconnect() + func (_m *FluxMonitor) OnNewLongestChain(_a0 *models.Head) + func (_m *FluxMonitor) RemoveJob(_a0 models.JobID) + func (_m *FluxMonitor) Start() error + func (_m *FluxMonitor) Stop() + type GethClient struct + func (_m *GethClient) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error) + func (_m *GethClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error) + func (_m *GethClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error) + func (_m *GethClient) ChainID(ctx context.Context) (*big.Int, error) + func (_m *GethClient) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error) + func (_m *GethClient) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error) + func (_m *GethClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error) + func (_m *GethClient) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error) + func (_m *GethClient) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error) + func (_m *GethClient) SendTransaction(ctx context.Context, tx *types.Transaction) error + func (_m *GethClient) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error) + func (_m *GethClient) SuggestGasPrice(ctx context.Context) (*big.Int, error) + func (_m *GethClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error) + type HeadTrackable struct + func (_m *HeadTrackable) Connect(head *models.Head) error + func (_m *HeadTrackable) Disconnect() + func (_m *HeadTrackable) OnNewLongestChain(ctx context.Context, head models.Head) + type JobSubscriber struct + func (_m *JobSubscriber) AddJob(job models.JobSpec, bn *models.Head) error + func (_m *JobSubscriber) Connect(head *models.Head) error + func (_m *JobSubscriber) Disconnect() + func (_m *JobSubscriber) Jobs() []models.JobSpec + func (_m *JobSubscriber) OnNewLongestChain(ctx context.Context, head models.Head) + func (_m *JobSubscriber) RemoveJob(ID models.JobID) error + func (_m *JobSubscriber) Stop() error + type KeyStoreInterface struct + func (_m *KeyStoreInterface) Accounts() []accounts.Account + func (_m *KeyStoreInterface) Delete(address common.Address) error + func (_m *KeyStoreInterface) Export(address common.Address, newPassword string) ([]byte, error) + func (_m *KeyStoreInterface) GetAccountByAddress(_a0 common.Address) (accounts.Account, error) + func (_m *KeyStoreInterface) GetAccounts() []accounts.Account + func (_m *KeyStoreInterface) HasAccountWithAddress(_a0 common.Address) bool + func (_m *KeyStoreInterface) HasAccounts() bool + func (_m *KeyStoreInterface) Import(keyJSON []byte, oldPassword string) (accounts.Account, error) + func (_m *KeyStoreInterface) NewAccount() (accounts.Account, error) + func (_m *KeyStoreInterface) SignTx(account accounts.Account, tx *types.Transaction, chainID *big.Int) (*types.Transaction, error) + func (_m *KeyStoreInterface) Unlock(password string) error + func (_m *KeyStoreInterface) Wallets() []accounts.Wallet + type NotifyNewEthTx struct + func (_m *NotifyNewEthTx) Trigger() + type PrometheusBackend struct + func (_m *PrometheusBackend) SetMaxUnconfirmedBlocks(_a0 int64) + func (_m *PrometheusBackend) SetPipelineRunsQueued(n int) + func (_m *PrometheusBackend) SetPipelineTaskRunsQueued(n int) + func (_m *PrometheusBackend) SetUnconfirmedTransactions(_a0 int64) + type RPCClient struct + func (_m *RPCClient) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error + func (_m *RPCClient) Call(result interface{}, method string, args ...interface{}) error + func (_m *RPCClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error + func (_m *RPCClient) Close() + func (_m *RPCClient) EthSubscribe(ctx context.Context, channel interface{}, args ...interface{}) (ethereum.Subscription, error) + type RunExecutor struct + func (_m *RunExecutor) Execute(_a0 uuid.UUID) error + type RunManager struct + func (_m *RunManager) Cancel(runID uuid.UUID) (*models.JobRun, error) + func (_m *RunManager) Create(jobSpecID models.JobID, initiator *models.Initiator, creationHeight *big.Int, ...) (*models.JobRun, error) + func (_m *RunManager) CreateErrored(jobSpecID models.JobID, initiator models.Initiator, err error) (*models.JobRun, error) + func (_m *RunManager) ResumeAllInProgress() error + func (_m *RunManager) ResumeAllPendingConnection() error + func (_m *RunManager) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error + func (_m *RunManager) ResumePendingBridge(runID uuid.UUID, input models.BridgeRunResult) error + type RunQueue struct + func (_m *RunQueue) Run(_a0 uuid.UUID) + func (_m *RunQueue) Start() error + func (_m *RunQueue) Stop() + func (_m *RunQueue) WorkerCount() int + type Service struct + func (_m *Service) AddJob(_a0 models.JobSpec) error + func (_m *Service) RemoveJob(_a0 models.JobID) + func (_m *Service) Start() error + func (_m *Service) Stop() + type StatsPusher struct + func (_m *StatsPusher) AllSyncEvents(cb func(models.SyncEvent) error) error + func (_m *StatsPusher) Close() error + func (_m *StatsPusher) GetStatus() synchronization.ConnectionStatus + func (_m *StatsPusher) GetURL() url.URL + func (_m *StatsPusher) PushNow() + func (_m *StatsPusher) Start() error + type Subscription struct + func (_m *Subscription) Err() <-chan error + func (_m *Subscription) Unsubscribe()