fakes

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2019 License: AGPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FakeAddress = common.HexToAddress("0x1234567890abcdef")
	FakeError   = errors.New("failed")
	FakeHash    = common.BytesToHash([]byte{1, 2, 3, 4, 5})
)
View Source 
var FakeHeader = core.Header{
	Hash:      FakeHash.String(),
	Raw:       rawFakeHeader,
	Timestamp: strconv.FormatInt(fakeTimestamp, 10),
}
View Source 
var FakeTransaction = core.TransactionModel{
	Data:     []byte{},
	From:     "",
	GasLimit: 0,
	GasPrice: 0,
	Hash:     "",
	Nonce:    0,
	Raw:      rawTransaction.Bytes(),
	Receipt:  core.Receipt{},
	To:       "",
	TxIndex:  0,
	Value:    "0",
}

Functions

func GetFakeHeader 

func GetFakeHeader(blockNumber int64) core.Header

func GetFakeTransaction 

func GetFakeTransaction(hash string, receipt core.Receipt) core.TransactionModel

func GetFakeUncle 

func GetFakeUncle(hash, reward string) core.Uncle

Types

type MockBlockChain 

type MockBlockChain struct {
	GetTransactionsCalled       bool
	GetTransactionsError        error
	GetTransactionsPassedHashes []common.Hash

	Transactions []core.TransactionModel
	// contains filtered or unexported fields
}

func NewMockBlockChain 

func NewMockBlockChain() *MockBlockChain

func (*MockBlockChain) AssertFetchContractDataCalledWith 

func (chain *MockBlockChain) AssertFetchContractDataCalledWith(abiJSON string, address string, method string, methodArgs []interface{}, result interface{}, blockNumber int64)

func (*MockBlockChain) AssertGetEthLogsWithCustomQueryCalledWith 

func (blockChain *MockBlockChain) AssertGetEthLogsWithCustomQueryCalledWith(query ethereum.FilterQuery)

func (*MockBlockChain) CallContract 

func (chain *MockBlockChain) CallContract(contractHash string, input []byte, blockNumber *big.Int) ([]byte, error)

func (*MockBlockChain) FetchContractData 

func (blockChain *MockBlockChain) FetchContractData(abiJSON string, address string, method string, methodArgs []interface{}, result interface{}, blockNumber int64) error

func (*MockBlockChain) GetAccountBalance 

func (blockChain *MockBlockChain) GetAccountBalance(address common.Address, blockNumber *big.Int) (*big.Int, error)

func (*MockBlockChain) GetBlockByNumber 

func (chain *MockBlockChain) GetBlockByNumber(blockNumber int64) (core.Block, error)

func (*MockBlockChain) GetEthLogsWithCustomQuery 

func (blockChain *MockBlockChain) GetEthLogsWithCustomQuery(query ethereum.FilterQuery) ([]types.Log, error)

func (*MockBlockChain) GetHeaderByNumber 

func (chain *MockBlockChain) GetHeaderByNumber(blockNumber int64) (core.Header, error)

func (*MockBlockChain) GetHeaderByNumbers 

func (chain *MockBlockChain) GetHeaderByNumbers(blockNumbers []int64) ([]core.Header, error)

func (*MockBlockChain) GetLogs 

func (chain *MockBlockChain) GetLogs(contract core.Contract, startingBlockNumber, endingBlockNumber *big.Int) ([]core.Log, error)

func (*MockBlockChain) GetTransactions 

func (chain *MockBlockChain) GetTransactions(transactionHashes []common.Hash) ([]core.TransactionModel, error)

func (*MockBlockChain) LastBlock 

func (chain *MockBlockChain) LastBlock() (*big.Int, error)

func (*MockBlockChain) Node 

func (chain *MockBlockChain) Node() core.Node

func (*MockBlockChain) SetFetchContractDataErr 

func (chain *MockBlockChain) SetFetchContractDataErr(err error)

