Documentation ¶
Index ¶
- type AfterNower
- type Application
- func (_m *Application) AddJob(job models.JobSpec) error
- func (_m *Application) AddServiceAgreement(_a0 *models.ServiceAgreement) error
- func (_m *Application) ArchiveJob(_a0 *models.ID) error
- func (_m *Application) Cancel(runID *models.ID) (*models.JobRun, error)
- func (_m *Application) Create(jobSpecID *models.ID, initiator *models.Initiator, creationHeight *big.Int, ...) (*models.JobRun, error)
- func (_m *Application) CreateErrored(jobSpecID *models.ID, initiator models.Initiator, err error) (*models.JobRun, error)
- func (_m *Application) GetStatsPusher() synchronization.StatsPusher
- func (_m *Application) GetStore() *store.Store
- func (_m *Application) NewBox() packr.Box
- func (_m *Application) ResumeAllInProgress() error
- func (_m *Application) ResumeAllPendingConnection() error
- func (_m *Application) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error
- func (_m *Application) ResumePendingBridge(runID *models.ID, input models.BridgeRunResult) error
- func (_m *Application) Start() error
- func (_m *Application) Stop() error
- func (_m *Application) WakeSessionReaper()
- type CallerSubscriber
- type Client
- func (_m *Client) Call(result interface{}, method string, args ...interface{}) error
- func (_m *Client) GetBlockByNumber(hex string) (eth.Block, error)
- func (_m *Client) GetBlockHeight() (uint64, error)
- func (_m *Client) GetChainID() (*big.Int, error)
- func (_m *Client) GetERC20Balance(address common.Address, contractAddress common.Address) (*big.Int, error)
- func (_m *Client) GetEthBalance(address common.Address) (*assets.Eth, error)
- func (_m *Client) GetLatestBlock() (eth.Block, error)
- func (_m *Client) GetLogs(q ethereum.FilterQuery) ([]eth.Log, error)
- func (_m *Client) GetNonce(address common.Address) (uint64, error)
- func (_m *Client) GetTxReceipt(hash common.Hash) (*eth.TxReceipt, error)
- func (_m *Client) SendRawTx(bytes []byte) (common.Hash, error)
- func (_m *Client) Subscribe(_a0 context.Context, _a1 interface{}, _a2 ...interface{}) (eth.Subscription, error)
- func (_m *Client) SubscribeToLogs(ctx context.Context, channel chan<- eth.Log, q ethereum.FilterQuery) (eth.Subscription, error)
- func (_m *Client) SubscribeToNewHeads(ctx context.Context, channel chan<- eth.BlockHeader) (eth.Subscription, error)
- type DeviationChecker
- type DeviationCheckerFactory
- type Fetcher
- type FluxAggregator
- func (_m *FluxAggregator) ABI() *abi.ABI
- func (_m *FluxAggregator) Call(result interface{}, methodName string, args ...interface{}) error
- func (_m *FluxAggregator) EncodeMessageCall(method string, args ...interface{}) ([]byte, error)
- func (_m *FluxAggregator) GetMethodID(method string) ([]byte, error)
- func (_m *FluxAggregator) RoundState(oracle common.Address) (contracts.FluxAggregatorRoundState, error)
- func (_m *FluxAggregator) SubscribeToLogs(listener eth.LogListener) (bool, eth.UnsubscribeFunc)
- func (_m *FluxAggregator) UnpackLog(out interface{}, event string, log coreeth.Log) error
- type FluxMonitor
- func (_m *FluxMonitor) AddJob(_a0 models.JobSpec) error
- func (_m *FluxMonitor) Connect(_a0 *models.Head) error
- func (_m *FluxMonitor) Disconnect()
- func (_m *FluxMonitor) OnNewLongestChain(_a0 *models.Head)
- func (_m *FluxMonitor) RemoveJob(_a0 *models.ID)
- func (_m *FluxMonitor) Start() error
- func (_m *FluxMonitor) Stop()
- type HeadTrackable
- type JobSubscriber
- func (_m *JobSubscriber) AddJob(job models.JobSpec, bn *models.Head) error
- func (_m *JobSubscriber) Connect(_a0 *models.Head) error
- func (_m *JobSubscriber) Disconnect()
- func (_m *JobSubscriber) Jobs() []models.JobSpec
- func (_m *JobSubscriber) OnNewLongestChain(head models.Head)
- func (_m *JobSubscriber) RemoveJob(ID *models.ID) error
- func (_m *JobSubscriber) Stop() error
- type KeyStoreInterface
- func (_m *KeyStoreInterface) Accounts() []accounts.Account
- func (_m *KeyStoreInterface) GetAccounts() []accounts.Account
- func (_m *KeyStoreInterface) GetFirstAccount() (accounts.Account, error)
- func (_m *KeyStoreInterface) HasAccounts() bool
- func (_m *KeyStoreInterface) Import(keyJSON []byte, passphrase string, newPassphrase string) (accounts.Account, error)
- func (_m *KeyStoreInterface) NewAccount(passphrase string) (accounts.Account, error)
- func (_m *KeyStoreInterface) SignHash(hash common.Hash) (models.Signature, error)
- func (_m *KeyStoreInterface) SignTx(account accounts.Account, tx *types.Transaction, chainID *big.Int) (*types.Transaction, error)
- func (_m *KeyStoreInterface) Unlock(phrase string) error
- func (_m *KeyStoreInterface) Wallets() []accounts.Wallet
- type LogBroadcast
- type LogBroadcaster
- func (_m *LogBroadcaster) AddDependents(n int)
- func (_m *LogBroadcaster) AwaitDependents() <-chan struct{}
- func (_m *LogBroadcaster) DependentReady()
- func (_m *LogBroadcaster) Register(address common.Address, listener eth.LogListener) bool
- func (_m *LogBroadcaster) Start()
- func (_m *LogBroadcaster) Stop()
- func (_m *LogBroadcaster) Unregister(address common.Address, listener eth.LogListener)
- type LogListener
- type RunExecutor
- type RunManager
- func (_m *RunManager) Cancel(runID *models.ID) (*models.JobRun, error)
- func (_m *RunManager) Create(jobSpecID *models.ID, initiator *models.Initiator, creationHeight *big.Int, ...) (*models.JobRun, error)
- func (_m *RunManager) CreateErrored(jobSpecID *models.ID, 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 *models.ID, input models.BridgeRunResult) error
- type RunQueue
- type Service
- type StatsPusher
- type Subscription
- type TxManager
- func (_m *TxManager) BumpGasUntilSafe(hash common.Hash) (*eth.TxReceipt, store.AttemptState, error)
- func (_m *TxManager) Call(result interface{}, method string, args ...interface{}) error
- func (_m *TxManager) CheckAttempt(txAttempt *models.TxAttempt, blockHeight uint64) (*eth.TxReceipt, store.AttemptState, error)
- func (_m *TxManager) Connect(_a0 *models.Head) error
- func (_m *TxManager) Connected() bool
- func (_m *TxManager) ContractLINKBalance(wr models.WithdrawalRequest) (assets.Link, error)
- func (_m *TxManager) CreateTx(to common.Address, data []byte) (*models.Tx, error)
- func (_m *TxManager) CreateTxWithEth(from common.Address, to common.Address, value *assets.Eth) (*models.Tx, error)
- func (_m *TxManager) CreateTxWithGas(surrogateID null.String, to common.Address, data []byte, gasPriceWei *big.Int, ...) (*models.Tx, error)
- func (_m *TxManager) Disconnect()
- func (_m *TxManager) GetBlockByNumber(hex string) (eth.Block, error)
- func (_m *TxManager) GetBlockHeight() (uint64, error)
- func (_m *TxManager) GetChainID() (*big.Int, error)
- func (_m *TxManager) GetERC20Balance(address common.Address, contractAddress common.Address) (*big.Int, error)
- func (_m *TxManager) GetEthBalance(address common.Address) (*assets.Eth, error)
- func (_m *TxManager) GetLINKBalance(address common.Address) (*assets.Link, error)
- func (_m *TxManager) GetLatestBlock() (eth.Block, error)
- func (_m *TxManager) GetLogs(q ethereum.FilterQuery) ([]eth.Log, error)
- func (_m *TxManager) GetNonce(address common.Address) (uint64, error)
- func (_m *TxManager) GetTxReceipt(hash common.Hash) (*eth.TxReceipt, error)
- func (_m *TxManager) NextActiveAccount() *store.ManagedAccount
- func (_m *TxManager) OnNewLongestChain(head models.Head)
- func (_m *TxManager) Register(_a0 []accounts.Account)
- func (_m *TxManager) SendRawTx(bytes []byte) (common.Hash, error)
- func (_m *TxManager) SignedRawTxWithBumpedGas(originalTx models.Tx, gasLimit uint64, gasPrice big.Int) ([]byte, error)
- func (_m *TxManager) Subscribe(_a0 context.Context, _a1 interface{}, _a2 ...interface{}) (eth.Subscription, error)
- func (_m *TxManager) SubscribeToLogs(ctx context.Context, channel chan<- eth.Log, q ethereum.FilterQuery) (eth.Subscription, error)
- func (_m *TxManager) SubscribeToNewHeads(ctx context.Context, channel chan<- eth.BlockHeader) (eth.Subscription, error)
- func (_m *TxManager) WithdrawLINK(wr models.WithdrawalRequest) (common.Hash, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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(job models.JobSpec) error
AddJob provides a mock function with given fields: job
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.ID) 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.ID, 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.ID, initiator models.Initiator, err error) (*models.JobRun, error)
CreateErrored provides a mock function with given fields: jobSpecID, initiator, err
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) NewBox ¶ added in v0.8.2
func (_m *Application) NewBox() packr.Box
NewBox provides a mock function with given fields:
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) ResumePendingBridge ¶ added in v0.8.4
func (_m *Application) ResumePendingBridge(runID *models.ID, input models.BridgeRunResult) error
ResumePendingBridge provides a mock function with given fields: runID, input
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 CallerSubscriber ¶ added in v0.8.2
CallerSubscriber is an autogenerated mock type for the CallerSubscriber type
func (*CallerSubscriber) Call ¶ added in v0.8.2
func (_m *CallerSubscriber) Call(result interface{}, method string, args ...interface{}) error
Call provides a mock function with given fields: result, method, args
func (*CallerSubscriber) Subscribe ¶ added in v0.8.2
func (_m *CallerSubscriber) Subscribe(_a0 context.Context, _a1 interface{}, _a2 ...interface{}) (eth.Subscription, error)
Subscribe provides a mock function with given fields: _a0, _a1, _a2
type Client ¶ added in v0.8.2
Client is an autogenerated mock type for the Client type
func (*Client) Call ¶ added in v0.8.2
Call provides a mock function with given fields: result, method, args
func (*Client) GetBlockByNumber ¶ added in v0.8.2
GetBlockByNumber provides a mock function with given fields: hex
func (*Client) GetBlockHeight ¶ added in v0.8.2
GetBlockHeight provides a mock function with given fields:
func (*Client) GetChainID ¶ added in v0.8.2
GetChainID provides a mock function with given fields:
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
GetEthBalance provides a mock function with given fields: address
func (*Client) GetLatestBlock ¶ added in v0.8.3
GetLatestBlock provides a mock function with given fields:
func (*Client) GetNonce ¶ added in v0.8.2
GetNonce provides a mock function with given fields: address
func (*Client) GetTxReceipt ¶ added in v0.8.2
GetTxReceipt provides a mock function with given fields: hash
func (*Client) SendRawTx ¶ added in v0.8.2
SendRawTx provides a mock function with given fields: bytes
func (*Client) Subscribe ¶ added in v0.8.2
func (_m *Client) Subscribe(_a0 context.Context, _a1 interface{}, _a2 ...interface{}) (eth.Subscription, error)
Subscribe provides a mock function with given fields: _a0, _a1, _a2
func (*Client) SubscribeToLogs ¶ added in v0.8.2
func (_m *Client) SubscribeToLogs(ctx context.Context, channel chan<- eth.Log, q ethereum.FilterQuery) (eth.Subscription, error)
SubscribeToLogs provides a mock function with given fields: ctx, channel, q
func (*Client) SubscribeToNewHeads ¶ added in v0.8.2
func (_m *Client) SubscribeToNewHeads(ctx context.Context, channel chan<- eth.BlockHeader) (eth.Subscription, error)
SubscribeToNewHeads provides a mock function with given fields: ctx, channel
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 FluxAggregator ¶ added in v0.8.2
FluxAggregator is an autogenerated mock type for the FluxAggregator type
func (*FluxAggregator) ABI ¶ added in v0.8.2
func (_m *FluxAggregator) ABI() *abi.ABI
ABI provides a mock function with given fields:
func (*FluxAggregator) Call ¶ added in v0.8.2
func (_m *FluxAggregator) Call(result interface{}, methodName string, args ...interface{}) error
Call provides a mock function with given fields: result, methodName, args
func (*FluxAggregator) EncodeMessageCall ¶ added in v0.8.2
func (_m *FluxAggregator) EncodeMessageCall(method string, args ...interface{}) ([]byte, error)
EncodeMessageCall provides a mock function with given fields: method, args
func (*FluxAggregator) GetMethodID ¶ added in v0.8.2
func (_m *FluxAggregator) GetMethodID(method string) ([]byte, error)
GetMethodID provides a mock function with given fields: method
func (*FluxAggregator) RoundState ¶ added in v0.8.2
func (_m *FluxAggregator) RoundState(oracle common.Address) (contracts.FluxAggregatorRoundState, error)
RoundState provides a mock function with given fields: oracle
func (*FluxAggregator) SubscribeToLogs ¶ added in v0.8.2
func (_m *FluxAggregator) SubscribeToLogs(listener eth.LogListener) (bool, eth.UnsubscribeFunc)
SubscribeToLogs provides a mock function with given fields: listener
type FluxMonitor ¶ added in v0.8.2
FluxMonitor is an autogenerated mock type for the FluxMonitor type
func (*FluxMonitor) AddJob ¶ added in v0.8.2
func (_m *FluxMonitor) AddJob(_a0 models.JobSpec) error
AddJob provides a mock function with given fields: _a0
func (*FluxMonitor) Connect ¶ added in v0.8.2
func (_m *FluxMonitor) Connect(_a0 *models.Head) error
Connect provides a mock function with given fields: _a0
func (*FluxMonitor) Disconnect ¶ added in v0.8.2
func (_m *FluxMonitor) Disconnect()
Disconnect provides a mock function with given fields:
func (*FluxMonitor) OnNewLongestChain ¶ added in v0.8.5
func (_m *FluxMonitor) OnNewLongestChain(_a0 *models.Head)
OnNewLongestChain provides a mock function with given fields: _a0
func (*FluxMonitor) RemoveJob ¶ added in v0.8.2
func (_m *FluxMonitor) RemoveJob(_a0 *models.ID)
RemoveJob provides a mock function with given fields: _a0
func (*FluxMonitor) Start ¶ added in v0.8.2
func (_m *FluxMonitor) Start() error
Start provides a mock function with given fields:
func (*FluxMonitor) Stop ¶ added in v0.8.2
func (_m *FluxMonitor) Stop()
Stop provides a mock function with given fields:
type HeadTrackable ¶ added in v0.8.5
HeadTrackable is an autogenerated mock type for the HeadTrackable type
func (*HeadTrackable) Connect ¶ added in v0.8.5
func (_m *HeadTrackable) Connect(_a0 *models.Head) error
Connect provides a mock function with given fields: _a0
func (*HeadTrackable) Disconnect ¶ added in v0.8.5
func (_m *HeadTrackable) Disconnect()
Disconnect provides a mock function with given fields:
func (*HeadTrackable) OnNewLongestChain ¶ added in v0.8.5
func (_m *HeadTrackable) OnNewLongestChain(head models.Head)
OnNewLongestChain provides a mock function with given fields: head
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) Connect ¶ added in v0.8.2
func (_m *JobSubscriber) Connect(_a0 *models.Head) error
Connect provides a mock function with given fields: _a0
func (*JobSubscriber) Disconnect ¶ added in v0.8.2
func (_m *JobSubscriber) Disconnect()
Disconnect 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(head models.Head)
OnNewLongestChain provides a mock function with given fields: head
func (*JobSubscriber) RemoveJob ¶ added in v0.8.2
func (_m *JobSubscriber) RemoveJob(ID *models.ID) error
RemoveJob provides a mock function with given fields: ID
func (*JobSubscriber) Stop ¶ added in v0.8.2
func (_m *JobSubscriber) Stop() error
Stop provides a mock function with given fields:
type KeyStoreInterface ¶ added in v0.8.4
KeyStoreInterface is an autogenerated mock type for the KeyStoreInterface type
func (*KeyStoreInterface) Accounts ¶ added in v0.8.4
func (_m *KeyStoreInterface) Accounts() []accounts.Account
Accounts provides a mock function with given fields:
func (*KeyStoreInterface) GetAccounts ¶ added in v0.8.4
func (_m *KeyStoreInterface) GetAccounts() []accounts.Account
GetAccounts provides a mock function with given fields:
func (*KeyStoreInterface) GetFirstAccount ¶ added in v0.8.4
func (_m *KeyStoreInterface) GetFirstAccount() (accounts.Account, error)
GetFirstAccount provides a mock function with given fields:
func (*KeyStoreInterface) HasAccounts ¶ added in v0.8.4
func (_m *KeyStoreInterface) HasAccounts() bool
HasAccounts provides a mock function with given fields:
func (*KeyStoreInterface) Import ¶ added in v0.8.4
func (_m *KeyStoreInterface) Import(keyJSON []byte, passphrase string, newPassphrase string) (accounts.Account, error)
Import provides a mock function with given fields: keyJSON, passphrase, newPassphrase
func (*KeyStoreInterface) NewAccount ¶ added in v0.8.4
func (_m *KeyStoreInterface) NewAccount(passphrase string) (accounts.Account, error)
NewAccount provides a mock function with given fields: passphrase
func (*KeyStoreInterface) SignHash ¶ added in v0.8.4
SignHash provides a mock function with given fields: hash
func (*KeyStoreInterface) SignTx ¶ added in v0.8.4
func (_m *KeyStoreInterface) SignTx(account accounts.Account, tx *types.Transaction, chainID *big.Int) (*types.Transaction, error)
SignTx provides a mock function with given fields: account, tx, chainID
func (*KeyStoreInterface) Unlock ¶ added in v0.8.4
func (_m *KeyStoreInterface) Unlock(phrase string) error
Unlock provides a mock function with given fields: phrase
func (*KeyStoreInterface) Wallets ¶ added in v0.8.4
func (_m *KeyStoreInterface) Wallets() []accounts.Wallet
Wallets provides a mock function with given fields:
type LogBroadcast ¶ added in v0.8.3
LogBroadcast is an autogenerated mock type for the LogBroadcast type
func (*LogBroadcast) Log ¶ added in v0.8.3
func (_m *LogBroadcast) Log() interface{}
Log provides a mock function with given fields:
func (*LogBroadcast) MarkConsumed ¶ added in v0.8.3
func (_m *LogBroadcast) MarkConsumed() error
MarkConsumed provides a mock function with given fields:
func (*LogBroadcast) UpdateLog ¶ added in v0.8.3
func (_m *LogBroadcast) UpdateLog(_a0 coreeth.RawLog)
UpdateLog provides a mock function with given fields: _a0
func (*LogBroadcast) WasAlreadyConsumed ¶ added in v0.8.3
func (_m *LogBroadcast) WasAlreadyConsumed() (bool, error)
WasAlreadyConsumed provides a mock function with given fields:
type LogBroadcaster ¶ added in v0.8.2
LogBroadcaster is an autogenerated mock type for the LogBroadcaster type
func (*LogBroadcaster) AddDependents ¶ added in v0.8.3
func (_m *LogBroadcaster) AddDependents(n int)
AddDependents provides a mock function with given fields: n
func (*LogBroadcaster) AwaitDependents ¶ added in v0.8.3
func (_m *LogBroadcaster) AwaitDependents() <-chan struct{}
AwaitDependents provides a mock function with given fields:
func (*LogBroadcaster) DependentReady ¶ added in v0.8.3
func (_m *LogBroadcaster) DependentReady()
DependentReady provides a mock function with given fields:
func (*LogBroadcaster) Register ¶ added in v0.8.2
func (_m *LogBroadcaster) Register(address common.Address, listener eth.LogListener) bool
Register provides a mock function with given fields: address, listener
func (*LogBroadcaster) Start ¶ added in v0.8.2
func (_m *LogBroadcaster) Start()
Start provides a mock function with given fields:
func (*LogBroadcaster) Stop ¶ added in v0.8.2
func (_m *LogBroadcaster) Stop()
Stop provides a mock function with given fields:
func (*LogBroadcaster) Unregister ¶ added in v0.8.2
func (_m *LogBroadcaster) Unregister(address common.Address, listener eth.LogListener)
Unregister provides a mock function with given fields: address, listener
type LogListener ¶ added in v0.8.2
LogListener is an autogenerated mock type for the LogListener type
func (*LogListener) HandleLog ¶ added in v0.8.2
func (_m *LogListener) HandleLog(lb eth.LogBroadcast, err error)
HandleLog provides a mock function with given fields: lb, err
func (*LogListener) JobID ¶ added in v0.8.3
func (_m *LogListener) JobID() *models.ID
JobID provides a mock function with given fields:
func (*LogListener) OnConnect ¶ added in v0.8.2
func (_m *LogListener) OnConnect()
OnConnect provides a mock function with given fields:
func (*LogListener) OnDisconnect ¶ added in v0.8.2
func (_m *LogListener) OnDisconnect()
OnDisconnect provides a mock function with given fields:
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.ID, 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.ID, 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 *models.ID, 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) Stop ¶ added in v0.8.2
func (_m *RunQueue) Stop()
Stop provides a mock function with given fields:
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) 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) PushNow ¶ added in v0.8.2
func (_m *StatsPusher) PushNow()
PushNow 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:
type TxManager ¶ added in v0.8.2
TxManager is an autogenerated mock type for the TxManager type
func (*TxManager) BumpGasUntilSafe ¶ added in v0.8.2
BumpGasUntilSafe provides a mock function with given fields: hash
func (*TxManager) Call ¶ added in v0.8.2
Call provides a mock function with given fields: result, method, args
func (*TxManager) CheckAttempt ¶ added in v0.8.2
func (_m *TxManager) CheckAttempt(txAttempt *models.TxAttempt, blockHeight uint64) (*eth.TxReceipt, store.AttemptState, error)
CheckAttempt provides a mock function with given fields: txAttempt, blockHeight
func (*TxManager) ContractLINKBalance ¶ added in v0.8.2
ContractLINKBalance provides a mock function with given fields: wr
func (*TxManager) CreateTx ¶ added in v0.8.2
CreateTx provides a mock function with given fields: to, data
func (*TxManager) CreateTxWithEth ¶ added in v0.8.2
func (_m *TxManager) CreateTxWithEth(from common.Address, to common.Address, value *assets.Eth) (*models.Tx, error)
CreateTxWithEth provides a mock function with given fields: from, to, value
func (*TxManager) CreateTxWithGas ¶ added in v0.8.2
func (_m *TxManager) CreateTxWithGas(surrogateID null.String, to common.Address, data []byte, gasPriceWei *big.Int, gasLimit uint64) (*models.Tx, error)
CreateTxWithGas provides a mock function with given fields: surrogateID, to, data, gasPriceWei, gasLimit
func (*TxManager) Disconnect ¶ added in v0.8.2
func (_m *TxManager) Disconnect()
Disconnect provides a mock function with given fields:
func (*TxManager) GetBlockByNumber ¶ added in v0.8.2
GetBlockByNumber provides a mock function with given fields: hex
func (*TxManager) GetBlockHeight ¶ added in v0.8.2
GetBlockHeight provides a mock function with given fields:
func (*TxManager) GetChainID ¶ added in v0.8.2
GetChainID provides a mock function with given fields:
func (*TxManager) GetERC20Balance ¶ added in v0.8.2
func (_m *TxManager) GetERC20Balance(address common.Address, contractAddress common.Address) (*big.Int, error)
GetERC20Balance provides a mock function with given fields: address, contractAddress
func (*TxManager) GetEthBalance ¶ added in v0.8.2
GetEthBalance provides a mock function with given fields: address
func (*TxManager) GetLINKBalance ¶ added in v0.8.2
GetLINKBalance provides a mock function with given fields: address
func (*TxManager) GetLatestBlock ¶ added in v0.8.3
GetLatestBlock provides a mock function with given fields:
func (*TxManager) GetNonce ¶ added in v0.8.2
GetNonce provides a mock function with given fields: address
func (*TxManager) GetTxReceipt ¶ added in v0.8.2
GetTxReceipt provides a mock function with given fields: hash
func (*TxManager) NextActiveAccount ¶ added in v0.8.2
func (_m *TxManager) NextActiveAccount() *store.ManagedAccount
NextActiveAccount provides a mock function with given fields:
func (*TxManager) OnNewLongestChain ¶ added in v0.8.5
OnNewLongestChain provides a mock function with given fields: head
func (*TxManager) Register ¶ added in v0.8.2
Register provides a mock function with given fields: _a0
func (*TxManager) SendRawTx ¶ added in v0.8.2
SendRawTx provides a mock function with given fields: bytes
func (*TxManager) SignedRawTxWithBumpedGas ¶ added in v0.8.2
func (_m *TxManager) SignedRawTxWithBumpedGas(originalTx models.Tx, gasLimit uint64, gasPrice big.Int) ([]byte, error)
SignedRawTxWithBumpedGas provides a mock function with given fields: originalTx, gasLimit, gasPrice
func (*TxManager) Subscribe ¶ added in v0.8.2
func (_m *TxManager) Subscribe(_a0 context.Context, _a1 interface{}, _a2 ...interface{}) (eth.Subscription, error)
Subscribe provides a mock function with given fields: _a0, _a1, _a2
func (*TxManager) SubscribeToLogs ¶ added in v0.8.2
func (_m *TxManager) SubscribeToLogs(ctx context.Context, channel chan<- eth.Log, q ethereum.FilterQuery) (eth.Subscription, error)
SubscribeToLogs provides a mock function with given fields: ctx, channel, q
func (*TxManager) SubscribeToNewHeads ¶ added in v0.8.2
func (_m *TxManager) SubscribeToNewHeads(ctx context.Context, channel chan<- eth.BlockHeader) (eth.Subscription, error)
SubscribeToNewHeads provides a mock function with given fields: ctx, channel
func (*TxManager) WithdrawLINK ¶ added in v0.8.2
WithdrawLINK provides a mock function with given fields: wr
Source Files ¶
- after_nower.go
- application.go
- caller_subscriber.go
- client.go
- deviation_checker.go
- deviation_checker_factory.go
- fetcher.go
- flux_aggregator.go
- flux_monitor.go
- head_trackable.go
- job_subscriber.go
- key_store_interface.go
- log_broadcast.go
- log_broadcaster.go
- log_listener.go
- run_executor.go
- run_manager.go
- run_queue.go
- service.go
- stats_pusher.go
- subscription.go
- tx_manager.go