Documentation ¶
Index ¶
- type AdvisoryLocker
- type AfterNower
- type Application
- func (_m *Application) AddJob(_a0 models.JobSpec) error
- func (_m *Application) AddJobV2(ctx context.Context, _a1 job.Job, name null.String) (job.Job, error)
- func (_m *Application) AddServiceAgreement(_a0 *models.ServiceAgreement) error
- func (_m *Application) ArchiveJob(_a0 models.JobID) 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) GetConfig() *config.Config
- func (_m *Application) GetEthClient() eth.Client
- func (_m *Application) GetExternalInitiatorManager() webhook.ExternalInitiatorManager
- func (_m *Application) GetFeedsService() feeds.Service
- func (_m *Application) GetHeadBroadcaster() types.HeadBroadcasterRegistry
- func (_m *Application) GetHealthChecker() health.Checker
- func (_m *Application) GetKeyStore() *keystore.Master
- func (_m *Application) GetLogger() *logger.Logger
- func (_m *Application) GetStatsPusher() synchronization.StatsPusher
- func (_m *Application) GetStore() *store.Store
- func (_m *Application) JobORM() job.ORM
- func (_m *Application) JobSpawner() job.Spawner
- func (_m *Application) NewBox() packr.Box
- func (_m *Application) PipelineORM() pipeline.ORM
- func (_m *Application) ReplayFromBlock(number uint64) error
- func (_m *Application) ResumeAllInProgress() error
- func (_m *Application) ResumeAllPendingConnection() error
- func (_m *Application) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error
- func (_m *Application) ResumeJobV2(ctx context.Context, run *pipeline.Run) (bool, 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) RunWebhookJobV2(ctx context.Context, jobUUID uuid.UUID, requestBody string, ...) (int64, error)
- func (_m *Application) SetServiceLogger(ctx context.Context, service string, level zapcore.Level) error
- func (_m *Application) Start() error
- func (_m *Application) Stop() error
- func (_m *Application) WakeSessionReaper()
- type Checker
- type Client
- 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) HeadByNumber(ctx context.Context, n *big.Int) (*models.Head, error)
- func (_m *Client) HeaderByNumber(_a0 context.Context, _a1 *big.Int) (*types.Header, error)
- func (_m *Client) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, 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) RoundRobinBatchCallContext(ctx context.Context, b []rpc.BatchElem) 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) SuggestGasTipCap(ctx context.Context) (*big.Int, error)
- func (_m *Client) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
- type DeviationChecker
- type DeviationCheckerFactory
- type Fetcher
- type Flags
- func (_m *Flags) AcceptOwnership(opts *bind.TransactOpts) (*types.Transaction, error)
- func (_m *Flags) AddAccess(opts *bind.TransactOpts, _user common.Address) (*types.Transaction, error)
- func (_m *Flags) Address() common.Address
- func (_m *Flags) CheckEnabled(opts *bind.CallOpts) (bool, error)
- func (_m *Flags) DisableAccessCheck(opts *bind.TransactOpts) (*types.Transaction, error)
- func (_m *Flags) EnableAccessCheck(opts *bind.TransactOpts) (*types.Transaction, error)
- func (_m *Flags) FilterAddedAccess(opts *bind.FilterOpts) (*flags_wrapper.FlagsAddedAccessIterator, error)
- func (_m *Flags) FilterCheckAccessDisabled(opts *bind.FilterOpts) (*flags_wrapper.FlagsCheckAccessDisabledIterator, error)
- func (_m *Flags) FilterCheckAccessEnabled(opts *bind.FilterOpts) (*flags_wrapper.FlagsCheckAccessEnabledIterator, error)
- func (_m *Flags) FilterFlagLowered(opts *bind.FilterOpts, subject []common.Address) (*flags_wrapper.FlagsFlagLoweredIterator, error)
- func (_m *Flags) FilterFlagRaised(opts *bind.FilterOpts, subject []common.Address) (*flags_wrapper.FlagsFlagRaisedIterator, error)
- func (_m *Flags) FilterOwnershipTransferRequested(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flags_wrapper.FlagsOwnershipTransferRequestedIterator, error)
- func (_m *Flags) FilterOwnershipTransferred(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flags_wrapper.FlagsOwnershipTransferredIterator, error)
- func (_m *Flags) FilterRaisingAccessControllerUpdated(opts *bind.FilterOpts, previous []common.Address, current []common.Address) (*flags_wrapper.FlagsRaisingAccessControllerUpdatedIterator, error)
- func (_m *Flags) FilterRemovedAccess(opts *bind.FilterOpts) (*flags_wrapper.FlagsRemovedAccessIterator, error)
- func (_m *Flags) GetFlag(opts *bind.CallOpts, subject common.Address) (bool, error)
- func (_m *Flags) GetFlags(opts *bind.CallOpts, subjects []common.Address) ([]bool, error)
- func (_m *Flags) HasAccess(opts *bind.CallOpts, _user common.Address, _calldata []byte) (bool, error)
- func (_m *Flags) LowerFlags(opts *bind.TransactOpts, subjects []common.Address) (*types.Transaction, error)
- func (_m *Flags) Owner(opts *bind.CallOpts) (common.Address, error)
- func (_m *Flags) ParseAddedAccess(log types.Log) (*flags_wrapper.FlagsAddedAccess, error)
- func (_m *Flags) ParseCheckAccessDisabled(log types.Log) (*flags_wrapper.FlagsCheckAccessDisabled, error)
- func (_m *Flags) ParseCheckAccessEnabled(log types.Log) (*flags_wrapper.FlagsCheckAccessEnabled, error)
- func (_m *Flags) ParseFlagLowered(log types.Log) (*flags_wrapper.FlagsFlagLowered, error)
- func (_m *Flags) ParseFlagRaised(log types.Log) (*flags_wrapper.FlagsFlagRaised, error)
- func (_m *Flags) ParseLog(log types.Log) (generated.AbigenLog, error)
- func (_m *Flags) ParseOwnershipTransferRequested(log types.Log) (*flags_wrapper.FlagsOwnershipTransferRequested, error)
- func (_m *Flags) ParseOwnershipTransferred(log types.Log) (*flags_wrapper.FlagsOwnershipTransferred, error)
- func (_m *Flags) ParseRaisingAccessControllerUpdated(log types.Log) (*flags_wrapper.FlagsRaisingAccessControllerUpdated, error)
- func (_m *Flags) ParseRemovedAccess(log types.Log) (*flags_wrapper.FlagsRemovedAccess, error)
- func (_m *Flags) RaiseFlag(opts *bind.TransactOpts, subject common.Address) (*types.Transaction, error)
- func (_m *Flags) RaiseFlags(opts *bind.TransactOpts, subjects []common.Address) (*types.Transaction, error)
- func (_m *Flags) RaisingAccessController(opts *bind.CallOpts) (common.Address, error)
- func (_m *Flags) RemoveAccess(opts *bind.TransactOpts, _user common.Address) (*types.Transaction, error)
- func (_m *Flags) SetRaisingAccessController(opts *bind.TransactOpts, racAddress common.Address) (*types.Transaction, error)
- func (_m *Flags) TransferOwnership(opts *bind.TransactOpts, _to common.Address) (*types.Transaction, error)
- func (_m *Flags) WatchAddedAccess(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsAddedAccess) (event.Subscription, error)
- func (_m *Flags) WatchCheckAccessDisabled(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsCheckAccessDisabled) (event.Subscription, error)
- func (_m *Flags) WatchCheckAccessEnabled(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsCheckAccessEnabled) (event.Subscription, error)
- func (_m *Flags) WatchFlagLowered(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsFlagLowered, ...) (event.Subscription, error)
- func (_m *Flags) WatchFlagRaised(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsFlagRaised, ...) (event.Subscription, error)
- func (_m *Flags) WatchOwnershipTransferRequested(opts *bind.WatchOpts, ...) (event.Subscription, error)
- func (_m *Flags) WatchOwnershipTransferred(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsOwnershipTransferred, ...) (event.Subscription, error)
- func (_m *Flags) WatchRaisingAccessControllerUpdated(opts *bind.WatchOpts, ...) (event.Subscription, error)
- func (_m *Flags) WatchRemovedAccess(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsRemovedAccess) (event.Subscription, error)
- type FluxAggregator
- 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) ParseLog(log types.Log) (generated.AbigenLog, 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) 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 JobSubscriber
- func (_m *JobSubscriber) AddJob(job models.JobSpec, bn *models.Head) error
- func (_m *JobSubscriber) Close() error
- func (_m *JobSubscriber) Connect(head *models.Head) error
- func (_m *JobSubscriber) Healthy() error
- func (_m *JobSubscriber) Jobs() []models.JobSpec
- func (_m *JobSubscriber) OnNewLongestChain(ctx context.Context, head models.Head)
- func (_m *JobSubscriber) Ready() error
- func (_m *JobSubscriber) RemoveJob(ID models.JobID) error
- func (_m *JobSubscriber) Start() error
- type NotifyNewEthTx
- type PrometheusBackend
- func (_m *PrometheusBackend) SetMaxUnconfirmedAge(_a0 float64)
- 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 RunExecutor
- type RunManager
- 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
- type Service
- type StatsPusher
- 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) Healthy() error
- func (_m *StatsPusher) PushNow()
- func (_m *StatsPusher) Ready() error
- func (_m *StatsPusher) Start() error
- type Subscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AdvisoryLocker ¶ added in v0.9.3
AdvisoryLocker is an autogenerated mock type for the AdvisoryLocker type
func (*AdvisoryLocker) Close ¶ added in v0.9.3
func (_m *AdvisoryLocker) Close() error
Close provides a mock function with given fields:
func (*AdvisoryLocker) Unlock ¶ added in v0.9.3
Unlock provides a mock function with given fields: ctx, classID, objectID
func (*AdvisoryLocker) WithAdvisoryLock ¶ added in v0.9.3
func (_m *AdvisoryLocker) WithAdvisoryLock(ctx context.Context, classID int32, objectID int32, f func() error) error
WithAdvisoryLock provides a mock function with given fields: ctx, classID, objectID, f
type AfterNower ¶ added in v0.8.3
AfterNower is an autogenerated mock type for the AfterNower type
func (*AfterNower) After ¶ added in v0.8.3
func (_m *AfterNower) After(d time.Duration) <-chan time.Time
After provides a mock function with given fields: d
func (*AfterNower) Now ¶ added in v0.8.3
func (_m *AfterNower) Now() time.Time
Now provides a mock function with given fields:
type Application ¶ added in v0.8.2
Application is an autogenerated mock type for the Application type
func (*Application) AddJob ¶ added in v0.8.2
func (_m *Application) AddJob(_a0 models.JobSpec) error
AddJob provides a mock function with given fields: _a0
func (*Application) AddJobV2 ¶ added in v0.9.3
func (_m *Application) AddJobV2(ctx context.Context, _a1 job.Job, name null.String) (job.Job, error)
AddJobV2 provides a mock function with given fields: ctx, _a1, name
func (*Application) AddServiceAgreement ¶ added in v0.8.2
func (_m *Application) AddServiceAgreement(_a0 *models.ServiceAgreement) error
AddServiceAgreement provides a mock function with given fields: _a0
func (*Application) ArchiveJob ¶ added in v0.8.2
func (_m *Application) ArchiveJob(_a0 models.JobID) error
ArchiveJob provides a mock function with given fields: _a0
func (*Application) Cancel ¶ added in v0.8.2
Cancel provides a mock function with given fields: runID
func (*Application) Create ¶ added in v0.8.2
func (_m *Application) Create(jobSpecID models.JobID, initiator *models.Initiator, creationHeight *big.Int, runRequest *models.RunRequest) (*models.JobRun, error)
Create provides a mock function with given fields: jobSpecID, initiator, creationHeight, runRequest
func (*Application) CreateErrored ¶ added in v0.8.2
func (_m *Application) CreateErrored(jobSpecID models.JobID, initiator models.Initiator, err error) (*models.JobRun, error)
CreateErrored provides a mock function with given fields: jobSpecID, initiator, err
func (*Application) DeleteJobV2 ¶ added in v0.9.3
func (_m *Application) DeleteJobV2(ctx context.Context, jobID int32) error
DeleteJobV2 provides a mock function with given fields: ctx, jobID
func (*Application) GetConfig ¶ added in v0.10.11
func (_m *Application) GetConfig() *config.Config
GetConfig provides a mock function with given fields:
func (*Application) GetEthClient ¶ added in v0.10.11
func (_m *Application) GetEthClient() eth.Client
GetEthClient provides a mock function with given fields:
func (*Application) GetExternalInitiatorManager ¶ added in v0.9.10
func (_m *Application) GetExternalInitiatorManager() webhook.ExternalInitiatorManager
GetExternalInitiatorManager provides a mock function with given fields:
func (*Application) GetFeedsService ¶ added in v0.10.8
func (_m *Application) GetFeedsService() feeds.Service
GetFeedsService provides a mock function with given fields:
func (*Application) GetHeadBroadcaster ¶ added in v0.10.8
func (_m *Application) GetHeadBroadcaster() types.HeadBroadcasterRegistry
GetHeadBroadcaster provides a mock function with given fields:
func (*Application) GetHealthChecker ¶ added in v0.10.8
func (_m *Application) GetHealthChecker() health.Checker
GetHealthChecker provides a mock function with given fields:
func (*Application) GetKeyStore ¶ added in v0.10.8
func (_m *Application) GetKeyStore() *keystore.Master
GetKeyStore provides a mock function with given fields:
func (*Application) GetLogger ¶ added in v0.10.6
func (_m *Application) GetLogger() *logger.Logger
GetLogger provides a mock function with given fields:
func (*Application) GetStatsPusher ¶ added in v0.8.2
func (_m *Application) GetStatsPusher() synchronization.StatsPusher
GetStatsPusher provides a mock function with given fields:
func (*Application) GetStore ¶ added in v0.8.2
func (_m *Application) GetStore() *store.Store
GetStore provides a mock function with given fields:
func (*Application) JobORM ¶ added in v0.10.8
func (_m *Application) JobORM() job.ORM
JobORM provides a mock function with given fields:
func (*Application) JobSpawner ¶ added in v0.10.8
func (_m *Application) JobSpawner() job.Spawner
JobSpawner provides a mock function with given fields:
func (*Application) NewBox ¶ added in v0.8.2
func (_m *Application) NewBox() packr.Box
NewBox provides a mock function with given fields:
func (*Application) PipelineORM ¶ added in v0.10.8
func (_m *Application) PipelineORM() pipeline.ORM
PipelineORM provides a mock function with given fields:
func (*Application) ReplayFromBlock ¶ added in v0.10.11
func (_m *Application) ReplayFromBlock(number uint64) error
ReplayFromBlock provides a mock function with given fields: number
func (*Application) ResumeAllInProgress ¶ added in v0.8.2
func (_m *Application) ResumeAllInProgress() error
ResumeAllInProgress provides a mock function with given fields:
func (*Application) ResumeAllPendingConnection ¶ added in v0.8.4
func (_m *Application) ResumeAllPendingConnection() error
ResumeAllPendingConnection provides a mock function with given fields:
func (*Application) ResumeAllPendingNextBlock ¶ added in v0.8.4
func (_m *Application) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error
ResumeAllPendingNextBlock provides a mock function with given fields: currentBlockHeight
func (*Application) ResumeJobV2 ¶ added in v0.10.10
ResumeJobV2 provides a mock function with given fields: ctx, run
func (*Application) ResumePendingBridge ¶ added in v0.8.4
func (_m *Application) ResumePendingBridge(runID uuid.UUID, input models.BridgeRunResult) error
ResumePendingBridge provides a mock function with given fields: runID, input
func (*Application) RunJobV2 ¶ added in v0.9.6
func (_m *Application) RunJobV2(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)
RunJobV2 provides a mock function with given fields: ctx, jobID, meta
func (*Application) RunWebhookJobV2 ¶ added in v0.10.8
func (_m *Application) RunWebhookJobV2(ctx context.Context, jobUUID uuid.UUID, requestBody string, meta pipeline.JSONSerializable) (int64, error)
RunWebhookJobV2 provides a mock function with given fields: ctx, jobUUID, requestBody, meta
func (*Application) SetServiceLogger ¶ added in v0.10.6
func (_m *Application) SetServiceLogger(ctx context.Context, service string, level zapcore.Level) error
SetServiceLogger provides a mock function with given fields: ctx, service, level
func (*Application) Start ¶ added in v0.8.2
func (_m *Application) Start() error
Start provides a mock function with given fields:
func (*Application) Stop ¶ added in v0.8.2
func (_m *Application) Stop() error
Stop provides a mock function with given fields:
func (*Application) WakeSessionReaper ¶ added in v0.8.2
func (_m *Application) WakeSessionReaper()
WakeSessionReaper provides a mock function with given fields:
type Checker ¶ added in v0.10.8
Checker is an autogenerated mock type for the Checker type
func (*Checker) Register ¶ added in v0.10.8
Register provides a mock function with given fields: name, service
func (*Checker) Unregister ¶ added in v0.10.8
Unregister provides a mock function with given fields: name
type Client ¶ added in v0.8.2
Client is an autogenerated mock type for the Client type
func (*Client) BalanceAt ¶ added in v0.8.13
func (_m *Client) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
BalanceAt provides a mock function with given fields: ctx, account, blockNumber
func (*Client) BatchCallContext ¶ added in v0.10.0
BatchCallContext provides a mock function with given fields: ctx, b
func (*Client) BlockByNumber ¶ added in v0.8.13
BlockByNumber provides a mock function with given fields: ctx, number
func (*Client) Call ¶ added in v0.8.2
Call provides a mock function with given fields: result, method, args
func (*Client) CallContext ¶ added in v0.8.13
func (_m *Client) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
CallContext provides a mock function with given fields: ctx, result, method, args
func (*Client) CallContract ¶ added in v0.8.13
func (_m *Client) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
CallContract provides a mock function with given fields: ctx, msg, blockNumber
func (*Client) Close ¶ added in v0.8.13
func (_m *Client) Close()
Close provides a mock function with given fields:
func (*Client) CodeAt ¶ added in v0.8.13
func (_m *Client) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)
CodeAt provides a mock function with given fields: ctx, account, blockNumber
func (*Client) EstimateGas ¶ added in v0.9.0
EstimateGas provides a mock function with given fields: ctx, call
func (*Client) FilterLogs ¶ added in v0.8.13
FilterLogs provides a mock function with given fields: ctx, q
func (*Client) GetERC20Balance ¶ added in v0.8.2
func (_m *Client) GetERC20Balance(address common.Address, contractAddress common.Address) (*big.Int, error)
GetERC20Balance provides a mock function with given fields: address, contractAddress
func (*Client) GetEthBalance ¶ added in v0.8.2
func (_m *Client) GetEthBalance(ctx context.Context, account common.Address, blockNumber *big.Int) (*assets.Eth, error)
GetEthBalance provides a mock function with given fields: ctx, account, blockNumber
func (*Client) GetLINKBalance ¶ added in v0.9.6
func (_m *Client) GetLINKBalance(linkAddress common.Address, address common.Address) (*assets.Link, error)
GetLINKBalance provides a mock function with given fields: linkAddress, address
func (*Client) HeadByNumber ¶ added in v0.10.10
HeadByNumber provides a mock function with given fields: ctx, n
func (*Client) HeaderByNumber ¶ added in v0.8.13
HeaderByNumber provides a mock function with given fields: _a0, _a1
func (*Client) NonceAt ¶ added in v0.10.6
func (_m *Client) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)
NonceAt provides a mock function with given fields: ctx, account, blockNumber
func (*Client) PendingCodeAt ¶ added in v0.9.0
PendingCodeAt provides a mock function with given fields: ctx, account
func (*Client) PendingNonceAt ¶ added in v0.8.13
PendingNonceAt provides a mock function with given fields: ctx, account
func (*Client) RoundRobinBatchCallContext ¶ added in v0.10.4
RoundRobinBatchCallContext provides a mock function with given fields: ctx, b
func (*Client) SendTransaction ¶ added in v0.8.13
SendTransaction provides a mock function with given fields: ctx, tx
func (*Client) SubscribeFilterLogs ¶ added in v0.8.13
func (_m *Client) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
SubscribeFilterLogs provides a mock function with given fields: ctx, q, ch
func (*Client) SubscribeNewHead ¶ added in v0.8.13
func (_m *Client) SubscribeNewHead(ctx context.Context, ch chan<- *models.Head) (ethereum.Subscription, error)
SubscribeNewHead provides a mock function with given fields: ctx, ch
func (*Client) SuggestGasPrice ¶ added in v0.9.0
SuggestGasPrice provides a mock function with given fields: ctx
func (*Client) SuggestGasTipCap ¶ added in v0.10.10
SuggestGasTipCap provides a mock function with given fields: ctx
type DeviationChecker ¶ added in v0.8.2
DeviationChecker is an autogenerated mock type for the DeviationChecker type
func (*DeviationChecker) Start ¶ added in v0.8.2
func (_m *DeviationChecker) Start()
Start provides a mock function with given fields:
func (*DeviationChecker) Stop ¶ added in v0.8.2
func (_m *DeviationChecker) Stop()
Stop provides a mock function with given fields:
type DeviationCheckerFactory ¶ added in v0.8.2
DeviationCheckerFactory is an autogenerated mock type for the DeviationCheckerFactory type
func (*DeviationCheckerFactory) New ¶ added in v0.8.2
func (_m *DeviationCheckerFactory) New(_a0 models.Initiator, _a1 *assets.Link, _a2 fluxmonitor.RunManager, _a3 *orm.ORM, _a4 models.Duration) (fluxmonitor.DeviationChecker, error)
New provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
type Flags ¶ added in v0.10.3
Flags is an autogenerated mock type for the FlagsInterface type
func (*Flags) AcceptOwnership ¶ added in v0.10.3
func (_m *Flags) AcceptOwnership(opts *bind.TransactOpts) (*types.Transaction, error)
AcceptOwnership provides a mock function with given fields: opts
func (*Flags) AddAccess ¶ added in v0.10.3
func (_m *Flags) AddAccess(opts *bind.TransactOpts, _user common.Address) (*types.Transaction, error)
AddAccess provides a mock function with given fields: opts, _user
func (*Flags) CheckEnabled ¶ added in v0.10.3
CheckEnabled provides a mock function with given fields: opts
func (*Flags) DisableAccessCheck ¶ added in v0.10.3
func (_m *Flags) DisableAccessCheck(opts *bind.TransactOpts) (*types.Transaction, error)
DisableAccessCheck provides a mock function with given fields: opts
func (*Flags) EnableAccessCheck ¶ added in v0.10.3
func (_m *Flags) EnableAccessCheck(opts *bind.TransactOpts) (*types.Transaction, error)
EnableAccessCheck provides a mock function with given fields: opts
func (*Flags) FilterAddedAccess ¶ added in v0.10.3
func (_m *Flags) FilterAddedAccess(opts *bind.FilterOpts) (*flags_wrapper.FlagsAddedAccessIterator, error)
FilterAddedAccess provides a mock function with given fields: opts
func (*Flags) FilterCheckAccessDisabled ¶ added in v0.10.3
func (_m *Flags) FilterCheckAccessDisabled(opts *bind.FilterOpts) (*flags_wrapper.FlagsCheckAccessDisabledIterator, error)
FilterCheckAccessDisabled provides a mock function with given fields: opts
func (*Flags) FilterCheckAccessEnabled ¶ added in v0.10.3
func (_m *Flags) FilterCheckAccessEnabled(opts *bind.FilterOpts) (*flags_wrapper.FlagsCheckAccessEnabledIterator, error)
FilterCheckAccessEnabled provides a mock function with given fields: opts
func (*Flags) FilterFlagLowered ¶ added in v0.10.3
func (_m *Flags) FilterFlagLowered(opts *bind.FilterOpts, subject []common.Address) (*flags_wrapper.FlagsFlagLoweredIterator, error)
FilterFlagLowered provides a mock function with given fields: opts, subject
func (*Flags) FilterFlagRaised ¶ added in v0.10.3
func (_m *Flags) FilterFlagRaised(opts *bind.FilterOpts, subject []common.Address) (*flags_wrapper.FlagsFlagRaisedIterator, error)
FilterFlagRaised provides a mock function with given fields: opts, subject
func (*Flags) FilterOwnershipTransferRequested ¶ added in v0.10.3
func (_m *Flags) FilterOwnershipTransferRequested(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flags_wrapper.FlagsOwnershipTransferRequestedIterator, error)
FilterOwnershipTransferRequested provides a mock function with given fields: opts, from, to
func (*Flags) FilterOwnershipTransferred ¶ added in v0.10.3
func (_m *Flags) FilterOwnershipTransferred(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flags_wrapper.FlagsOwnershipTransferredIterator, error)
FilterOwnershipTransferred provides a mock function with given fields: opts, from, to
func (*Flags) FilterRaisingAccessControllerUpdated ¶ added in v0.10.3
func (_m *Flags) FilterRaisingAccessControllerUpdated(opts *bind.FilterOpts, previous []common.Address, current []common.Address) (*flags_wrapper.FlagsRaisingAccessControllerUpdatedIterator, error)
FilterRaisingAccessControllerUpdated provides a mock function with given fields: opts, previous, current
func (*Flags) FilterRemovedAccess ¶ added in v0.10.3
func (_m *Flags) FilterRemovedAccess(opts *bind.FilterOpts) (*flags_wrapper.FlagsRemovedAccessIterator, error)
FilterRemovedAccess provides a mock function with given fields: opts
func (*Flags) GetFlag ¶ added in v0.10.3
GetFlag provides a mock function with given fields: opts, subject
func (*Flags) GetFlags ¶ added in v0.10.3
GetFlags provides a mock function with given fields: opts, subjects
func (*Flags) HasAccess ¶ added in v0.10.3
func (_m *Flags) HasAccess(opts *bind.CallOpts, _user common.Address, _calldata []byte) (bool, error)
HasAccess provides a mock function with given fields: opts, _user, _calldata
func (*Flags) LowerFlags ¶ added in v0.10.3
func (_m *Flags) LowerFlags(opts *bind.TransactOpts, subjects []common.Address) (*types.Transaction, error)
LowerFlags provides a mock function with given fields: opts, subjects
func (*Flags) ParseAddedAccess ¶ added in v0.10.3
func (_m *Flags) ParseAddedAccess(log types.Log) (*flags_wrapper.FlagsAddedAccess, error)
ParseAddedAccess provides a mock function with given fields: log
func (*Flags) ParseCheckAccessDisabled ¶ added in v0.10.3
func (_m *Flags) ParseCheckAccessDisabled(log types.Log) (*flags_wrapper.FlagsCheckAccessDisabled, error)
ParseCheckAccessDisabled provides a mock function with given fields: log
func (*Flags) ParseCheckAccessEnabled ¶ added in v0.10.3
func (_m *Flags) ParseCheckAccessEnabled(log types.Log) (*flags_wrapper.FlagsCheckAccessEnabled, error)
ParseCheckAccessEnabled provides a mock function with given fields: log
func (*Flags) ParseFlagLowered ¶ added in v0.10.3
func (_m *Flags) ParseFlagLowered(log types.Log) (*flags_wrapper.FlagsFlagLowered, error)
ParseFlagLowered provides a mock function with given fields: log
func (*Flags) ParseFlagRaised ¶ added in v0.10.3
func (_m *Flags) ParseFlagRaised(log types.Log) (*flags_wrapper.FlagsFlagRaised, error)
ParseFlagRaised provides a mock function with given fields: log
func (*Flags) ParseOwnershipTransferRequested ¶ added in v0.10.3
func (_m *Flags) ParseOwnershipTransferRequested(log types.Log) (*flags_wrapper.FlagsOwnershipTransferRequested, error)
ParseOwnershipTransferRequested provides a mock function with given fields: log
func (*Flags) ParseOwnershipTransferred ¶ added in v0.10.3
func (_m *Flags) ParseOwnershipTransferred(log types.Log) (*flags_wrapper.FlagsOwnershipTransferred, error)
ParseOwnershipTransferred provides a mock function with given fields: log
func (*Flags) ParseRaisingAccessControllerUpdated ¶ added in v0.10.3
func (_m *Flags) ParseRaisingAccessControllerUpdated(log types.Log) (*flags_wrapper.FlagsRaisingAccessControllerUpdated, error)
ParseRaisingAccessControllerUpdated provides a mock function with given fields: log
func (*Flags) ParseRemovedAccess ¶ added in v0.10.3
func (_m *Flags) ParseRemovedAccess(log types.Log) (*flags_wrapper.FlagsRemovedAccess, error)
ParseRemovedAccess provides a mock function with given fields: log
func (*Flags) RaiseFlag ¶ added in v0.10.3
func (_m *Flags) RaiseFlag(opts *bind.TransactOpts, subject common.Address) (*types.Transaction, error)
RaiseFlag provides a mock function with given fields: opts, subject
func (*Flags) RaiseFlags ¶ added in v0.10.3
func (_m *Flags) RaiseFlags(opts *bind.TransactOpts, subjects []common.Address) (*types.Transaction, error)
RaiseFlags provides a mock function with given fields: opts, subjects
func (*Flags) RaisingAccessController ¶ added in v0.10.3
RaisingAccessController provides a mock function with given fields: opts
func (*Flags) RemoveAccess ¶ added in v0.10.3
func (_m *Flags) RemoveAccess(opts *bind.TransactOpts, _user common.Address) (*types.Transaction, error)
RemoveAccess provides a mock function with given fields: opts, _user
func (*Flags) SetRaisingAccessController ¶ added in v0.10.3
func (_m *Flags) SetRaisingAccessController(opts *bind.TransactOpts, racAddress common.Address) (*types.Transaction, error)
SetRaisingAccessController provides a mock function with given fields: opts, racAddress
func (*Flags) TransferOwnership ¶ added in v0.10.3
func (_m *Flags) TransferOwnership(opts *bind.TransactOpts, _to common.Address) (*types.Transaction, error)
TransferOwnership provides a mock function with given fields: opts, _to
func (*Flags) WatchAddedAccess ¶ added in v0.10.3
func (_m *Flags) WatchAddedAccess(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsAddedAccess) (event.Subscription, error)
WatchAddedAccess provides a mock function with given fields: opts, sink
func (*Flags) WatchCheckAccessDisabled ¶ added in v0.10.3
func (_m *Flags) WatchCheckAccessDisabled(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsCheckAccessDisabled) (event.Subscription, error)
WatchCheckAccessDisabled provides a mock function with given fields: opts, sink
func (*Flags) WatchCheckAccessEnabled ¶ added in v0.10.3
func (_m *Flags) WatchCheckAccessEnabled(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsCheckAccessEnabled) (event.Subscription, error)
WatchCheckAccessEnabled provides a mock function with given fields: opts, sink
func (*Flags) WatchFlagLowered ¶ added in v0.10.3
func (_m *Flags) WatchFlagLowered(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsFlagLowered, subject []common.Address) (event.Subscription, error)
WatchFlagLowered provides a mock function with given fields: opts, sink, subject
func (*Flags) WatchFlagRaised ¶ added in v0.10.3
func (_m *Flags) WatchFlagRaised(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsFlagRaised, subject []common.Address) (event.Subscription, error)
WatchFlagRaised provides a mock function with given fields: opts, sink, subject
func (*Flags) WatchOwnershipTransferRequested ¶ added in v0.10.3
func (_m *Flags) WatchOwnershipTransferRequested(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsOwnershipTransferRequested, from []common.Address, to []common.Address) (event.Subscription, error)
WatchOwnershipTransferRequested provides a mock function with given fields: opts, sink, from, to
func (*Flags) WatchOwnershipTransferred ¶ added in v0.10.3
func (_m *Flags) WatchOwnershipTransferred(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsOwnershipTransferred, from []common.Address, to []common.Address) (event.Subscription, error)
WatchOwnershipTransferred provides a mock function with given fields: opts, sink, from, to
func (*Flags) WatchRaisingAccessControllerUpdated ¶ added in v0.10.3
func (_m *Flags) WatchRaisingAccessControllerUpdated(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsRaisingAccessControllerUpdated, previous []common.Address, current []common.Address) (event.Subscription, error)
WatchRaisingAccessControllerUpdated provides a mock function with given fields: opts, sink, previous, current
func (*Flags) WatchRemovedAccess ¶ added in v0.10.3
func (_m *Flags) WatchRemovedAccess(opts *bind.WatchOpts, sink chan<- *flags_wrapper.FlagsRemovedAccess) (event.Subscription, error)
WatchRemovedAccess provides a mock function with given fields: opts, sink
type FluxAggregator ¶ added in v0.8.2
FluxAggregator is an autogenerated mock type for the FluxAggregatorInterface type
func (*FluxAggregator) AcceptAdmin ¶ added in v0.9.10
func (_m *FluxAggregator) AcceptAdmin(opts *bind.TransactOpts, _oracle common.Address) (*types.Transaction, error)
AcceptAdmin provides a mock function with given fields: opts, _oracle
func (*FluxAggregator) AcceptOwnership ¶ added in v0.9.10
func (_m *FluxAggregator) AcceptOwnership(opts *bind.TransactOpts) (*types.Transaction, error)
AcceptOwnership provides a mock function with given fields: opts
func (*FluxAggregator) Address ¶ added in v0.9.10
func (_m *FluxAggregator) Address() common.Address
Address provides a mock function with given fields:
func (*FluxAggregator) AllocatedFunds ¶ added in v0.9.10
AllocatedFunds provides a mock function with given fields: opts
func (*FluxAggregator) AvailableFunds ¶ added in v0.9.10
AvailableFunds provides a mock function with given fields: opts
func (*FluxAggregator) ChangeOracles ¶ added in v0.9.10
func (_m *FluxAggregator) ChangeOracles(opts *bind.TransactOpts, _removed []common.Address, _added []common.Address, _addedAdmins []common.Address, _minSubmissions uint32, _maxSubmissions uint32, _restartDelay uint32) (*types.Transaction, error)
ChangeOracles provides a mock function with given fields: opts, _removed, _added, _addedAdmins, _minSubmissions, _maxSubmissions, _restartDelay
func (*FluxAggregator) Decimals ¶ added in v0.9.10
func (_m *FluxAggregator) Decimals(opts *bind.CallOpts) (uint8, error)
Decimals provides a mock function with given fields: opts
func (*FluxAggregator) Description ¶ added in v0.9.10
func (_m *FluxAggregator) Description(opts *bind.CallOpts) (string, error)
Description provides a mock function with given fields: opts
func (*FluxAggregator) FilterAnswerUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) FilterAnswerUpdated(opts *bind.FilterOpts, current []*big.Int, roundId []*big.Int) (*flux_aggregator_wrapper.FluxAggregatorAnswerUpdatedIterator, error)
FilterAnswerUpdated provides a mock function with given fields: opts, current, roundId
func (*FluxAggregator) FilterAvailableFundsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) FilterAvailableFundsUpdated(opts *bind.FilterOpts, amount []*big.Int) (*flux_aggregator_wrapper.FluxAggregatorAvailableFundsUpdatedIterator, error)
FilterAvailableFundsUpdated provides a mock function with given fields: opts, amount
func (*FluxAggregator) FilterNewRound ¶ added in v0.9.10
func (_m *FluxAggregator) FilterNewRound(opts *bind.FilterOpts, roundId []*big.Int, startedBy []common.Address) (*flux_aggregator_wrapper.FluxAggregatorNewRoundIterator, error)
FilterNewRound provides a mock function with given fields: opts, roundId, startedBy
func (*FluxAggregator) FilterOracleAdminUpdateRequested ¶ added in v0.9.10
func (_m *FluxAggregator) FilterOracleAdminUpdateRequested(opts *bind.FilterOpts, oracle []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdateRequestedIterator, error)
FilterOracleAdminUpdateRequested provides a mock function with given fields: opts, oracle
func (*FluxAggregator) FilterOracleAdminUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) FilterOracleAdminUpdated(opts *bind.FilterOpts, oracle []common.Address, newAdmin []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdatedIterator, error)
FilterOracleAdminUpdated provides a mock function with given fields: opts, oracle, newAdmin
func (*FluxAggregator) FilterOraclePermissionsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) FilterOraclePermissionsUpdated(opts *bind.FilterOpts, oracle []common.Address, whitelisted []bool) (*flux_aggregator_wrapper.FluxAggregatorOraclePermissionsUpdatedIterator, error)
FilterOraclePermissionsUpdated provides a mock function with given fields: opts, oracle, whitelisted
func (*FluxAggregator) FilterOwnershipTransferRequested ¶ added in v0.9.10
func (_m *FluxAggregator) FilterOwnershipTransferRequested(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferRequestedIterator, error)
FilterOwnershipTransferRequested provides a mock function with given fields: opts, from, to
func (*FluxAggregator) FilterOwnershipTransferred ¶ added in v0.9.10
func (_m *FluxAggregator) FilterOwnershipTransferred(opts *bind.FilterOpts, from []common.Address, to []common.Address) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferredIterator, error)
FilterOwnershipTransferred provides a mock function with given fields: opts, from, to
func (*FluxAggregator) FilterRequesterPermissionsSet ¶ added in v0.9.10
func (_m *FluxAggregator) FilterRequesterPermissionsSet(opts *bind.FilterOpts, requester []common.Address) (*flux_aggregator_wrapper.FluxAggregatorRequesterPermissionsSetIterator, error)
FilterRequesterPermissionsSet provides a mock function with given fields: opts, requester
func (*FluxAggregator) FilterRoundDetailsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) FilterRoundDetailsUpdated(opts *bind.FilterOpts, paymentAmount []*big.Int, minSubmissionCount []uint32, maxSubmissionCount []uint32) (*flux_aggregator_wrapper.FluxAggregatorRoundDetailsUpdatedIterator, error)
FilterRoundDetailsUpdated provides a mock function with given fields: opts, paymentAmount, minSubmissionCount, maxSubmissionCount
func (*FluxAggregator) FilterSubmissionReceived ¶ added in v0.9.10
func (_m *FluxAggregator) FilterSubmissionReceived(opts *bind.FilterOpts, submission []*big.Int, round []uint32, oracle []common.Address) (*flux_aggregator_wrapper.FluxAggregatorSubmissionReceivedIterator, error)
FilterSubmissionReceived provides a mock function with given fields: opts, submission, round, oracle
func (*FluxAggregator) FilterValidatorUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) FilterValidatorUpdated(opts *bind.FilterOpts, previous []common.Address, current []common.Address) (*flux_aggregator_wrapper.FluxAggregatorValidatorUpdatedIterator, error)
FilterValidatorUpdated provides a mock function with given fields: opts, previous, current
func (*FluxAggregator) GetAdmin ¶ added in v0.9.10
func (_m *FluxAggregator) GetAdmin(opts *bind.CallOpts, _oracle common.Address) (common.Address, error)
GetAdmin provides a mock function with given fields: opts, _oracle
func (*FluxAggregator) GetAnswer ¶ added in v0.9.10
GetAnswer provides a mock function with given fields: opts, _roundId
func (*FluxAggregator) GetOracles ¶ added in v0.9.6
GetOracles provides a mock function with given fields: opts
func (*FluxAggregator) GetRoundData ¶ added in v0.9.10
func (_m *FluxAggregator) GetRoundData(opts *bind.CallOpts, _roundId *big.Int) (flux_aggregator_wrapper.GetRoundData, error)
GetRoundData provides a mock function with given fields: opts, _roundId
func (*FluxAggregator) GetTimestamp ¶ added in v0.9.10
GetTimestamp provides a mock function with given fields: opts, _roundId
func (*FluxAggregator) LatestAnswer ¶ added in v0.9.10
LatestAnswer provides a mock function with given fields: opts
func (*FluxAggregator) LatestRound ¶ added in v0.9.10
LatestRound provides a mock function with given fields: opts
func (*FluxAggregator) LatestRoundData ¶ added in v0.9.7
func (_m *FluxAggregator) LatestRoundData(opts *bind.CallOpts) (flux_aggregator_wrapper.LatestRoundData, error)
LatestRoundData provides a mock function with given fields: opts
func (*FluxAggregator) LatestTimestamp ¶ added in v0.9.10
LatestTimestamp provides a mock function with given fields: opts
func (*FluxAggregator) LinkToken ¶ added in v0.9.10
LinkToken provides a mock function with given fields: opts
func (*FluxAggregator) MaxSubmissionCount ¶ added in v0.9.10
func (_m *FluxAggregator) MaxSubmissionCount(opts *bind.CallOpts) (uint32, error)
MaxSubmissionCount provides a mock function with given fields: opts
func (*FluxAggregator) MaxSubmissionValue ¶ added in v0.9.10
MaxSubmissionValue provides a mock function with given fields: opts
func (*FluxAggregator) MinSubmissionCount ¶ added in v0.9.10
func (_m *FluxAggregator) MinSubmissionCount(opts *bind.CallOpts) (uint32, error)
MinSubmissionCount provides a mock function with given fields: opts
func (*FluxAggregator) MinSubmissionValue ¶ added in v0.9.10
MinSubmissionValue provides a mock function with given fields: opts
func (*FluxAggregator) OnTokenTransfer ¶ added in v0.9.10
func (_m *FluxAggregator) OnTokenTransfer(opts *bind.TransactOpts, arg0 common.Address, arg1 *big.Int, _data []byte) (*types.Transaction, error)
OnTokenTransfer provides a mock function with given fields: opts, arg0, arg1, _data
func (*FluxAggregator) OracleCount ¶ added in v0.9.10
func (_m *FluxAggregator) OracleCount(opts *bind.CallOpts) (uint8, error)
OracleCount provides a mock function with given fields: opts
func (*FluxAggregator) OracleRoundState ¶ added in v0.9.10
func (_m *FluxAggregator) OracleRoundState(opts *bind.CallOpts, _oracle common.Address, _queriedRoundId uint32) (flux_aggregator_wrapper.OracleRoundState, error)
OracleRoundState provides a mock function with given fields: opts, _oracle, _queriedRoundId
func (*FluxAggregator) Owner ¶ added in v0.9.10
Owner provides a mock function with given fields: opts
func (*FluxAggregator) ParseAnswerUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) ParseAnswerUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorAnswerUpdated, error)
ParseAnswerUpdated provides a mock function with given fields: log
func (*FluxAggregator) ParseAvailableFundsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) ParseAvailableFundsUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorAvailableFundsUpdated, error)
ParseAvailableFundsUpdated provides a mock function with given fields: log
func (*FluxAggregator) ParseLog ¶ added in v0.10.3
ParseLog provides a mock function with given fields: log
func (*FluxAggregator) ParseNewRound ¶ added in v0.9.10
func (_m *FluxAggregator) ParseNewRound(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorNewRound, error)
ParseNewRound provides a mock function with given fields: log
func (*FluxAggregator) ParseOracleAdminUpdateRequested ¶ added in v0.9.10
func (_m *FluxAggregator) ParseOracleAdminUpdateRequested(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdateRequested, error)
ParseOracleAdminUpdateRequested provides a mock function with given fields: log
func (*FluxAggregator) ParseOracleAdminUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) ParseOracleAdminUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdated, error)
ParseOracleAdminUpdated provides a mock function with given fields: log
func (*FluxAggregator) ParseOraclePermissionsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) ParseOraclePermissionsUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOraclePermissionsUpdated, error)
ParseOraclePermissionsUpdated provides a mock function with given fields: log
func (*FluxAggregator) ParseOwnershipTransferRequested ¶ added in v0.9.10
func (_m *FluxAggregator) ParseOwnershipTransferRequested(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferRequested, error)
ParseOwnershipTransferRequested provides a mock function with given fields: log
func (*FluxAggregator) ParseOwnershipTransferred ¶ added in v0.9.10
func (_m *FluxAggregator) ParseOwnershipTransferred(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorOwnershipTransferred, error)
ParseOwnershipTransferred provides a mock function with given fields: log
func (*FluxAggregator) ParseRequesterPermissionsSet ¶ added in v0.9.10
func (_m *FluxAggregator) ParseRequesterPermissionsSet(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorRequesterPermissionsSet, error)
ParseRequesterPermissionsSet provides a mock function with given fields: log
func (*FluxAggregator) ParseRoundDetailsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) ParseRoundDetailsUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorRoundDetailsUpdated, error)
ParseRoundDetailsUpdated provides a mock function with given fields: log
func (*FluxAggregator) ParseSubmissionReceived ¶ added in v0.9.10
func (_m *FluxAggregator) ParseSubmissionReceived(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorSubmissionReceived, error)
ParseSubmissionReceived provides a mock function with given fields: log
func (*FluxAggregator) ParseValidatorUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) ParseValidatorUpdated(log types.Log) (*flux_aggregator_wrapper.FluxAggregatorValidatorUpdated, error)
ParseValidatorUpdated provides a mock function with given fields: log
func (*FluxAggregator) PaymentAmount ¶ added in v0.9.10
PaymentAmount provides a mock function with given fields: opts
func (*FluxAggregator) RequestNewRound ¶ added in v0.9.10
func (_m *FluxAggregator) RequestNewRound(opts *bind.TransactOpts) (*types.Transaction, error)
RequestNewRound provides a mock function with given fields: opts
func (*FluxAggregator) RestartDelay ¶ added in v0.9.10
func (_m *FluxAggregator) RestartDelay(opts *bind.CallOpts) (uint32, error)
RestartDelay provides a mock function with given fields: opts
func (*FluxAggregator) SetRequesterPermissions ¶ added in v0.9.10
func (_m *FluxAggregator) SetRequesterPermissions(opts *bind.TransactOpts, _requester common.Address, _authorized bool, _delay uint32) (*types.Transaction, error)
SetRequesterPermissions provides a mock function with given fields: opts, _requester, _authorized, _delay
func (*FluxAggregator) SetValidator ¶ added in v0.9.10
func (_m *FluxAggregator) SetValidator(opts *bind.TransactOpts, _newValidator common.Address) (*types.Transaction, error)
SetValidator provides a mock function with given fields: opts, _newValidator
func (*FluxAggregator) Submit ¶ added in v0.9.10
func (_m *FluxAggregator) Submit(opts *bind.TransactOpts, _roundId *big.Int, _submission *big.Int) (*types.Transaction, error)
Submit provides a mock function with given fields: opts, _roundId, _submission
func (*FluxAggregator) Timeout ¶ added in v0.9.10
func (_m *FluxAggregator) Timeout(opts *bind.CallOpts) (uint32, error)
Timeout provides a mock function with given fields: opts
func (*FluxAggregator) TransferAdmin ¶ added in v0.9.10
func (_m *FluxAggregator) TransferAdmin(opts *bind.TransactOpts, _oracle common.Address, _newAdmin common.Address) (*types.Transaction, error)
TransferAdmin provides a mock function with given fields: opts, _oracle, _newAdmin
func (*FluxAggregator) TransferOwnership ¶ added in v0.9.10
func (_m *FluxAggregator) TransferOwnership(opts *bind.TransactOpts, _to common.Address) (*types.Transaction, error)
TransferOwnership provides a mock function with given fields: opts, _to
func (*FluxAggregator) UpdateAvailableFunds ¶ added in v0.9.10
func (_m *FluxAggregator) UpdateAvailableFunds(opts *bind.TransactOpts) (*types.Transaction, error)
UpdateAvailableFunds provides a mock function with given fields: opts
func (*FluxAggregator) UpdateFutureRounds ¶ added in v0.9.10
func (_m *FluxAggregator) UpdateFutureRounds(opts *bind.TransactOpts, _paymentAmount *big.Int, _minSubmissions uint32, _maxSubmissions uint32, _restartDelay uint32, _timeout uint32) (*types.Transaction, error)
UpdateFutureRounds provides a mock function with given fields: opts, _paymentAmount, _minSubmissions, _maxSubmissions, _restartDelay, _timeout
func (*FluxAggregator) Validator ¶ added in v0.9.10
Validator provides a mock function with given fields: opts
func (*FluxAggregator) Version ¶ added in v0.9.10
Version provides a mock function with given fields: opts
func (*FluxAggregator) WatchAnswerUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) WatchAnswerUpdated(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorAnswerUpdated, current []*big.Int, roundId []*big.Int) (event.Subscription, error)
WatchAnswerUpdated provides a mock function with given fields: opts, sink, current, roundId
func (*FluxAggregator) WatchAvailableFundsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) WatchAvailableFundsUpdated(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorAvailableFundsUpdated, amount []*big.Int) (event.Subscription, error)
WatchAvailableFundsUpdated provides a mock function with given fields: opts, sink, amount
func (*FluxAggregator) WatchNewRound ¶ added in v0.9.10
func (_m *FluxAggregator) WatchNewRound(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorNewRound, roundId []*big.Int, startedBy []common.Address) (event.Subscription, error)
WatchNewRound provides a mock function with given fields: opts, sink, roundId, startedBy
func (*FluxAggregator) WatchOracleAdminUpdateRequested ¶ added in v0.9.10
func (_m *FluxAggregator) WatchOracleAdminUpdateRequested(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdateRequested, oracle []common.Address) (event.Subscription, error)
WatchOracleAdminUpdateRequested provides a mock function with given fields: opts, sink, oracle
func (*FluxAggregator) WatchOracleAdminUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) WatchOracleAdminUpdated(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorOracleAdminUpdated, oracle []common.Address, newAdmin []common.Address) (event.Subscription, error)
WatchOracleAdminUpdated provides a mock function with given fields: opts, sink, oracle, newAdmin
func (*FluxAggregator) WatchOraclePermissionsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) WatchOraclePermissionsUpdated(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorOraclePermissionsUpdated, oracle []common.Address, whitelisted []bool) (event.Subscription, error)
WatchOraclePermissionsUpdated provides a mock function with given fields: opts, sink, oracle, whitelisted
func (*FluxAggregator) WatchOwnershipTransferRequested ¶ added in v0.9.10
func (_m *FluxAggregator) WatchOwnershipTransferRequested(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorOwnershipTransferRequested, from []common.Address, to []common.Address) (event.Subscription, error)
WatchOwnershipTransferRequested provides a mock function with given fields: opts, sink, from, to
func (*FluxAggregator) WatchOwnershipTransferred ¶ added in v0.9.10
func (_m *FluxAggregator) WatchOwnershipTransferred(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorOwnershipTransferred, from []common.Address, to []common.Address) (event.Subscription, error)
WatchOwnershipTransferred provides a mock function with given fields: opts, sink, from, to
func (*FluxAggregator) WatchRequesterPermissionsSet ¶ added in v0.9.10
func (_m *FluxAggregator) WatchRequesterPermissionsSet(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorRequesterPermissionsSet, requester []common.Address) (event.Subscription, error)
WatchRequesterPermissionsSet provides a mock function with given fields: opts, sink, requester
func (*FluxAggregator) WatchRoundDetailsUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) WatchRoundDetailsUpdated(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorRoundDetailsUpdated, paymentAmount []*big.Int, minSubmissionCount []uint32, maxSubmissionCount []uint32) (event.Subscription, error)
WatchRoundDetailsUpdated provides a mock function with given fields: opts, sink, paymentAmount, minSubmissionCount, maxSubmissionCount
func (*FluxAggregator) WatchSubmissionReceived ¶ added in v0.9.10
func (_m *FluxAggregator) WatchSubmissionReceived(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorSubmissionReceived, submission []*big.Int, round []uint32, oracle []common.Address) (event.Subscription, error)
WatchSubmissionReceived provides a mock function with given fields: opts, sink, submission, round, oracle
func (*FluxAggregator) WatchValidatorUpdated ¶ added in v0.9.10
func (_m *FluxAggregator) WatchValidatorUpdated(opts *bind.WatchOpts, sink chan<- *flux_aggregator_wrapper.FluxAggregatorValidatorUpdated, previous []common.Address, current []common.Address) (event.Subscription, error)
WatchValidatorUpdated provides a mock function with given fields: opts, sink, previous, current
func (*FluxAggregator) WithdrawFunds ¶ added in v0.9.10
func (_m *FluxAggregator) WithdrawFunds(opts *bind.TransactOpts, _recipient common.Address, _amount *big.Int) (*types.Transaction, error)
WithdrawFunds provides a mock function with given fields: opts, _recipient, _amount
func (*FluxAggregator) WithdrawPayment ¶ added in v0.9.10
func (_m *FluxAggregator) WithdrawPayment(opts *bind.TransactOpts, _oracle common.Address, _recipient common.Address, _amount *big.Int) (*types.Transaction, error)
WithdrawPayment provides a mock function with given fields: opts, _oracle, _recipient, _amount
func (*FluxAggregator) WithdrawablePayment ¶ added in v0.9.10
func (_m *FluxAggregator) WithdrawablePayment(opts *bind.CallOpts, _oracle common.Address) (*big.Int, error)
WithdrawablePayment provides a mock function with given fields: opts, _oracle
type JobSubscriber ¶ added in v0.8.2
JobSubscriber is an autogenerated mock type for the JobSubscriber type
func (*JobSubscriber) AddJob ¶ added in v0.8.2
AddJob provides a mock function with given fields: job, bn
func (*JobSubscriber) Close ¶ added in v0.10.8
func (_m *JobSubscriber) Close() error
Close provides a mock function with given fields:
func (*JobSubscriber) Connect ¶ added in v0.8.2
func (_m *JobSubscriber) Connect(head *models.Head) error
Connect provides a mock function with given fields: head
func (*JobSubscriber) Healthy ¶ added in v0.10.8
func (_m *JobSubscriber) Healthy() error
Healthy provides a mock function with given fields:
func (*JobSubscriber) Jobs ¶ added in v0.8.2
func (_m *JobSubscriber) Jobs() []models.JobSpec
Jobs provides a mock function with given fields:
func (*JobSubscriber) OnNewLongestChain ¶ added in v0.8.5
func (_m *JobSubscriber) OnNewLongestChain(ctx context.Context, head models.Head)
OnNewLongestChain provides a mock function with given fields: ctx, head
func (*JobSubscriber) Ready ¶ added in v0.10.8
func (_m *JobSubscriber) Ready() error
Ready provides a mock function with given fields:
func (*JobSubscriber) RemoveJob ¶ added in v0.8.2
func (_m *JobSubscriber) RemoveJob(ID models.JobID) error
RemoveJob provides a mock function with given fields: ID
func (*JobSubscriber) Start ¶ added in v0.10.8
func (_m *JobSubscriber) Start() error
Start provides a mock function with given fields:
type NotifyNewEthTx ¶ added in v0.8.7
NotifyNewEthTx is an autogenerated mock type for the NotifyNewEthTx type
func (*NotifyNewEthTx) Trigger ¶ added in v0.8.7
func (_m *NotifyNewEthTx) Trigger()
Trigger provides a mock function with given fields:
type PrometheusBackend ¶ added in v0.9.6
PrometheusBackend is an autogenerated mock type for the PrometheusBackend type
func (*PrometheusBackend) SetMaxUnconfirmedAge ¶ added in v0.10.5
func (_m *PrometheusBackend) SetMaxUnconfirmedAge(_a0 float64)
SetMaxUnconfirmedAge provides a mock function with given fields: _a0
func (*PrometheusBackend) SetMaxUnconfirmedBlocks ¶ added in v0.9.6
func (_m *PrometheusBackend) SetMaxUnconfirmedBlocks(_a0 int64)
SetMaxUnconfirmedBlocks provides a mock function with given fields: _a0
func (*PrometheusBackend) SetPipelineRunsQueued ¶ added in v0.9.7
func (_m *PrometheusBackend) SetPipelineRunsQueued(n int)
SetPipelineRunsQueued provides a mock function with given fields: n
func (*PrometheusBackend) SetPipelineTaskRunsQueued ¶ added in v0.9.7
func (_m *PrometheusBackend) SetPipelineTaskRunsQueued(n int)
SetPipelineTaskRunsQueued provides a mock function with given fields: n
func (*PrometheusBackend) SetUnconfirmedTransactions ¶ added in v0.9.6
func (_m *PrometheusBackend) SetUnconfirmedTransactions(_a0 int64)
SetUnconfirmedTransactions provides a mock function with given fields: _a0
type RunExecutor ¶ added in v0.8.2
RunExecutor is an autogenerated mock type for the RunExecutor type
type RunManager ¶ added in v0.8.2
RunManager is an autogenerated mock type for the RunManager type
func (*RunManager) Cancel ¶ added in v0.8.2
Cancel provides a mock function with given fields: runID
func (*RunManager) Create ¶ added in v0.8.2
func (_m *RunManager) Create(jobSpecID models.JobID, initiator *models.Initiator, creationHeight *big.Int, runRequest *models.RunRequest) (*models.JobRun, error)
Create provides a mock function with given fields: jobSpecID, initiator, creationHeight, runRequest
func (*RunManager) CreateErrored ¶ added in v0.8.2
func (_m *RunManager) CreateErrored(jobSpecID models.JobID, initiator models.Initiator, err error) (*models.JobRun, error)
CreateErrored provides a mock function with given fields: jobSpecID, initiator, err
func (*RunManager) ResumeAllInProgress ¶ added in v0.8.2
func (_m *RunManager) ResumeAllInProgress() error
ResumeAllInProgress provides a mock function with given fields:
func (*RunManager) ResumeAllPendingConnection ¶ added in v0.8.4
func (_m *RunManager) ResumeAllPendingConnection() error
ResumeAllPendingConnection provides a mock function with given fields:
func (*RunManager) ResumeAllPendingNextBlock ¶ added in v0.8.4
func (_m *RunManager) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error
ResumeAllPendingNextBlock provides a mock function with given fields: currentBlockHeight
func (*RunManager) ResumePendingBridge ¶ added in v0.8.4
func (_m *RunManager) ResumePendingBridge(runID uuid.UUID, input models.BridgeRunResult) error
ResumePendingBridge provides a mock function with given fields: runID, input
type RunQueue ¶ added in v0.8.2
RunQueue is an autogenerated mock type for the RunQueue type
func (*RunQueue) WorkerCount ¶ added in v0.8.2
WorkerCount provides a mock function with given fields:
type Service ¶ added in v0.8.2
Service is an autogenerated mock type for the Service type
func (*Service) RemoveJob ¶ added in v0.8.2
RemoveJob provides a mock function with given fields: _a0
type StatsPusher ¶ added in v0.8.2
StatsPusher is an autogenerated mock type for the StatsPusher type
func (*StatsPusher) AllSyncEvents ¶ added in v0.9.7
func (_m *StatsPusher) AllSyncEvents(cb func(models.SyncEvent) error) error
AllSyncEvents provides a mock function with given fields: cb
func (*StatsPusher) Close ¶ added in v0.8.2
func (_m *StatsPusher) Close() error
Close provides a mock function with given fields:
func (*StatsPusher) GetStatus ¶ added in v0.8.2
func (_m *StatsPusher) GetStatus() synchronization.ConnectionStatus
GetStatus provides a mock function with given fields:
func (*StatsPusher) GetURL ¶ added in v0.8.2
func (_m *StatsPusher) GetURL() url.URL
GetURL provides a mock function with given fields:
func (*StatsPusher) Healthy ¶ added in v0.10.8
func (_m *StatsPusher) Healthy() error
Healthy provides a mock function with given fields:
func (*StatsPusher) PushNow ¶ added in v0.8.2
func (_m *StatsPusher) PushNow()
PushNow provides a mock function with given fields:
func (*StatsPusher) Ready ¶ added in v0.10.8
func (_m *StatsPusher) Ready() error
Ready provides a mock function with given fields:
func (*StatsPusher) Start ¶ added in v0.8.2
func (_m *StatsPusher) Start() error
Start provides a mock function with given fields:
type Subscription ¶ added in v0.8.2
Subscription is an autogenerated mock type for the Subscription type
func (*Subscription) Err ¶ added in v0.8.2
func (_m *Subscription) Err() <-chan error
Err provides a mock function with given fields:
func (*Subscription) Unsubscribe ¶ added in v0.8.2
func (_m *Subscription) Unsubscribe()
Unsubscribe provides a mock function with given fields:
Source Files ¶
- advisory_locker.go
- after_nower.go
- application.go
- checker.go
- client.go
- deviation_checker.go
- deviation_checker_factory.go
- fetcher.go
- flags.go
- flux_aggregator.go
- job_subscriber.go
- notify_new_eth_tx.go
- prometheus_backend.go
- run_executor.go
- run_manager.go
- run_queue.go
- service.go
- stats_pusher.go
- subscription.go