func (*MockBlockChain) SetGetAccountBalance 

func (blockChain *MockBlockChain) SetGetAccountBalance(balance *big.Int)

func (*MockBlockChain) SetGetAccountBalanceErr 

func (blockChain *MockBlockChain) SetGetAccountBalanceErr(err error)

func (*MockBlockChain) SetGetBlockByNumberErr 

func (chain *MockBlockChain) SetGetBlockByNumberErr(err error)

func (*MockBlockChain) SetGetEthLogsWithCustomQueryErr 

func (chain *MockBlockChain) SetGetEthLogsWithCustomQueryErr(err error)

func (*MockBlockChain) SetGetEthLogsWithCustomQueryReturnLogs 

func (chain *MockBlockChain) SetGetEthLogsWithCustomQueryReturnLogs(logs []types.Log)

func (*MockBlockChain) SetLastBlock 

func (chain *MockBlockChain) SetLastBlock(blockNumber *big.Int)

type MockBlockRepository 

type MockBlockRepository struct {
	// contains filtered or unexported fields
}

func NewMockBlockRepository 

func NewMockBlockRepository() *MockBlockRepository

func (*MockBlockRepository) AssertCreateOrUpdateBlockCallCountEquals 

func (repository *MockBlockRepository) AssertCreateOrUpdateBlockCallCountEquals(times int)

func (*MockBlockRepository) AssertCreateOrUpdateBlockCalledWith 

func (repository *MockBlockRepository) AssertCreateOrUpdateBlockCalledWith(block core.Block)

func (*MockBlockRepository) AssertCreateOrUpdateBlocksCallCountAndBlockNumbersEquals 

func (repository *MockBlockRepository) AssertCreateOrUpdateBlocksCallCountAndBlockNumbersEquals(times int, blockNumbers []int64)

func (*MockBlockRepository) AssertMissingBlockNumbersCalledWith 

func (repository *MockBlockRepository) AssertMissingBlockNumbersCalledWith(startingBlockNumber int64, endingBlockNumber int64, nodeId string)

func (*MockBlockRepository) AssertSetBlockStatusCalledWith 

func (repository *MockBlockRepository) AssertSetBlockStatusCalledWith(chainHead int64)

func (*MockBlockRepository) CreateOrUpdateBlock 

func (repository *MockBlockRepository) CreateOrUpdateBlock(block core.Block) (int64, error)

func (*MockBlockRepository) GetBlock 

func (repository *MockBlockRepository) GetBlock(blockNumber int64) (core.Block, error)

func (*MockBlockRepository) MissingBlockNumbers 

func (repository *MockBlockRepository) MissingBlockNumbers(startingBlockNumber int64, endingBlockNumber int64, nodeId string) []int64

func (*MockBlockRepository) SetBlocksStatus 

func (repository *MockBlockRepository) SetBlocksStatus(chainHead int64) error

func (*MockBlockRepository) SetCreateOrUpdateBlockReturnVals 

func (repository *MockBlockRepository) SetCreateOrUpdateBlockReturnVals(i int64, err error)

func (*MockBlockRepository) SetMissingBlockNumbersReturnArray 

func (repository *MockBlockRepository) SetMissingBlockNumbersReturnArray(returnArray []int64)

type MockCryptoParser 

type MockCryptoParser struct {
	// contains filtered or unexported fields
}

func NewMockCryptoParser 

func NewMockCryptoParser() *MockCryptoParser

func (*MockCryptoParser) AssertParsePublicKeyCalledWith 

func (mcp *MockCryptoParser) AssertParsePublicKeyCalledWith(privateKey string)

func (*MockCryptoParser) ParsePublicKey 

func (mcp *MockCryptoParser) ParsePublicKey(privateKey string) (string, error)

func (*MockCryptoParser) SetReturnErr 

func (mcp *MockCryptoParser) SetReturnErr(err error)

