Documentation
¶
Index ¶
- type BridgeStore
- func (_m *BridgeStore) CreateTransfer(ctx context.Context, transfer *relayer.Transfer) (bool, error)
- func (_m *BridgeStore) EXPECT() *BridgeStore_Expecter
- func (_m *BridgeStore) GetChainState(ctx context.Context, chainID string) (*relayer.ChainState, error)
- func (_m *BridgeStore) GetPendingTransfers(ctx context.Context, direction relayer.TransferDirection) ([]*relayer.Transfer, error)
- func (_m *BridgeStore) GetTransfer(ctx context.Context, id string) (*relayer.Transfer, error)
- func (_m *BridgeStore) IncrementRetryCount(ctx context.Context, id string) error
- func (_m *BridgeStore) ListTransfers(ctx context.Context, limit int) ([]*relayer.Transfer, error)
- func (_m *BridgeStore) SetChainState(ctx context.Context, chainID string, blockNumber uint64, offset string) error
- func (_m *BridgeStore) UpdateTransferStatus(ctx context.Context, id string, status relayer.TransferStatus, ...) error
- type BridgeStore_CreateTransfer_Call
- func (_c *BridgeStore_CreateTransfer_Call) Return(_a0 bool, _a1 error) *BridgeStore_CreateTransfer_Call
- func (_c *BridgeStore_CreateTransfer_Call) Run(run func(ctx context.Context, transfer *relayer.Transfer)) *BridgeStore_CreateTransfer_Call
- func (_c *BridgeStore_CreateTransfer_Call) RunAndReturn(run func(context.Context, *relayer.Transfer) (bool, error)) *BridgeStore_CreateTransfer_Call
- type BridgeStore_Expecter
- func (_e *BridgeStore_Expecter) CreateTransfer(ctx interface{}, transfer interface{}) *BridgeStore_CreateTransfer_Call
- func (_e *BridgeStore_Expecter) GetChainState(ctx interface{}, chainID interface{}) *BridgeStore_GetChainState_Call
- func (_e *BridgeStore_Expecter) GetPendingTransfers(ctx interface{}, direction interface{}) *BridgeStore_GetPendingTransfers_Call
- func (_e *BridgeStore_Expecter) GetTransfer(ctx interface{}, id interface{}) *BridgeStore_GetTransfer_Call
- func (_e *BridgeStore_Expecter) IncrementRetryCount(ctx interface{}, id interface{}) *BridgeStore_IncrementRetryCount_Call
- func (_e *BridgeStore_Expecter) ListTransfers(ctx interface{}, limit interface{}) *BridgeStore_ListTransfers_Call
- func (_e *BridgeStore_Expecter) SetChainState(ctx interface{}, chainID interface{}, blockNumber interface{}, ...) *BridgeStore_SetChainState_Call
- func (_e *BridgeStore_Expecter) UpdateTransferStatus(ctx interface{}, id interface{}, status interface{}, destTxHash interface{}, ...) *BridgeStore_UpdateTransferStatus_Call
- type BridgeStore_GetChainState_Call
- func (_c *BridgeStore_GetChainState_Call) Return(_a0 *relayer.ChainState, _a1 error) *BridgeStore_GetChainState_Call
- func (_c *BridgeStore_GetChainState_Call) Run(run func(ctx context.Context, chainID string)) *BridgeStore_GetChainState_Call
- func (_c *BridgeStore_GetChainState_Call) RunAndReturn(run func(context.Context, string) (*relayer.ChainState, error)) *BridgeStore_GetChainState_Call
- type BridgeStore_GetPendingTransfers_Call
- func (_c *BridgeStore_GetPendingTransfers_Call) Return(_a0 []*relayer.Transfer, _a1 error) *BridgeStore_GetPendingTransfers_Call
- func (_c *BridgeStore_GetPendingTransfers_Call) Run(run func(ctx context.Context, direction relayer.TransferDirection)) *BridgeStore_GetPendingTransfers_Call
- func (_c *BridgeStore_GetPendingTransfers_Call) RunAndReturn(...) *BridgeStore_GetPendingTransfers_Call
- type BridgeStore_GetTransfer_Call
- func (_c *BridgeStore_GetTransfer_Call) Return(_a0 *relayer.Transfer, _a1 error) *BridgeStore_GetTransfer_Call
- func (_c *BridgeStore_GetTransfer_Call) Run(run func(ctx context.Context, id string)) *BridgeStore_GetTransfer_Call
- func (_c *BridgeStore_GetTransfer_Call) RunAndReturn(run func(context.Context, string) (*relayer.Transfer, error)) *BridgeStore_GetTransfer_Call
- type BridgeStore_IncrementRetryCount_Call
- func (_c *BridgeStore_IncrementRetryCount_Call) Return(_a0 error) *BridgeStore_IncrementRetryCount_Call
- func (_c *BridgeStore_IncrementRetryCount_Call) Run(run func(ctx context.Context, id string)) *BridgeStore_IncrementRetryCount_Call
- func (_c *BridgeStore_IncrementRetryCount_Call) RunAndReturn(run func(context.Context, string) error) *BridgeStore_IncrementRetryCount_Call
- type BridgeStore_ListTransfers_Call
- func (_c *BridgeStore_ListTransfers_Call) Return(_a0 []*relayer.Transfer, _a1 error) *BridgeStore_ListTransfers_Call
- func (_c *BridgeStore_ListTransfers_Call) Run(run func(ctx context.Context, limit int)) *BridgeStore_ListTransfers_Call
- func (_c *BridgeStore_ListTransfers_Call) RunAndReturn(run func(context.Context, int) ([]*relayer.Transfer, error)) *BridgeStore_ListTransfers_Call
- type BridgeStore_SetChainState_Call
- func (_c *BridgeStore_SetChainState_Call) Return(_a0 error) *BridgeStore_SetChainState_Call
- func (_c *BridgeStore_SetChainState_Call) Run(...) *BridgeStore_SetChainState_Call
- func (_c *BridgeStore_SetChainState_Call) RunAndReturn(run func(context.Context, string, uint64, string) error) *BridgeStore_SetChainState_Call
- type BridgeStore_UpdateTransferStatus_Call
- func (_c *BridgeStore_UpdateTransferStatus_Call) Return(_a0 error) *BridgeStore_UpdateTransferStatus_Call
- func (_c *BridgeStore_UpdateTransferStatus_Call) Run(run func(ctx context.Context, id string, status relayer.TransferStatus, ...)) *BridgeStore_UpdateTransferStatus_Call
- func (_c *BridgeStore_UpdateTransferStatus_Call) RunAndReturn(...) *BridgeStore_UpdateTransferStatus_Call
- type CantonBridge
- func (_m *CantonBridge) CompleteWithdrawal(ctx context.Context, req bridge.CompleteWithdrawalRequest) error
- func (_m *CantonBridge) CreatePendingDeposit(ctx context.Context, req bridge.CreatePendingDepositRequest) (*bridge.PendingDeposit, error)
- func (_m *CantonBridge) EXPECT() *CantonBridge_Expecter
- func (_m *CantonBridge) GetLatestLedgerOffset(ctx context.Context) (int64, error)
- func (_m *CantonBridge) GetWayfinderBridgeConfigCID(ctx context.Context) (string, error)
- func (_m *CantonBridge) InitiateWithdrawal(ctx context.Context, req bridge.InitiateWithdrawalRequest) (string, error)
- func (_m *CantonBridge) IsDepositProcessed(ctx context.Context, evmTxHash string) (bool, error)
- func (_m *CantonBridge) ProcessDepositAndMint(ctx context.Context, req bridge.ProcessDepositRequest) (*bridge.ProcessedDeposit, error)
- func (_m *CantonBridge) ProcessWithdrawal(ctx context.Context, withdrawalRequestCID string) (string, error)
- func (_m *CantonBridge) StreamWithdrawalEvents(ctx context.Context, offset string) <-chan *bridge.WithdrawalEvent
- type CantonBridge_CompleteWithdrawal_Call
- func (_c *CantonBridge_CompleteWithdrawal_Call) Return(_a0 error) *CantonBridge_CompleteWithdrawal_Call
- func (_c *CantonBridge_CompleteWithdrawal_Call) Run(run func(ctx context.Context, req bridge.CompleteWithdrawalRequest)) *CantonBridge_CompleteWithdrawal_Call
- func (_c *CantonBridge_CompleteWithdrawal_Call) RunAndReturn(run func(context.Context, bridge.CompleteWithdrawalRequest) error) *CantonBridge_CompleteWithdrawal_Call
- type CantonBridge_CreatePendingDeposit_Call
- func (_c *CantonBridge_CreatePendingDeposit_Call) Return(_a0 *bridge.PendingDeposit, _a1 error) *CantonBridge_CreatePendingDeposit_Call
- func (_c *CantonBridge_CreatePendingDeposit_Call) Run(run func(ctx context.Context, req bridge.CreatePendingDepositRequest)) *CantonBridge_CreatePendingDeposit_Call
- func (_c *CantonBridge_CreatePendingDeposit_Call) RunAndReturn(...) *CantonBridge_CreatePendingDeposit_Call
- type CantonBridge_Expecter
- func (_e *CantonBridge_Expecter) CompleteWithdrawal(ctx interface{}, req interface{}) *CantonBridge_CompleteWithdrawal_Call
- func (_e *CantonBridge_Expecter) CreatePendingDeposit(ctx interface{}, req interface{}) *CantonBridge_CreatePendingDeposit_Call
- func (_e *CantonBridge_Expecter) GetLatestLedgerOffset(ctx interface{}) *CantonBridge_GetLatestLedgerOffset_Call
- func (_e *CantonBridge_Expecter) GetWayfinderBridgeConfigCID(ctx interface{}) *CantonBridge_GetWayfinderBridgeConfigCID_Call
- func (_e *CantonBridge_Expecter) InitiateWithdrawal(ctx interface{}, req interface{}) *CantonBridge_InitiateWithdrawal_Call
- func (_e *CantonBridge_Expecter) IsDepositProcessed(ctx interface{}, evmTxHash interface{}) *CantonBridge_IsDepositProcessed_Call
- func (_e *CantonBridge_Expecter) ProcessDepositAndMint(ctx interface{}, req interface{}) *CantonBridge_ProcessDepositAndMint_Call
- func (_e *CantonBridge_Expecter) ProcessWithdrawal(ctx interface{}, withdrawalRequestCID interface{}) *CantonBridge_ProcessWithdrawal_Call
- func (_e *CantonBridge_Expecter) StreamWithdrawalEvents(ctx interface{}, offset interface{}) *CantonBridge_StreamWithdrawalEvents_Call
- type CantonBridge_GetLatestLedgerOffset_Call
- func (_c *CantonBridge_GetLatestLedgerOffset_Call) Return(_a0 int64, _a1 error) *CantonBridge_GetLatestLedgerOffset_Call
- func (_c *CantonBridge_GetLatestLedgerOffset_Call) Run(run func(ctx context.Context)) *CantonBridge_GetLatestLedgerOffset_Call
- func (_c *CantonBridge_GetLatestLedgerOffset_Call) RunAndReturn(run func(context.Context) (int64, error)) *CantonBridge_GetLatestLedgerOffset_Call
- type CantonBridge_GetWayfinderBridgeConfigCID_Call
- func (_c *CantonBridge_GetWayfinderBridgeConfigCID_Call) Return(_a0 string, _a1 error) *CantonBridge_GetWayfinderBridgeConfigCID_Call
- func (_c *CantonBridge_GetWayfinderBridgeConfigCID_Call) Run(run func(ctx context.Context)) *CantonBridge_GetWayfinderBridgeConfigCID_Call
- func (_c *CantonBridge_GetWayfinderBridgeConfigCID_Call) RunAndReturn(run func(context.Context) (string, error)) *CantonBridge_GetWayfinderBridgeConfigCID_Call
- type CantonBridge_InitiateWithdrawal_Call
- func (_c *CantonBridge_InitiateWithdrawal_Call) Return(_a0 string, _a1 error) *CantonBridge_InitiateWithdrawal_Call
- func (_c *CantonBridge_InitiateWithdrawal_Call) Run(run func(ctx context.Context, req bridge.InitiateWithdrawalRequest)) *CantonBridge_InitiateWithdrawal_Call
- func (_c *CantonBridge_InitiateWithdrawal_Call) RunAndReturn(run func(context.Context, bridge.InitiateWithdrawalRequest) (string, error)) *CantonBridge_InitiateWithdrawal_Call
- type CantonBridge_IsDepositProcessed_Call
- func (_c *CantonBridge_IsDepositProcessed_Call) Return(_a0 bool, _a1 error) *CantonBridge_IsDepositProcessed_Call
- func (_c *CantonBridge_IsDepositProcessed_Call) Run(run func(ctx context.Context, evmTxHash string)) *CantonBridge_IsDepositProcessed_Call
- func (_c *CantonBridge_IsDepositProcessed_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *CantonBridge_IsDepositProcessed_Call
- type CantonBridge_ProcessDepositAndMint_Call
- func (_c *CantonBridge_ProcessDepositAndMint_Call) Return(_a0 *bridge.ProcessedDeposit, _a1 error) *CantonBridge_ProcessDepositAndMint_Call
- func (_c *CantonBridge_ProcessDepositAndMint_Call) Run(run func(ctx context.Context, req bridge.ProcessDepositRequest)) *CantonBridge_ProcessDepositAndMint_Call
- func (_c *CantonBridge_ProcessDepositAndMint_Call) RunAndReturn(...) *CantonBridge_ProcessDepositAndMint_Call
- type CantonBridge_ProcessWithdrawal_Call
- func (_c *CantonBridge_ProcessWithdrawal_Call) Return(_a0 string, _a1 error) *CantonBridge_ProcessWithdrawal_Call
- func (_c *CantonBridge_ProcessWithdrawal_Call) Run(run func(ctx context.Context, withdrawalRequestCID string)) *CantonBridge_ProcessWithdrawal_Call
- func (_c *CantonBridge_ProcessWithdrawal_Call) RunAndReturn(run func(context.Context, string) (string, error)) *CantonBridge_ProcessWithdrawal_Call
- type CantonBridge_StreamWithdrawalEvents_Call
- func (_c *CantonBridge_StreamWithdrawalEvents_Call) Return(_a0 <-chan *bridge.WithdrawalEvent) *CantonBridge_StreamWithdrawalEvents_Call
- func (_c *CantonBridge_StreamWithdrawalEvents_Call) Run(run func(ctx context.Context, offset string)) *CantonBridge_StreamWithdrawalEvents_Call
- func (_c *CantonBridge_StreamWithdrawalEvents_Call) RunAndReturn(run func(context.Context, string) <-chan *bridge.WithdrawalEvent) *CantonBridge_StreamWithdrawalEvents_Call
- type Destination
- type Destination_Expecter
- type Destination_GetChainID_Call
- type Destination_SubmitTransfer_Call
- func (_c *Destination_SubmitTransfer_Call) Return(destTxHash string, skipped bool, err error) *Destination_SubmitTransfer_Call
- func (_c *Destination_SubmitTransfer_Call) Run(run func(ctx context.Context, event *relayer.Event)) *Destination_SubmitTransfer_Call
- func (_c *Destination_SubmitTransfer_Call) RunAndReturn(run func(context.Context, *relayer.Event) (string, bool, error)) *Destination_SubmitTransfer_Call
- type EthereumBridgeClient
- func (_m *EthereumBridgeClient) EXPECT() *EthereumBridgeClient_Expecter
- func (_m *EthereumBridgeClient) GetLastScannedBlock() uint64
- func (_m *EthereumBridgeClient) GetLatestBlockNumber(ctx context.Context) (uint64, error)
- func (_m *EthereumBridgeClient) IsWithdrawalProcessed(ctx context.Context, cantonTxHash [32]byte) (bool, error)
- func (_m *EthereumBridgeClient) WatchDepositEvents(ctx context.Context, fromBlock uint64, ...) error
- func (_m *EthereumBridgeClient) WithdrawFromCanton(ctx context.Context, token common.Address, recipient common.Address, ...) (common.Hash, error)
- type EthereumBridgeClient_Expecter
- func (_e *EthereumBridgeClient_Expecter) GetLastScannedBlock() *EthereumBridgeClient_GetLastScannedBlock_Call
- func (_e *EthereumBridgeClient_Expecter) GetLatestBlockNumber(ctx interface{}) *EthereumBridgeClient_GetLatestBlockNumber_Call
- func (_e *EthereumBridgeClient_Expecter) IsWithdrawalProcessed(ctx interface{}, cantonTxHash interface{}) *EthereumBridgeClient_IsWithdrawalProcessed_Call
- func (_e *EthereumBridgeClient_Expecter) WatchDepositEvents(ctx interface{}, fromBlock interface{}, handler interface{}) *EthereumBridgeClient_WatchDepositEvents_Call
- func (_e *EthereumBridgeClient_Expecter) WithdrawFromCanton(ctx interface{}, token interface{}, recipient interface{}, amount interface{}, ...) *EthereumBridgeClient_WithdrawFromCanton_Call
- type EthereumBridgeClient_GetLastScannedBlock_Call
- func (_c *EthereumBridgeClient_GetLastScannedBlock_Call) Return(_a0 uint64) *EthereumBridgeClient_GetLastScannedBlock_Call
- func (_c *EthereumBridgeClient_GetLastScannedBlock_Call) Run(run func()) *EthereumBridgeClient_GetLastScannedBlock_Call
- func (_c *EthereumBridgeClient_GetLastScannedBlock_Call) RunAndReturn(run func() uint64) *EthereumBridgeClient_GetLastScannedBlock_Call
- type EthereumBridgeClient_GetLatestBlockNumber_Call
- func (_c *EthereumBridgeClient_GetLatestBlockNumber_Call) Return(_a0 uint64, _a1 error) *EthereumBridgeClient_GetLatestBlockNumber_Call
- func (_c *EthereumBridgeClient_GetLatestBlockNumber_Call) Run(run func(ctx context.Context)) *EthereumBridgeClient_GetLatestBlockNumber_Call
- func (_c *EthereumBridgeClient_GetLatestBlockNumber_Call) RunAndReturn(run func(context.Context) (uint64, error)) *EthereumBridgeClient_GetLatestBlockNumber_Call
- type EthereumBridgeClient_IsWithdrawalProcessed_Call
- func (_c *EthereumBridgeClient_IsWithdrawalProcessed_Call) Return(_a0 bool, _a1 error) *EthereumBridgeClient_IsWithdrawalProcessed_Call
- func (_c *EthereumBridgeClient_IsWithdrawalProcessed_Call) Run(run func(ctx context.Context, cantonTxHash [32]byte)) *EthereumBridgeClient_IsWithdrawalProcessed_Call
- func (_c *EthereumBridgeClient_IsWithdrawalProcessed_Call) RunAndReturn(run func(context.Context, [32]byte) (bool, error)) *EthereumBridgeClient_IsWithdrawalProcessed_Call
- type EthereumBridgeClient_WatchDepositEvents_Call
- func (_c *EthereumBridgeClient_WatchDepositEvents_Call) Return(_a0 error) *EthereumBridgeClient_WatchDepositEvents_Call
- func (_c *EthereumBridgeClient_WatchDepositEvents_Call) Run(run func(ctx context.Context, fromBlock uint64, ...)) *EthereumBridgeClient_WatchDepositEvents_Call
- func (_c *EthereumBridgeClient_WatchDepositEvents_Call) RunAndReturn(run func(context.Context, uint64, func(*ethereum.DepositEvent) error) error) *EthereumBridgeClient_WatchDepositEvents_Call
- type EthereumBridgeClient_WithdrawFromCanton_Call
- func (_c *EthereumBridgeClient_WithdrawFromCanton_Call) Return(_a0 common.Hash, _a1 error) *EthereumBridgeClient_WithdrawFromCanton_Call
- func (_c *EthereumBridgeClient_WithdrawFromCanton_Call) Run(...) *EthereumBridgeClient_WithdrawFromCanton_Call
- func (_c *EthereumBridgeClient_WithdrawFromCanton_Call) RunAndReturn(...) *EthereumBridgeClient_WithdrawFromCanton_Call
- type Source
- type Source_Expecter
- type Source_ExtractOffset_Call
- type Source_GetChainID_Call
- type Source_StreamEvents_Call
- func (_c *Source_StreamEvents_Call) Return(_a0 <-chan *relayer.Event, _a1 <-chan error) *Source_StreamEvents_Call
- func (_c *Source_StreamEvents_Call) Run(run func(ctx context.Context, offset string)) *Source_StreamEvents_Call
- func (_c *Source_StreamEvents_Call) RunAndReturn(run func(context.Context, string) (<-chan *relayer.Event, <-chan error)) *Source_StreamEvents_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BridgeStore ¶
BridgeStore is an autogenerated mock type for the BridgeStore type
func NewBridgeStore ¶
func NewBridgeStore(t interface {
mock.TestingT
Cleanup(func())
}) *BridgeStore
NewBridgeStore creates a new instance of BridgeStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*BridgeStore) CreateTransfer ¶
func (_m *BridgeStore) CreateTransfer(ctx context.Context, transfer *relayer.Transfer) (bool, error)
CreateTransfer provides a mock function with given fields: ctx, transfer
func (*BridgeStore) EXPECT ¶
func (_m *BridgeStore) EXPECT() *BridgeStore_Expecter
func (*BridgeStore) GetChainState ¶
func (_m *BridgeStore) GetChainState(ctx context.Context, chainID string) (*relayer.ChainState, error)
GetChainState provides a mock function with given fields: ctx, chainID
func (*BridgeStore) GetPendingTransfers ¶
func (_m *BridgeStore) GetPendingTransfers(ctx context.Context, direction relayer.TransferDirection) ([]*relayer.Transfer, error)
GetPendingTransfers provides a mock function with given fields: ctx, direction
func (*BridgeStore) GetTransfer ¶
GetTransfer provides a mock function with given fields: ctx, id
func (*BridgeStore) IncrementRetryCount ¶
func (_m *BridgeStore) IncrementRetryCount(ctx context.Context, id string) error
IncrementRetryCount provides a mock function with given fields: ctx, id
func (*BridgeStore) ListTransfers ¶
ListTransfers provides a mock function with given fields: ctx, limit
func (*BridgeStore) SetChainState ¶
func (_m *BridgeStore) SetChainState(ctx context.Context, chainID string, blockNumber uint64, offset string) error
SetChainState provides a mock function with given fields: ctx, chainID, blockNumber, offset
func (*BridgeStore) UpdateTransferStatus ¶
func (_m *BridgeStore) UpdateTransferStatus(ctx context.Context, id string, status relayer.TransferStatus, destTxHash *string, errMsg *string) error
UpdateTransferStatus provides a mock function with given fields: ctx, id, status, destTxHash, errMsg
type BridgeStore_CreateTransfer_Call ¶
BridgeStore_CreateTransfer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTransfer'
func (*BridgeStore_CreateTransfer_Call) Return ¶
func (_c *BridgeStore_CreateTransfer_Call) Return(_a0 bool, _a1 error) *BridgeStore_CreateTransfer_Call
func (*BridgeStore_CreateTransfer_Call) Run ¶
func (_c *BridgeStore_CreateTransfer_Call) Run(run func(ctx context.Context, transfer *relayer.Transfer)) *BridgeStore_CreateTransfer_Call
func (*BridgeStore_CreateTransfer_Call) RunAndReturn ¶
func (_c *BridgeStore_CreateTransfer_Call) RunAndReturn(run func(context.Context, *relayer.Transfer) (bool, error)) *BridgeStore_CreateTransfer_Call
type BridgeStore_Expecter ¶
type BridgeStore_Expecter struct {
// contains filtered or unexported fields
}
func (*BridgeStore_Expecter) CreateTransfer ¶
func (_e *BridgeStore_Expecter) CreateTransfer(ctx interface{}, transfer interface{}) *BridgeStore_CreateTransfer_Call
CreateTransfer is a helper method to define mock.On call
- ctx context.Context
- transfer *relayer.Transfer
func (*BridgeStore_Expecter) GetChainState ¶
func (_e *BridgeStore_Expecter) GetChainState(ctx interface{}, chainID interface{}) *BridgeStore_GetChainState_Call
GetChainState is a helper method to define mock.On call
- ctx context.Context
- chainID string
func (*BridgeStore_Expecter) GetPendingTransfers ¶
func (_e *BridgeStore_Expecter) GetPendingTransfers(ctx interface{}, direction interface{}) *BridgeStore_GetPendingTransfers_Call
GetPendingTransfers is a helper method to define mock.On call
- ctx context.Context
- direction relayer.TransferDirection
func (*BridgeStore_Expecter) GetTransfer ¶
func (_e *BridgeStore_Expecter) GetTransfer(ctx interface{}, id interface{}) *BridgeStore_GetTransfer_Call
GetTransfer is a helper method to define mock.On call
- ctx context.Context
- id string
func (*BridgeStore_Expecter) IncrementRetryCount ¶
func (_e *BridgeStore_Expecter) IncrementRetryCount(ctx interface{}, id interface{}) *BridgeStore_IncrementRetryCount_Call
IncrementRetryCount is a helper method to define mock.On call
- ctx context.Context
- id string
func (*BridgeStore_Expecter) ListTransfers ¶
func (_e *BridgeStore_Expecter) ListTransfers(ctx interface{}, limit interface{}) *BridgeStore_ListTransfers_Call
ListTransfers is a helper method to define mock.On call
- ctx context.Context
- limit int
func (*BridgeStore_Expecter) SetChainState ¶
func (_e *BridgeStore_Expecter) SetChainState(ctx interface{}, chainID interface{}, blockNumber interface{}, offset interface{}) *BridgeStore_SetChainState_Call
SetChainState is a helper method to define mock.On call
- ctx context.Context
- chainID string
- blockNumber uint64
- offset string
func (*BridgeStore_Expecter) UpdateTransferStatus ¶
func (_e *BridgeStore_Expecter) UpdateTransferStatus(ctx interface{}, id interface{}, status interface{}, destTxHash interface{}, errMsg interface{}) *BridgeStore_UpdateTransferStatus_Call
UpdateTransferStatus is a helper method to define mock.On call
- ctx context.Context
- id string
- status relayer.TransferStatus
- destTxHash *string
- errMsg *string
type BridgeStore_GetChainState_Call ¶
BridgeStore_GetChainState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChainState'
func (*BridgeStore_GetChainState_Call) Return ¶
func (_c *BridgeStore_GetChainState_Call) Return(_a0 *relayer.ChainState, _a1 error) *BridgeStore_GetChainState_Call
func (*BridgeStore_GetChainState_Call) Run ¶
func (_c *BridgeStore_GetChainState_Call) Run(run func(ctx context.Context, chainID string)) *BridgeStore_GetChainState_Call
func (*BridgeStore_GetChainState_Call) RunAndReturn ¶
func (_c *BridgeStore_GetChainState_Call) RunAndReturn(run func(context.Context, string) (*relayer.ChainState, error)) *BridgeStore_GetChainState_Call
type BridgeStore_GetPendingTransfers_Call ¶
BridgeStore_GetPendingTransfers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPendingTransfers'
func (*BridgeStore_GetPendingTransfers_Call) Return ¶
func (_c *BridgeStore_GetPendingTransfers_Call) Return(_a0 []*relayer.Transfer, _a1 error) *BridgeStore_GetPendingTransfers_Call
func (*BridgeStore_GetPendingTransfers_Call) Run ¶
func (_c *BridgeStore_GetPendingTransfers_Call) Run(run func(ctx context.Context, direction relayer.TransferDirection)) *BridgeStore_GetPendingTransfers_Call
func (*BridgeStore_GetPendingTransfers_Call) RunAndReturn ¶
func (_c *BridgeStore_GetPendingTransfers_Call) RunAndReturn(run func(context.Context, relayer.TransferDirection) ([]*relayer.Transfer, error)) *BridgeStore_GetPendingTransfers_Call
type BridgeStore_GetTransfer_Call ¶
BridgeStore_GetTransfer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTransfer'
func (*BridgeStore_GetTransfer_Call) Return ¶
func (_c *BridgeStore_GetTransfer_Call) Return(_a0 *relayer.Transfer, _a1 error) *BridgeStore_GetTransfer_Call
func (*BridgeStore_GetTransfer_Call) Run ¶
func (_c *BridgeStore_GetTransfer_Call) Run(run func(ctx context.Context, id string)) *BridgeStore_GetTransfer_Call
func (*BridgeStore_GetTransfer_Call) RunAndReturn ¶
func (_c *BridgeStore_GetTransfer_Call) RunAndReturn(run func(context.Context, string) (*relayer.Transfer, error)) *BridgeStore_GetTransfer_Call
type BridgeStore_IncrementRetryCount_Call ¶
BridgeStore_IncrementRetryCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IncrementRetryCount'
func (*BridgeStore_IncrementRetryCount_Call) Return ¶
func (_c *BridgeStore_IncrementRetryCount_Call) Return(_a0 error) *BridgeStore_IncrementRetryCount_Call
func (*BridgeStore_IncrementRetryCount_Call) Run ¶
func (_c *BridgeStore_IncrementRetryCount_Call) Run(run func(ctx context.Context, id string)) *BridgeStore_IncrementRetryCount_Call
func (*BridgeStore_IncrementRetryCount_Call) RunAndReturn ¶
func (_c *BridgeStore_IncrementRetryCount_Call) RunAndReturn(run func(context.Context, string) error) *BridgeStore_IncrementRetryCount_Call
type BridgeStore_ListTransfers_Call ¶
BridgeStore_ListTransfers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTransfers'
func (*BridgeStore_ListTransfers_Call) Return ¶
func (_c *BridgeStore_ListTransfers_Call) Return(_a0 []*relayer.Transfer, _a1 error) *BridgeStore_ListTransfers_Call
func (*BridgeStore_ListTransfers_Call) Run ¶
func (_c *BridgeStore_ListTransfers_Call) Run(run func(ctx context.Context, limit int)) *BridgeStore_ListTransfers_Call
func (*BridgeStore_ListTransfers_Call) RunAndReturn ¶
func (_c *BridgeStore_ListTransfers_Call) RunAndReturn(run func(context.Context, int) ([]*relayer.Transfer, error)) *BridgeStore_ListTransfers_Call
type BridgeStore_SetChainState_Call ¶
BridgeStore_SetChainState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetChainState'
func (*BridgeStore_SetChainState_Call) Return ¶
func (_c *BridgeStore_SetChainState_Call) Return(_a0 error) *BridgeStore_SetChainState_Call
func (*BridgeStore_SetChainState_Call) Run ¶
func (_c *BridgeStore_SetChainState_Call) Run(run func(ctx context.Context, chainID string, blockNumber uint64, offset string)) *BridgeStore_SetChainState_Call
func (*BridgeStore_SetChainState_Call) RunAndReturn ¶
func (_c *BridgeStore_SetChainState_Call) RunAndReturn(run func(context.Context, string, uint64, string) error) *BridgeStore_SetChainState_Call
type BridgeStore_UpdateTransferStatus_Call ¶
BridgeStore_UpdateTransferStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTransferStatus'
func (*BridgeStore_UpdateTransferStatus_Call) Return ¶
func (_c *BridgeStore_UpdateTransferStatus_Call) Return(_a0 error) *BridgeStore_UpdateTransferStatus_Call
func (*BridgeStore_UpdateTransferStatus_Call) Run ¶
func (_c *BridgeStore_UpdateTransferStatus_Call) Run(run func(ctx context.Context, id string, status relayer.TransferStatus, destTxHash *string, errMsg *string)) *BridgeStore_UpdateTransferStatus_Call
func (*BridgeStore_UpdateTransferStatus_Call) RunAndReturn ¶
func (_c *BridgeStore_UpdateTransferStatus_Call) RunAndReturn(run func(context.Context, string, relayer.TransferStatus, *string, *string) error) *BridgeStore_UpdateTransferStatus_Call
type CantonBridge ¶
CantonBridge is an autogenerated mock type for the CantonBridgeClient type
func NewCantonBridge ¶
func NewCantonBridge(t interface {
mock.TestingT
Cleanup(func())
}) *CantonBridge
NewCantonBridge creates a new instance of CantonBridge. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*CantonBridge) CompleteWithdrawal ¶
func (_m *CantonBridge) CompleteWithdrawal(ctx context.Context, req bridge.CompleteWithdrawalRequest) error
CompleteWithdrawal provides a mock function with given fields: ctx, req
func (*CantonBridge) CreatePendingDeposit ¶
func (_m *CantonBridge) CreatePendingDeposit(ctx context.Context, req bridge.CreatePendingDepositRequest) (*bridge.PendingDeposit, error)
CreatePendingDeposit provides a mock function with given fields: ctx, req
func (*CantonBridge) EXPECT ¶
func (_m *CantonBridge) EXPECT() *CantonBridge_Expecter
func (*CantonBridge) GetLatestLedgerOffset ¶
func (_m *CantonBridge) GetLatestLedgerOffset(ctx context.Context) (int64, error)
GetLatestLedgerOffset provides a mock function with given fields: ctx
func (*CantonBridge) GetWayfinderBridgeConfigCID ¶
func (_m *CantonBridge) GetWayfinderBridgeConfigCID(ctx context.Context) (string, error)
GetWayfinderBridgeConfigCID provides a mock function with given fields: ctx
func (*CantonBridge) InitiateWithdrawal ¶
func (_m *CantonBridge) InitiateWithdrawal(ctx context.Context, req bridge.InitiateWithdrawalRequest) (string, error)
InitiateWithdrawal provides a mock function with given fields: ctx, req
func (*CantonBridge) IsDepositProcessed ¶
IsDepositProcessed provides a mock function with given fields: ctx, evmTxHash
func (*CantonBridge) ProcessDepositAndMint ¶
func (_m *CantonBridge) ProcessDepositAndMint(ctx context.Context, req bridge.ProcessDepositRequest) (*bridge.ProcessedDeposit, error)
ProcessDepositAndMint provides a mock function with given fields: ctx, req
func (*CantonBridge) ProcessWithdrawal ¶
func (_m *CantonBridge) ProcessWithdrawal(ctx context.Context, withdrawalRequestCID string) (string, error)
ProcessWithdrawal provides a mock function with given fields: ctx, withdrawalRequestCID
func (*CantonBridge) StreamWithdrawalEvents ¶
func (_m *CantonBridge) StreamWithdrawalEvents(ctx context.Context, offset string) <-chan *bridge.WithdrawalEvent
StreamWithdrawalEvents provides a mock function with given fields: ctx, offset
type CantonBridge_CompleteWithdrawal_Call ¶
CantonBridge_CompleteWithdrawal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CompleteWithdrawal'
func (*CantonBridge_CompleteWithdrawal_Call) Return ¶
func (_c *CantonBridge_CompleteWithdrawal_Call) Return(_a0 error) *CantonBridge_CompleteWithdrawal_Call
func (*CantonBridge_CompleteWithdrawal_Call) Run ¶
func (_c *CantonBridge_CompleteWithdrawal_Call) Run(run func(ctx context.Context, req bridge.CompleteWithdrawalRequest)) *CantonBridge_CompleteWithdrawal_Call
func (*CantonBridge_CompleteWithdrawal_Call) RunAndReturn ¶
func (_c *CantonBridge_CompleteWithdrawal_Call) RunAndReturn(run func(context.Context, bridge.CompleteWithdrawalRequest) error) *CantonBridge_CompleteWithdrawal_Call
type CantonBridge_CreatePendingDeposit_Call ¶
CantonBridge_CreatePendingDeposit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreatePendingDeposit'
func (*CantonBridge_CreatePendingDeposit_Call) Return ¶
func (_c *CantonBridge_CreatePendingDeposit_Call) Return(_a0 *bridge.PendingDeposit, _a1 error) *CantonBridge_CreatePendingDeposit_Call
func (*CantonBridge_CreatePendingDeposit_Call) Run ¶
func (_c *CantonBridge_CreatePendingDeposit_Call) Run(run func(ctx context.Context, req bridge.CreatePendingDepositRequest)) *CantonBridge_CreatePendingDeposit_Call
func (*CantonBridge_CreatePendingDeposit_Call) RunAndReturn ¶
func (_c *CantonBridge_CreatePendingDeposit_Call) RunAndReturn(run func(context.Context, bridge.CreatePendingDepositRequest) (*bridge.PendingDeposit, error)) *CantonBridge_CreatePendingDeposit_Call
type CantonBridge_Expecter ¶
type CantonBridge_Expecter struct {
// contains filtered or unexported fields
}
func (*CantonBridge_Expecter) CompleteWithdrawal ¶
func (_e *CantonBridge_Expecter) CompleteWithdrawal(ctx interface{}, req interface{}) *CantonBridge_CompleteWithdrawal_Call
CompleteWithdrawal is a helper method to define mock.On call
- ctx context.Context
- req bridge.CompleteWithdrawalRequest
func (*CantonBridge_Expecter) CreatePendingDeposit ¶
func (_e *CantonBridge_Expecter) CreatePendingDeposit(ctx interface{}, req interface{}) *CantonBridge_CreatePendingDeposit_Call
CreatePendingDeposit is a helper method to define mock.On call
- ctx context.Context
- req bridge.CreatePendingDepositRequest
func (*CantonBridge_Expecter) GetLatestLedgerOffset ¶
func (_e *CantonBridge_Expecter) GetLatestLedgerOffset(ctx interface{}) *CantonBridge_GetLatestLedgerOffset_Call
GetLatestLedgerOffset is a helper method to define mock.On call
- ctx context.Context
func (*CantonBridge_Expecter) GetWayfinderBridgeConfigCID ¶
func (_e *CantonBridge_Expecter) GetWayfinderBridgeConfigCID(ctx interface{}) *CantonBridge_GetWayfinderBridgeConfigCID_Call
GetWayfinderBridgeConfigCID is a helper method to define mock.On call
- ctx context.Context
func (*CantonBridge_Expecter) InitiateWithdrawal ¶
func (_e *CantonBridge_Expecter) InitiateWithdrawal(ctx interface{}, req interface{}) *CantonBridge_InitiateWithdrawal_Call
InitiateWithdrawal is a helper method to define mock.On call
- ctx context.Context
- req bridge.InitiateWithdrawalRequest
func (*CantonBridge_Expecter) IsDepositProcessed ¶
func (_e *CantonBridge_Expecter) IsDepositProcessed(ctx interface{}, evmTxHash interface{}) *CantonBridge_IsDepositProcessed_Call
IsDepositProcessed is a helper method to define mock.On call
- ctx context.Context
- evmTxHash string
func (*CantonBridge_Expecter) ProcessDepositAndMint ¶
func (_e *CantonBridge_Expecter) ProcessDepositAndMint(ctx interface{}, req interface{}) *CantonBridge_ProcessDepositAndMint_Call
ProcessDepositAndMint is a helper method to define mock.On call
- ctx context.Context
- req bridge.ProcessDepositRequest
func (*CantonBridge_Expecter) ProcessWithdrawal ¶
func (_e *CantonBridge_Expecter) ProcessWithdrawal(ctx interface{}, withdrawalRequestCID interface{}) *CantonBridge_ProcessWithdrawal_Call
ProcessWithdrawal is a helper method to define mock.On call
- ctx context.Context
- withdrawalRequestCID string
func (*CantonBridge_Expecter) StreamWithdrawalEvents ¶
func (_e *CantonBridge_Expecter) StreamWithdrawalEvents(ctx interface{}, offset interface{}) *CantonBridge_StreamWithdrawalEvents_Call
StreamWithdrawalEvents is a helper method to define mock.On call
- ctx context.Context
- offset string
type CantonBridge_GetLatestLedgerOffset_Call ¶
CantonBridge_GetLatestLedgerOffset_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestLedgerOffset'
func (*CantonBridge_GetLatestLedgerOffset_Call) Return ¶
func (_c *CantonBridge_GetLatestLedgerOffset_Call) Return(_a0 int64, _a1 error) *CantonBridge_GetLatestLedgerOffset_Call
func (*CantonBridge_GetLatestLedgerOffset_Call) Run ¶
func (_c *CantonBridge_GetLatestLedgerOffset_Call) Run(run func(ctx context.Context)) *CantonBridge_GetLatestLedgerOffset_Call
func (*CantonBridge_GetLatestLedgerOffset_Call) RunAndReturn ¶
func (_c *CantonBridge_GetLatestLedgerOffset_Call) RunAndReturn(run func(context.Context) (int64, error)) *CantonBridge_GetLatestLedgerOffset_Call
type CantonBridge_GetWayfinderBridgeConfigCID_Call ¶
CantonBridge_GetWayfinderBridgeConfigCID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWayfinderBridgeConfigCID'
func (*CantonBridge_GetWayfinderBridgeConfigCID_Call) Return ¶
func (_c *CantonBridge_GetWayfinderBridgeConfigCID_Call) Return(_a0 string, _a1 error) *CantonBridge_GetWayfinderBridgeConfigCID_Call
func (*CantonBridge_GetWayfinderBridgeConfigCID_Call) Run ¶
func (_c *CantonBridge_GetWayfinderBridgeConfigCID_Call) Run(run func(ctx context.Context)) *CantonBridge_GetWayfinderBridgeConfigCID_Call
func (*CantonBridge_GetWayfinderBridgeConfigCID_Call) RunAndReturn ¶
func (_c *CantonBridge_GetWayfinderBridgeConfigCID_Call) RunAndReturn(run func(context.Context) (string, error)) *CantonBridge_GetWayfinderBridgeConfigCID_Call
type CantonBridge_InitiateWithdrawal_Call ¶
CantonBridge_InitiateWithdrawal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InitiateWithdrawal'
func (*CantonBridge_InitiateWithdrawal_Call) Return ¶
func (_c *CantonBridge_InitiateWithdrawal_Call) Return(_a0 string, _a1 error) *CantonBridge_InitiateWithdrawal_Call
func (*CantonBridge_InitiateWithdrawal_Call) Run ¶
func (_c *CantonBridge_InitiateWithdrawal_Call) Run(run func(ctx context.Context, req bridge.InitiateWithdrawalRequest)) *CantonBridge_InitiateWithdrawal_Call
func (*CantonBridge_InitiateWithdrawal_Call) RunAndReturn ¶
func (_c *CantonBridge_InitiateWithdrawal_Call) RunAndReturn(run func(context.Context, bridge.InitiateWithdrawalRequest) (string, error)) *CantonBridge_InitiateWithdrawal_Call
type CantonBridge_IsDepositProcessed_Call ¶
CantonBridge_IsDepositProcessed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsDepositProcessed'
func (*CantonBridge_IsDepositProcessed_Call) Return ¶
func (_c *CantonBridge_IsDepositProcessed_Call) Return(_a0 bool, _a1 error) *CantonBridge_IsDepositProcessed_Call
func (*CantonBridge_IsDepositProcessed_Call) Run ¶
func (_c *CantonBridge_IsDepositProcessed_Call) Run(run func(ctx context.Context, evmTxHash string)) *CantonBridge_IsDepositProcessed_Call
func (*CantonBridge_IsDepositProcessed_Call) RunAndReturn ¶
func (_c *CantonBridge_IsDepositProcessed_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *CantonBridge_IsDepositProcessed_Call
type CantonBridge_ProcessDepositAndMint_Call ¶
CantonBridge_ProcessDepositAndMint_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessDepositAndMint'
func (*CantonBridge_ProcessDepositAndMint_Call) Return ¶
func (_c *CantonBridge_ProcessDepositAndMint_Call) Return(_a0 *bridge.ProcessedDeposit, _a1 error) *CantonBridge_ProcessDepositAndMint_Call
func (*CantonBridge_ProcessDepositAndMint_Call) Run ¶
func (_c *CantonBridge_ProcessDepositAndMint_Call) Run(run func(ctx context.Context, req bridge.ProcessDepositRequest)) *CantonBridge_ProcessDepositAndMint_Call
func (*CantonBridge_ProcessDepositAndMint_Call) RunAndReturn ¶
func (_c *CantonBridge_ProcessDepositAndMint_Call) RunAndReturn(run func(context.Context, bridge.ProcessDepositRequest) (*bridge.ProcessedDeposit, error)) *CantonBridge_ProcessDepositAndMint_Call
type CantonBridge_ProcessWithdrawal_Call ¶
CantonBridge_ProcessWithdrawal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessWithdrawal'
func (*CantonBridge_ProcessWithdrawal_Call) Return ¶
func (_c *CantonBridge_ProcessWithdrawal_Call) Return(_a0 string, _a1 error) *CantonBridge_ProcessWithdrawal_Call
func (*CantonBridge_ProcessWithdrawal_Call) Run ¶
func (_c *CantonBridge_ProcessWithdrawal_Call) Run(run func(ctx context.Context, withdrawalRequestCID string)) *CantonBridge_ProcessWithdrawal_Call
func (*CantonBridge_ProcessWithdrawal_Call) RunAndReturn ¶
func (_c *CantonBridge_ProcessWithdrawal_Call) RunAndReturn(run func(context.Context, string) (string, error)) *CantonBridge_ProcessWithdrawal_Call
type CantonBridge_StreamWithdrawalEvents_Call ¶
CantonBridge_StreamWithdrawalEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamWithdrawalEvents'
func (*CantonBridge_StreamWithdrawalEvents_Call) Return ¶
func (_c *CantonBridge_StreamWithdrawalEvents_Call) Return(_a0 <-chan *bridge.WithdrawalEvent) *CantonBridge_StreamWithdrawalEvents_Call
func (*CantonBridge_StreamWithdrawalEvents_Call) Run ¶
func (_c *CantonBridge_StreamWithdrawalEvents_Call) Run(run func(ctx context.Context, offset string)) *CantonBridge_StreamWithdrawalEvents_Call
func (*CantonBridge_StreamWithdrawalEvents_Call) RunAndReturn ¶
func (_c *CantonBridge_StreamWithdrawalEvents_Call) RunAndReturn(run func(context.Context, string) <-chan *bridge.WithdrawalEvent) *CantonBridge_StreamWithdrawalEvents_Call
type Destination ¶
Destination is an autogenerated mock type for the Destination type
func NewDestination ¶
func NewDestination(t interface {
mock.TestingT
Cleanup(func())
}) *Destination
NewDestination creates a new instance of Destination. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Destination) EXPECT ¶
func (_m *Destination) EXPECT() *Destination_Expecter
func (*Destination) GetChainID ¶
func (_m *Destination) GetChainID() string
GetChainID provides a mock function with no fields
func (*Destination) SubmitTransfer ¶
func (_m *Destination) SubmitTransfer(ctx context.Context, event *relayer.Event) (string, bool, error)
SubmitTransfer provides a mock function with given fields: ctx, event
type Destination_Expecter ¶
type Destination_Expecter struct {
// contains filtered or unexported fields
}
func (*Destination_Expecter) GetChainID ¶
func (_e *Destination_Expecter) GetChainID() *Destination_GetChainID_Call
GetChainID is a helper method to define mock.On call
func (*Destination_Expecter) SubmitTransfer ¶
func (_e *Destination_Expecter) SubmitTransfer(ctx interface{}, event interface{}) *Destination_SubmitTransfer_Call
SubmitTransfer is a helper method to define mock.On call
- ctx context.Context
- event *relayer.Event
type Destination_GetChainID_Call ¶
Destination_GetChainID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChainID'
func (*Destination_GetChainID_Call) Return ¶
func (_c *Destination_GetChainID_Call) Return(_a0 string) *Destination_GetChainID_Call
func (*Destination_GetChainID_Call) Run ¶
func (_c *Destination_GetChainID_Call) Run(run func()) *Destination_GetChainID_Call
func (*Destination_GetChainID_Call) RunAndReturn ¶
func (_c *Destination_GetChainID_Call) RunAndReturn(run func() string) *Destination_GetChainID_Call
type Destination_SubmitTransfer_Call ¶
Destination_SubmitTransfer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubmitTransfer'
func (*Destination_SubmitTransfer_Call) Return ¶
func (_c *Destination_SubmitTransfer_Call) Return(destTxHash string, skipped bool, err error) *Destination_SubmitTransfer_Call
func (*Destination_SubmitTransfer_Call) Run ¶
func (_c *Destination_SubmitTransfer_Call) Run(run func(ctx context.Context, event *relayer.Event)) *Destination_SubmitTransfer_Call
func (*Destination_SubmitTransfer_Call) RunAndReturn ¶
func (_c *Destination_SubmitTransfer_Call) RunAndReturn(run func(context.Context, *relayer.Event) (string, bool, error)) *Destination_SubmitTransfer_Call
type EthereumBridgeClient ¶
EthereumBridgeClient is an autogenerated mock type for the EthereumBridgeClient type
func NewEthereumBridgeClient ¶
func NewEthereumBridgeClient(t interface {
mock.TestingT
Cleanup(func())
}) *EthereumBridgeClient
NewEthereumBridgeClient creates a new instance of EthereumBridgeClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*EthereumBridgeClient) EXPECT ¶
func (_m *EthereumBridgeClient) EXPECT() *EthereumBridgeClient_Expecter
func (*EthereumBridgeClient) GetLastScannedBlock ¶
func (_m *EthereumBridgeClient) GetLastScannedBlock() uint64
GetLastScannedBlock provides a mock function with no fields
func (*EthereumBridgeClient) GetLatestBlockNumber ¶
func (_m *EthereumBridgeClient) GetLatestBlockNumber(ctx context.Context) (uint64, error)
GetLatestBlockNumber provides a mock function with given fields: ctx
func (*EthereumBridgeClient) IsWithdrawalProcessed ¶
func (_m *EthereumBridgeClient) IsWithdrawalProcessed(ctx context.Context, cantonTxHash [32]byte) (bool, error)
IsWithdrawalProcessed provides a mock function with given fields: ctx, cantonTxHash
func (*EthereumBridgeClient) WatchDepositEvents ¶
func (_m *EthereumBridgeClient) WatchDepositEvents(ctx context.Context, fromBlock uint64, handler func(*ethereum.DepositEvent) error) error
WatchDepositEvents provides a mock function with given fields: ctx, fromBlock, handler
func (*EthereumBridgeClient) WithdrawFromCanton ¶
func (_m *EthereumBridgeClient) WithdrawFromCanton(ctx context.Context, token common.Address, recipient common.Address, amount *big.Int, nonce *big.Int, cantonTxHash [32]byte) (common.Hash, error)
WithdrawFromCanton provides a mock function with given fields: ctx, token, recipient, amount, nonce, cantonTxHash
type EthereumBridgeClient_Expecter ¶
type EthereumBridgeClient_Expecter struct {
// contains filtered or unexported fields
}
func (*EthereumBridgeClient_Expecter) GetLastScannedBlock ¶
func (_e *EthereumBridgeClient_Expecter) GetLastScannedBlock() *EthereumBridgeClient_GetLastScannedBlock_Call
GetLastScannedBlock is a helper method to define mock.On call
func (*EthereumBridgeClient_Expecter) GetLatestBlockNumber ¶
func (_e *EthereumBridgeClient_Expecter) GetLatestBlockNumber(ctx interface{}) *EthereumBridgeClient_GetLatestBlockNumber_Call
GetLatestBlockNumber is a helper method to define mock.On call
- ctx context.Context
func (*EthereumBridgeClient_Expecter) IsWithdrawalProcessed ¶
func (_e *EthereumBridgeClient_Expecter) IsWithdrawalProcessed(ctx interface{}, cantonTxHash interface{}) *EthereumBridgeClient_IsWithdrawalProcessed_Call
IsWithdrawalProcessed is a helper method to define mock.On call
- ctx context.Context
- cantonTxHash [32]byte
func (*EthereumBridgeClient_Expecter) WatchDepositEvents ¶
func (_e *EthereumBridgeClient_Expecter) WatchDepositEvents(ctx interface{}, fromBlock interface{}, handler interface{}) *EthereumBridgeClient_WatchDepositEvents_Call
WatchDepositEvents is a helper method to define mock.On call
- ctx context.Context
- fromBlock uint64
- handler func(*ethereum.DepositEvent) error
func (*EthereumBridgeClient_Expecter) WithdrawFromCanton ¶
func (_e *EthereumBridgeClient_Expecter) WithdrawFromCanton(ctx interface{}, token interface{}, recipient interface{}, amount interface{}, nonce interface{}, cantonTxHash interface{}) *EthereumBridgeClient_WithdrawFromCanton_Call
WithdrawFromCanton is a helper method to define mock.On call
- ctx context.Context
- token common.Address
- recipient common.Address
- amount *big.Int
- nonce *big.Int
- cantonTxHash [32]byte
type EthereumBridgeClient_GetLastScannedBlock_Call ¶
EthereumBridgeClient_GetLastScannedBlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLastScannedBlock'
func (*EthereumBridgeClient_GetLastScannedBlock_Call) Return ¶
func (_c *EthereumBridgeClient_GetLastScannedBlock_Call) Return(_a0 uint64) *EthereumBridgeClient_GetLastScannedBlock_Call
func (*EthereumBridgeClient_GetLastScannedBlock_Call) Run ¶
func (_c *EthereumBridgeClient_GetLastScannedBlock_Call) Run(run func()) *EthereumBridgeClient_GetLastScannedBlock_Call
func (*EthereumBridgeClient_GetLastScannedBlock_Call) RunAndReturn ¶
func (_c *EthereumBridgeClient_GetLastScannedBlock_Call) RunAndReturn(run func() uint64) *EthereumBridgeClient_GetLastScannedBlock_Call
type EthereumBridgeClient_GetLatestBlockNumber_Call ¶
EthereumBridgeClient_GetLatestBlockNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestBlockNumber'
func (*EthereumBridgeClient_GetLatestBlockNumber_Call) Return ¶
func (_c *EthereumBridgeClient_GetLatestBlockNumber_Call) Return(_a0 uint64, _a1 error) *EthereumBridgeClient_GetLatestBlockNumber_Call
func (*EthereumBridgeClient_GetLatestBlockNumber_Call) Run ¶
func (_c *EthereumBridgeClient_GetLatestBlockNumber_Call) Run(run func(ctx context.Context)) *EthereumBridgeClient_GetLatestBlockNumber_Call
func (*EthereumBridgeClient_GetLatestBlockNumber_Call) RunAndReturn ¶
func (_c *EthereumBridgeClient_GetLatestBlockNumber_Call) RunAndReturn(run func(context.Context) (uint64, error)) *EthereumBridgeClient_GetLatestBlockNumber_Call
type EthereumBridgeClient_IsWithdrawalProcessed_Call ¶
EthereumBridgeClient_IsWithdrawalProcessed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsWithdrawalProcessed'
func (*EthereumBridgeClient_IsWithdrawalProcessed_Call) Return ¶
func (_c *EthereumBridgeClient_IsWithdrawalProcessed_Call) Return(_a0 bool, _a1 error) *EthereumBridgeClient_IsWithdrawalProcessed_Call
func (*EthereumBridgeClient_IsWithdrawalProcessed_Call) Run ¶
func (_c *EthereumBridgeClient_IsWithdrawalProcessed_Call) Run(run func(ctx context.Context, cantonTxHash [32]byte)) *EthereumBridgeClient_IsWithdrawalProcessed_Call
func (*EthereumBridgeClient_IsWithdrawalProcessed_Call) RunAndReturn ¶
func (_c *EthereumBridgeClient_IsWithdrawalProcessed_Call) RunAndReturn(run func(context.Context, [32]byte) (bool, error)) *EthereumBridgeClient_IsWithdrawalProcessed_Call
type EthereumBridgeClient_WatchDepositEvents_Call ¶
EthereumBridgeClient_WatchDepositEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WatchDepositEvents'
func (*EthereumBridgeClient_WatchDepositEvents_Call) Return ¶
func (_c *EthereumBridgeClient_WatchDepositEvents_Call) Return(_a0 error) *EthereumBridgeClient_WatchDepositEvents_Call
func (*EthereumBridgeClient_WatchDepositEvents_Call) Run ¶
func (_c *EthereumBridgeClient_WatchDepositEvents_Call) Run(run func(ctx context.Context, fromBlock uint64, handler func(*ethereum.DepositEvent) error)) *EthereumBridgeClient_WatchDepositEvents_Call
func (*EthereumBridgeClient_WatchDepositEvents_Call) RunAndReturn ¶
func (_c *EthereumBridgeClient_WatchDepositEvents_Call) RunAndReturn(run func(context.Context, uint64, func(*ethereum.DepositEvent) error) error) *EthereumBridgeClient_WatchDepositEvents_Call
type EthereumBridgeClient_WithdrawFromCanton_Call ¶
EthereumBridgeClient_WithdrawFromCanton_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithdrawFromCanton'
func (*EthereumBridgeClient_WithdrawFromCanton_Call) Return ¶
func (_c *EthereumBridgeClient_WithdrawFromCanton_Call) Return(_a0 common.Hash, _a1 error) *EthereumBridgeClient_WithdrawFromCanton_Call
type Source ¶
Source is an autogenerated mock type for the Source type
func NewSource ¶
NewSource creates a new instance of Source. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Source) EXPECT ¶
func (_m *Source) EXPECT() *Source_Expecter
func (*Source) ExtractOffset ¶
ExtractOffset provides a mock function with given fields: event
func (*Source) GetChainID ¶
GetChainID provides a mock function with no fields
type Source_Expecter ¶
type Source_Expecter struct {
// contains filtered or unexported fields
}
func (*Source_Expecter) ExtractOffset ¶
func (_e *Source_Expecter) ExtractOffset(event interface{}) *Source_ExtractOffset_Call
ExtractOffset is a helper method to define mock.On call
- event *relayer.Event
func (*Source_Expecter) GetChainID ¶
func (_e *Source_Expecter) GetChainID() *Source_GetChainID_Call
GetChainID is a helper method to define mock.On call
func (*Source_Expecter) StreamEvents ¶
func (_e *Source_Expecter) StreamEvents(ctx interface{}, offset interface{}) *Source_StreamEvents_Call
StreamEvents is a helper method to define mock.On call
- ctx context.Context
- offset string
type Source_ExtractOffset_Call ¶
Source_ExtractOffset_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExtractOffset'
func (*Source_ExtractOffset_Call) Return ¶
func (_c *Source_ExtractOffset_Call) Return(_a0 string) *Source_ExtractOffset_Call
func (*Source_ExtractOffset_Call) Run ¶
func (_c *Source_ExtractOffset_Call) Run(run func(event *relayer.Event)) *Source_ExtractOffset_Call
func (*Source_ExtractOffset_Call) RunAndReturn ¶
func (_c *Source_ExtractOffset_Call) RunAndReturn(run func(*relayer.Event) string) *Source_ExtractOffset_Call
type Source_GetChainID_Call ¶
Source_GetChainID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChainID'
func (*Source_GetChainID_Call) Return ¶
func (_c *Source_GetChainID_Call) Return(_a0 string) *Source_GetChainID_Call
func (*Source_GetChainID_Call) Run ¶
func (_c *Source_GetChainID_Call) Run(run func()) *Source_GetChainID_Call
func (*Source_GetChainID_Call) RunAndReturn ¶
func (_c *Source_GetChainID_Call) RunAndReturn(run func() string) *Source_GetChainID_Call
type Source_StreamEvents_Call ¶
Source_StreamEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamEvents'
func (*Source_StreamEvents_Call) Return ¶
func (_c *Source_StreamEvents_Call) Return(_a0 <-chan *relayer.Event, _a1 <-chan error) *Source_StreamEvents_Call
func (*Source_StreamEvents_Call) Run ¶
func (_c *Source_StreamEvents_Call) Run(run func(ctx context.Context, offset string)) *Source_StreamEvents_Call
func (*Source_StreamEvents_Call) RunAndReturn ¶
func (_c *Source_StreamEvents_Call) RunAndReturn(run func(context.Context, string) (<-chan *relayer.Event, <-chan error)) *Source_StreamEvents_Call