Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mock

package

Go to main page

Versions in this module

v0

v0.0.2

Oct 31, 2023

Changes in this version

type StorerStub

+ GetBulkFromEpochCalled func(keys [][]byte, epoch uint32) (map[string][]byte, error)

+ RangeKeysCalled func(handler func(key []byte, val []byte) bool)

+ func (ss *StorerStub) GetBulkFromEpoch(keys [][]byte, epoch uint32) (map[string][]byte, error)

+ func (ss *StorerStub) RangeKeys(handler func(key []byte, val []byte) bool)

type TrieStub

+ func (ts *TrieStub) GetSnapshotDbBatchDelay() int

v0.0.1

Oct 30, 2023

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

+ SendToConnectedPeerCalled func(topic string, buff []byte, peerID core.PeerID) error

+ func (mhs *MessageHandlerStub) ConnectedPeersOnTopic(topic string) []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

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

+ TopicsField []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) Topics() []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

+ 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

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

+ CancelPruneCalled func(rootHash []byte, identifier data.TriePruningIdentifier)

+ CommitCalled func() error

+ DatabaseCalled func() data.DBWriteCacher

+ DeleteCalled func(key []byte) error

+ GetAllHashesCalled func() ([][]byte, error)

+ GetAllLeavesOnChannelCalled func() chan core.KeyValueHolder

+ GetCalled func(key []byte) ([]byte, error)

+ GetSerializedNodesCalled func([]byte, uint64) ([][]byte, uint64, error)

+ PruneCalled func(rootHash []byte, identifier data.TriePruningIdentifier)

+ RecreateCalled func(root []byte) (data.Trie, error)

+ ResetOldHashesCalled func() [][]byte

+ RootCalled func() ([]byte, error)

+ UpdateCalled func(key, value []byte) error

+ func (ts *TrieStub) AppendToOldHashes(hashes [][]byte)

+ func (ts *TrieStub) CancelPrune(rootHash []byte, identifier data.TriePruningIdentifier)

+ func (ts *TrieStub) ClosePersister() error

+ func (ts *TrieStub) Commit() error

+ func (ts *TrieStub) Database() data.DBWriteCacher

+ func (ts *TrieStub) Delete(key []byte) error

+ func (ts *TrieStub) EnterSnapshotMode()

+ func (ts *TrieStub) ExitSnapshotMode()

+ func (ts *TrieStub) Get(key []byte) ([]byte, error)

+ func (ts *TrieStub) GetAllHashes() ([][]byte, error)

+ func (ts *TrieStub) GetAllLeaves() (map[string][]byte, error)

+ func (ts *TrieStub) GetAllLeavesOnChannel() chan core.KeyValueHolder

+ func (ts *TrieStub) GetDirtyHashes() (data.ModifiedHashes, error)

+ func (ts *TrieStub) GetSerializedNodes(hash []byte, maxBuffToSend uint64) ([][]byte, uint64, error)

+ func (ts *TrieStub) IsInterfaceNil() bool

+ func (ts *TrieStub) IsPruningEnabled() bool

+ func (ts *TrieStub) Prune(rootHash []byte, identifier data.TriePruningIdentifier)

+ func (ts *TrieStub) Recreate(root []byte) (data.Trie, error)

+ func (ts *TrieStub) ResetOldHashes() [][]byte

+ func (ts *TrieStub) Root() ([]byte, error)

+ func (ts *TrieStub) SetCheckpoint(_ []byte)

+ func (ts *TrieStub) SetNewHashes(_ data.ModifiedHashes)

+ func (ts *TrieStub) String() string

+ func (ts *TrieStub) TakeSnapshot(_ []byte)

+ func (ts *TrieStub) Update(key, value []byte) 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)