func (*MockCryptoParser) SetReturnVal 

func (mcp *MockCryptoParser) SetReturnVal(pubKey string)

type MockEthClient 

type MockEthClient struct {
	// contains filtered or unexported fields
}

func NewMockEthClient 

func NewMockEthClient() *MockEthClient

func (*MockEthClient) AssertBalanceAtCalled 

func (client *MockEthClient) AssertBalanceAtCalled(ctx context.Context, account common.Address, blockNumber *big.Int)

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

func (client *MockEthClient) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

func (*MockEthClient) BatchCall 

func (client *MockEthClient) BatchCall(batch []client.BatchElem) error

func (*MockEthClient) BlockByNumber 

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

func (*MockEthClient) CallContract 

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

func (*MockEthClient) FilterLogs 

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

func (*MockEthClient) HeaderByNumber 

func (client *MockEthClient) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

func (*MockEthClient) HeaderByNumbers 

func (client *MockEthClient) HeaderByNumbers(numbers []*big.Int) ([]*types.Header, error)

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 (client *MockEthClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

func (*MockEthClient) TransactionSender 

func (client *MockEthClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)

type MockEthereumDatabase 

type MockEthereumDatabase struct {
	// contains filtered or unexported fields
}

func NewMockEthereumDatabase 

func NewMockEthereumDatabase() *MockEthereumDatabase

func (*MockEthereumDatabase) AssertGetBlockCalledWith 

func (med *MockEthereumDatabase) AssertGetBlockCalledWith(hash []byte, blockNumber int64)

func (*MockEthereumDatabase) AssertGetBlockHashCalledWith 

func (med *MockEthereumDatabase) AssertGetBlockHashCalledWith(blockNumber int64)

func (*MockEthereumDatabase) AssertGetBlockReceiptsCalledWith 

func (med *MockEthereumDatabase) AssertGetBlockReceiptsCalledWith(blockHash []byte, blockNumber int64)

func (*MockEthereumDatabase) GetBlock 

func (med *MockEthereumDatabase) GetBlock(hash []byte, blockNumber int64) *types.Block

func (*MockEthereumDatabase) GetBlockHash 

func (med *MockEthereumDatabase) GetBlockHash(blockNumber int64) []byte

func (*MockEthereumDatabase) GetBlockReceipts 

func (med *MockEthereumDatabase) GetBlockReceipts(blockHash []byte, blockNumber int64) types.Receipts

func (*MockEthereumDatabase) GetHeadBlockNumber 

func (med *MockEthereumDatabase) GetHeadBlockNumber() int64

func (*MockEthereumDatabase) SetReturnBlock 

func (med *MockEthereumDatabase) SetReturnBlock(block *types.Block)

func (*MockEthereumDatabase) SetReturnHash 

func (med *MockEthereumDatabase) SetReturnHash(hash []byte)

func (*MockEthereumDatabase) SetReturnReceipts 

func (med *MockEthereumDatabase) SetReturnReceipts(receipts types.Receipts)

type MockFilterRepository 

type MockFilterRepository struct {
}

func (*MockFilterRepository) CreateFilter 

func (*MockFilterRepository) CreateFilter(filter filters.LogFilter) error

func (*MockFilterRepository) GetFilter 

func (*MockFilterRepository) GetFilter(name string) (filters.LogFilter, error)

type MockFsReader 

type MockFsReader struct {
	// contains filtered or unexported fields
}

func NewMockFsReader 

func NewMockFsReader() *MockFsReader

func (*MockFsReader) AssertReadCalledWith 

func (mfr *MockFsReader) AssertReadCalledWith(path string)

func (*MockFsReader) Read 

func (mfr *MockFsReader) Read(path string) ([]byte, error)

func (*MockFsReader) SetReturnBytes 

func (mfr *MockFsReader) SetReturnBytes(returnBytes []byte)

func (*MockFsReader) SetReturnErr 

func (mfr *MockFsReader) SetReturnErr(err error)

type MockFullBlockRetriever 

type MockFullBlockRetriever struct {
	FirstBlock      int64
	FirstBlockErr   error
	MostRecentBlock int64
}

func (*MockFullBlockRetriever) RetrieveFirstBlock 

func (retriever *MockFullBlockRetriever) RetrieveFirstBlock(contractAddr string) (int64, error)

func (*MockFullBlockRetriever) RetrieveMostRecentBlock 

func (retriever *MockFullBlockRetriever) RetrieveMostRecentBlock() (int64, error)

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

func (repository *MockHeaderRepository) CreateTransactions(headerID int64, transactions []core.TransactionModel) 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 MockLevelDatabaseReader 

type MockLevelDatabaseReader struct {
	// contains filtered or unexported fields
}

func NewMockLevelDatabaseReader 

func NewMockLevelDatabaseReader() *MockLevelDatabaseReader

func (*MockLevelDatabaseReader) AssertGetBlockCalledWith 

func (mldr *MockLevelDatabaseReader) AssertGetBlockCalledWith(hash common.Hash, number uint64)

func (*MockLevelDatabaseReader) AssertGetBlockNumberCalledWith 

func (mldr *MockLevelDatabaseReader) AssertGetBlockNumberCalledWith(hash common.Hash)

func (*MockLevelDatabaseReader) AssertGetBlockReceiptsCalledWith 

func (mldr *MockLevelDatabaseReader) AssertGetBlockReceiptsCalledWith(hash common.Hash, number uint64)

func (*MockLevelDatabaseReader) AssertGetCanonicalHashCalledWith 

func (mldr *MockLevelDatabaseReader) AssertGetCanonicalHashCalledWith(number uint64)

func (*MockLevelDatabaseReader) AssertGetHeadBlockHashCalled 

func (mldr *MockLevelDatabaseReader) AssertGetHeadBlockHashCalled()

func (*MockLevelDatabaseReader) GetBlock 

func (mldr *MockLevelDatabaseReader) GetBlock(hash common.Hash, number uint64) *types.Block

func (*MockLevelDatabaseReader) GetBlockNumber 

func (mldr *MockLevelDatabaseReader) GetBlockNumber(hash common.Hash) *uint64

func (*MockLevelDatabaseReader) GetBlockReceipts 

func (mldr *MockLevelDatabaseReader) GetBlockReceipts(hash common.Hash, number uint64) types.Receipts

func (*MockLevelDatabaseReader) GetCanonicalHash 

func (mldr *MockLevelDatabaseReader) GetCanonicalHash(number uint64) common.Hash

func (*MockLevelDatabaseReader) GetHeadBlockHash 

func (mldr *MockLevelDatabaseReader) GetHeadBlockHash() common.Hash

func (*MockLevelDatabaseReader) SetGetCanonicalHashReturnHash 

func (mldr *MockLevelDatabaseReader) SetGetCanonicalHashReturnHash(hash common.Hash)

func (*MockLevelDatabaseReader) SetHeadBlockHashReturnHash 

func (mldr *MockLevelDatabaseReader) SetHeadBlockHashReturnHash(hash common.Hash)

func (*MockLevelDatabaseReader) SetReturnBlock 

func (mldr *MockLevelDatabaseReader) SetReturnBlock(block *types.Block)

func (*MockLevelDatabaseReader) SetReturnBlockNumber 

func (mldr *MockLevelDatabaseReader) SetReturnBlockNumber(n uint64)

func (*MockLevelDatabaseReader) SetReturnReceipts 

func (mldr *MockLevelDatabaseReader) SetReturnReceipts(receipts types.Receipts)

type MockLightBlockRetriever 

type MockLightBlockRetriever struct {
	FirstBlock    int64
	FirstBlockErr error
}

func (*MockLightBlockRetriever) RetrieveFirstBlock 

func (retriever *MockLightBlockRetriever) RetrieveFirstBlock() (int64, error)

func (*MockLightBlockRetriever) RetrieveMostRecentBlock 

func (retriever *MockLightBlockRetriever) RetrieveMostRecentBlock() (int64, error)

type MockLightHeaderRepository 

type MockLightHeaderRepository struct {
}

func (*MockLightHeaderRepository) AddCheckColumn 

func (*MockLightHeaderRepository) AddCheckColumn(id string) error

func (*MockLightHeaderRepository) AddCheckColumns 

func (*MockLightHeaderRepository) AddCheckColumns(ids []string) error

func (*MockLightHeaderRepository) CheckCache 

func (*MockLightHeaderRepository) CheckCache(key string) (interface{}, bool)

func (*MockLightHeaderRepository) MarkHeaderChecked 

func (*MockLightHeaderRepository) MarkHeaderChecked(headerID int64, eventID string) error

func (*MockLightHeaderRepository) MarkHeaderCheckedForAll 

func (*MockLightHeaderRepository) MarkHeaderCheckedForAll(headerID int64, ids []string) error

func (*MockLightHeaderRepository) MarkHeadersCheckedForAll 

func (*MockLightHeaderRepository) MarkHeadersCheckedForAll(headers []core.Header, ids []string) error

func (*MockLightHeaderRepository) MissingHeaders 

func (*MockLightHeaderRepository) MissingHeaders(startingBlockNumber int64, endingBlockNumber int64, eventID string) ([]core.Header, error)

func (*MockLightHeaderRepository) MissingHeadersForAll 

func (*MockLightHeaderRepository) MissingHeadersForAll(startingBlockNumber, endingBlockNumber int64, ids []string) ([]core.Header, error)

func (*MockLightHeaderRepository) MissingMethodsCheckedEventsIntersection 

func (*MockLightHeaderRepository) MissingMethodsCheckedEventsIntersection(startingBlockNumber, endingBlockNumber int64, methodIds, eventIds []string) ([]core.Header, error)

type MockParser 

type MockParser struct {
	AbiToReturn string
	EventName   string
	Event       types.Event
}

func (*MockParser) Abi 

func (parser *MockParser) Abi() string

func (*MockParser) GetEvents 

func (parser *MockParser) GetEvents(wanted []string) map[string]types.Event

func (*MockParser) GetMethods 

func (*MockParser) GetMethods(wanted []string) []types.Method

func (*MockParser) GetSelectMethods 

func (*MockParser) GetSelectMethods(wanted []string) []types.Method

func (*MockParser) Parse 

func (*MockParser) Parse(contractAddr string) error

func (*MockParser) ParseAbiStr 

func (m *MockParser) ParseAbiStr(abiStr string) error

func (*MockParser) ParsedAbi 

func (*MockParser) ParsedAbi() abi.ABI

type MockPoller 

type MockPoller struct {
	ContractName string
}

func (*MockPoller) FetchContractData 

func (poller *MockPoller) FetchContractData(contractAbi, contractAddress, method string, methodArgs []interface{}, result interface{}, blockNumber int64) error

func (*MockPoller) PollContract 

func (*MockPoller) PollContract(con contract.Contract, lastBlock int64) error

func (*MockPoller) PollContractAt 

func (*MockPoller) PollContractAt(con contract.Contract, blockNumber int64) error

type MockReceiptRepository 

type MockReceiptRepository struct {
	// contains filtered or unexported fields
}

func NewMockReceiptRepository 

func NewMockReceiptRepository() *MockReceiptRepository

func (*MockReceiptRepository) AssertCreateReceiptsAndLogsCalledWith 

func (mrr *MockReceiptRepository) AssertCreateReceiptsAndLogsCalledWith(blockId int64, receipts []core.Receipt)

func (*MockReceiptRepository) AssertCreateReceiptsAndLogsNotCalled 

func (mrr *MockReceiptRepository) AssertCreateReceiptsAndLogsNotCalled()

func (*MockReceiptRepository) CreateReceipt 

func (mrr *MockReceiptRepository) CreateReceipt(blockId int64, receipt core.Receipt) (int64, error)

func (*MockReceiptRepository) CreateReceiptsAndLogs 

func (mrr *MockReceiptRepository) CreateReceiptsAndLogs(blockId int64, receipts []core.Receipt) error

func (*MockReceiptRepository) GetReceipt 

func (mrr *MockReceiptRepository) GetReceipt(txHash string) (core.Receipt, error)

func (*MockReceiptRepository) SetCreateReceiptsAndLogsReturnErr 

func (mrr *MockReceiptRepository) SetCreateReceiptsAndLogsReturnErr(err error)

type MockRpcClient 

type MockRpcClient struct {
	// contains filtered or unexported fields
}

func NewMockRpcClient 

func NewMockRpcClient() *MockRpcClient

func (*MockRpcClient) AssertBatchCalledWith 

func (client *MockRpcClient) AssertBatchCalledWith(method string, lengthOfBatch int)

func (*MockRpcClient) AssertCallContextCalledWith 

func (client *MockRpcClient) AssertCallContextCalledWith(ctx context.Context, result interface{}, method string)

func (*MockRpcClient) BatchCall 

func (client *MockRpcClient) BatchCall(batch []client.BatchElem) error

func (*MockRpcClient) CallContext 

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

func (*MockRpcClient) IpcPath 

func (client *MockRpcClient) IpcPath() string

func (*MockRpcClient) SetCallContextErr 

func (client *MockRpcClient) SetCallContextErr(err error)

func (*MockRpcClient) SetIpcPath 

func (client *MockRpcClient) SetIpcPath(ipcPath string)

func (*MockRpcClient) SetReturnPOAHeader 

func (client *MockRpcClient) SetReturnPOAHeader(header core.POAHeader)

func (*MockRpcClient) SetReturnPOAHeaders 

func (client *MockRpcClient) SetReturnPOAHeaders(headers []core.POAHeader)

func (*MockRpcClient) SetReturnPOWHeaders 

func (client *MockRpcClient) SetReturnPOWHeaders(headers []*types.Header)

func (*MockRpcClient) SetSupporedModules 

func (client *MockRpcClient) SetSupporedModules(supportedModules map[string]string)

func (*MockRpcClient) SupportedModules 

func (client *MockRpcClient) SupportedModules() (map[string]string, error)

type MockTailer 

type MockTailer struct {
	Lines      chan *tail.Line
	TailCalled bool
}

func NewMockTailer 

func NewMockTailer() *MockTailer

func (*MockTailer) Tail 

func (mock *MockTailer) Tail() (*tail.Tail, error)

type MockTransactionConverter 

type MockTransactionConverter struct {
	ConvertHeaderTransactionIndexToIntCalled  bool
	ConvertBlockTransactionsToCoreCalled      bool
	ConvertBlockTransactionsToCorePassedBlock *types.Block
}

func NewMockTransactionConverter 

func NewMockTransactionConverter() *MockTransactionConverter

func (*MockTransactionConverter) ConvertBlockTransactionsToCore 

func (converter *MockTransactionConverter) ConvertBlockTransactionsToCore(gethBlock *types.Block) ([]core.TransactionModel, error)

func (*MockTransactionConverter) ConvertRpcTransactionsToModels 

func (converter *MockTransactionConverter) ConvertRpcTransactionsToModels(transactions []core.RpcTransaction) ([]core.TransactionModel, error)

type MockTransactionSyncer 

type MockTransactionSyncer struct {
	SyncTransactionsCalled bool
	SyncTransactionsError  error
}

func (*MockTransactionSyncer) SyncTransactions 

func (syncer *MockTransactionSyncer) SyncTransactions(headerID int64, logs []types.Log) error

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.