Documentation ¶
Index ¶
- Variables
- type MockEthClient
- func (client *MockEthClient) AssertBalanceAtCalled(ctx context.Context, account common.Address, blockNumber *big.Int)
- func (client *MockEthClient) AssertBatchCalledWith(method string)
- func (client *MockEthClient) AssertBlockByNumberCalledWith(ctx context.Context, number *big.Int)
- func (client *MockEthClient) AssertCallContractCalledWith(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int)
- func (client *MockEthClient) AssertFilterLogsCalledWith(ctx context.Context, q ethereum.FilterQuery)
- func (client *MockEthClient) AssertHeaderByNumberCalledWith(ctx context.Context, number *big.Int)
- func (client *MockEthClient) AssertHeaderByNumbersCalledWith(number []*big.Int)
- func (client *MockEthClient) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
- func (client *MockEthClient) BatchCall(batch []client.BatchElem) error
- func (client *MockEthClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
- func (client *MockEthClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
- func (client *MockEthClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)
- func (client *MockEthClient) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
- func (client *MockEthClient) HeaderByNumbers(numbers []*big.Int) ([]*types.Header, error)
- func (client *MockEthClient) SetBalanceAt(balance *big.Int)
- func (client *MockEthClient) SetBalanceAtErr(err error)
- func (client *MockEthClient) SetBlockByNumberErr(err error)
- func (client *MockEthClient) SetBlockByNumberReturnBlock(block *types.Block)
- func (client *MockEthClient) SetCallContractErr(err error)
- func (client *MockEthClient) SetCallContractReturnBytes(returnBytes []byte)
- func (client *MockEthClient) SetFilterLogsErr(err error)
- func (client *MockEthClient) SetFilterLogsReturnLogs(logs []types.Log)
- func (client *MockEthClient) SetHeaderByNumberErr(err error)
- func (client *MockEthClient) SetHeaderByNumberReturnHeader(header *types.Header)
- func (client *MockEthClient) SetHeaderByNumbersReturnHeader(headers []*types.Header)
- func (client *MockEthClient) SetTransactionReceiptErr(err error)
- func (client *MockEthClient) SetTransactionReceipts(receipts []*types.Receipt)
- func (client *MockEthClient) SetTransactionSenderErr(err error)
- func (client *MockEthClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
- func (client *MockEthClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)
- type MockFetcher
- func (fetcher *MockFetcher) GetHeaderByNumber(blockNumber int64) (core.Header, error)
- func (fetcher *MockFetcher) GetHeadersByNumbers(blockNumbers []int64) ([]core.Header, error)
- func (fetcher *MockFetcher) LastBlock() (*big.Int, error)
- func (fetcher *MockFetcher) Node() core.Node
- func (fetcher *MockFetcher) SetLastBlock(blockNumber *big.Int)
- type MockHeaderRepository
- func (repository *MockHeaderRepository) AssertCreateOrUpdateHeaderCallCountAndPassedBlockNumbers(times int, blockNumbers []int64)
- func (repository *MockHeaderRepository) CreateOrUpdateHeader(header core.Header) (int64, error)
- func (repository *MockHeaderRepository) GetHeader(blockNumber int64) (core.Header, error)
- func (repository *MockHeaderRepository) MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64, nodeID string) ([]int64, error)
- func (repository *MockHeaderRepository) SetCreateOrUpdateHeaderReturnErr(err error)
- func (repository *MockHeaderRepository) SetCreateOrUpdateHeaderReturnID(id int64)
- func (repository *MockHeaderRepository) SetGetHeaderError(err error)
- func (repository *MockHeaderRepository) SetGetHeaderReturnBlockHash(hash string)
- func (repository *MockHeaderRepository) SetMissingBlockNumbers(blockNumbers []int64)
- type MockRPCClient
- func (client *MockRPCClient) AssertBatchCalledWith(method string, lengthOfBatch int)
- func (client *MockRPCClient) AssertCallContextCalledWith(ctx context.Context, result interface{}, method string)
- func (client *MockRPCClient) AssertSubscribeCalledWith(namespace string, payloadChan interface{}, args []interface{})
- func (client *MockRPCClient) BatchCall(batch []client.BatchElem) error
- func (client *MockRPCClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
- func (client *MockRPCClient) RPCPath() string
- func (client *MockRPCClient) SetCallContextErr(err error)
- func (client *MockRPCClient) SetRPCPath(rpcPath string)
- func (client *MockRPCClient) SetReturnPOAHeader(header core.POAHeader)
- func (client *MockRPCClient) SetReturnPOAHeaders(headers []core.POAHeader)
- func (client *MockRPCClient) SetReturnPOWHeaders(headers []*types.Header)
- func (client *MockRPCClient) SetSupporedModules(supportedModules map[string]string)
- func (client *MockRPCClient) Subscribe(namespace string, payloadChan interface{}, args ...interface{}) (*rpc.ClientSubscription, error)
- func (client *MockRPCClient) SupportedModules() (map[string]string, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( FakeError = errors.New("failed") FakeHash = common.BytesToHash([]byte{1, 2, 3, 4, 5}) )
Functions ¶
This section is empty.
Types ¶
type MockEthClient ¶
type MockEthClient struct {
// contains filtered or unexported fields
}
func NewMockEthClient ¶
func NewMockEthClient() *MockEthClient
func (*MockEthClient) AssertBalanceAtCalled ¶
func (*MockEthClient) AssertBatchCalledWith ¶
func (client *MockEthClient) AssertBatchCalledWith(method string)
func (*MockEthClient) AssertBlockByNumberCalledWith ¶
func (client *MockEthClient) AssertBlockByNumberCalledWith(ctx context.Context, number *big.Int)
func (*MockEthClient) AssertCallContractCalledWith ¶
func (client *MockEthClient) AssertCallContractCalledWith(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int)
func (*MockEthClient) AssertFilterLogsCalledWith ¶
func (client *MockEthClient) AssertFilterLogsCalledWith(ctx context.Context, q ethereum.FilterQuery)
func (*MockEthClient) AssertHeaderByNumberCalledWith ¶
func (client *MockEthClient) AssertHeaderByNumberCalledWith(ctx context.Context, number *big.Int)
func (*MockEthClient) AssertHeaderByNumbersCalledWith ¶
func (client *MockEthClient) AssertHeaderByNumbersCalledWith(number []*big.Int)
func (*MockEthClient) BatchCall ¶
func (client *MockEthClient) BatchCall(batch []client.BatchElem) error
func (*MockEthClient) BlockByNumber ¶
func (*MockEthClient) CallContract ¶
func (*MockEthClient) FilterLogs ¶
func (*MockEthClient) HeaderByNumber ¶
func (*MockEthClient) HeaderByNumbers ¶
func (*MockEthClient) SetBalanceAt ¶
func (client *MockEthClient) SetBalanceAt(balance *big.Int)
func (*MockEthClient) SetBalanceAtErr ¶
func (client *MockEthClient) SetBalanceAtErr(err error)
func (*MockEthClient) SetBlockByNumberErr ¶
func (client *MockEthClient) SetBlockByNumberErr(err error)
func (*MockEthClient) SetBlockByNumberReturnBlock ¶
func (client *MockEthClient) SetBlockByNumberReturnBlock(block *types.Block)
func (*MockEthClient) SetCallContractErr ¶
func (client *MockEthClient) SetCallContractErr(err error)
func (*MockEthClient) SetCallContractReturnBytes ¶
func (client *MockEthClient) SetCallContractReturnBytes(returnBytes []byte)
func (*MockEthClient) SetFilterLogsErr ¶
func (client *MockEthClient) SetFilterLogsErr(err error)
func (*MockEthClient) SetFilterLogsReturnLogs ¶
func (client *MockEthClient) SetFilterLogsReturnLogs(logs []types.Log)
func (*MockEthClient) SetHeaderByNumberErr ¶
func (client *MockEthClient) SetHeaderByNumberErr(err error)
func (*MockEthClient) SetHeaderByNumberReturnHeader ¶
func (client *MockEthClient) SetHeaderByNumberReturnHeader(header *types.Header)
func (*MockEthClient) SetHeaderByNumbersReturnHeader ¶
func (client *MockEthClient) SetHeaderByNumbersReturnHeader(headers []*types.Header)
func (*MockEthClient) SetTransactionReceiptErr ¶
func (client *MockEthClient) SetTransactionReceiptErr(err error)
func (*MockEthClient) SetTransactionReceipts ¶
func (client *MockEthClient) SetTransactionReceipts(receipts []*types.Receipt)
func (*MockEthClient) SetTransactionSenderErr ¶
func (client *MockEthClient) SetTransactionSenderErr(err error)
func (*MockEthClient) TransactionReceipt ¶
func (*MockEthClient) TransactionSender ¶
type MockFetcher ¶ added in v0.1.0
type MockFetcher struct {
// contains filtered or unexported fields
}
func NewMockFetcher ¶ added in v0.1.0
func NewMockFetcher() *MockFetcher
func (*MockFetcher) GetHeaderByNumber ¶ added in v0.1.0
func (fetcher *MockFetcher) GetHeaderByNumber(blockNumber int64) (core.Header, error)
func (*MockFetcher) GetHeadersByNumbers ¶ added in v0.1.0
func (fetcher *MockFetcher) GetHeadersByNumbers(blockNumbers []int64) ([]core.Header, error)
func (*MockFetcher) LastBlock ¶ added in v0.1.0
func (fetcher *MockFetcher) LastBlock() (*big.Int, error)
func (*MockFetcher) Node ¶ added in v0.1.0
func (fetcher *MockFetcher) Node() core.Node
func (*MockFetcher) SetLastBlock ¶ added in v0.1.0
func (fetcher *MockFetcher) SetLastBlock(blockNumber *big.Int)
type MockHeaderRepository ¶
type MockHeaderRepository struct { CreateTransactionsCalled bool CreateTransactionsError error GetHeaderPassedBlockNumber int64 // contains filtered or unexported fields }
func NewMockHeaderRepository ¶
func NewMockHeaderRepository() *MockHeaderRepository
func (*MockHeaderRepository) AssertCreateOrUpdateHeaderCallCountAndPassedBlockNumbers ¶
func (repository *MockHeaderRepository) AssertCreateOrUpdateHeaderCallCountAndPassedBlockNumbers(times int, blockNumbers []int64)
func (*MockHeaderRepository) CreateOrUpdateHeader ¶
func (repository *MockHeaderRepository) CreateOrUpdateHeader(header core.Header) (int64, error)
func (*MockHeaderRepository) GetHeader ¶
func (repository *MockHeaderRepository) GetHeader(blockNumber int64) (core.Header, error)
func (*MockHeaderRepository) MissingBlockNumbers ¶
func (repository *MockHeaderRepository) MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64, nodeID string) ([]int64, error)
func (*MockHeaderRepository) SetCreateOrUpdateHeaderReturnErr ¶
func (repository *MockHeaderRepository) SetCreateOrUpdateHeaderReturnErr(err error)
func (*MockHeaderRepository) SetCreateOrUpdateHeaderReturnID ¶
func (repository *MockHeaderRepository) SetCreateOrUpdateHeaderReturnID(id int64)
func (*MockHeaderRepository) SetGetHeaderError ¶
func (repository *MockHeaderRepository) SetGetHeaderError(err error)
func (*MockHeaderRepository) SetGetHeaderReturnBlockHash ¶
func (repository *MockHeaderRepository) SetGetHeaderReturnBlockHash(hash string)
func (*MockHeaderRepository) SetMissingBlockNumbers ¶
func (repository *MockHeaderRepository) SetMissingBlockNumbers(blockNumbers []int64)
type MockRPCClient ¶ added in v0.1.0
type MockRPCClient struct {
// contains filtered or unexported fields
}
func NewMockRPCClient ¶ added in v0.1.0
func NewMockRPCClient() *MockRPCClient
func (*MockRPCClient) AssertBatchCalledWith ¶ added in v0.1.0
func (client *MockRPCClient) AssertBatchCalledWith(method string, lengthOfBatch int)
func (*MockRPCClient) AssertCallContextCalledWith ¶ added in v0.1.0
func (client *MockRPCClient) AssertCallContextCalledWith(ctx context.Context, result interface{}, method string)
func (*MockRPCClient) AssertSubscribeCalledWith ¶ added in v0.1.0
func (client *MockRPCClient) AssertSubscribeCalledWith(namespace string, payloadChan interface{}, args []interface{})
func (*MockRPCClient) BatchCall ¶ added in v0.1.0
func (client *MockRPCClient) BatchCall(batch []client.BatchElem) error
func (*MockRPCClient) CallContext ¶ added in v0.1.0
func (client *MockRPCClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
func (*MockRPCClient) RPCPath ¶ added in v0.1.0
func (client *MockRPCClient) RPCPath() string
func (*MockRPCClient) SetCallContextErr ¶ added in v0.1.0
func (client *MockRPCClient) SetCallContextErr(err error)
func (*MockRPCClient) SetRPCPath ¶ added in v0.1.0
func (client *MockRPCClient) SetRPCPath(rpcPath string)
func (*MockRPCClient) SetReturnPOAHeader ¶ added in v0.1.0
func (client *MockRPCClient) SetReturnPOAHeader(header core.POAHeader)
func (*MockRPCClient) SetReturnPOAHeaders ¶ added in v0.1.0
func (client *MockRPCClient) SetReturnPOAHeaders(headers []core.POAHeader)
func (*MockRPCClient) SetReturnPOWHeaders ¶ added in v0.1.0
func (client *MockRPCClient) SetReturnPOWHeaders(headers []*types.Header)
func (*MockRPCClient) SetSupporedModules ¶ added in v0.1.0
func (client *MockRPCClient) SetSupporedModules(supportedModules map[string]string)
func (*MockRPCClient) Subscribe ¶ added in v0.1.0
func (client *MockRPCClient) Subscribe(namespace string, payloadChan interface{}, args ...interface{}) (*rpc.ClientSubscription, error)
func (*MockRPCClient) SupportedModules ¶ added in v0.1.0
func (client *MockRPCClient) SupportedModules() (map[string]string, error)
Click to show internal directories.
Click to hide internal directories.