fakes

package

Go to main page

Versions in this module

v0

v0.0.4

Jul 23, 2019

v0.0.3

Jun 17, 2019

Changes in this version

type MockBlockChain

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

v0.0.2

May 2, 2019

Changes in this version

+ func GetFakeHeaderWithTimestamp(timestamp, blockNumber int64) core.Header

+ type MockFullSyncBlockRetriever struct

+ FirstBlock int64

+ FirstBlockErr error

+ MostRecentBlock int64

+ func (retriever *MockFullSyncBlockRetriever) RetrieveFirstBlock(contractAddr string) (int64, error)

+ func (retriever *MockFullSyncBlockRetriever) RetrieveMostRecentBlock() (int64, error)

+ type MockHeaderSyncBlockRetriever struct

+ FirstBlock int64

+ FirstBlockErr error

+ func (retriever *MockHeaderSyncBlockRetriever) RetrieveFirstBlock() (int64, error)

+ func (retriever *MockHeaderSyncBlockRetriever) RetrieveMostRecentBlock() (int64, error)

+ type MockHeaderSyncHeaderRepository struct

+ func (*MockHeaderSyncHeaderRepository) AddCheckColumn(id string) error

+ func (*MockHeaderSyncHeaderRepository) AddCheckColumns(ids []string) error

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

+ func (*MockHeaderSyncHeaderRepository) MarkHeaderChecked(headerID int64, eventID string) error

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

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

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

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

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

type MockTailer

+ TailErr error

v0.0.1

Apr 9, 2019

Changes in this version

+ var FakeAddress = common.HexToAddress("0x1234567890abcdef")

+ var FakeError = errors.New("failed")

+ var FakeHash = common.BytesToHash([]byte{ ... })

+ var FakeHeader = core.Header

+ var FakeTransaction = core.TransactionModel

+ func GetFakeHeader(blockNumber int64) core.Header

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

+ func GetFakeUncle(hash, reward string) core.Uncle

+ type MockBlockChain struct

+ GetTransactionsCalled bool

+ GetTransactionsError error

+ GetTransactionsPassedHashes []common.Hash

+ Transactions []core.TransactionModel

+ func NewMockBlockChain() *MockBlockChain

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

+ func (blockChain *MockBlockChain) FetchContractData(abiJSON string, address string, method string, methodArgs []interface{}, ...) error

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

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

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

+ func (blockChain *MockBlockChain) SetGetAccountBalanceErr(err error)

+ func (chain *MockBlockChain) AssertFetchContractDataCalledWith(abiJSON string, address string, method string, methodArgs []interface{}, ...)

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

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

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

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

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

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

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

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

+ func (chain *MockBlockChain) SetFetchContractDataErr(err error)

+ func (chain *MockBlockChain) SetGetBlockByNumberErr(err error)

+ func (chain *MockBlockChain) SetGetEthLogsWithCustomQueryErr(err error)

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

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

+ type MockBlockRepository struct

+ func NewMockBlockRepository() *MockBlockRepository

+ func (repository *MockBlockRepository) AssertCreateOrUpdateBlockCallCountEquals(times int)

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

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

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

+ func (repository *MockBlockRepository) AssertSetBlockStatusCalledWith(chainHead int64)

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

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

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

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

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

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

+ type MockCryptoParser struct

+ func NewMockCryptoParser() *MockCryptoParser

+ func (mcp *MockCryptoParser) AssertParsePublicKeyCalledWith(privateKey string)

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

+ func (mcp *MockCryptoParser) SetReturnErr(err error)

+ func (mcp *MockCryptoParser) SetReturnVal(pubKey string)

+ type MockEthClient struct

+ func NewMockEthClient() *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 MockEthereumDatabase struct

+ func NewMockEthereumDatabase() *MockEthereumDatabase

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

+ func (med *MockEthereumDatabase) AssertGetBlockHashCalledWith(blockNumber int64)

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

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

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

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

+ func (med *MockEthereumDatabase) GetHeadBlockNumber() int64

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

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

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

+ type MockFilterRepository struct

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

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

+ type MockFsReader struct

+ func NewMockFsReader() *MockFsReader

+ func (mfr *MockFsReader) AssertReadCalledWith(path string)

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

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

+ func (mfr *MockFsReader) SetReturnErr(err error)

+ type MockFullBlockRetriever struct

+ FirstBlock int64

+ FirstBlockErr error

+ MostRecentBlock int64

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

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

+ type MockHeaderRepository struct

+ CreateTransactionsCalled bool

+ CreateTransactionsError error

+ GetHeaderPassedBlockNumber int64

+ func NewMockHeaderRepository() *MockHeaderRepository

+ func (repository *MockHeaderRepository) AssertCreateOrUpdateHeaderCallCountAndPassedBlockNumbers(times int, blockNumbers []int64)

+ func (repository *MockHeaderRepository) CreateOrUpdateHeader(header core.Header) (int64, error)

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

+ func NewMockLevelDatabaseReader() *MockLevelDatabaseReader

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

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

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

+ func (mldr *MockLevelDatabaseReader) AssertGetCanonicalHashCalledWith(number uint64)

+ func (mldr *MockLevelDatabaseReader) AssertGetHeadBlockHashCalled()

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

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

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

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

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

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

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

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

+ func (mldr *MockLevelDatabaseReader) SetReturnBlockNumber(n uint64)

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

+ type MockLightBlockRetriever struct

+ FirstBlock int64

+ FirstBlockErr error

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

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

+ type MockLightHeaderRepository struct

+ func (*MockLightHeaderRepository) AddCheckColumn(id string) error

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

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

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

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

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

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

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

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

+ type MockParser struct

+ AbiToReturn string

+ Event types.Event

+ EventName string

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

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

+ func (*MockParser) Parse(contractAddr string) error

+ func (*MockParser) ParsedAbi() abi.ABI

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

+ func (parser *MockParser) Abi() string

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

+ type MockPoller struct

+ ContractName string

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

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

+ func (poller *MockPoller) FetchContractData(contractAbi, contractAddress, method string, methodArgs []interface{}, ...) error

+ type MockReceiptRepository struct

+ func NewMockReceiptRepository() *MockReceiptRepository

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

+ func (mrr *MockReceiptRepository) AssertCreateReceiptsAndLogsNotCalled()

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

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

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

+ func (mrr *MockReceiptRepository) SetCreateReceiptsAndLogsReturnErr(err error)

+ type MockRpcClient struct

+ func NewMockRpcClient() *MockRpcClient

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

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

+ 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) IpcPath() string

+ func (client *MockRpcClient) SetCallContextErr(err error)

+ func (client *MockRpcClient) SetIpcPath(ipcPath 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) SupportedModules() (map[string]string, error)

+ type MockTailer struct

+ Lines chan *tail.Line

+ TailCalled bool

+ func NewMockTailer() *MockTailer

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

+ type MockTransactionConverter struct

+ ConvertBlockTransactionsToCoreCalled bool

+ ConvertBlockTransactionsToCorePassedBlock *types.Block

+ ConvertHeaderTransactionIndexToIntCalled bool

+ func NewMockTransactionConverter() *MockTransactionConverter

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

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

+ type MockTransactionSyncer struct

+ SyncTransactionsCalled bool

+ SyncTransactionsError error

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL