mocks

package
v0.0.0-...-e348512 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 6, 2021 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdvisoryLocker 

type AdvisoryLocker struct {
	mock.Mock
}

AdvisoryLocker is an autogenerated mock type for the AdvisoryLocker type

func (*AdvisoryLocker) Close 

func (_m *AdvisoryLocker) Close() error

Close provides a mock function with given fields:

func (*AdvisoryLocker) TryLock 

func (_m *AdvisoryLocker) TryLock(ctx context.Context, classID int32, objectID int32) error

TryLock provides a mock function with given fields: ctx, classID, objectID

func (*AdvisoryLocker) Unlock 

func (_m *AdvisoryLocker) Unlock(ctx context.Context, classID int32, objectID int32) error

Unlock provides a mock function with given fields: ctx, classID, objectID

func (*AdvisoryLocker) WithAdvisoryLock 

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 

type AfterNower struct {
	mock.Mock
}

AfterNower is an autogenerated mock type for the AfterNower type

func (*AfterNower) After 

func (_m *AfterNower) After(d time.Duration) <-chan time.Time

After provides a mock function with given fields: d

func (*AfterNower) Now 

func (_m *AfterNower) Now() time.Time

Now provides a mock function with given fields:

type Application 

type Application struct {
	mock.Mock
}

Application is an autogenerated mock type for the Application type

func (*Application) AddJob 

func (_m *Application) AddJob(_a0 models.JobSpec) error

AddJob provides a mock function with given fields: _a0

func (*Application) AddJobV2 

func (_m *Application) AddJobV2(ctx context.Context, _a1 job.Spec) (int32, error)

AddJobV2 provides a mock function with given fields: ctx, _a1

func (*Application) AddServiceAgreement 

func (_m *Application) AddServiceAgreement(_a0 *models.ServiceAgreement) error

AddServiceAgreement provides a mock function with given fields: _a0

func (*Application) ArchiveJob 

func (_m *Application) ArchiveJob(_a0 *models.ID) error

ArchiveJob provides a mock function with given fields: _a0

func (*Application) AwaitRun 

func (_m *Application) AwaitRun(ctx context.Context, runID int64) error

AwaitRun provides a mock function with given fields: ctx, runID

func (*Application) Cancel 

func (_m *Application) Cancel(runID *models.ID) (*models.JobRun, error)

Cancel provides a mock function with given fields: runID

func (*Application) Create 

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 

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) DeleteJobV2 

func (_m *Application) DeleteJobV2(ctx context.Context, jobID int32) error

DeleteJobV2 provides a mock function with given fields: ctx, jobID

func (*Application) GetStatsPusher 

func (_m *Application) GetStatsPusher() synchronization.StatsPusher

GetStatsPusher provides a mock function with given fields:

func (*Application) GetStore 

func (_m *Application) GetStore() *store.Store

GetStore provides a mock function with given fields:

func (*Application) NewBox 

func (_m *Application) NewBox() packr.Box

NewBox provides a mock function with given fields:

func (*Application) ResumeAllInProgress 

func (_m *Application) ResumeAllInProgress() error

ResumeAllInProgress provides a mock function with given fields:

func (*Application) ResumeAllPendingConnection 

func (_m *Application) ResumeAllPendingConnection() error

ResumeAllPendingConnection provides a mock function with given fields:

func (*Application) ResumeAllPendingNextBlock 

func (_m *Application) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error

ResumeAllPendingNextBlock provides a mock function with given fields: currentBlockHeight

func (*Application) ResumePendingBridge 

func (_m *Application) ResumePendingBridge(runID *models.ID, input models.BridgeRunResult) error

ResumePendingBridge provides a mock function with given fields: runID, input

func (*Application) RunJobV2 

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) Start 

func (_m *Application) Start() error

Start provides a mock function with given fields:

func (*Application) Stop 

func (_m *Application) Stop() error

Stop provides a mock function with given fields:

func (*Application) WakeSessionReaper 

func (_m *Application) WakeSessionReaper()

