Versions in this module Expand all Collapse all v1 v1.1.66 Jun 17, 2021 v1.1.65 Jun 17, 2021 Changes in this version + func NewMultipleShardsCoordinatorMock() *multipleShardsCoordinatorMock + func NewNonceHashConverterMock() *nonceHashConverterMock + func NewOneShardCoordinatorMock() *oneShardCoordinatorMock + func NewTopicMessageHandlerStub() *topicMessageHandlerStub + type BlockChainMock struct + CreateNewHeaderCalled func() data.HeaderHandler + GetCurrentBlockHeaderCalled func() data.HeaderHandler + GetCurrentBlockHeaderHashCalled func() []byte + GetGenesisHeaderCalled func() data.HeaderHandler + GetGenesisHeaderHashCalled func() []byte + GetLocalHeightCalled func() int64 + GetNetworkHeightCalled func() int64 + HasBadBlockCalled func([]byte) bool + PutBadBlockCalled func([]byte) + SetCurrentBlockHeaderCalled func(data.HeaderHandler) error + SetCurrentBlockHeaderHashCalled func([]byte) + SetGenesisHeaderCalled func(handler data.HeaderHandler) error + SetGenesisHeaderHashCalled func([]byte) + SetLocalHeightCalled func(int64) + SetNetworkHeightCalled func(int64) + func (bc *BlockChainMock) CreateNewHeader() data.HeaderHandler + func (bc *BlockChainMock) GetCurrentBlockHeader() data.HeaderHandler + func (bc *BlockChainMock) GetCurrentBlockHeaderHash() []byte + func (bc *BlockChainMock) GetGenesisHeader() data.HeaderHandler + func (bc *BlockChainMock) GetGenesisHeaderHash() []byte + func (bc *BlockChainMock) IsInterfaceNil() bool + func (bc *BlockChainMock) SetCurrentBlockHeader(header data.HeaderHandler) error + func (bc *BlockChainMock) SetCurrentBlockHeaderHash(hash []byte) + func (bc *BlockChainMock) SetGenesisHeader(genesisBlock data.HeaderHandler) error + func (bc *BlockChainMock) SetGenesisHeaderHash(hash []byte) + type ChainStorerMock struct + AddStorerCalled func(key dataRetriever.UnitType, s storage.Storer) + CloseAllCalled func() error + DestroyCalled func() error + GetAllCalled func(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error) + GetCalled func(unitType dataRetriever.UnitType, key []byte) ([]byte, error) + GetStorerCalled func(unitType dataRetriever.UnitType) storage.Storer + HasCalled func(unitType dataRetriever.UnitType, key []byte) error + PutCalled func(unitType dataRetriever.UnitType, key []byte, value []byte) error + func (bc *ChainStorerMock) AddStorer(key dataRetriever.UnitType, s storage.Storer) + func (bc *ChainStorerMock) CloseAll() error + func (bc *ChainStorerMock) Destroy() error + func (bc *ChainStorerMock) Get(unitType dataRetriever.UnitType, key []byte) ([]byte, error) + func (bc *ChainStorerMock) GetAll(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error) + func (bc *ChainStorerMock) GetStorer(unitType dataRetriever.UnitType) storage.Storer + func (bc *ChainStorerMock) Has(unitType dataRetriever.UnitType, key []byte) error + func (bc *ChainStorerMock) IsInterfaceNil() bool + func (bc *ChainStorerMock) Put(unitType dataRetriever.UnitType, key []byte, value []byte) error + func (bc *ChainStorerMock) SetEpochForPutOperation(epoch uint32) + type CoordinatorStub struct + CommunicationIdentifierCalled func(destShardID uint32) string + ComputeIdCalled func(address []byte) uint32 + NumberOfShardsCalled func() uint32 + SameShardCalled func(firstAddress, secondAddress []byte) bool + SelfIdCalled func() uint32 + func (coordinator *CoordinatorStub) CommunicationIdentifier(destShardID uint32) string + func (coordinator *CoordinatorStub) ComputeId(address []byte) uint32 + func (coordinator *CoordinatorStub) IsInterfaceNil() bool + func (coordinator *CoordinatorStub) NumberOfShards() uint32 + func (coordinator *CoordinatorStub) SameShard(firstAddress, secondAddress []byte) bool + func (coordinator *CoordinatorStub) SelfId() uint32 + type DataPackerStub struct + PackDataInChunksCalled func(data [][]byte, limit int) ([][]byte, error) + func (dps *DataPackerStub) IsInterfaceNil() bool + func (dps *DataPackerStub) PackDataInChunks(data [][]byte, limit int) ([][]byte, error) + type EpochHandlerStub struct + MetaEpochCalled func() uint32 + func (ehs *EpochHandlerStub) IsInterfaceNil() bool + func (ehs *EpochHandlerStub) MetaEpoch() uint32 + type HashSliceResolverStub struct + NumPeersToQueryCalled func() (int, int) + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + RequestDataFromHashArrayCalled func(hashes [][]byte, epoch uint32) error + RequestDataFromHashCalled func(hash []byte, epoch uint32) error + SetNumPeersToQueryCalled func(intra int, cross int) + SetResolverDebugHandlerCalled func(handler dataRetriever.ResolverDebugHandler) error + func (hsrs *HashSliceResolverStub) IsInterfaceNil() bool + func (hsrs *HashSliceResolverStub) NumPeersToQuery() (int, int) + func (hsrs *HashSliceResolverStub) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (hsrs *HashSliceResolverStub) RequestDataFromHash(hash []byte, epoch uint32) error + func (hsrs *HashSliceResolverStub) RequestDataFromHashArray(hashes [][]byte, epoch uint32) error + func (hsrs *HashSliceResolverStub) SetNumPeersToQuery(intra int, cross int) + func (hsrs *HashSliceResolverStub) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + type HasherMock struct + func (HasherMock) Size() int + func (sha HasherMock) Compute(s string) []byte + func (sha HasherMock) EmptyHash() []byte + func (sha HasherMock) IsInterfaceNil() bool + type HasherStub struct + ComputeCalled func(s string) []byte + EmptyHashCalled func() []byte + func (HasherStub) Size() int + func (hash *HasherStub) IsInterfaceNil() bool + func (hash HasherStub) Compute(s string) []byte + func (hash HasherStub) EmptyHash() []byte + type HeaderResolverStub struct + NumPeersToQueryCalled func() (int, int) + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + RequestDataFromEpochCalled func(identifier []byte) error + RequestDataFromHashCalled func(hash []byte, epoch uint32) error + RequestDataFromNonceCalled func(nonce uint64, epoch uint32) error + SetEpochHandlerCalled func(epochHandler dataRetriever.EpochHandler) error + SetNumPeersToQueryCalled func(intra int, cross int) + SetResolverDebugHandlerCalled func(handler dataRetriever.ResolverDebugHandler) error + func (hrs *HeaderResolverStub) IsInterfaceNil() bool + func (hrs *HeaderResolverStub) NumPeersToQuery() (int, int) + func (hrs *HeaderResolverStub) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (hrs *HeaderResolverStub) RequestDataFromEpoch(identifier []byte) error + func (hrs *HeaderResolverStub) RequestDataFromHash(hash []byte, epoch uint32) error + func (hrs *HeaderResolverStub) RequestDataFromNonce(nonce uint64, epoch uint32) error + func (hrs *HeaderResolverStub) SetEpochHandler(epochHandler dataRetriever.EpochHandler) error + func (hrs *HeaderResolverStub) SetNumPeersToQuery(intra int, cross int) + func (hrs *HeaderResolverStub) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + type HeadersCacherStub struct + AddCalled func(headerHash []byte, header data.HeaderHandler) + ClearCalled func() + GetHeaderByHashCalled func(hash []byte) (data.HeaderHandler, error) + GetHeaderByNonceAndShardIdCalled func(hdrNonce uint64, shardId uint32) ([]data.HeaderHandler, [][]byte, error) + GetNumHeadersCalled func(shardId uint32) int + LenCalled func() int + MaxSizeCalled func() int + NoncesCalled func(shardId uint32) []uint64 + RegisterHandlerCalled func(handler func(header data.HeaderHandler, shardHeaderHash []byte)) + RemoveHeaderByHashCalled func(headerHash []byte) + RemoveHeaderByNonceAndShardIdCalled func(hdrNonce uint64, shardId uint32) + func (hcs *HeadersCacherStub) AddHeader(headerHash []byte, header data.HeaderHandler) + func (hcs *HeadersCacherStub) Clear() + func (hcs *HeadersCacherStub) GetHeaderByHash(hash []byte) (data.HeaderHandler, error) + func (hcs *HeadersCacherStub) GetHeadersByNonceAndShardId(hdrNonce uint64, shardId uint32) ([]data.HeaderHandler, [][]byte, error) + func (hcs *HeadersCacherStub) GetNumHeaders(shardId uint32) int + func (hcs *HeadersCacherStub) IsInterfaceNil() bool + func (hcs *HeadersCacherStub) Len() int + func (hcs *HeadersCacherStub) MaxSize() int + func (hcs *HeadersCacherStub) Nonces(shardId uint32) []uint64 + func (hcs *HeadersCacherStub) RegisterHandler(handler func(header data.HeaderHandler, shardHeaderHash []byte)) + func (hcs *HeadersCacherStub) RemoveHeaderByHash(headerHash []byte) + func (hcs *HeadersCacherStub) RemoveHeaderByNonceAndShardId(hdrNonce uint64, shardId uint32) + type IntRandomizerStub struct + IntnCalled func(n int) int + func (irs *IntRandomizerStub) Intn(n int) int + func (irs *IntRandomizerStub) IsInterfaceNil() bool + type ManualEpochStartNotifierStub struct + CurrentEpochCalled func() uint32 + NewEpochCalled func(epoch uint32) + func (mesns *ManualEpochStartNotifierStub) CurrentEpoch() uint32 + func (mesns *ManualEpochStartNotifierStub) IsInterfaceNil() bool + func (mesns *ManualEpochStartNotifierStub) NewEpoch(epoch uint32) + type MarshalizerMock struct + Fail bool + func (mm *MarshalizerMock) IsInterfaceNil() bool + func (mm *MarshalizerMock) Marshal(obj interface{}) ([]byte, error) + func (mm *MarshalizerMock) Unmarshal(obj interface{}, buff []byte) error + type MarshalizerStub struct + MarshalCalled func(obj interface{}) ([]byte, error) + UnmarshalCalled func(obj interface{}, buff []byte) error + func (ms *MarshalizerStub) IsInterfaceNil() bool + func (ms *MarshalizerStub) Marshal(obj interface{}) ([]byte, error) + func (ms *MarshalizerStub) Unmarshal(obj interface{}, buff []byte) error + type MessageHandlerStub struct + ConnectedPeersOnTopicCalled func(topic string) []core.PeerID + IDCalled func() core.PeerID + SendToConnectedPeerCalled func(topic string, buff []byte, peerID core.PeerID) error + func (mhs *MessageHandlerStub) ConnectedPeersOnTopic(topic string) []core.PeerID + func (mhs *MessageHandlerStub) ID() core.PeerID + func (mhs *MessageHandlerStub) IsInterfaceNil() bool + func (mhs *MessageHandlerStub) SendToConnectedPeer(topic string, buff []byte, peerID core.PeerID) error + type MessengerStub struct + AddressesCalled func() []string + BootstrapCalled func() error + BroadcastCalled func(topic string, buff []byte) + BroadcastOnChannelCalled func(channel string, topic string, buff []byte) + CloseCalled func() error + ConnectToPeerCalled func(address string) error + ConnectedPeersCalled func() []core.PeerID + ConnectedPeersOnTopicCalled func(topic string) []core.PeerID + CreateTopicCalled func(name string, createChannelForTopic bool) error + HasTopicCalled func(name string) bool + HasTopicValidatorCalled func(name string) bool + IDCalled func() core.PeerID + IsConnectedCalled func(peerID core.PeerID) bool + OutgoingChannelLoadBalancerCalled func() p2p.ChannelLoadBalancer + PeersCalled func() []core.PeerID + RegisterMessageProcessorCalled func(topic string, handler p2p.MessageProcessor) error + SendToConnectedPeerCalled func(topic string, buff []byte, peerID core.PeerID) error + TrimConnectionsCalled func() + UnregisterMessageProcessorCalled func(topic string) error + func (ms *MessengerStub) Addresses() []string + func (ms *MessengerStub) Bootstrap() error + func (ms *MessengerStub) Broadcast(topic string, buff []byte) + func (ms *MessengerStub) BroadcastOnChannel(channel string, topic string, buff []byte) + func (ms *MessengerStub) Close() error + func (ms *MessengerStub) ConnectToPeer(address string) error + func (ms *MessengerStub) ConnectedPeers() []core.PeerID + func (ms *MessengerStub) ConnectedPeersOnTopic(topic string) []core.PeerID + func (ms *MessengerStub) CreateTopic(name string, createChannelForTopic bool) error + func (ms *MessengerStub) HasTopic(name string) bool + func (ms *MessengerStub) HasTopicValidator(name string) bool + func (ms *MessengerStub) ID() core.PeerID + func (ms *MessengerStub) IsConnected(peerID core.PeerID) bool + func (ms *MessengerStub) IsInterfaceNil() bool + func (ms *MessengerStub) OutgoingChannelLoadBalancer() p2p.ChannelLoadBalancer + func (ms *MessengerStub) Peers() []core.PeerID + func (ms *MessengerStub) RegisterMessageProcessor(topic string, handler p2p.MessageProcessor) error + func (ms *MessengerStub) SendToConnectedPeer(topic string, buff []byte, peerID core.PeerID) error + func (ms *MessengerStub) TrimConnections() + func (ms *MessengerStub) UnregisterMessageProcessor(topic string) error + type P2PAntifloodHandlerStub struct + BlacklistPeerCalled func(peer core.PeerID, reason string, duration time.Duration) + CanProcessMessageCalled func(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + CanProcessMessagesOnTopicCalled func(peer core.PeerID, topic string, numMessages uint32, totalSize uint64, ...) error + func (p2pahs *P2PAntifloodHandlerStub) BlacklistPeer(peer core.PeerID, reason string, duration time.Duration) + func (p2pahs *P2PAntifloodHandlerStub) CanProcessMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (p2pahs *P2PAntifloodHandlerStub) CanProcessMessagesOnTopic(peer core.PeerID, topic string, numMessages uint32, totalSize uint64, ...) error + func (p2pahs *P2PAntifloodHandlerStub) IsInterfaceNil() bool + type P2PMessageMock struct + DataField []byte + FromField []byte + KeyField []byte + PayloadField []byte + PeerField core.PeerID + SeqNoField []byte + SignatureField []byte + TimestampField int64 + TopicField string + func (msg *P2PMessageMock) Data() []byte + func (msg *P2PMessageMock) From() []byte + func (msg *P2PMessageMock) IsInterfaceNil() bool + func (msg *P2PMessageMock) Key() []byte + func (msg *P2PMessageMock) Payload() []byte + func (msg *P2PMessageMock) Peer() core.PeerID + func (msg *P2PMessageMock) SeqNo() []byte + func (msg *P2PMessageMock) Signature() []byte + func (msg *P2PMessageMock) Timestamp() int64 + func (msg *P2PMessageMock) Topic() string + type PeerListCreatorStub struct + IntraShardPeerListCalled func() []core.PeerID + PeerListCalled func() []core.PeerID + func (p *PeerListCreatorStub) IntraShardPeerList() []core.PeerID + func (p *PeerListCreatorStub) IsInterfaceNil() bool + func (p *PeerListCreatorStub) PeerList() []core.PeerID + type RequestedItemsHandlerStub struct + AddCalled func(key string) error + HasCalled func(key string) bool + SweepCalled func() + func (rihs *RequestedItemsHandlerStub) Add(key string) error + func (rihs *RequestedItemsHandlerStub) Has(key string) bool + func (rihs *RequestedItemsHandlerStub) IsInterfaceNil() bool + func (rihs *RequestedItemsHandlerStub) Sweep() + type ResolverDebugHandler struct + EnabledCalled func() bool + LogFailedToResolveDataCalled func(topic string, hash []byte, err error) + LogRequestedDataCalled func(topic string, hash [][]byte, numReqIntra int, numReqCross int) + LogSucceededToResolveDataCalled func(topic string, hash []byte) + func (rdh *ResolverDebugHandler) IsInterfaceNil() bool + func (rdh *ResolverDebugHandler) LogFailedToResolveData(topic string, hash []byte, err error) + func (rdh *ResolverDebugHandler) LogRequestedData(topic string, hashes [][]byte, numReqIntra int, numReqCross int) + func (rdh *ResolverDebugHandler) LogSucceededToResolveData(topic string, hash []byte) + type ResolverStub struct + NumPeersToQueryCalled func() (int, int) + ProcessReceivedMessageCalled func(message p2p.MessageP2P) error + RequestDataFromHashCalled func(hash []byte, epoch uint32) error + SetNumPeersToQueryCalled func(intra int, cross int) + SetResolverDebugHandlerCalled func(handler dataRetriever.ResolverDebugHandler) error + func (rs *ResolverStub) IsInterfaceNil() bool + func (rs *ResolverStub) NumPeersToQuery() (int, int) + func (rs *ResolverStub) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (rs *ResolverStub) RequestDataFromHash(hash []byte, epoch uint32) error + func (rs *ResolverStub) SetNumPeersToQuery(intra int, cross int) + func (rs *ResolverStub) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + type ResolversContainerStub struct + AddCalled func(key string, val dataRetriever.Resolver) error + GetCalled func(key string) (dataRetriever.Resolver, error) + IterateCalled func(handler func(key string, resolver dataRetriever.Resolver) bool) + LenCalled func() int + RemoveCalled func(key string) + ReplaceCalled func(key string, val dataRetriever.Resolver) error + ResolverKeysCalled func() string + func (rcs *ResolversContainerStub) Add(key string, val dataRetriever.Resolver) error + func (rcs *ResolversContainerStub) AddMultiple(_ []string, _ []dataRetriever.Resolver) error + func (rcs *ResolversContainerStub) Get(key string) (dataRetriever.Resolver, error) + func (rcs *ResolversContainerStub) IsInterfaceNil() bool + func (rcs *ResolversContainerStub) Iterate(handler func(key string, resolver dataRetriever.Resolver) bool) + func (rcs *ResolversContainerStub) Len() int + func (rcs *ResolversContainerStub) Remove(key string) + func (rcs *ResolversContainerStub) Replace(key string, val dataRetriever.Resolver) error + func (rcs *ResolversContainerStub) ResolverKeys() string + type ResolversFinderStub struct + CrossShardResolverCalled func(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + IntraShardResolverCalled func(baseTopic string) (dataRetriever.Resolver, error) + MetaChainResolverCalled func(baseTopic string) (dataRetriever.Resolver, error) + MetaCrossShardResolverCalled func(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) CrossShardResolver(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) IntraShardResolver(baseTopic string) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) MetaChainResolver(baseTopic string) (dataRetriever.Resolver, error) + func (rfs *ResolversFinderStub) MetaCrossShardResolver(baseTopic string, crossShard uint32) (dataRetriever.Resolver, error) + type StorerStub struct + ClearCacheCalled func() + DestroyUnitCalled func() error + GetBulkFromEpochCalled func(keys [][]byte, epoch uint32) (map[string][]byte, error) + GetCalled func(key []byte) ([]byte, error) + GetFromEpochCalled func(key []byte, epoch uint32) ([]byte, error) + HasCalled func(key []byte) error + HasInEpochCalled func(key []byte, epoch uint32) error + PutCalled func(key, data []byte) error + PutInEpochCalled func(key, data []byte, epoch uint32) error + RangeKeysCalled func(handler func(key []byte, val []byte) bool) + RemoveCalled func(key []byte) error + SearchFirstCalled func(key []byte) ([]byte, error) + func (ss *StorerStub) ClearCache() + func (ss *StorerStub) Close() error + func (ss *StorerStub) DestroyUnit() error + func (ss *StorerStub) Get(key []byte) ([]byte, error) + func (ss *StorerStub) GetBulkFromEpoch(keys [][]byte, epoch uint32) (map[string][]byte, error) + func (ss *StorerStub) GetFromEpoch(key []byte, epoch uint32) ([]byte, error) + func (ss *StorerStub) Has(key []byte) error + func (ss *StorerStub) HasInEpoch(key []byte, epoch uint32) error + func (ss *StorerStub) IsInterfaceNil() bool + func (ss *StorerStub) Put(key, data []byte) error + func (ss *StorerStub) PutInEpoch(key, data []byte, epoch uint32) error + func (ss *StorerStub) RangeKeys(handler func(key []byte, val []byte) bool) + func (ss *StorerStub) Remove(key []byte) error + func (ss *StorerStub) SearchFirst(key []byte) ([]byte, error) + type ThrottlerStub struct + CanProcessCalled func() bool + EndProcessingCalled func() + EndWasCalled bool + StartProcessingCalled func() + StartWasCalled bool + func (ts *ThrottlerStub) CanProcess() bool + func (ts *ThrottlerStub) EndProcessing() + func (ts *ThrottlerStub) IsInterfaceNil() bool + func (ts *ThrottlerStub) StartProcessing() + type TopicHandlerStub struct + CreateTopicCalled func(name string, createChannelForTopic bool) error + HasTopicCalled func(name string) bool + RegisterMessageProcessorCalled func(topic string, handler p2p.MessageProcessor) error + func (ths *TopicHandlerStub) CreateTopic(name string, createChannelForTopic bool) error + func (ths *TopicHandlerStub) HasTopic(name string) bool + func (ths *TopicHandlerStub) IsInterfaceNil() bool + func (ths *TopicHandlerStub) RegisterMessageProcessor(topic string, handler p2p.MessageProcessor) error + type TopicResolverSenderStub struct + GetNumPeersToQueryCalled func() (int, int) + SendCalled func(buff []byte, peer core.PeerID) error + SendOnRequestTopicCalled func(rd *dataRetriever.RequestData, originalHashes [][]byte) error + SetNumPeersToQueryCalled func(intra int, cross int) + TargetShardIDCalled func() uint32 + func (trss *TopicResolverSenderStub) IsInterfaceNil() bool + func (trss *TopicResolverSenderStub) NumPeersToQuery() (int, int) + func (trss *TopicResolverSenderStub) RequestTopic() string + func (trss *TopicResolverSenderStub) ResolverDebugHandler() dataRetriever.ResolverDebugHandler + func (trss *TopicResolverSenderStub) Send(buff []byte, peer core.PeerID) error + func (trss *TopicResolverSenderStub) SendOnRequestTopic(rd *dataRetriever.RequestData, originalHashes [][]byte) error + func (trss *TopicResolverSenderStub) SetNumPeersToQuery(intra int, cross int) + func (trss *TopicResolverSenderStub) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + func (trss *TopicResolverSenderStub) TargetShardID() uint32 + type TrieStub struct + AppendToOldHashesCalled func([][]byte) + CommitCalled func() error + DeleteCalled func(key []byte) error + GetAllHashesCalled func() ([][]byte, error) + GetAllLeavesOnChannelCalled func(rootHash []byte) (chan core.KeyValueHolder, error) + GetCalled func(key []byte) ([]byte, error) + GetNumNodesCalled func() data.NumNodesDTO + GetProofCalled func(key []byte) ([][]byte, error) + GetSerializedNodeCalled func(bytes []byte) ([]byte, error) + GetSerializedNodesCalled func([]byte, uint64) ([][]byte, uint64, error) + GetStorageManagerCalled func() data.StorageManager + RecreateCalled func(root []byte) (data.Trie, error) + ResetOldHashesCalled func() [][]byte + RootCalled func() ([]byte, error) + UpdateCalled func(key, value []byte) error + VerifyProofCalled func(key []byte, proof [][]byte) (bool, error) + func (ts *TrieStub) AppendToOldHashes(hashes [][]byte) + func (ts *TrieStub) ClosePersister() error + func (ts *TrieStub) Commit() error + func (ts *TrieStub) Delete(key []byte) error + func (ts *TrieStub) Get(key []byte) ([]byte, error) + func (ts *TrieStub) GetAllHashes() ([][]byte, error) + func (ts *TrieStub) GetAllLeavesOnChannel(rootHash []byte, _ context.Context) (chan core.KeyValueHolder, error) + func (ts *TrieStub) GetDirtyHashes() (data.ModifiedHashes, error) + func (ts *TrieStub) GetNumNodes() data.NumNodesDTO + func (ts *TrieStub) GetProof(key []byte) ([][]byte, error) + func (ts *TrieStub) GetSerializedNode(bytes []byte) ([]byte, error) + func (ts *TrieStub) GetSerializedNodes(hash []byte, maxBuffToSend uint64) ([][]byte, uint64, error) + func (ts *TrieStub) GetStorageManager() data.StorageManager + func (ts *TrieStub) IsInterfaceNil() bool + func (ts *TrieStub) Recreate(root []byte) (data.Trie, error) + func (ts *TrieStub) ResetOldHashes() [][]byte + func (ts *TrieStub) RootHash() ([]byte, error) + func (ts *TrieStub) SetNewHashes(_ data.ModifiedHashes) + func (ts *TrieStub) String() string + func (ts *TrieStub) Update(key, value []byte) error + func (ts *TrieStub) VerifyProof(key []byte, proof [][]byte) (bool, error) + type TxForCurrentBlockStub struct + AddTxCalled func(txHash []byte, tx data.TransactionHandler) + CleanCalled func() + GetTxCalled func(txHash []byte) (data.TransactionHandler, error) + func (t *TxForCurrentBlockStub) AddTx(txHash []byte, tx data.TransactionHandler) + func (t *TxForCurrentBlockStub) Clean() + func (t *TxForCurrentBlockStub) GetTx(txHash []byte) (data.TransactionHandler, error) + func (t *TxForCurrentBlockStub) IsInterfaceNil() bool + type Uint64ByteSliceConverterMock struct + ToByteSliceCalled func(uint64) []byte + ToUint64Called func([]byte) (uint64, error) + func (u *Uint64ByteSliceConverterMock) IsInterfaceNil() bool + func (u *Uint64ByteSliceConverterMock) ToByteSlice(p uint64) []byte + func (u *Uint64ByteSliceConverterMock) ToUint64(p []byte) (uint64, error) + type WhiteListHandlerStub struct + AddCalled func(keys [][]byte) + RemoveCalled func(keys [][]byte) + func (w *WhiteListHandlerStub) Add(keys [][]byte) + func (w *WhiteListHandlerStub) IsInterfaceNil() bool + func (w *WhiteListHandlerStub) Remove(keys [][]byte)
Go to main page