Documentation ¶
Index ¶
- type AdvisoryLocker
- type AfterNower
- type Application
- func (_m *Application) AddJobV2(ctx context.Context, _a1 *job.Job) error
- func (_m *Application) BridgeORM() bridges.ORM
- func (_m *Application) DeleteJob(ctx context.Context, jobID int32) error
- func (_m *Application) EVMORM() types.ORM
- func (_m *Application) GetChains() chainlink.Chains
- func (_m *Application) GetConfig() config.GeneralConfig
- func (_m *Application) GetEventBroadcaster() pg.EventBroadcaster
- func (_m *Application) GetExternalInitiatorManager() webhook.ExternalInitiatorManager
- func (_m *Application) GetFeedsService() feeds.Service
- func (_m *Application) GetHealthChecker() services.Checker
- func (_m *Application) GetKeyStore() keystore.Master
- func (_m *Application) GetLogger() logger.Logger
- func (_m *Application) GetSqlxDB() *sqlx.DB
- func (_m *Application) GetWebAuthnConfiguration() sessions.WebAuthnConfiguration
- func (_m *Application) ID() uuid.UUID
- func (_m *Application) JobORM() job.ORM
- func (_m *Application) JobSpawner() job.Spawner
- func (_m *Application) PipelineORM() pipeline.ORM
- func (_m *Application) ReplayFromBlock(chainID *big.Int, number uint64, forceBroadcast bool) error
- func (_m *Application) ResumeJobV2(ctx context.Context, taskID uuid.UUID, result pipeline.Result) 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) SessionORM() sessions.ORM
- func (_m *Application) SetLogLevel(lvl zapcore.Level) error
- func (_m *Application) SetServiceLogLevel(ctx context.Context, service string, level zapcore.Level) error
- func (_m *Application) Start(ctx context.Context) error
- func (_m *Application) Stop() error
- func (_m *Application) TxmORM() txmgr.ORM
- func (_m *Application) WakeSessionReaper()
- type Checker
- type DeviationChecker
- 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 NotifyNewEthTx
- type PrometheusBackend
- func (_m *PrometheusBackend) SetMaxUnconfirmedAge(_a0 *big.Int, _a1 float64)
- func (_m *PrometheusBackend) SetMaxUnconfirmedBlocks(_a0 *big.Int, _a1 int64)
- func (_m *PrometheusBackend) SetPipelineRunsQueued(n int)
- func (_m *PrometheusBackend) SetPipelineTaskRunsQueued(n int)
- func (_m *PrometheusBackend) SetUnconfirmedTransactions(_a0 *big.Int, _a1 int64)
- type RunExecutor
- type RunQueue
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) AddJobV2 ¶ added in v0.9.3
AddJobV2 provides a mock function with given fields: ctx, _a1
func (*Application) BridgeORM ¶ added in v1.1.0
func (_m *Application) BridgeORM() bridges.ORM
BridgeORM provides a mock function with given fields:
func (*Application) DeleteJob ¶ added in v1.0.0
func (_m *Application) DeleteJob(ctx context.Context, jobID int32) error
DeleteJob provides a mock function with given fields: ctx, jobID
func (*Application) EVMORM ¶ added in v1.0.0
func (_m *Application) EVMORM() types.ORM
EVMORM provides a mock function with given fields:
func (*Application) GetChains ¶ added in v1.2.0
func (_m *Application) GetChains() chainlink.Chains
GetChains provides a mock function with given fields:
func (*Application) GetConfig ¶ added in v0.10.11
func (_m *Application) GetConfig() config.GeneralConfig
GetConfig provides a mock function with given fields:
func (*Application) GetEventBroadcaster ¶ added in v1.1.0
func (_m *Application) GetEventBroadcaster() pg.EventBroadcaster
GetEventBroadcaster 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) GetHealthChecker ¶ added in v0.10.8
func (_m *Application) GetHealthChecker() services.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) GetSqlxDB ¶ added in v1.1.0
func (_m *Application) GetSqlxDB() *sqlx.DB
GetSqlxDB provides a mock function with given fields:
func (*Application) GetWebAuthnConfiguration ¶ added in v1.1.0
func (_m *Application) GetWebAuthnConfiguration() sessions.WebAuthnConfiguration
GetWebAuthnConfiguration provides a mock function with given fields:
func (*Application) ID ¶ added in v1.1.0
func (_m *Application) ID() uuid.UUID
ID 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) 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
ReplayFromBlock provides a mock function with given fields: chainID, number, forceBroadcast
func (*Application) ResumeJobV2 ¶ added in v0.10.10
func (_m *Application) ResumeJobV2(ctx context.Context, taskID uuid.UUID, result pipeline.Result) error
ResumeJobV2 provides a mock function with given fields: ctx, taskID, result
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) SessionORM ¶ added in v1.1.0
func (_m *Application) SessionORM() sessions.ORM
SessionORM provides a mock function with given fields:
func (*Application) SetLogLevel ¶ added in v1.1.0
func (_m *Application) SetLogLevel(lvl zapcore.Level) error
SetLogLevel provides a mock function with given fields: lvl
func (*Application) SetServiceLogLevel ¶ added in v1.1.0
func (_m *Application) SetServiceLogLevel(ctx context.Context, service string, level zapcore.Level) error
SetServiceLogLevel provides a mock function with given fields: ctx, service, level
func (*Application) Start ¶ added in v0.8.2
func (_m *Application) Start(ctx context.Context) error
Start provides a mock function with given fields: ctx
func (*Application) Stop ¶ added in v0.8.2
func (_m *Application) Stop() error
Stop provides a mock function with given fields:
func (*Application) TxmORM ¶ added in v1.3.0
func (_m *Application) TxmORM() txmgr.ORM
TxmORM 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 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 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 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 *big.Int, _a1 float64)
SetMaxUnconfirmedAge provides a mock function with given fields: _a0, _a1
func (*PrometheusBackend) SetMaxUnconfirmedBlocks ¶ added in v0.9.6
func (_m *PrometheusBackend) SetMaxUnconfirmedBlocks(_a0 *big.Int, _a1 int64)
SetMaxUnconfirmedBlocks provides a mock function with given fields: _a0, _a1
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 *big.Int, _a1 int64)
SetUnconfirmedTransactions provides a mock function with given fields: _a0, _a1
type RunExecutor ¶ added in v0.8.2
RunExecutor is an autogenerated mock type for the RunExecutor type
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: