mock

package
v1.0.131 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2020 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewInterceptedMetaBlockMock added in v1.0.102 

func NewInterceptedMetaBlockMock(hdr data.HeaderHandler, hash []byte) *interceptedMetaBlockMock

NewInterceptedMetaBlockMock -

func NewMultiShardsCoordinatorMock added in v1.0.102 

func NewMultiShardsCoordinatorMock(nrShard uint32) *multipleShardsCoordinatorMock

NewMultiShardsCoordinatorMock -

func NewMultipleShardsCoordinatorMock added in v1.0.102 

func NewMultipleShardsCoordinatorMock() *multipleShardsCoordinatorMock

NewMultipleShardsCoordinatorMock -

Types

type AddressMock added in v1.0.102 

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

AddressMock is the struct holding a mock address

func NewAddressMock added in v1.0.102 

func NewAddressMock(adr []byte) *AddressMock

NewAddressMock creates a new Address with the same byte slice as the parameter received

func (*AddressMock) Bytes added in v1.0.102 

func (adr *AddressMock) Bytes() []byte

Bytes returns the data corresponding to this address

func (*AddressMock) IsInterfaceNil added in v1.0.102 

func (adr *AddressMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

type AppStatusHandlerStub added in v1.0.127 

type AppStatusHandlerStub struct {
	AddUint64Handler      func(key string, value uint64)
	IncrementHandler      func(key string)
	DecrementHandler      func(key string)
	SetUInt64ValueHandler func(key string, value uint64)
	SetInt64ValueHandler  func(key string, value int64)
	SetStringValueHandler func(key string, value string)
	CloseHandler          func()
}

AppStatusHandlerStub is a stub implementation of AppStatusHandler

func (*AppStatusHandlerStub) AddUint64 added in v1.0.127 

func (ashs *AppStatusHandlerStub) AddUint64(key string, value uint64)

AddUint64 will call the handler of the stub for incrementing

func (*AppStatusHandlerStub) Close added in v1.0.127 

func (ashs *AppStatusHandlerStub) Close()

Close will call the handler of the stub for closing

func (*AppStatusHandlerStub) Decrement added in v1.0.127 

func (ashs *AppStatusHandlerStub) Decrement(key string)

Decrement will call the handler of the stub for decrementing

func (*AppStatusHandlerStub) Increment added in v1.0.127 

func (ashs *AppStatusHandlerStub) Increment(key string)

Increment will call the handler of the stub for incrementing

func (*AppStatusHandlerStub) IsInterfaceNil added in v1.0.127 

func (ashs *AppStatusHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*AppStatusHandlerStub) SetInt64Value added in v1.0.127 

func (ashs *AppStatusHandlerStub) SetInt64Value(key string, value int64)

SetInt64Value will call the handler of the stub for setting an int64 value

func (*AppStatusHandlerStub) SetStringValue added in v1.0.127 

func (ashs *AppStatusHandlerStub) SetStringValue(key string, value string)

SetStringValue will call the handler of the stub for setting an string value

func (*AppStatusHandlerStub) SetUInt64Value added in v1.0.127 

func (ashs *AppStatusHandlerStub) SetUInt64Value(key string, value uint64)

SetUInt64Value will call the handler of the stub for setting an uint64 value

type CacherStub 

type CacherStub struct {
	ClearCalled             func()
	PutCalled               func(key []byte, value interface{}, sizeInBytes int) (evicted bool)
	GetCalled               func(key []byte) (value interface{}, ok bool)
	HasCalled               func(key []byte) bool
	PeekCalled              func(key []byte) (value interface{}, ok bool)
	HasOrAddCalled          func(key []byte, value interface{}, sizeInBytes int) (ok, evicted bool)
	RemoveCalled            func(key []byte)
	RemoveOldestCalled      func()
	KeysCalled              func() [][]byte
	LenCalled               func() int
	MaxSizeCalled           func() int
	RegisterHandlerCalled   func(func(key []byte, value interface{}))
	UnRegisterHandlerCalled func(id string)
}

CacherStub -

func (*CacherStub) Clear 

func (cs *CacherStub) Clear()

Clear -

func (*CacherStub) Get 

func (cs *CacherStub) Get(key []byte) (value interface{}, ok bool)

Get -

func (*CacherStub) Has 

func (cs *CacherStub) Has(key []byte) bool

Has -

func (*CacherStub) HasOrAdd 

func (cs *CacherStub) HasOrAdd(key []byte, value interface{}, sizeInBytes int) (ok, evicted bool)

HasOrAdd -

func (*CacherStub) IsInterfaceNil 

func (cs *CacherStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*CacherStub) Keys 

func (cs *CacherStub) Keys() [][]byte

Keys -

func (*CacherStub) Len 

func (cs *CacherStub) Len() int

Len -

func (*CacherStub) MaxSize 

func (cs *CacherStub) MaxSize() int

MaxSize -

func (*CacherStub) Peek 

func (cs *CacherStub) Peek(key []byte) (value interface{}, ok bool)

Peek -

func (*CacherStub) Put 

func (cs *CacherStub) Put(key []byte, value interface{}, sizeInBytes int) (evicted bool)

Put -

func (*CacherStub) RegisterHandler 

func (cs *CacherStub) RegisterHandler(handler func(key []byte, value interface{}), _ string)

RegisterHandler -

func (*CacherStub) Remove 

func (cs *CacherStub) Remove(key []byte)

Remove -

func (*CacherStub) UnRegisterHandler added in v1.0.126 

func (cs *CacherStub) UnRegisterHandler(id string)

UnRegisterHandler -

type ChainStorerStub 

type ChainStorerStub struct {
	AddStorerCalled func(key dataRetriever.UnitType, s storage.Storer)
	GetStorerCalled func(unitType dataRetriever.UnitType) storage.Storer
	HasCalled       func(unitType dataRetriever.UnitType, key []byte) error
	GetCalled       func(unitType dataRetriever.UnitType, key []byte) ([]byte, error)
	PutCalled       func(unitType dataRetriever.UnitType, key []byte, value []byte) error
	GetAllCalled    func(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error)
	DestroyCalled   func() error
	CloseAllCalled  func() error
}

ChainStorerStub is a mock implementation of the ChainStorer interface

func (*ChainStorerStub) AddStorer 

func (bc *ChainStorerStub) AddStorer(key dataRetriever.UnitType, s storage.Storer)

AddStorer will add a new storer to the chain map

func (*ChainStorerStub) CloseAll 

func (bc *ChainStorerStub) CloseAll() error

CloseAll -

func (*ChainStorerStub) Destroy 

func (bc *ChainStorerStub) Destroy() error

Destroy removes the underlying files/resources used by the storage service

func (*ChainStorerStub) Get 

func (bc *ChainStorerStub) Get(unitType dataRetriever.UnitType, key []byte) ([]byte, error)

Get returns the value for the given key if found in the selected storage unit, nil otherwise. It can return an error if the provided unit type is not supported or if the storage unit underlying implementation reports an error

func (*ChainStorerStub) GetAll 

func (bc *ChainStorerStub) GetAll(unitType dataRetriever.UnitType, keys [][]byte) (map[string][]byte, error)

GetAll gets all the elements with keys in the keys array, from the selected storage unit It can report an error if the provided unit type is not supported, if there is a missing key in the unit, or if the underlying implementation of the storage unit reports an error.

func (*ChainStorerStub) GetStorer 

func (bc *ChainStorerStub) GetStorer(unitType dataRetriever.UnitType) storage.Storer

GetStorer returns the storer from the chain map or nil if the storer was not found

func (*ChainStorerStub) Has 

func (bc *ChainStorerStub) Has(unitType dataRetriever.UnitType, key []byte) error

Has returns true if the key is found in the selected Unit or false otherwise It can return an error if the provided unit type is not supported or if the underlying implementation of the storage unit reports an error.

func (*ChainStorerStub) IsInterfaceNil 

func (bc *ChainStorerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ChainStorerStub) Put 

func (bc *ChainStorerStub) Put(unitType dataRetriever.UnitType, key []byte, value []byte) error

Put stores the key, value pair in the selected storage unit It can return an error if the provided unit type is not supported or if the storage unit underlying implementation reports an error

func (*ChainStorerStub) SetEpochForPutOperation added in v1.0.109 

func (bc *ChainStorerStub) SetEpochForPutOperation(epoch uint32)

SetEpochForPutOperation won't do anything

type EpochStartNotifierStub 

type EpochStartNotifierStub struct {
	NotifyAllCalled                  func(hdr data.HeaderHandler)
	NotifyAllPrepareCalled           func(hdr data.HeaderHandler, body data.BodyHandler)
	NotifyEpochChangeConfirmedCalled func(epoch uint32)
}

EpochStartNotifierStub -

func (*EpochStartNotifierStub) IsInterfaceNil 

func (esnm *EpochStartNotifierStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*EpochStartNotifierStub) NotifyAll 

func (esnm *EpochStartNotifierStub) NotifyAll(hdr data.HeaderHandler)

NotifyAll -

func (*EpochStartNotifierStub) NotifyAllPrepare 

func (esnm *EpochStartNotifierStub) NotifyAllPrepare(metaHdr data.HeaderHandler, body data.BodyHandler)

NotifyAllPrepare -

func (*EpochStartNotifierStub) NotifyEpochChangeConfirmed added in v1.0.120 

func (esnm *EpochStartNotifierStub) NotifyEpochChangeConfirmed(epoch uint32)

NotifyEpochChangeConfirmed -

type HasherMock 

type HasherMock struct {
}

HasherMock that will be used for testing

func (HasherMock) Compute 

func (sha HasherMock) Compute(s string) []byte

Compute will output the SHA's equivalent of the input string

func (HasherMock) EmptyHash 

func (sha HasherMock) EmptyHash() []byte

EmptyHash will return the equivalent of empty string SHA's

func (HasherMock) IsInterfaceNil 

func (sha HasherMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (HasherMock) Size 

func (HasherMock) Size() int

Size return the required size in bytes

type HeaderValidatorStub 

type HeaderValidatorStub struct {
	IsHeaderConstructionValidCalled func(currHdr, prevHdr data.HeaderHandler) error
}

HeaderValidatorStub -

func (*HeaderValidatorStub) IsHeaderConstructionValid 

func (hvs *HeaderValidatorStub) IsHeaderConstructionValid(currHdr, prevHdr data.HeaderHandler) error

IsHeaderConstructionValid -

func (*HeaderValidatorStub) IsInterfaceNil 

func (hvs *HeaderValidatorStub) IsInterfaceNil() bool

IsInterfaceNil returns if underlying object is true

type HeadersByHashSyncerStub added in v1.0.104 

type HeadersByHashSyncerStub struct {
	SyncMissingHeadersByHashCalled func(shardIDs []uint32, headersHashes [][]byte, ctx context.Context) error
	GetHeadersCalled               func() (map[string]data.HeaderHandler, error)
	ClearFieldsCalled              func()
}

HeadersByHashSyncerStub --

func (*HeadersByHashSyncerStub) ClearFields added in v1.0.104 

func (hhss *HeadersByHashSyncerStub) ClearFields()

ClearFields --

func (*HeadersByHashSyncerStub) GetHeaders added in v1.0.104 

func (hhss *HeadersByHashSyncerStub) GetHeaders() (map[string]data.HeaderHandler, error)

GetHeaders --

func (*HeadersByHashSyncerStub) IsInterfaceNil added in v1.0.104 

func (hhss *HeadersByHashSyncerStub) IsInterfaceNil() bool

IsInterfaceNil --

func (*HeadersByHashSyncerStub) SyncMissingHeadersByHash added in v1.0.104 

func (hhss *HeadersByHashSyncerStub) SyncMissingHeadersByHash(shardIDs []uint32, headersHashes [][]byte, ctx context.Context) error

SyncMissingHeadersByHash --

type HeadersCacherStub 

type HeadersCacherStub struct {
	AddCalled                           func(headerHash []byte, header data.HeaderHandler)
	RemoveHeaderByHashCalled            func(headerHash []byte)
	RemoveHeaderByNonceAndShardIdCalled func(hdrNonce uint64, shardId uint32)
	GetHeaderByNonceAndShardIdCalled    func(hdrNonce uint64, shardId uint32) ([]data.HeaderHandler, [][]byte, error)
	GetHeaderByHashCalled               func(hash []byte) (data.HeaderHandler, error)
	ClearCalled                         func()
	RegisterHandlerCalled               func(handler func(header data.HeaderHandler, shardHeaderHash []byte))
	NoncesCalled                        func(shardId uint32) []uint64
	LenCalled                           func() int
	MaxSizeCalled                       func() int
	GetNumHeadersCalled                 func(shardId uint32) int
}

HeadersCacherStub -

func (*HeadersCacherStub) AddHeader 

func (hcs *HeadersCacherStub) AddHeader(headerHash []byte, header data.HeaderHandler)

AddHeader -

func (*HeadersCacherStub) Clear 

func (hcs *HeadersCacherStub) Clear()

Clear -

func (*HeadersCacherStub) GetHeaderByHash 

func (hcs *HeadersCacherStub) GetHeaderByHash(hash []byte) (data.HeaderHandler, error)

GetHeaderByHash -

func (*HeadersCacherStub) GetHeadersByNonceAndShardId 

func (hcs *HeadersCacherStub) GetHeadersByNonceAndShardId(hdrNonce uint64, shardId uint32) ([]data.HeaderHandler, [][]byte, error)

GetHeadersByNonceAndShardId -

func (*HeadersCacherStub) GetNumHeaders 

func (hcs *HeadersCacherStub) GetNumHeaders(shardId uint32) int

GetNumHeaders -

func (*HeadersCacherStub) IsInterfaceNil 

func (hcs *HeadersCacherStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*HeadersCacherStub) Len 

func (hcs *HeadersCacherStub) Len() int

Len -

func (*HeadersCacherStub) MaxSize 

func (hcs *HeadersCacherStub) MaxSize() int

MaxSize -

func (*HeadersCacherStub) Nonces 

func (hcs *HeadersCacherStub) Nonces(shardId uint32) []uint64

Nonces -

func (*HeadersCacherStub) RegisterHandler 

func (hcs *HeadersCacherStub) RegisterHandler(handler func(header data.HeaderHandler, shardHeaderHash []byte))

RegisterHandler -

func (*HeadersCacherStub) RemoveHeaderByHash 

func (hcs *HeadersCacherStub) RemoveHeaderByHash(headerHash []byte)

RemoveHeaderByHash -

func (*HeadersCacherStub) RemoveHeaderByNonceAndShardId 

func (hcs *HeadersCacherStub) RemoveHeaderByNonceAndShardId(hdrNonce uint64, shardId uint32)

RemoveHeaderByNonceAndShardId -

type KeyGenMock added in v1.0.104 

type KeyGenMock struct {
}

KeyGenMock -

func (*KeyGenMock) CheckPublicKeyValid added in v1.0.120 

func (keyGen *KeyGenMock) CheckPublicKeyValid(_ []byte) error

CheckPublicKeyValid -

func (*KeyGenMock) GeneratePair added in v1.0.104 

func (keyGen *KeyGenMock) GeneratePair() (crypto.PrivateKey, crypto.PublicKey)

GeneratePair -

func (*KeyGenMock) IsInterfaceNil added in v1.0.104 

func (keyGen *KeyGenMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*KeyGenMock) PrivateKeyFromByteArray added in v1.0.104 

func (keyGen *KeyGenMock) PrivateKeyFromByteArray(_ []byte) (crypto.PrivateKey, error)

PrivateKeyFromByteArray -

func (*KeyGenMock) PublicKeyFromByteArray added in v1.0.104 

func (keyGen *KeyGenMock) PublicKeyFromByteArray(_ []byte) (crypto.PublicKey, error)

PublicKeyFromByteArray -

func (*KeyGenMock) Suite added in v1.0.104 

func (keyGen *KeyGenMock) Suite() crypto.Suite

Suite -

type LatestStorageDataProviderStub added in v1.0.111 

type LatestStorageDataProviderStub struct {
	GetParentDirAndLastEpochCalled func() (string, uint32, error)
	GetCalled                      func() (storage.LatestDataFromStorage, error)
	GetShardsFromDirectoryCalled   func(path string) ([]string, error)
}

LatestStorageDataProviderStub -

func (*LatestStorageDataProviderStub) Get added in v1.0.111 

func (lsdps *LatestStorageDataProviderStub) Get() (storage.LatestDataFromStorage, error)

Get -

func (*LatestStorageDataProviderStub) GetParentDirAndLastEpoch added in v1.0.111 

func (lsdps *LatestStorageDataProviderStub) GetParentDirAndLastEpoch() (string, uint32, error)

GetParentDirAndLastEpoch -

func (*LatestStorageDataProviderStub) GetShardsFromDirectory added in v1.0.111 

func (lsdps *LatestStorageDataProviderStub) GetShardsFromDirectory(path string) ([]string, error)

GetShardsFromDirectory -

func (*LatestStorageDataProviderStub) IsInterfaceNil added in v1.0.111 

func (lsdps *LatestStorageDataProviderStub) IsInterfaceNil() bool

IsInterfaceNil --

type MarshalizerMock 

type MarshalizerMock struct {
	Fail bool
}

MarshalizerMock that will be used for testing

func (*MarshalizerMock) IsInterfaceNil 

func (mm *MarshalizerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*MarshalizerMock) Marshal 

func (mm *MarshalizerMock) Marshal(obj interface{}) ([]byte, error)

Marshal converts the input object in a slice of bytes

func (*MarshalizerMock) Unmarshal 

func (mm *MarshalizerMock) Unmarshal(obj interface{}, buff []byte) error

Unmarshal applies the serialized values over an instantiated object

type MessengerStub added in v1.0.102 

type MessengerStub struct {
	ConnectedPeersCalled           func() []core.PeerID
	RegisterMessageProcessorCalled func(topic string, handler p2p.MessageProcessor) error
}

MessengerStub -

func (*MessengerStub) ConnectedPeers added in v1.0.102 

func (m *MessengerStub) ConnectedPeers() []core.PeerID

ConnectedPeers -

func (*MessengerStub) ConnectedPeersOnTopic added in v1.0.102 

func (m *MessengerStub) ConnectedPeersOnTopic(_ string) []core.PeerID

ConnectedPeersOnTopic -

func (*MessengerStub) CreateTopic added in v1.0.102 

func (m *MessengerStub) CreateTopic(_ string, _ bool) error

CreateTopic -

func (*MessengerStub) HasTopic added in v1.0.102 

func (m *MessengerStub) HasTopic(_ string) bool

HasTopic -

func (*MessengerStub) IsInterfaceNil added in v1.0.102 

func (m *MessengerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*MessengerStub) RegisterMessageProcessor added in v1.0.102 

func (m *MessengerStub) RegisterMessageProcessor(topic string, handler p2p.MessageProcessor) error

RegisterMessageProcessor -

func (*MessengerStub) SendToConnectedPeer added in v1.0.102 

func (m *MessengerStub) SendToConnectedPeer(_ string, _ []byte, _ core.PeerID) error

SendToConnectedPeer -

func (*MessengerStub) UnregisterAllMessageProcessors added in v1.0.102 

func (m *MessengerStub) UnregisterAllMessageProcessors() error

UnregisterAllMessageProcessors -

func (*MessengerStub) UnregisterMessageProcessor added in v1.0.102 

func (m *MessengerStub) UnregisterMessageProcessor(_ string) error

UnregisterMessageProcessor -

type MetaBlockInterceptorProcessorStub added in v1.0.116 

type MetaBlockInterceptorProcessorStub struct {
	GetEpochStartMetaBlockCalled func() (*block.MetaBlock, error)
}

MetaBlockInterceptorProcessorStub -

func (*MetaBlockInterceptorProcessorStub) GetEpochStartMetaBlock added in v1.0.116 

func (m *MetaBlockInterceptorProcessorStub) GetEpochStartMetaBlock(_ context.Context) (*block.MetaBlock, error)

GetEpochStartMetaBlock -

func (*MetaBlockInterceptorProcessorStub) IsInterfaceNil added in v1.0.116 

func (m *MetaBlockInterceptorProcessorStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*MetaBlockInterceptorProcessorStub) Save added in v1.0.116 

func (m *MetaBlockInterceptorProcessorStub) Save(_ process.InterceptedData, _ core.PeerID) error

Save -

func (*MetaBlockInterceptorProcessorStub) SignalEndOfProcessing added in v1.0.116 

func (m *MetaBlockInterceptorProcessorStub) SignalEndOfProcessing(_ []process.InterceptedData)

SignalEndOfProcessing -

func (*MetaBlockInterceptorProcessorStub) Validate added in v1.0.116 

func (m *MetaBlockInterceptorProcessorStub) Validate(_ process.InterceptedData, _ core.PeerID) error

Validate -

type NodeInfoMock added in v1.0.104 

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

NodeInfoMock -

func NewNodeInfo added in v1.0.104 

func NewNodeInfo(address []byte, pubKey []byte, shardId uint32) *NodeInfoMock

NewNodeInfo -

func (*NodeInfoMock) AddressBytes added in v1.0.115 

func (n *NodeInfoMock) AddressBytes() []byte

AddressBytes -

func (*NodeInfoMock) AssignedShard added in v1.0.104 

func (n *NodeInfoMock) AssignedShard() uint32

AssignedShard -

func (*NodeInfoMock) IsInterfaceNil added in v1.0.104 

func (n *NodeInfoMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*NodeInfoMock) PubKeyBytes added in v1.0.115 

func (n *NodeInfoMock) PubKeyBytes() []byte

PubKeyBytes -

type NodeShufflerMock added in v1.0.104 

type NodeShufflerMock struct {
}

NodeShufflerMock -

func (*NodeShufflerMock) IsInterfaceNil added in v1.0.104 

func (nsm *NodeShufflerMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*NodeShufflerMock) UpdateNodeLists added in v1.0.104 

func (nsm *NodeShufflerMock) UpdateNodeLists(args sharding.ArgsUpdateNodes) (*sharding.ResUpdateNodes, error)

UpdateNodeLists -

func (*NodeShufflerMock) UpdateParams added in v1.0.104 

func (nsm *NodeShufflerMock) UpdateParams(
	_ uint32,
	_ uint32,
	_ float32,
	_ bool,
)

UpdateParams -

type NodesCoordinatorStub added in v1.0.102 

type NodesCoordinatorStub struct {
	ComputeValidatorsGroupCalled        func(randomness []byte, round uint64, shardId uint32, epoch uint32) ([]sharding.Validator, error)
	GetValidatorsPublicKeysCalled       func(randomness []byte, round uint64, shardId uint32, epoch uint32) ([]string, error)
	GetValidatorsRewardsAddressesCalled func(randomness []byte, round uint64, shardId uint32, epoch uint32) ([]string, error)
	GetValidatorWithPublicKeyCalled     func(publicKey []byte) (validator sharding.Validator, shardId uint32, err error)
	GetAllValidatorsPublicKeysCalled    func() (map[uint32][][]byte, error)
	ConsensusGroupSizeCalled            func(shardID uint32) int
}

NodesCoordinatorStub -

func (*NodesCoordinatorStub) ComputeAdditionalLeaving added in v1.0.115 

func (ncm *NodesCoordinatorStub) ComputeAdditionalLeaving(_ []*state.ShardValidatorInfo) (map[uint32][]sharding.Validator, error)

ComputeAdditionalLeaving -

func (*NodesCoordinatorStub) ComputeConsensusGroup added in v1.0.102 

func (ncm *NodesCoordinatorStub) ComputeConsensusGroup(
	randomness []byte,
	round uint64,
	shardId uint32,
	epoch uint32,
) (validatorsGroup []sharding.Validator, err error)

ComputeConsensusGroup -

func (*NodesCoordinatorStub) ConsensusGroupSize added in v1.0.102 

func (ncm *NodesCoordinatorStub) ConsensusGroupSize(shardID uint32) int

ConsensusGroupSize -

func (*NodesCoordinatorStub) GetAllEligibleValidatorsPublicKeys added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetAllEligibleValidatorsPublicKeys(_ uint32) (map[uint32][][]byte, error)

GetAllEligibleValidatorsPublicKeys -

func (*NodesCoordinatorStub) GetAllLeavingValidatorsPublicKeys added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetAllLeavingValidatorsPublicKeys(_ uint32) (map[uint32][][]byte, error)

GetAllLeavingValidatorsPublicKeys -

func (*NodesCoordinatorStub) GetAllValidatorsPublicKeys added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetAllValidatorsPublicKeys(_ uint32) (map[uint32][][]byte, error)

GetAllValidatorsPublicKeys -

func (*NodesCoordinatorStub) GetAllWaitingValidatorsPublicKeys added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetAllWaitingValidatorsPublicKeys(_ uint32) (map[uint32][][]byte, error)

GetAllWaitingValidatorsPublicKeys -

func (*NodesCoordinatorStub) GetChance added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetChance(uint32) uint32

GetChance -

func (*NodesCoordinatorStub) GetConsensusValidatorsPublicKeys added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetConsensusValidatorsPublicKeys(
	randomness []byte,
	round uint64,
	shardId uint32,
	epoch uint32,
) ([]string, error)

GetConsensusValidatorsPublicKeys -

func (*NodesCoordinatorStub) GetConsensusWhitelistedNodes added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetConsensusWhitelistedNodes(
	_ uint32,
) (map[string]struct{}, error)

GetConsensusWhitelistedNodes return the whitelisted nodes allowed to send consensus messages, for each of the shards

func (*NodesCoordinatorStub) GetNumTotalEligible added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetNumTotalEligible() uint64

GetNumTotalEligible -

func (*NodesCoordinatorStub) GetOwnPublicKey added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetOwnPublicKey() []byte

GetOwnPublicKey -

func (*NodesCoordinatorStub) GetSavedStateKey added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetSavedStateKey() []byte

GetSavedStateKey -

func (*NodesCoordinatorStub) GetSelectedPublicKeys added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetSelectedPublicKeys(_ []byte, _ uint32, _ uint32) ([]string, error)

GetSelectedPublicKeys -

func (*NodesCoordinatorStub) GetValidatorWithPublicKey added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetValidatorWithPublicKey(address []byte, _ uint32) (sharding.Validator, uint32, error)

GetValidatorWithPublicKey -

func (*NodesCoordinatorStub) GetValidatorsIndexes added in v1.0.102 

func (ncm *NodesCoordinatorStub) GetValidatorsIndexes(_ []string, _ uint32) ([]uint64, error)

GetValidatorsIndexes -

func (*NodesCoordinatorStub) IsInterfaceNil added in v1.0.102 

func (ncm *NodesCoordinatorStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*NodesCoordinatorStub) LoadState added in v1.0.102 

func (ncm *NodesCoordinatorStub) LoadState(_ []byte) error

LoadState -

func (*NodesCoordinatorStub) SetConfig added in v1.0.102 

func (ncm *NodesCoordinatorStub) SetConfig(_ *sharding.NodesCoordinatorRegistry) error

SetConfig -

func (*NodesCoordinatorStub) SetNodesPerShards added in v1.0.102 

func (ncm *NodesCoordinatorStub) SetNodesPerShards(_ map[uint32][]sharding.Validator, _ map[uint32][]sharding.Validator, _ []sharding.Validator, _ uint32) error

SetNodesPerShards -

func (*NodesCoordinatorStub) ShardIdForEpoch added in v1.0.102 

func (ncm *NodesCoordinatorStub) ShardIdForEpoch(_ uint32) (uint32, error)

ShardIdForEpoch returns the nodesCoordinator configured ShardId for specified epoch if epoch configuration exists, otherwise error

func (*NodesCoordinatorStub) ShuffleOutForEpoch added in v1.0.111 

func (ncm *NodesCoordinatorStub) ShuffleOutForEpoch(_ uint32)

ShuffleOutForEpoch verifies if the shards changed in the new epoch and calls the shuffleOutHandler

func (*NodesCoordinatorStub) ValidatorsWeights added in v1.0.102 

func (ncm *NodesCoordinatorStub) ValidatorsWeights(_ []sharding.Validator) ([]uint32, error)

ValidatorsWeights -

type NodesSetupStub added in v1.0.104 

type NodesSetupStub struct {
	InitialNodesInfoForShardCalled   func(shardId uint32) ([]sharding.GenesisNodeInfoHandler, []sharding.GenesisNodeInfoHandler, error)
	InitialNodesInfoCalled           func() (map[uint32][]sharding.GenesisNodeInfoHandler, map[uint32][]sharding.GenesisNodeInfoHandler)
	GetStartTimeCalled               func() int64
	GetRoundDurationCalled           func() uint64
	GetChainIdCalled                 func() string
	GetShardConsensusGroupSizeCalled func() uint32
	GetMetaConsensusGroupSizeCalled  func() uint32
	NumberOfShardsCalled             func() uint32
	MinNumberOfNodesCalled           func() uint32
}

NodesSetupStub -

func (*NodesSetupStub) GetChainId added in v1.0.104 

func (n *NodesSetupStub) GetChainId() string

GetChainId -

func (*NodesSetupStub) GetMetaConsensusGroupSize added in v1.0.104 

func (n *NodesSetupStub) GetMetaConsensusGroupSize() uint32

GetMetaConsensusGroupSize -

func (*NodesSetupStub) GetRoundDuration added in v1.0.104 

func (n *NodesSetupStub) GetRoundDuration() uint64

GetRoundDuration -

func (*NodesSetupStub) GetShardConsensusGroupSize added in v1.0.104 

func (n *NodesSetupStub) GetShardConsensusGroupSize() uint32

GetShardConsensusGroupSize -

func (*NodesSetupStub) GetStartTime added in v1.0.104 

func (n *NodesSetupStub) GetStartTime() int64

GetStartTime -

func (*NodesSetupStub) InitialNodesInfo added in v1.0.104 

func (n *NodesSetupStub) InitialNodesInfo() (map[uint32][]sharding.GenesisNodeInfoHandler, map[uint32][]sharding.GenesisNodeInfoHandler)

InitialNodesInfo -

func (*NodesSetupStub) InitialNodesInfoForShard added in v1.0.104 

func (n *NodesSetupStub) InitialNodesInfoForShard(shardId uint32) ([]sharding.GenesisNodeInfoHandler, []sharding.GenesisNodeInfoHandler, error)

InitialNodesInfoForShard -

func (*NodesSetupStub) IsInterfaceNil added in v1.0.104 

func (n *NodesSetupStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*NodesSetupStub) MinNumberOfNodes added in v1.0.110 

func (n *NodesSetupStub) MinNumberOfNodes() uint32

MinNumberOfNodes -

func (*NodesSetupStub) NumberOfShards added in v1.0.104 

func (n *NodesSetupStub) NumberOfShards() uint32

NumberOfShards -

type PathManagerStub added in v1.0.104 

type PathManagerStub struct {
	PathForEpochCalled  func(shardId string, epoch uint32, identifier string) string
	PathForStaticCalled func(shardId string, identifier string) string
}

PathManagerStub -

func (*PathManagerStub) IsInterfaceNil added in v1.0.104 

func (p *PathManagerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*PathManagerStub) PathForEpoch added in v1.0.104 

func (p *PathManagerStub) PathForEpoch(shardId string, epoch uint32, identifier string) string

PathForEpoch -

func (*PathManagerStub) PathForStatic added in v1.0.104 

func (p *PathManagerStub) PathForStatic(shardId string, identifier string) string

PathForStatic -

type PendingMiniBlockSyncHandlerStub added in v1.0.104 

type PendingMiniBlockSyncHandlerStub struct {
	SyncPendingMiniBlocksCalled func(miniBlockHeaders []block.MiniBlockHeader, ctx context.Context) error
	GetMiniBlocksCalled         func() (map[string]*block.MiniBlock, error)
}

PendingMiniBlockSyncHandlerStub -

func (*PendingMiniBlockSyncHandlerStub) ClearFields added in v1.0.104 

func (pm *PendingMiniBlockSyncHandlerStub) ClearFields()

ClearFields --

func (*PendingMiniBlockSyncHandlerStub) GetMiniBlocks added in v1.0.104 

func (pm *PendingMiniBlockSyncHandlerStub) GetMiniBlocks() (map[string]*block.MiniBlock, error)

GetMiniBlocks -

func (*PendingMiniBlockSyncHandlerStub) IsInterfaceNil added in v1.0.104 

func (pm *PendingMiniBlockSyncHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*PendingMiniBlockSyncHandlerStub) SyncPendingMiniBlocks added in v1.0.104 

func (pm *PendingMiniBlockSyncHandlerStub) SyncPendingMiniBlocks(miniBlockHeaders []block.MiniBlockHeader, ctx context.Context) error

SyncPendingMiniBlocks -

type PoolsHolderStub 

type PoolsHolderStub struct {
	HeadersCalled              func() dataRetriever.HeadersPool
	PeerChangesBlocksCalled    func() storage.Cacher
	TransactionsCalled         func() dataRetriever.ShardedDataCacherNotifier
	UnsignedTransactionsCalled func() dataRetriever.ShardedDataCacherNotifier
	RewardTransactionsCalled   func() dataRetriever.ShardedDataCacherNotifier
	MiniBlocksCalled           func() storage.Cacher
	TrieNodesCalled            func() storage.Cacher
	CurrBlockTxsCalled         func() dataRetriever.TransactionCacher
}

PoolsHolderStub -

func (*PoolsHolderStub) CurrentBlockTxs 

func (phs *PoolsHolderStub) CurrentBlockTxs() dataRetriever.TransactionCacher

CurrentBlockTxs -

func (*PoolsHolderStub) Headers 

func (phs *PoolsHolderStub) Headers() dataRetriever.HeadersPool

Headers -

func (*PoolsHolderStub) IsInterfaceNil 

func (phs *PoolsHolderStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PoolsHolderStub) MiniBlocks 

func (phs *PoolsHolderStub) MiniBlocks() storage.Cacher

MiniBlocks -

func (*PoolsHolderStub) PeerChangesBlocks 

func (phs *PoolsHolderStub) PeerChangesBlocks() storage.Cacher

PeerChangesBlocks -

func (*PoolsHolderStub) RewardTransactions 

func (phs *PoolsHolderStub) RewardTransactions() dataRetriever.ShardedDataCacherNotifier

RewardTransactions -

func (*PoolsHolderStub) Transactions 

func (phs *PoolsHolderStub) Transactions() dataRetriever.ShardedDataCacherNotifier

Transactions -

func (*PoolsHolderStub) TrieNodes 

func (phs *PoolsHolderStub) TrieNodes() storage.Cacher

TrieNodes -

func (*PoolsHolderStub) UnsignedTransactions 

func (phs *PoolsHolderStub) UnsignedTransactions() dataRetriever.ShardedDataCacherNotifier

UnsignedTransactions -

type PrivateKeyMock added in v1.0.104 

type PrivateKeyMock struct {
}

PrivateKeyMock -

func (*PrivateKeyMock) GeneratePublic added in v1.0.104 

func (sk *PrivateKeyMock) GeneratePublic() crypto.PublicKey

GeneratePublic -

func (*PrivateKeyMock) IsInterfaceNil added in v1.0.104 

func (sk *PrivateKeyMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PrivateKeyMock) Scalar added in v1.0.104 

func (sk *PrivateKeyMock) Scalar() crypto.Scalar

Scalar -

func (*PrivateKeyMock) Suite added in v1.0.104 

func (sk *PrivateKeyMock) Suite() crypto.Suite

Suite -

func (*PrivateKeyMock) ToByteArray added in v1.0.104 

func (sk *PrivateKeyMock) ToByteArray() ([]byte, error)

ToByteArray -

type PrivateKeyStub added in v1.0.104 

type PrivateKeyStub struct {
	ToByteArrayStub    func() ([]byte, error)
	GeneratePublicStub func() crypto.PublicKey
	ScalarStub         func() crypto.Scalar
	SuiteStub          func() crypto.Suite
}

PrivateKeyStub provides stubs for a PrivateKey implementation

func (*PrivateKeyStub) GeneratePublic added in v1.0.104 

func (privKey *PrivateKeyStub) GeneratePublic() crypto.PublicKey

GeneratePublic builds a public key for the current private key

func (*PrivateKeyStub) IsInterfaceNil added in v1.0.104 

func (privKey *PrivateKeyStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PrivateKeyStub) Scalar added in v1.0.104 

func (privKey *PrivateKeyStub) Scalar() crypto.Scalar

Scalar returns the Scalar corresponding to this Private Key

func (*PrivateKeyStub) Suite added in v1.0.104 

func (privKey *PrivateKeyStub) Suite() crypto.Suite

Suite returns the Suite (curve data) used for this private key

func (*PrivateKeyStub) ToByteArray added in v1.0.104 

func (privKey *PrivateKeyStub) ToByteArray() ([]byte, error)

ToByteArray returns the byte array representation of the private key

type PubkeyConverterMock added in v1.0.104 

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

PubkeyConverterMock -

func NewPubkeyConverterMock added in v1.0.104 

func NewPubkeyConverterMock(addressLen int) *PubkeyConverterMock

NewPubkeyConverterMock -

func (*PubkeyConverterMock) Decode added in v1.0.104 

func (pcm *PubkeyConverterMock) Decode(humanReadable string) ([]byte, error)

Decode -

func (*PubkeyConverterMock) Encode added in v1.0.104 

func (pcm *PubkeyConverterMock) Encode(pkBytes []byte) string

Encode -

func (*PubkeyConverterMock) IsInterfaceNil added in v1.0.104 

func (pcm *PubkeyConverterMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*PubkeyConverterMock) Len added in v1.0.104 

func (pcm *PubkeyConverterMock) Len() int

Len -

type PublicKeyMock added in v1.0.104 

type PublicKeyMock struct {
}

PublicKeyMock -

func (*PublicKeyMock) IsInterfaceNil added in v1.0.104 

func (sspk *PublicKeyMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PublicKeyMock) Point added in v1.0.104 

func (sspk *PublicKeyMock) Point() crypto.Point

Point -

func (*PublicKeyMock) Suite added in v1.0.104 

func (sspk *PublicKeyMock) Suite() crypto.Suite

Suite -

func (*PublicKeyMock) ToByteArray added in v1.0.104 

func (sspk *PublicKeyMock) ToByteArray() ([]byte, error)

ToByteArray -

type PublicKeyStub added in v1.0.104 

type PublicKeyStub struct {
	ToByteArrayStub func() ([]byte, error)
	PointStub       func() crypto.Point
	SuiteStub       func() crypto.Suite
}

PublicKeyStub provides stubs for a PublicKey implementation

func (*PublicKeyStub) IsInterfaceNil added in v1.0.104 

func (pubKey *PublicKeyStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PublicKeyStub) Point added in v1.0.104 

func (pubKey *PublicKeyStub) Point() crypto.Point

Point returns the Point corresponding to this Public Key

func (*PublicKeyStub) Suite added in v1.0.104 

func (pubKey *PublicKeyStub) Suite() crypto.Suite

Suite returns the Suite (curve data) used for this private key

func (*PublicKeyStub) ToByteArray added in v1.0.104 

func (pubKey *PublicKeyStub) ToByteArray() ([]byte, error)

ToByteArray returns the byte array representation of the public key

type RaterStub added in v1.0.104 

type RaterStub struct {
	GetRatingCalled                func(string) uint32
	GetStartRatingCalled           func() uint32
	GetSignedBlocksThresholdCalled func() float32
	ComputeIncreaseProposerCalled  func(shardId uint32, rating uint32) uint32
	ComputeDecreaseProposerCalled  func(shardId uint32, rating uint32, consecutiveMissedBlocks uint32) uint32
	RevertIncreaseProposerCalled   func(shardId uint32, rating uint32, nrReverts uint32) uint32
	ComputeIncreaseValidatorCalled func(shardId uint32, rating uint32) uint32
	ComputeDecreaseValidatorCalled func(shardId uint32, rating uint32) uint32
	GetChanceCalled                func(rating uint32) uint32
}

RaterStub -

func (*RaterStub) ComputeDecreaseProposer added in v1.0.104 

func (rm *RaterStub) ComputeDecreaseProposer(shardId uint32, currentRating uint32, consecutiveMisses uint32) uint32

ComputeDecreaseProposer -

func (*RaterStub) ComputeDecreaseValidator added in v1.0.104 

func (rm *RaterStub) ComputeDecreaseValidator(shardId uint32, currentRating uint32) uint32

ComputeDecreaseValidator -

func (*RaterStub) ComputeIncreaseProposer added in v1.0.104 

func (rm *RaterStub) ComputeIncreaseProposer(shardId uint32, currentRating uint32) uint32

ComputeIncreaseProposer -

func (*RaterStub) ComputeIncreaseValidator added in v1.0.104 

func (rm *RaterStub) ComputeIncreaseValidator(shardId uint32, currentRating uint32) uint32

ComputeIncreaseValidator -

func (*RaterStub) GetChance added in v1.0.104 

func (rm *RaterStub) GetChance(rating uint32) uint32

GetChance -

func (*RaterStub) GetRating added in v1.0.104 

func (rm *RaterStub) GetRating(pk string) uint32

GetRating -

func (*RaterStub) GetSignedBlocksThreshold added in v1.0.104 

func (rm *RaterStub) GetSignedBlocksThreshold() float32

GetSignedBlocksThreshold -

func (*RaterStub) GetStartRating added in v1.0.104 

func (rm *RaterStub) GetStartRating() uint32

GetStartRating -

func (*RaterStub) IsInterfaceNil added in v1.0.104 

func (rm *RaterStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*RaterStub) RevertIncreaseValidator added in v1.0.104 

func (rm *RaterStub) RevertIncreaseValidator(shardId uint32, currentRating uint32, nrReverts uint32) uint32

RevertIncreaseValidator -

type RequestHandlerStub 

type RequestHandlerStub struct {
	RequestShardHeaderCalled           func(shardId uint32, hash []byte)
	RequestMetaHeaderCalled            func(hash []byte)
	RequestMetaHeaderByNonceCalled     func(nonce uint64)
	RequestShardHeaderByNonceCalled    func(shardId uint32, nonce uint64)
	RequestTransactionHandlerCalled    func(destShardID uint32, txHashes [][]byte)
	RequestScrHandlerCalled            func(destShardID uint32, txHashes [][]byte)
	RequestRewardTxHandlerCalled       func(destShardID uint32, txHashes [][]byte)
	RequestMiniBlocksHandlerCalled     func(destShardID uint32, miniblockHashes [][]byte)
	RequestStartOfEpochMetaBlockCalled func(epoch uint32)
	SetNumPeersToQueryCalled           func(key string, intra int, cross int) error
	GetNumPeersToQueryCalled           func(key string) (int, int, error)
}

RequestHandlerStub -

func (*RequestHandlerStub) GetNumPeersToQuery added in v1.0.102 

func (rhs *RequestHandlerStub) GetNumPeersToQuery(key string) (int, int, error)

GetNumPeersToQuery -

func (*RequestHandlerStub) IsInterfaceNil 

func (rhs *RequestHandlerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*RequestHandlerStub) RequestInterval added in v1.0.102 

func (rhs *RequestHandlerStub) RequestInterval() time.Duration

RequestInterval -

func (*RequestHandlerStub) RequestMetaHeader 

func (rhs *RequestHandlerStub) RequestMetaHeader(hash []byte)

RequestMetaHeader -

func (*RequestHandlerStub) RequestMetaHeaderByNonce 

func (rhs *RequestHandlerStub) RequestMetaHeaderByNonce(nonce uint64)

RequestMetaHeaderByNonce -

func (*RequestHandlerStub) RequestMiniBlock added in v1.0.67 

func (rhs *RequestHandlerStub) RequestMiniBlock(_ uint32, _ []byte)

RequestMiniBlock -

func (*RequestHandlerStub) RequestMiniBlocks 

func (rhs *RequestHandlerStub) RequestMiniBlocks(shardId uint32, miniblockHashes [][]byte)

RequestMiniBlock -

func (*RequestHandlerStub) RequestRewardTransactions 

func (rhs *RequestHandlerStub) RequestRewardTransactions(destShardID uint32, txHashes [][]byte)

RequestRewardTransactions -

func (*RequestHandlerStub) RequestShardHeader 

func (rhs *RequestHandlerStub) RequestShardHeader(shardId uint32, hash []byte)

RequestShardHeader -

func (*RequestHandlerStub) RequestShardHeaderByNonce 

func (rhs *RequestHandlerStub) RequestShardHeaderByNonce(shardId uint32, nonce uint64)

RequestShardHeaderByNonce -

func (*RequestHandlerStub) RequestStartOfEpochMetaBlock 

func (rhs *RequestHandlerStub) RequestStartOfEpochMetaBlock(epoch uint32)

RequestStartOfEpochMetaBlock -

func (*RequestHandlerStub) RequestTransaction 

func (rhs *RequestHandlerStub) RequestTransaction(destShardID uint32, txHashes [][]byte)

RequestTransaction -

func (*RequestHandlerStub) RequestTrieNodes added in v1.0.102 

func (rhs *RequestHandlerStub) RequestTrieNodes(_ uint32, _ [][]byte, _ string)

RequestTrieNodes -

func (*RequestHandlerStub) RequestUnsignedTransactions 

func (rhs *RequestHandlerStub) RequestUnsignedTransactions(destShardID uint32, txHashes [][]byte)

RequestUnsignedTransactions -

func (*RequestHandlerStub) SetEpoch added in v1.0.102 

func (rhs *RequestHandlerStub) SetEpoch(_ uint32)

SetEpoch -

func (*RequestHandlerStub) SetNumPeersToQuery added in v1.0.102 

func (rhs *RequestHandlerStub) SetNumPeersToQuery(key string, intra int, cross int) error

SetNumPeersToQuery -

type RewardsHandlerStub added in v1.0.102 

type RewardsHandlerStub struct {
	LeaderPercentageCalled    func() float64
	CommunityPercentageCalled func() float64
	CommunityAddressCalled    func() string
	MinInflationRateCalled    func() float64
	MaxInflationRateCalled    func() float64
}

RewardsHandlerStub -

func (*RewardsHandlerStub) CommunityAddress added in v1.0.113 

func (r *RewardsHandlerStub) CommunityAddress() string

CommunityAddress will return the community address

func (*RewardsHandlerStub) CommunityPercentage added in v1.0.113 

func (r *RewardsHandlerStub) CommunityPercentage() float64

CommunityPercentage will return the community percentage value

func (*RewardsHandlerStub) IsInterfaceNil added in v1.0.102 

func (r *RewardsHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*RewardsHandlerStub) LeaderPercentage added in v1.0.102 

func (r *RewardsHandlerStub) LeaderPercentage() float64

LeaderPercentage -

func (*RewardsHandlerStub) MaxInflationRate added in v1.0.102 

func (r *RewardsHandlerStub) MaxInflationRate() float64

MaxInflationRate -

func (*RewardsHandlerStub) MinInflationRate added in v1.0.102 

func (r *RewardsHandlerStub) MinInflationRate() float64

MinInflationRate -

type RoundTimeDurationHandler added in v1.0.102 

type RoundTimeDurationHandler struct {
	TimeDurationCalled func() time.Duration
}

RoundTimeDurationHandler -

func (*RoundTimeDurationHandler) IsInterfaceNil added in v1.0.102 

func (r *RoundTimeDurationHandler) IsInterfaceNil() bool

IsInterfaceNil -

func (*RoundTimeDurationHandler) TimeDuration added in v1.0.102 

func (r *RoundTimeDurationHandler) TimeDuration() time.Duration

TimeDuration -

type RounderStub 

type RounderStub struct {
	RoundIndex int64

	IndexCalled         func() int64
	TimeDurationCalled  func() time.Duration
	TimeStampCalled     func() time.Time
	UpdateRoundCalled   func(time.Time, time.Time)
	RemainingTimeCalled func(startTime time.Time, maxTime time.Duration) time.Duration
}

RounderStub -

func (*RounderStub) Index 

func (rndm *RounderStub) Index() int64

Index -

func (*RounderStub) IsInterfaceNil 

func (rndm *RounderStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*RounderStub) RemainingTime 

func (rndm *RounderStub) RemainingTime(startTime time.Time, maxTime time.Duration) time.Duration

RemainingTime -

func (*RounderStub) TimeDuration 

func (rndm *RounderStub) TimeDuration() time.Duration

TimeDuration -

func (*RounderStub) TimeStamp 

func (rndm *RounderStub) TimeStamp() time.Time

TimeStamp -

func (*RounderStub) UpdateRound 

func (rndm *RounderStub) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time)

UpdateRound -

type ShardCoordinatorStub added in v1.0.104 

type ShardCoordinatorStub struct {
	NumberOfShardsCalled          func() uint32
	ComputeIdCalled               func(address []byte) uint32
	SelfIdCalled                  func() uint32
	SameShardCalled               func(firstAddress, secondAddress []byte) bool
	CommunicationIdentifierCalled func(destShardID uint32) string
}

ShardCoordinatorStub -

func (*ShardCoordinatorStub) CommunicationIdentifier added in v1.0.104 

func (coordinator *ShardCoordinatorStub) CommunicationIdentifier(destShardID uint32) string

CommunicationIdentifier -

func (*ShardCoordinatorStub) ComputeId added in v1.0.104 

func (coordinator *ShardCoordinatorStub) ComputeId(address []byte) uint32

ComputeId -

func (*ShardCoordinatorStub) IsInterfaceNil added in v1.0.104 

func (coordinator *ShardCoordinatorStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ShardCoordinatorStub) NumberOfShards added in v1.0.104 

func (coordinator *ShardCoordinatorStub) NumberOfShards() uint32

NumberOfShards -

func (*ShardCoordinatorStub) SameShard added in v1.0.104 

func (coordinator *ShardCoordinatorStub) SameShard(firstAddress, secondAddress []byte) bool

SameShard -

func (*ShardCoordinatorStub) SelfId added in v1.0.104 

func (coordinator *ShardCoordinatorStub) SelfId() uint32

SelfId -

type ShardIdHasMapStub 

type ShardIdHasMapStub struct {
	LoadCalled   func(shardId uint32) ([]byte, bool)
	StoreCalled  func(shardId uint32, hash []byte)
	RangeCalled  func(f func(shardId uint32, hash []byte) bool)
	DeleteCalled func(shardId uint32)
}

ShardIdHasMapStub -

func (*ShardIdHasMapStub) Delete 

func (sihsm *ShardIdHasMapStub) Delete(shardId uint32)

Delete -

func (*ShardIdHasMapStub) IsInterfaceNil 

func (sihsm *ShardIdHasMapStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ShardIdHasMapStub) Load 

func (sihsm *ShardIdHasMapStub) Load(shardId uint32) ([]byte, bool)

Load -

func (*ShardIdHasMapStub) Range 

func (sihsm *ShardIdHasMapStub) Range(f func(shardId uint32, hash []byte) bool)

Range -

func (*ShardIdHasMapStub) Store 

func (sihsm *ShardIdHasMapStub) Store(shardId uint32, hash []byte)

Store -

type ShardedDataStub added in v1.0.104 

type ShardedDataStub struct {
	RegisterHandlerCalled                  func(func(key []byte, value interface{}))
	ShardDataStoreCalled                   func(cacheId string) (c storage.Cacher)
	AddDataCalled                          func(key []byte, data interface{}, sizeInBytes int, cacheId string)
	SearchFirstDataCalled                  func(key []byte) (value interface{}, ok bool)
	RemoveDataCalled                       func(key []byte, cacheId string)
	RemoveDataFromAllShardsCalled          func(key []byte)
	MergeShardStoresCalled                 func(sourceCacheId, destCacheId string)
	MoveDataCalled                         func(sourceCacheId, destCacheId string, key [][]byte)
	ClearCalled                            func()
	ClearShardStoreCalled                  func(cacheId string)
	RemoveSetOfDataFromPoolCalled          func(keys [][]byte, destCacheId string)
	ImmunizeSetOfDataAgainstEvictionCalled func(keys [][]byte, cacheId string)
	CreateShardStoreCalled                 func(destCacheId string)
}

ShardedDataStub -

func (*ShardedDataStub) AddData added in v1.0.104 

func (sd *ShardedDataStub) AddData(key []byte, data interface{}, sizeInBytes int, cacheId string)

AddData -

func (*ShardedDataStub) Clear added in v1.0.104 

func (sd *ShardedDataStub) Clear()

Clear -

func (*ShardedDataStub) ClearShardStore added in v1.0.104 

func (sd *ShardedDataStub) ClearShardStore(cacheId string)

ClearShardStore -

func (*ShardedDataStub) CreateShardStore added in v1.0.104 

func (sd *ShardedDataStub) CreateShardStore(cacheId string)

CreateShardStore -

func (*ShardedDataStub) ImmunizeSetOfDataAgainstEviction added in v1.0.123 

func (sd *ShardedDataStub) ImmunizeSetOfDataAgainstEviction(keys [][]byte, cacheId string)

ImmunizeSetOfDataAgainstEviction -

func (*ShardedDataStub) IsInterfaceNil added in v1.0.104 

func (sd *ShardedDataStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ShardedDataStub) MergeShardStores added in v1.0.104 

func (sd *ShardedDataStub) MergeShardStores(sourceCacheId, destCacheId string)

MergeShardStores -

func (*ShardedDataStub) RegisterHandler added in v1.0.104 

func (sd *ShardedDataStub) RegisterHandler(handler func(key []byte, value interface{}))

RegisterHandler -

func (*ShardedDataStub) RemoveData added in v1.0.104 

func (sd *ShardedDataStub) RemoveData(key []byte, cacheId string)

RemoveData -

func (*ShardedDataStub) RemoveDataFromAllShards added in v1.0.104 

func (sd *ShardedDataStub) RemoveDataFromAllShards(key []byte)

RemoveDataFromAllShards -

func (*ShardedDataStub) RemoveSetOfDataFromPool added in v1.0.104 

func (sd *ShardedDataStub) RemoveSetOfDataFromPool(keys [][]byte, cacheId string)

RemoveSetOfDataFromPool -

func (*ShardedDataStub) SearchFirstData added in v1.0.104 

func (sd *ShardedDataStub) SearchFirstData(key []byte) (value interface{}, ok bool)

SearchFirstData -

func (*ShardedDataStub) ShardDataStore added in v1.0.104 

func (sd *ShardedDataStub) ShardDataStore(cacheId string) (c storage.Cacher)

ShardDataStore -

type SignerStub added in v1.0.104 

type SignerStub struct {
	SignCalled   func(private crypto.PrivateKey, msg []byte) ([]byte, error)
	VerifyCalled func(public crypto.PublicKey, msg []byte, sig []byte) error
}

SignerStub -

func (*SignerStub) IsInterfaceNil added in v1.0.104 

func (s *SignerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*SignerStub) Sign added in v1.0.104 

func (s *SignerStub) Sign(private crypto.PrivateKey, msg []byte) ([]byte, error)

Sign -

func (*SignerStub) Verify added in v1.0.104 

func (s *SignerStub) Verify(public crypto.PublicKey, msg []byte, sig []byte) error

Verify -

type StorageManagerStub added in v1.0.104 

type StorageManagerStub struct {
	DatabaseCalled                    func() data.DBWriteCacher
	TakeSnapshotCalled                func([]byte)
	SetCheckpointCalled               func([]byte)
	PruneCalled                       func([]byte)
	CancelPruneCalled                 func([]byte)
	MarkForEvictionCalled             func([]byte, data.ModifiedHashes) error
	GetDbThatContainsHashCalled       func([]byte) data.DBWriteCacher
	GetSnapshotThatContainsHashCalled func(rootHash []byte) data.DBWriteCacher
	IsPruningEnabledCalled            func() bool
	EnterSnapshotModeCalled           func()
	ExitSnapshotModeCalled            func()
	IsInterfaceNilCalled              func() bool
}

StorageManagerStub --

func (*StorageManagerStub) CancelPrune added in v1.0.104 

func (sms *StorageManagerStub) CancelPrune([]byte, data.TriePruningIdentifier)

CancelPrune --

func (*StorageManagerStub) Database added in v1.0.104 

func (sms *StorageManagerStub) Database() data.DBWriteCacher

Database --

func (*StorageManagerStub) EnterSnapshotMode added in v1.0.104 

func (sms *StorageManagerStub) EnterSnapshotMode()

EnterSnapshotMode --

func (*StorageManagerStub) ExitSnapshotMode added in v1.0.104 

func (sms *StorageManagerStub) ExitSnapshotMode()

ExitSnapshotMode --

func (*StorageManagerStub) GetDbThatContainsHash added in v1.0.104 

func (sms *StorageManagerStub) GetDbThatContainsHash(d []byte) data.DBWriteCacher

GetDbThatContainsHash --

func (*StorageManagerStub) GetSnapshotThatContainsHash added in v1.0.129 

func (sms *StorageManagerStub) GetSnapshotThatContainsHash(d []byte) data.DBWriteCacher

GetSnapshotThatContainsHash --

func (*StorageManagerStub) IsInterfaceNil added in v1.0.104 

func (sms *StorageManagerStub) IsInterfaceNil() bool

IsInterfaceNil --

func (*StorageManagerStub) IsPruningEnabled added in v1.0.104 

func (sms *StorageManagerStub) IsPruningEnabled() bool

IsPruningEnabled --

func (*StorageManagerStub) MarkForEviction added in v1.0.104 

func (sms *StorageManagerStub) MarkForEviction(d []byte, m data.ModifiedHashes) error

MarkForEviction --

func (*StorageManagerStub) Prune added in v1.0.104 

func (sms *StorageManagerStub) Prune([]byte, data.TriePruningIdentifier)

Prune --

func (*StorageManagerStub) SetCheckpoint added in v1.0.104 

func (sms *StorageManagerStub) SetCheckpoint([]byte)

SetCheckpoint --

func (*StorageManagerStub) TakeSnapshot added in v1.0.104 

func (sms *StorageManagerStub) TakeSnapshot([]byte)

TakeSnapshot --

type StorerMock 

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

StorerMock -

func NewStorerMock 

func NewStorerMock() *StorerMock

NewStorerMock -

func (*StorerMock) ClearCache 

func (sm *StorerMock) ClearCache()

ClearCache -

func (*StorerMock) Close 

func (sm *StorerMock) Close() error

Close -

func (*StorerMock) DestroyUnit 

func (sm *StorerMock) DestroyUnit() error

DestroyUnit -

func (*StorerMock) Get 

func (sm *StorerMock) Get(key []byte) ([]byte, error)

Get -

func (*StorerMock) GetFromEpoch 

func (sm *StorerMock) GetFromEpoch(key []byte, _ uint32) ([]byte, error)

GetFromEpoch -

func (*StorerMock) Has 

func (sm *StorerMock) Has(key []byte) error

Has -

func (*StorerMock) HasInEpoch 

func (sm *StorerMock) HasInEpoch(key []byte, epoch uint32) error

HasInEpoch -

func (*StorerMock) IsInterfaceNil 

func (sm *StorerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*StorerMock) Put 

func (sm *StorerMock) Put(key, data []byte) error

Put -

func (*StorerMock) Remove 

func (sm *StorerMock) Remove(key []byte) error

Remove -

func (*StorerMock) SearchFirst 

func (sm *StorerMock) SearchFirst(key []byte) ([]byte, error)

SearchFirst -

type StorerStub 

type StorerStub struct {
	PutCalled          func(key, data []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
	SearchFirstCalled  func(key []byte) ([]byte, error)
	RemoveCalled       func(key []byte) error
	ClearCacheCalled   func()
	DestroyUnitCalled  func() error
}

StorerStub -

func (*StorerStub) ClearCache 

func (ss *StorerStub) ClearCache()

ClearCache -

func (*StorerStub) Close 

func (ss *StorerStub) Close() error

Close -

func (*StorerStub) DestroyUnit 

func (ss *StorerStub) DestroyUnit() error

DestroyUnit -

func (*StorerStub) Get 

func (ss *StorerStub) Get(key []byte) ([]byte, error)

Get -

func (*StorerStub) GetFromEpoch 

func (ss *StorerStub) GetFromEpoch(key []byte, epoch uint32) ([]byte, error)

GetFromEpoch -

func (*StorerStub) Has 

func (ss *StorerStub) Has(key []byte) error

Has -

func (*StorerStub) HasInEpoch 

func (ss *StorerStub) HasInEpoch(key []byte, epoch uint32) error

HasInEpoch -

func (*StorerStub) IsInterfaceNil 

func (ss *StorerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*StorerStub) Put 

func (ss *StorerStub) Put(key, data []byte) error

Put -

func (*StorerStub) Remove 

func (ss *StorerStub) Remove(key []byte) error

Remove -

func (*StorerStub) SearchFirst 

func (ss *StorerStub) SearchFirst(key []byte) ([]byte, error)

SearchFirst -

type SyncTimerStub 

type SyncTimerStub struct {
	StartSyncingTimeCalled     func()
	ClockOffsetCalled          func() time.Duration
	FormattedCurrentTimeCalled func() string
	CurrentTimeCalled          func() time.Time
}

SyncTimerStub is a mock implementation of SyncTimer interface

func (*SyncTimerStub) ClockOffset 

func (sts *SyncTimerStub) ClockOffset() time.Duration

ClockOffset is a mock implementation for ClockOffset

func (*SyncTimerStub) Close added in v1.0.116 

func (sts *SyncTimerStub) Close() error

Close -

func (*SyncTimerStub) CurrentTime 

func (sts *SyncTimerStub) CurrentTime() time.Time

CurrentTime is a mock implementation for CurrentTime

func (*SyncTimerStub) FormattedCurrentTime 

func (sts *SyncTimerStub) FormattedCurrentTime() string

FormattedCurrentTime is a mock implementation for FormattedCurrentTime

func (*SyncTimerStub) IsInterfaceNil 

func (sts *SyncTimerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*SyncTimerStub) StartSyncingTime added in v1.0.116 

func (sts *SyncTimerStub) StartSyncingTime()

StartSyncingTime is a mock implementation for StartSyncingTime

type TrieStub added in v1.0.104 

type TrieStub struct {
	GetCalled                func(key []byte) ([]byte, error)
	UpdateCalled             func(key, value []byte) error
	DeleteCalled             func(key []byte) error
	RootCalled               func() ([]byte, error)
	CommitCalled             func() error
	RecreateCalled           func(root []byte) (data.Trie, error)
	CancelPruneCalled        func(rootHash []byte, identifier data.TriePruningIdentifier)
	PruneCalled              func(rootHash []byte, identifier data.TriePruningIdentifier)
	ResetOldHashesCalled     func() [][]byte
	AppendToOldHashesCalled  func([][]byte)
	TakeSnapshotCalled       func(rootHash []byte)
	SetCheckpointCalled      func(rootHash []byte)
	GetSerializedNodesCalled func([]byte, uint64) ([][]byte, uint64, error)
	DatabaseCalled           func() data.DBWriteCacher
	GetAllLeavesCalled       func() (map[string][]byte, error)
	IsPruningEnabledCalled   func() bool
	ClosePersisterCalled     func() error
}

TrieStub -

func (*TrieStub) AppendToOldHashes added in v1.0.104 

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

AppendToOldHashes appends the given hashes to the trie's oldHashes variable

func (*TrieStub) CancelPrune added in v1.0.104 

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

CancelPrune invalidates the hashes that correspond to the given root hash from the eviction waiting list

func (*TrieStub) ClosePersister added in v1.0.104 

func (ts *TrieStub) ClosePersister() error

ClosePersister -

func (*TrieStub) Commit added in v1.0.104 

func (ts *TrieStub) Commit() error

Commit -

func (*TrieStub) Database added in v1.0.104 

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

Database -

func (*TrieStub) Delete added in v1.0.104 

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

Delete -

func (*TrieStub) EnterSnapshotMode added in v1.0.104 

func (ts *TrieStub) EnterSnapshotMode()

EnterSnapshotMode -

func (*TrieStub) ExitSnapshotMode added in v1.0.104 

func (ts *TrieStub) ExitSnapshotMode()

ExitSnapshotMode -

func (*TrieStub) Get added in v1.0.104 

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

Get -

func (*TrieStub) GetAllLeaves added in v1.0.104 

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

GetAllLeaves -

func (*TrieStub) GetDirtyHashes added in v1.0.111 

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

GetDirtyHashes -

func (*TrieStub) GetSerializedNodes added in v1.0.104 

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

GetSerializedNodes -

func (*TrieStub) IsInterfaceNil added in v1.0.104 

func (ts *TrieStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*TrieStub) IsPruningEnabled added in v1.0.104 

func (ts *TrieStub) IsPruningEnabled() bool

IsPruningEnabled -

func (*TrieStub) Prune added in v1.0.104 

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

Prune removes from the database all the old hashes that correspond to the given root hash

func (*TrieStub) Recreate added in v1.0.104 

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

Recreate -

func (*TrieStub) ResetOldHashes added in v1.0.104 

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

ResetOldHashes resets the oldHashes and oldRoot variables and returns the old hashes

func (*TrieStub) Root added in v1.0.104 

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

Root -

func (*TrieStub) SetCheckpoint added in v1.0.104 

func (ts *TrieStub) SetCheckpoint(rootHash []byte)

SetCheckpoint -

func (*TrieStub) SetNewHashes added in v1.0.111 

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

SetNewHashes -

func (*TrieStub) String added in v1.0.104 

func (ts *TrieStub) String() string

String -

func (*TrieStub) TakeSnapshot added in v1.0.104 

func (ts *TrieStub) TakeSnapshot(rootHash []byte)

TakeSnapshot -

func (*TrieStub) Update added in v1.0.104 

func (ts *TrieStub) Update(key, value []byte) error

Update -

type TriesHolderMock added in v1.0.104 

type TriesHolderMock struct {
	PutCalled    func([]byte, data.Trie)
	RemoveCalled func([]byte, data.Trie)
	GetCalled    func([]byte) data.Trie
	GetAllCalled func() []data.Trie
	ResetCalled  func()
}

TriesHolderMock -

func (*TriesHolderMock) Get added in v1.0.104 

func (thm *TriesHolderMock) Get(key []byte) data.Trie

Get -

func (*TriesHolderMock) GetAll added in v1.0.104 

func (thm *TriesHolderMock) GetAll() []data.Trie

GetAll -

func (*TriesHolderMock) IsInterfaceNil added in v1.0.104 

func (thm *TriesHolderMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*TriesHolderMock) Put added in v1.0.104 

func (thm *TriesHolderMock) Put(key []byte, trie data.Trie)

Put -

func (*TriesHolderMock) Replace added in v1.0.104 

func (thm *TriesHolderMock) Replace(key []byte, trie data.Trie)

Replace -

func (*TriesHolderMock) Reset added in v1.0.104 

func (thm *TriesHolderMock) Reset()

Reset -

type Uint64ByteSliceConverterMock 

type Uint64ByteSliceConverterMock struct {
	ToByteSliceCalled func(uint64) []byte
	ToUint64Called    func([]byte) (uint64, error)
}

Uint64ByteSliceConverterMock converts byte slice to/from uint64

func (*Uint64ByteSliceConverterMock) IsInterfaceNil 

func (u *Uint64ByteSliceConverterMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*Uint64ByteSliceConverterMock) ToByteSlice 

func (u *Uint64ByteSliceConverterMock) ToByteSlice(p uint64) []byte

ToByteSlice is a mock implementation for Uint64ByteSliceConverter

func (*Uint64ByteSliceConverterMock) ToUint64 

func (u *Uint64ByteSliceConverterMock) ToUint64(p []byte) (uint64, error)

ToUint64 is a mock implementation for Uint64ByteSliceConverter

type Uint64SyncMapCacherStub 

type Uint64SyncMapCacherStub struct {
	ClearCalled           func()
	GetCalled             func(nonce uint64) (dataRetriever.ShardIdHashMap, bool)
	MergeCalled           func(nonce uint64, src dataRetriever.ShardIdHashMap)
	RemoveCalled          func(nonce uint64, shardId uint32)
	RegisterHandlerCalled func(handler func(nonce uint64, shardId uint32, value []byte))
	HasCalled             func(nonce uint64, shardId uint32) bool
}

Uint64SyncMapCacherStub -

func (*Uint64SyncMapCacherStub) Clear 

func (usmcs *Uint64SyncMapCacherStub) Clear()

Clear -

func (*Uint64SyncMapCacherStub) Get 

func (usmcs *Uint64SyncMapCacherStub) Get(nonce uint64) (dataRetriever.ShardIdHashMap, bool)

Get -

func (*Uint64SyncMapCacherStub) Has 

func (usmcs *Uint64SyncMapCacherStub) Has(nonce uint64, shardId uint32) bool

Has -

func (*Uint64SyncMapCacherStub) IsInterfaceNil 

func (usmcs *Uint64SyncMapCacherStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*Uint64SyncMapCacherStub) Merge 

func (usmcs *Uint64SyncMapCacherStub) Merge(nonce uint64, src dataRetriever.ShardIdHashMap)

Merge -

func (*Uint64SyncMapCacherStub) RegisterHandler 

func (usmcs *Uint64SyncMapCacherStub) RegisterHandler(handler func(nonce uint64, shardId uint32, value []byte))

RegisterHandler -

func (*Uint64SyncMapCacherStub) Remove 

func (usmcs *Uint64SyncMapCacherStub) Remove(nonce uint64, shardId uint32)

Remove -

type UnitOpenerStub added in v1.0.111 

type UnitOpenerStub struct {
}

UnitOpenerStub -

func (*UnitOpenerStub) GetMostRecentBootstrapStorageUnit added in v1.0.111 

func (u *UnitOpenerStub) GetMostRecentBootstrapStorageUnit() (storage.Storer, error)

GetMostRecentBootstrapStorageUnit -

func (*UnitOpenerStub) IsInterfaceNil added in v1.0.111 

func (u *UnitOpenerStub) IsInterfaceNil() bool

IsInterfaceNil -

type ValidatorInfoSyncerStub added in v1.0.102 

type ValidatorInfoSyncerStub struct {
}

ValidatorInfoSyncerStub -

func (*ValidatorInfoSyncerStub) IsInterfaceNil added in v1.0.102 

func (vip *ValidatorInfoSyncerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*ValidatorInfoSyncerStub) SyncMiniBlocks added in v1.0.102 

func (vip *ValidatorInfoSyncerStub) SyncMiniBlocks(*block.MetaBlock) ([][]byte, data.BodyHandler, error)

SyncMiniBlocks -

type ValidatorStatisticsProcessorStub added in v0.0.5 

type ValidatorStatisticsProcessorStub struct {
	ProcessCalled        func(validatorInfo data.ShardValidatorInfoHandler) error
	CommitCalled         func() ([]byte, error)
	IsInterfaceNilCalled func() bool
}

ValidatorStatisticsProcessorStub -

func (*ValidatorStatisticsProcessorStub) Commit added in v0.0.5 

func (pm *ValidatorStatisticsProcessorStub) Commit() ([]byte, error)

Commit -

func (*ValidatorStatisticsProcessorStub) IsInterfaceNil added in v0.0.5 

func (pm *ValidatorStatisticsProcessorStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*ValidatorStatisticsProcessorStub) Process added in v0.0.5 

func (pm *ValidatorStatisticsProcessorStub) Process(validatorInfo data.ShardValidatorInfoHandler) error

Process -

type WhiteListHandlerStub added in v1.0.104 

type WhiteListHandlerStub struct {
	RemoveCalled            func(keys [][]byte)
	AddCalled               func(keys [][]byte)
	IsWhiteListedCalled     func(interceptedData process.InterceptedData) bool
	IsForCurrentShardCalled func(interceptedData process.InterceptedData) bool
}

WhiteListHandlerStub -

func (*WhiteListHandlerStub) Add added in v1.0.104 

func (w *WhiteListHandlerStub) Add(keys [][]byte)

Add -

func (*WhiteListHandlerStub) IsForCurrentShard added in v1.0.104 

func (w *WhiteListHandlerStub) IsForCurrentShard(interceptedData process.InterceptedData) bool

IsForCurrentShard -

func (*WhiteListHandlerStub) IsInterfaceNil added in v1.0.104 

func (w *WhiteListHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*WhiteListHandlerStub) IsWhiteListed added in v1.0.104 

func (w *WhiteListHandlerStub) IsWhiteListed(interceptedData process.InterceptedData) bool

IsWhiteListed -

func (*WhiteListHandlerStub) Remove added in v1.0.104 

func (w *WhiteListHandlerStub) Remove(keys [][]byte)

Remove -

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.