WakeSessionReaper provides a mock function with given fields:

type Client 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*Client) BalanceAt 

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) BlockByNumber 

func (_m *Client) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

BlockByNumber provides a mock function with given fields: ctx, number

func (*Client) Call 

func (_m *Client) Call(result interface{}, method string, args ...interface{}) error

Call provides a mock function with given fields: result, method, args

func (*Client) CallContext 

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 

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) ChainID 

func (_m *Client) ChainID(ctx context.Context) (*big.Int, error)

ChainID provides a mock function with given fields: ctx

func (*Client) Close 

func (_m *Client) Close()

Close provides a mock function with given fields:

func (*Client) CodeAt 

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) Dial 

func (_m *Client) Dial(ctx context.Context) error

Dial provides a mock function with given fields: ctx

func (*Client) EstimateGas 

func (_m *Client) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error)

EstimateGas provides a mock function with given fields: ctx, call

func (*Client) FilterLogs 

func (_m *Client) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

FilterLogs provides a mock function with given fields: ctx, q

func (*Client) GetERC20Balance 

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) GetLINKBalance 

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) HeaderByNumber 

func (_m *Client) HeaderByNumber(ctx context.Context, n *big.Int) (*models.Head, error)

HeaderByNumber provides a mock function with given fields: ctx, n

func (*Client) PendingCodeAt 

func (_m *Client) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)

PendingCodeAt provides a mock function with given fields: ctx, account

func (*Client) PendingNonceAt 

func (_m *Client) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

PendingNonceAt provides a mock function with given fields: ctx, account

func (*Client) SendRawTx 

func (_m *Client) SendRawTx(bytes []byte) (common.Hash, error)

SendRawTx provides a mock function with given fields: bytes

func (*Client) SendTransaction 

func (_m *Client) SendTransaction(ctx context.Context, tx *types.Transaction) error

SendTransaction provides a mock function with given fields: ctx, tx

func (*Client) SubscribeFilterLogs 

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 

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 

func (_m *Client) SuggestGasPrice(ctx context.Context) (*big.Int, error)

SuggestGasPrice provides a mock function with given fields: ctx

func (*Client) TransactionReceipt 

func (_m *Client) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

TransactionReceipt provides a mock function with given fields: ctx, txHash

type DeviationChecker 

type DeviationChecker struct {
	mock.Mock
}

DeviationChecker is an autogenerated mock type for the DeviationChecker type

func (*DeviationChecker) Start 

func (_m *DeviationChecker) Start()

Start provides a mock function with given fields:

func (*DeviationChecker) Stop 

func (_m *DeviationChecker) Stop()

Stop provides a mock function with given fields:

type DeviationCheckerFactory 

type DeviationCheckerFactory struct {
	mock.Mock
}

DeviationCheckerFactory is an autogenerated mock type for the DeviationCheckerFactory type

func (*DeviationCheckerFactory) New 

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 Fetcher 

type Fetcher struct {
	mock.Mock
}

Fetcher is an autogenerated mock type for the Fetcher type

func (*Fetcher) Fetch 

func (_m *Fetcher) Fetch(_a0 map[string]interface{}) (decimal.Decimal, error)

Fetch provides a mock function with given fields: _a0

type FluxAggregator 

type FluxAggregator struct {
	mock.Mock
}

FluxAggregator is an autogenerated mock type for the FluxAggregator type

func (*FluxAggregator) ABI 

func (_m *FluxAggregator) ABI() *abi.ABI

ABI provides a mock function with given fields:

func (*FluxAggregator) Call 

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 

func (_m *FluxAggregator) EncodeMessageCall(method string, args ...interface{}) ([]byte, error)

EncodeMessageCall provides a mock function with given fields: method, args

func (*FluxAggregator) GetMethodID 

func (_m *FluxAggregator) GetMethodID(method string) ([]byte, error)

GetMethodID provides a mock function with given fields: method

func (*FluxAggregator) RoundState 

func (_m *FluxAggregator) RoundState(oracle common.Address, roundID uint32) (contracts.FluxAggregatorRoundState, error)

RoundState provides a mock function with given fields: oracle, roundID

func (*FluxAggregator) SubscribeToLogs 

func (_m *FluxAggregator) SubscribeToLogs(listener eth.LogListener) (bool, eth.UnsubscribeFunc)

SubscribeToLogs provides a mock function with given fields: listener

func (*FluxAggregator) UnpackLog 

func (_m *FluxAggregator) UnpackLog(out interface{}, event string, log types.Log) error

UnpackLog provides a mock function with given fields: out, event, log

type FluxMonitor 

type FluxMonitor struct {
	mock.Mock
}

FluxMonitor is an autogenerated mock type for the FluxMonitor type

func (*FluxMonitor) AddJob 

func (_m *FluxMonitor) AddJob(_a0 models.JobSpec) error

AddJob provides a mock function with given fields: _a0

func (*FluxMonitor) Connect 

func (_m *FluxMonitor) Connect(_a0 *models.Head) error

Connect provides a mock function with given fields: _a0

func (*FluxMonitor) Disconnect 

func (_m *FluxMonitor) Disconnect()

Disconnect provides a mock function with given fields:

func (*FluxMonitor) OnNewLongestChain 

func (_m *FluxMonitor) OnNewLongestChain(_a0 *models.Head)

OnNewLongestChain provides a mock function with given fields: _a0

func (*FluxMonitor) RemoveJob 

func (_m *FluxMonitor) RemoveJob(_a0 *models.ID)

RemoveJob provides a mock function with given fields: _a0

func (*FluxMonitor) Start 

func (_m *FluxMonitor) Start() error

Start provides a mock function with given fields:

func (*FluxMonitor) Stop 

func (_m *FluxMonitor) Stop()

Stop provides a mock function with given fields:

type GethClient 

type GethClient struct {
	mock.Mock
}

GethClient is an autogenerated mock type for the GethClient type

func (*GethClient) BalanceAt 

func (_m *GethClient) 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 (*GethClient) BlockByNumber 

func (_m *GethClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

BlockByNumber provides a mock function with given fields: ctx, number

func (*GethClient) CallContract 

func (_m *GethClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

CallContract provides a mock function with given fields: ctx, msg, blockNumber

func (*GethClient) ChainID 

func (_m *GethClient) ChainID(ctx context.Context) (*big.Int, error)

ChainID provides a mock function with given fields: ctx

func (*GethClient) CodeAt 

func (_m *GethClient) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)

CodeAt provides a mock function with given fields: ctx, account, blockNumber

func (*GethClient) EstimateGas 

func (_m *GethClient) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error)

EstimateGas provides a mock function with given fields: ctx, call

func (*GethClient) FilterLogs 

func (_m *GethClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

FilterLogs provides a mock function with given fields: ctx, q

func (*GethClient) PendingCodeAt 

func (_m *GethClient) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)

PendingCodeAt provides a mock function with given fields: ctx, account

func (*GethClient) PendingNonceAt 

func (_m *GethClient) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

PendingNonceAt provides a mock function with given fields: ctx, account

func (*GethClient) SendTransaction 

func (_m *GethClient) SendTransaction(ctx context.Context, tx *types.Transaction) error

SendTransaction provides a mock function with given fields: ctx, tx

func (*GethClient) SubscribeFilterLogs 

func (_m *GethClient) 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 (*GethClient) SuggestGasPrice 

func (_m *GethClient) SuggestGasPrice(ctx context.Context) (*big.Int, error)

SuggestGasPrice provides a mock function with given fields: ctx

func (*GethClient) TransactionReceipt 

func (_m *GethClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

TransactionReceipt provides a mock function with given fields: ctx, txHash

type HeadTrackable 

type HeadTrackable struct {
	mock.Mock
}

HeadTrackable is an autogenerated mock type for the HeadTrackable type

func (*HeadTrackable) Connect 

func (_m *HeadTrackable) Connect(head *models.Head) error

Connect provides a mock function with given fields: head

func (*HeadTrackable) Disconnect 

func (_m *HeadTrackable) Disconnect()

Disconnect provides a mock function with given fields:

func (*HeadTrackable) OnNewLongestChain 

func (_m *HeadTrackable) OnNewLongestChain(ctx context.Context, head models.Head)

OnNewLongestChain provides a mock function with given fields: ctx, head

type JobSubscriber 

type JobSubscriber struct {
	mock.Mock
}

JobSubscriber is an autogenerated mock type for the JobSubscriber type

func (*JobSubscriber) AddJob 

func (_m *JobSubscriber) AddJob(job models.JobSpec, bn *models.Head) error

AddJob provides a mock function with given fields: job, bn

func (*JobSubscriber) Connect 

func (_m *JobSubscriber) Connect(head *models.Head) error

Connect provides a mock function with given fields: head

func (*JobSubscriber) Disconnect 

func (_m *JobSubscriber) Disconnect()

Disconnect provides a mock function with given fields:

func (*JobSubscriber) Jobs 

func (_m *JobSubscriber) Jobs() []models.JobSpec

Jobs provides a mock function with given fields:

func (*JobSubscriber) OnNewLongestChain 

func (_m *JobSubscriber) OnNewLongestChain(ctx context.Context, head models.Head)

OnNewLongestChain provides a mock function with given fields: ctx, head

func (*JobSubscriber) RemoveJob 

func (_m *JobSubscriber) RemoveJob(ID *models.ID) error

RemoveJob provides a mock function with given fields: ID

func (*JobSubscriber) Stop 

func (_m *JobSubscriber) Stop() error

Stop provides a mock function with given fields:

type KeyStoreInterface 

type KeyStoreInterface struct {
	mock.Mock
}

KeyStoreInterface is an autogenerated mock type for the KeyStoreInterface type

func (*KeyStoreInterface) Accounts 

func (_m *KeyStoreInterface) Accounts() []accounts.Account

Accounts provides a mock function with given fields:

func (*KeyStoreInterface) Export 

func (_m *KeyStoreInterface) Export(a accounts.Account, passphrase string, newPassphrase string) ([]byte, error)

Export provides a mock function with given fields: a, passphrase, newPassphrase

func (*KeyStoreInterface) GetAccountByAddress 

func (_m *KeyStoreInterface) GetAccountByAddress(_a0 common.Address) (accounts.Account, error)

GetAccountByAddress provides a mock function with given fields: _a0

func (*KeyStoreInterface) GetAccounts 

func (_m *KeyStoreInterface) GetAccounts() []accounts.Account

GetAccounts provides a mock function with given fields:

func (*KeyStoreInterface) GetFirstAccount 

func (_m *KeyStoreInterface) GetFirstAccount() (accounts.Account, error)

GetFirstAccount provides a mock function with given fields:

func (*KeyStoreInterface) HasAccounts 

func (_m *KeyStoreInterface) HasAccounts() bool

HasAccounts provides a mock function with given fields:

func (*KeyStoreInterface) Import 

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 

func (_m *KeyStoreInterface) NewAccount(passphrase string) (accounts.Account, error)

NewAccount provides a mock function with given fields: passphrase

func (*KeyStoreInterface) SignHash 

func (_m *KeyStoreInterface) SignHash(hash common.Hash) (models.Signature, error)

SignHash provides a mock function with given fields: hash

func (*KeyStoreInterface) SignTx 

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 

func (_m *KeyStoreInterface) Unlock(phrase string) error

Unlock provides a mock function with given fields: phrase

func (*KeyStoreInterface) Wallets 

func (_m *KeyStoreInterface) Wallets() []accounts.Wallet

Wallets provides a mock function with given fields:

type LogBroadcast 

type LogBroadcast struct {
	mock.Mock
}

LogBroadcast is an autogenerated mock type for the LogBroadcast type

func (*LogBroadcast) DecodedLog 

func (_m *LogBroadcast) DecodedLog() interface{}

DecodedLog provides a mock function with given fields:

func (*LogBroadcast) MarkConsumed 

func (_m *LogBroadcast) MarkConsumed() error

MarkConsumed provides a mock function with given fields:

func (*LogBroadcast) RawLog 

func (_m *LogBroadcast) RawLog() types.Log

RawLog provides a mock function with given fields:

func (*LogBroadcast) SetDecodedLog 

func (_m *LogBroadcast) SetDecodedLog(_a0 interface{})

SetDecodedLog provides a mock function with given fields: _a0

func (*LogBroadcast) WasAlreadyConsumed 

func (_m *LogBroadcast) WasAlreadyConsumed() (bool, error)

WasAlreadyConsumed provides a mock function with given fields:

type LogBroadcaster 

type LogBroadcaster struct {
	mock.Mock
}

LogBroadcaster is an autogenerated mock type for the LogBroadcaster type

func (*LogBroadcaster) AddDependents 

func (_m *LogBroadcaster) AddDependents(n int)

AddDependents provides a mock function with given fields: n

func (*LogBroadcaster) AwaitDependents 

func (_m *LogBroadcaster) AwaitDependents() <-chan struct{}

AwaitDependents provides a mock function with given fields:

func (*LogBroadcaster) DependentReady 

func (_m *LogBroadcaster) DependentReady()

DependentReady provides a mock function with given fields:

func (*LogBroadcaster) Register 

func (_m *LogBroadcaster) Register(address common.Address, listener eth.LogListener) bool

Register provides a mock function with given fields: address, listener

func (*LogBroadcaster) Start 

func (_m *LogBroadcaster) Start() error

Start provides a mock function with given fields:

func (*LogBroadcaster) Stop 

func (_m *LogBroadcaster) Stop() error

Stop provides a mock function with given fields:

func (*LogBroadcaster) Unregister 

func (_m *LogBroadcaster) Unregister(address common.Address, listener eth.LogListener)

Unregister provides a mock function with given fields: address, listener

type LogListener 

type LogListener struct {
	mock.Mock
}

LogListener is an autogenerated mock type for the LogListener type

func (*LogListener) HandleLog 

func (_m *LogListener) HandleLog(lb eth.LogBroadcast, err error)

HandleLog provides a mock function with given fields: lb, err

func (*LogListener) IsV2Job 

func (_m *LogListener) IsV2Job() bool

IsV2Job provides a mock function with given fields:

func (*LogListener) JobID 

func (_m *LogListener) JobID() *models.ID

JobID provides a mock function with given fields:

func (*LogListener) JobIDV2 

func (_m *LogListener) JobIDV2() int32

JobIDV2 provides a mock function with given fields:

func (*LogListener) OnConnect 

func (_m *LogListener) OnConnect()

OnConnect provides a mock function with given fields:

func (*LogListener) OnDisconnect 

func (_m *LogListener) OnDisconnect()

OnDisconnect provides a mock function with given fields:

type NotifyNewEthTx 

type NotifyNewEthTx struct {
	mock.Mock
}

NotifyNewEthTx is an autogenerated mock type for the NotifyNewEthTx type

func (*NotifyNewEthTx) Trigger 

func (_m *NotifyNewEthTx) Trigger()

Trigger provides a mock function with given fields:

type RPCClient 

type RPCClient struct {
	mock.Mock
}

RPCClient is an autogenerated mock type for the RPCClient type

func (*RPCClient) BatchCallContext 

func (_m *RPCClient) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error

BatchCallContext provides a mock function with given fields: ctx, b

func (*RPCClient) Call 

func (_m *RPCClient) Call(result interface{}, method string, args ...interface{}) error

Call provides a mock function with given fields: result, method, args

func (*RPCClient) CallContext 

func (_m *RPCClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error

CallContext provides a mock function with given fields: ctx, result, method, args

func (*RPCClient) Close 

func (_m *RPCClient) Close()

Close provides a mock function with given fields:

func (*RPCClient) EthSubscribe 

func (_m *RPCClient) EthSubscribe(ctx context.Context, channel interface{}, args ...interface{}) (ethereum.Subscription, error)

EthSubscribe provides a mock function with given fields: ctx, channel, args

type RunExecutor 

type RunExecutor struct {
	mock.Mock
}

RunExecutor is an autogenerated mock type for the RunExecutor type

func (*RunExecutor) Execute 

func (_m *RunExecutor) Execute(_a0 *models.ID) error

Execute provides a mock function with given fields: _a0

type RunManager 

type RunManager struct {
	mock.Mock
}

RunManager is an autogenerated mock type for the RunManager type

func (*RunManager) Cancel 

func (_m *RunManager) Cancel(runID *models.ID) (*models.JobRun, error)

Cancel provides a mock function with given fields: runID

func (*RunManager) Create 

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 

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 

func (_m *RunManager) ResumeAllInProgress() error

ResumeAllInProgress provides a mock function with given fields:

func (*RunManager) ResumeAllPendingConnection 

func (_m *RunManager) ResumeAllPendingConnection() error

ResumeAllPendingConnection provides a mock function with given fields:

func (*RunManager) ResumeAllPendingNextBlock 

func (_m *RunManager) ResumeAllPendingNextBlock(currentBlockHeight *big.Int) error

ResumeAllPendingNextBlock provides a mock function with given fields: currentBlockHeight

func (*RunManager) ResumePendingBridge 

func (_m *RunManager) ResumePendingBridge(runID *models.ID, input models.BridgeRunResult) error

ResumePendingBridge provides a mock function with given fields: runID, input

type RunQueue 

type RunQueue struct {
	mock.Mock
}

RunQueue is an autogenerated mock type for the RunQueue type

func (*RunQueue) Run 

func (_m *RunQueue) Run(_a0 *models.JobRun)

Run provides a mock function with given fields: _a0

func (*RunQueue) Start 

func (_m *RunQueue) Start() error

Start provides a mock function with given fields:

func (*RunQueue) Stop 

func (_m *RunQueue) Stop()

Stop provides a mock function with given fields:

func (*RunQueue) WorkerCount 

func (_m *RunQueue) WorkerCount() int

WorkerCount provides a mock function with given fields:

type Service 

type Service struct {
	mock.Mock
}

Service is an autogenerated mock type for the Service type

func (*Service) AddJob 

func (_m *Service) AddJob(_a0 models.JobSpec) error

AddJob provides a mock function with given fields: _a0

func (*Service) RemoveJob 

func (_m *Service) RemoveJob(_a0 *models.ID)

RemoveJob provides a mock function with given fields: _a0

func (*Service) Start 

func (_m *Service) Start() error

Start provides a mock function with given fields:

func (*Service) Stop 

func (_m *Service) Stop()

Stop provides a mock function with given fields:

type StatsPusher 

type StatsPusher struct {
	mock.Mock
}

StatsPusher is an autogenerated mock type for the StatsPusher type

func (*StatsPusher) Close 

func (_m *StatsPusher) Close() error

Close provides a mock function with given fields:

func (*StatsPusher) GetStatus 

func (_m *StatsPusher) GetStatus() synchronization.ConnectionStatus

GetStatus provides a mock function with given fields:

func (*StatsPusher) GetURL 

func (_m *StatsPusher) GetURL() url.URL

GetURL provides a mock function with given fields:

func (*StatsPusher) PushNow 

func (_m *StatsPusher) PushNow()

PushNow provides a mock function with given fields:

func (*StatsPusher) Start 

func (_m *StatsPusher) Start() error

Start provides a mock function with given fields:

type Subscription 

type Subscription struct {
	mock.Mock
}

Subscription is an autogenerated mock type for the Subscription type

func (*Subscription) Err 

func (_m *Subscription) Err() <-chan error

Err provides a mock function with given fields:

func (*Subscription) Unsubscribe 

func (_m *Subscription) Unsubscribe()

Unsubscribe provides a mock function with given fields:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.