Documentation ¶
Index ¶
- type BalanceMonitor
- func (_m *BalanceMonitor) Close() error
- func (_m *BalanceMonitor) GetEthBalance(_a0 common.Address) *assets.Eth
- func (_m *BalanceMonitor) Healthy() error
- func (_m *BalanceMonitor) OnNewLongestChain(ctx context.Context, head *types.Head)
- func (_m *BalanceMonitor) Ready() error
- func (_m *BalanceMonitor) Start(_a0 context.Context) error
- type Chain
- func (_m *Chain) BalanceMonitor() monitor.BalanceMonitor
- func (_m *Chain) Client() client.Client
- func (_m *Chain) Close() error
- func (_m *Chain) Config() config.ChainScopedConfig
- func (_m *Chain) HeadBroadcaster() types.HeadBroadcaster
- func (_m *Chain) HeadTracker() types.HeadTracker
- func (_m *Chain) Healthy() error
- func (_m *Chain) ID() *big.Int
- func (_m *Chain) LogBroadcaster() log.Broadcaster
- func (_m *Chain) LogPoller() logpoller.LogPoller
- func (_m *Chain) Logger() logger.Logger
- func (_m *Chain) Ready() error
- func (_m *Chain) Start(_a0 context.Context) error
- func (_m *Chain) TxManager() txmgr.TxManager
- func (_m *Chain) UpdateConfig(_a0 *evmtypes.ChainCfg)
- type ChainSet
- func (_m *ChainSet) Add(ctx context.Context, id utils.Big, config *types.ChainCfg) (chains.DBChain[utils.Big, *types.ChainCfg], error)
- func (_m *ChainSet) ChainCount() int
- func (_m *ChainSet) Chains() []evm.Chain
- func (_m *ChainSet) Close() error
- func (_m *ChainSet) Configure(ctx context.Context, id utils.Big, enabled bool, config *types.ChainCfg) (chains.DBChain[utils.Big, *types.ChainCfg], error)
- func (_m *ChainSet) CreateNode(ctx context.Context, data types.Node) (types.Node, error)
- func (_m *ChainSet) Default() (evm.Chain, error)
- func (_m *ChainSet) DeleteNode(ctx context.Context, id int32) error
- func (_m *ChainSet) Get(id *big.Int) (evm.Chain, error)
- func (_m *ChainSet) GetNode(ctx context.Context, id int32) (types.Node, error)
- func (_m *ChainSet) GetNodes(ctx context.Context, offset int, limit int) ([]types.Node, int, error)
- func (_m *ChainSet) GetNodesByChainIDs(ctx context.Context, chainIDs []utils.Big) ([]types.Node, error)
- func (_m *ChainSet) GetNodesForChain(ctx context.Context, chainID utils.Big, offset int, limit int) ([]types.Node, int, error)
- func (_m *ChainSet) Healthy() error
- func (_m *ChainSet) Index(offset int, limit int) ([]chains.DBChain[utils.Big, *types.ChainCfg], int, error)
- func (_m *ChainSet) ORM() types.ORM
- func (_m *ChainSet) Ready() error
- func (_m *ChainSet) Remove(id utils.Big) error
- func (_m *ChainSet) Show(id utils.Big) (chains.DBChain[utils.Big, *types.ChainCfg], error)
- func (_m *ChainSet) Start(_a0 context.Context) error
- func (_m *ChainSet) UpdateConfig(id *big.Int, updaters ...evm.ChainConfigUpdater) error
- type Client
- func (_m *Client) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
- func (_m *Client) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error
- func (_m *Client) BatchCallContextAll(ctx context.Context, b []rpc.BatchElem) error
- func (_m *Client) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
- func (_m *Client) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
- func (_m *Client) Call(result interface{}, method string, args ...interface{}) error
- func (_m *Client) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
- func (_m *Client) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
- func (_m *Client) ChainID() *big.Int
- func (_m *Client) Close()
- func (_m *Client) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)
- func (_m *Client) Dial(ctx context.Context) error
- func (_m *Client) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error)
- func (_m *Client) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)
- func (_m *Client) GetERC20Balance(address common.Address, contractAddress common.Address) (*big.Int, error)
- func (_m *Client) GetEthBalance(ctx context.Context, account common.Address, blockNumber *big.Int) (*assets.Eth, error)
- func (_m *Client) GetLINKBalance(linkAddress common.Address, address common.Address) (*assets.Link, error)
- func (_m *Client) HeadByNumber(ctx context.Context, n *big.Int) (*evmtypes.Head, error)
- func (_m *Client) HeaderByHash(_a0 context.Context, _a1 common.Hash) (*types.Header, error)
- func (_m *Client) HeaderByNumber(_a0 context.Context, _a1 *big.Int) (*types.Header, error)
- func (_m *Client) NodeStates() map[int32]string
- func (_m *Client) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)
- func (_m *Client) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)
- func (_m *Client) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)
- func (_m *Client) SendTransaction(ctx context.Context, tx *types.Transaction) error
- func (_m *Client) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
- func (_m *Client) SubscribeNewHead(ctx context.Context, ch chan<- *evmtypes.Head) (ethereum.Subscription, error)
- func (_m *Client) SuggestGasPrice(ctx context.Context) (*big.Int, error)
- func (_m *Client) SuggestGasTipCap(ctx context.Context) (*big.Int, error)
- func (_m *Client) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
- type Node
- func (_m *Node) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
- func (_m *Node) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error
- func (_m *Node) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
- func (_m *Node) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
- func (_m *Node) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
- func (_m *Node) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
- func (_m *Node) ChainID() *big.Int
- func (_m *Node) Close()
- func (_m *Node) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)
- func (_m *Node) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error)
- func (_m *Node) EthSubscribe(ctx context.Context, channel chan<- *evmtypes.Head, args ...interface{}) (ethereum.Subscription, error)
- func (_m *Node) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)
- func (_m *Node) HeaderByHash(_a0 context.Context, _a1 common.Hash) (*types.Header, error)
- func (_m *Node) HeaderByNumber(_a0 context.Context, _a1 *big.Int) (*types.Header, error)
- func (_m *Node) ID() int32
- func (_m *Node) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)
- func (_m *Node) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)
- func (_m *Node) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)
- func (_m *Node) SendTransaction(ctx context.Context, tx *types.Transaction) error
- func (_m *Node) Start(ctx context.Context) error
- func (_m *Node) State() client.NodeState
- func (_m *Node) StateAndLatestBlockNumber() (client.NodeState, int64)
- func (_m *Node) String() string
- func (_m *Node) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
- func (_m *Node) SuggestGasPrice(ctx context.Context) (*big.Int, error)
- func (_m *Node) SuggestGasTipCap(ctx context.Context) (*big.Int, error)
- func (_m *Node) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
- type SendOnlyNode
- func (_m *SendOnlyNode) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error
- func (_m *SendOnlyNode) ChainID() *big.Int
- func (_m *SendOnlyNode) Close()
- func (_m *SendOnlyNode) SendTransaction(ctx context.Context, tx *types.Transaction) error
- func (_m *SendOnlyNode) Start(_a0 context.Context) error
- func (_m *SendOnlyNode) String() string
- type Subscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BalanceMonitor ¶ added in v1.2.0
BalanceMonitor is an autogenerated mock type for the BalanceMonitor type
func NewBalanceMonitor ¶ added in v1.5.0
func NewBalanceMonitor(t mockConstructorTestingTNewBalanceMonitor) *BalanceMonitor
NewBalanceMonitor creates a new instance of BalanceMonitor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*BalanceMonitor) Close ¶ added in v1.2.0
func (_m *BalanceMonitor) Close() error
Close provides a mock function with given fields:
func (*BalanceMonitor) GetEthBalance ¶ added in v1.2.0
func (_m *BalanceMonitor) GetEthBalance(_a0 common.Address) *assets.Eth
GetEthBalance provides a mock function with given fields: _a0
func (*BalanceMonitor) Healthy ¶ added in v1.2.0
func (_m *BalanceMonitor) Healthy() error
Healthy provides a mock function with given fields:
func (*BalanceMonitor) OnNewLongestChain ¶ added in v1.2.0
func (_m *BalanceMonitor) OnNewLongestChain(ctx context.Context, head *types.Head)
OnNewLongestChain provides a mock function with given fields: ctx, head
func (*BalanceMonitor) Ready ¶ added in v1.2.0
func (_m *BalanceMonitor) Ready() error
Ready provides a mock function with given fields:
type Chain ¶
Chain is an autogenerated mock type for the Chain type
func NewChain ¶ added in v1.6.0
func NewChain(t mockConstructorTestingTNewChain) *Chain
NewChain creates a new instance of Chain. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Chain) BalanceMonitor ¶ added in v1.2.0
func (_m *Chain) BalanceMonitor() monitor.BalanceMonitor
BalanceMonitor provides a mock function with given fields:
func (*Chain) Config ¶
func (_m *Chain) Config() config.ChainScopedConfig
Config provides a mock function with given fields:
func (*Chain) HeadBroadcaster ¶
func (_m *Chain) HeadBroadcaster() types.HeadBroadcaster
HeadBroadcaster provides a mock function with given fields:
func (*Chain) HeadTracker ¶
func (_m *Chain) HeadTracker() types.HeadTracker
HeadTracker provides a mock function with given fields:
func (*Chain) LogBroadcaster ¶
func (_m *Chain) LogBroadcaster() log.Broadcaster
LogBroadcaster provides a mock function with given fields:
func (*Chain) UpdateConfig ¶ added in v1.5.0
UpdateConfig provides a mock function with given fields: _a0
type ChainSet ¶
ChainSet is an autogenerated mock type for the ChainSet type
func NewChainSet ¶ added in v1.6.0
func NewChainSet(t mockConstructorTestingTNewChainSet) *ChainSet
NewChainSet creates a new instance of ChainSet. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ChainSet) Add ¶
func (_m *ChainSet) Add(ctx context.Context, id utils.Big, config *types.ChainCfg) (chains.DBChain[utils.Big, *types.ChainCfg], error)
Add provides a mock function with given fields: ctx, id, config
func (*ChainSet) ChainCount ¶
ChainCount provides a mock function with given fields:
func (*ChainSet) Configure ¶
func (_m *ChainSet) Configure(ctx context.Context, id utils.Big, enabled bool, config *types.ChainCfg) (chains.DBChain[utils.Big, *types.ChainCfg], error)
Configure provides a mock function with given fields: ctx, id, enabled, config
func (*ChainSet) CreateNode ¶ added in v1.5.0
CreateNode provides a mock function with given fields: ctx, data
func (*ChainSet) DeleteNode ¶ added in v1.5.0
DeleteNode provides a mock function with given fields: ctx, id
func (*ChainSet) GetNode ¶ added in v1.3.0
GetNode provides a mock function with given fields: ctx, id
func (*ChainSet) GetNodes ¶ added in v1.3.0
GetNodes provides a mock function with given fields: ctx, offset, limit
func (*ChainSet) GetNodesByChainIDs ¶ added in v1.3.0
func (_m *ChainSet) GetNodesByChainIDs(ctx context.Context, chainIDs []utils.Big) ([]types.Node, error)
GetNodesByChainIDs provides a mock function with given fields: ctx, chainIDs
func (*ChainSet) GetNodesForChain ¶ added in v1.3.0
func (_m *ChainSet) GetNodesForChain(ctx context.Context, chainID utils.Big, offset int, limit int) ([]types.Node, int, error)
GetNodesForChain provides a mock function with given fields: ctx, chainID, offset, limit
func (*ChainSet) Index ¶ added in v1.5.0
func (_m *ChainSet) Index(offset int, limit int) ([]chains.DBChain[utils.Big, *types.ChainCfg], int, error)
Index provides a mock function with given fields: offset, limit
func (*ChainSet) UpdateConfig ¶
UpdateConfig provides a mock function with given fields: id, updaters
type Client ¶ added in v1.2.0
Client is an autogenerated mock type for the Client type
func NewClient ¶ added in v1.5.0
func NewClient(t mockConstructorTestingTNewClient) *Client
NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Client) BalanceAt ¶ added in v1.2.0
func (_m *Client) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
BalanceAt provides a mock function with given fields: ctx, account, blockNumber
func (*Client) BatchCallContext ¶ added in v1.2.0
BatchCallContext provides a mock function with given fields: ctx, b
func (*Client) BatchCallContextAll ¶ added in v1.3.0
BatchCallContextAll provides a mock function with given fields: ctx, b
func (*Client) BlockByHash ¶ added in v1.4.0
BlockByHash provides a mock function with given fields: ctx, hash
func (*Client) BlockByNumber ¶ added in v1.2.0
BlockByNumber provides a mock function with given fields: ctx, number
func (*Client) Call ¶ added in v1.2.0
Call provides a mock function with given fields: result, method, args
func (*Client) CallContext ¶ added in v1.2.0
func (_m *Client) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
CallContext provides a mock function with given fields: ctx, result, method, args
func (*Client) CallContract ¶ added in v1.2.0
func (_m *Client) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
CallContract provides a mock function with given fields: ctx, msg, blockNumber
func (*Client) Close ¶ added in v1.2.0
func (_m *Client) Close()
Close provides a mock function with given fields:
func (*Client) CodeAt ¶ added in v1.2.0
func (_m *Client) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)
CodeAt provides a mock function with given fields: ctx, account, blockNumber
func (*Client) EstimateGas ¶ added in v1.2.0
EstimateGas provides a mock function with given fields: ctx, call
func (*Client) FilterLogs ¶ added in v1.2.0
FilterLogs provides a mock function with given fields: ctx, q
func (*Client) GetERC20Balance ¶ added in v1.2.0
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 v1.2.0
func (_m *Client) GetEthBalance(ctx context.Context, account common.Address, blockNumber *big.Int) (*assets.Eth, error)
GetEthBalance provides a mock function with given fields: ctx, account, blockNumber
func (*Client) GetLINKBalance ¶ added in v1.2.0
func (_m *Client) GetLINKBalance(linkAddress common.Address, address common.Address) (*assets.Link, error)
GetLINKBalance provides a mock function with given fields: linkAddress, address
func (*Client) HeadByNumber ¶ added in v1.2.0
HeadByNumber provides a mock function with given fields: ctx, n
func (*Client) HeaderByHash ¶ added in v1.8.0
HeaderByHash provides a mock function with given fields: _a0, _a1
func (*Client) HeaderByNumber ¶ added in v1.2.0
HeaderByNumber provides a mock function with given fields: _a0, _a1
func (*Client) NodeStates ¶ added in v1.3.0
NodeStates provides a mock function with given fields:
func (*Client) NonceAt ¶ added in v1.2.0
func (_m *Client) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)
NonceAt provides a mock function with given fields: ctx, account, blockNumber
func (*Client) PendingCodeAt ¶ added in v1.2.0
PendingCodeAt provides a mock function with given fields: ctx, account
func (*Client) PendingNonceAt ¶ added in v1.2.0
PendingNonceAt provides a mock function with given fields: ctx, account
func (*Client) SendTransaction ¶ added in v1.2.0
SendTransaction provides a mock function with given fields: ctx, tx
func (*Client) SubscribeFilterLogs ¶ added in v1.2.0
func (_m *Client) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
SubscribeFilterLogs provides a mock function with given fields: ctx, q, ch
func (*Client) SubscribeNewHead ¶ added in v1.2.0
func (_m *Client) SubscribeNewHead(ctx context.Context, ch chan<- *evmtypes.Head) (ethereum.Subscription, error)
SubscribeNewHead provides a mock function with given fields: ctx, ch
func (*Client) SuggestGasPrice ¶ added in v1.2.0
SuggestGasPrice provides a mock function with given fields: ctx
func (*Client) SuggestGasTipCap ¶ added in v1.2.0
SuggestGasTipCap provides a mock function with given fields: ctx
type Node ¶ added in v1.2.0
Node is an autogenerated mock type for the Node type
func NewNode ¶ added in v1.5.0
func NewNode(t mockConstructorTestingTNewNode) *Node
NewNode creates a new instance of Node. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Node) BalanceAt ¶ added in v1.2.0
func (_m *Node) 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 (*Node) BatchCallContext ¶ added in v1.2.0
BatchCallContext provides a mock function with given fields: ctx, b
func (*Node) BlockByHash ¶ added in v1.4.0
BlockByHash provides a mock function with given fields: ctx, hash
func (*Node) BlockByNumber ¶ added in v1.2.0
BlockByNumber provides a mock function with given fields: ctx, number
func (*Node) CallContext ¶ added in v1.2.0
func (_m *Node) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
CallContext provides a mock function with given fields: ctx, result, method, args
func (*Node) CallContract ¶ added in v1.2.0
func (_m *Node) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
CallContract provides a mock function with given fields: ctx, msg, blockNumber
func (*Node) Close ¶ added in v1.2.0
func (_m *Node) Close()
Close provides a mock function with given fields:
func (*Node) CodeAt ¶ added in v1.2.0
func (_m *Node) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)
CodeAt provides a mock function with given fields: ctx, account, blockNumber
func (*Node) EstimateGas ¶ added in v1.2.0
EstimateGas provides a mock function with given fields: ctx, call
func (*Node) EthSubscribe ¶ added in v1.2.0
func (_m *Node) EthSubscribe(ctx context.Context, channel chan<- *evmtypes.Head, args ...interface{}) (ethereum.Subscription, error)
EthSubscribe provides a mock function with given fields: ctx, channel, args
func (*Node) FilterLogs ¶ added in v1.2.0
FilterLogs provides a mock function with given fields: ctx, q
func (*Node) HeaderByHash ¶ added in v1.8.0
HeaderByHash provides a mock function with given fields: _a0, _a1
func (*Node) HeaderByNumber ¶ added in v1.2.0
HeaderByNumber provides a mock function with given fields: _a0, _a1
func (*Node) NonceAt ¶ added in v1.2.0
func (_m *Node) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)
NonceAt provides a mock function with given fields: ctx, account, blockNumber
func (*Node) PendingCodeAt ¶ added in v1.2.0
PendingCodeAt provides a mock function with given fields: ctx, account
func (*Node) PendingNonceAt ¶ added in v1.2.0
PendingNonceAt provides a mock function with given fields: ctx, account
func (*Node) SendTransaction ¶ added in v1.2.0
SendTransaction provides a mock function with given fields: ctx, tx
func (*Node) StateAndLatestBlockNumber ¶ added in v1.8.0
StateAndLatestBlockNumber provides a mock function with given fields:
func (*Node) SubscribeFilterLogs ¶ added in v1.2.0
func (_m *Node) 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 (*Node) SuggestGasPrice ¶ added in v1.2.0
SuggestGasPrice provides a mock function with given fields: ctx
func (*Node) SuggestGasTipCap ¶ added in v1.2.0
SuggestGasTipCap provides a mock function with given fields: ctx
type SendOnlyNode ¶ added in v1.2.0
SendOnlyNode is an autogenerated mock type for the SendOnlyNode type
func NewSendOnlyNode ¶ added in v1.5.0
func NewSendOnlyNode(t mockConstructorTestingTNewSendOnlyNode) *SendOnlyNode
NewSendOnlyNode creates a new instance of SendOnlyNode. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*SendOnlyNode) BatchCallContext ¶ added in v1.2.0
BatchCallContext provides a mock function with given fields: ctx, b
func (*SendOnlyNode) ChainID ¶ added in v1.2.0
func (_m *SendOnlyNode) ChainID() *big.Int
ChainID provides a mock function with given fields:
func (*SendOnlyNode) Close ¶ added in v1.3.0
func (_m *SendOnlyNode) Close()
Close provides a mock function with given fields:
func (*SendOnlyNode) SendTransaction ¶ added in v1.2.0
func (_m *SendOnlyNode) SendTransaction(ctx context.Context, tx *types.Transaction) error
SendTransaction provides a mock function with given fields: ctx, tx
func (*SendOnlyNode) Start ¶ added in v1.3.0
func (_m *SendOnlyNode) Start(_a0 context.Context) error
Start provides a mock function with given fields: _a0
func (*SendOnlyNode) String ¶ added in v1.2.0
func (_m *SendOnlyNode) String() string
String provides a mock function with given fields:
type Subscription ¶ added in v1.2.0
Subscription is an autogenerated mock type for the Subscription type
func NewSubscription ¶ added in v1.5.0
func NewSubscription(t mockConstructorTestingTNewSubscription) *Subscription
NewSubscription creates a new instance of Subscription. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Subscription) Err ¶ added in v1.2.0
func (_m *Subscription) Err() <-chan error
Err provides a mock function with given fields:
func (*Subscription) Unsubscribe ¶ added in v1.2.0
func (_m *Subscription) Unsubscribe()
Unsubscribe provides a mock function with given fields: