mock

package
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Nov 11, 2022 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewOneShardCoordinatorMock

func NewOneShardCoordinatorMock() *oneShardCoordinatorMock

NewOneShardCoordinatorMock -

Types

type AccountsDBSyncerStub

type AccountsDBSyncerStub struct {
	GetSyncedTriesCalled func() map[string]common.Trie
	SyncAccountsCalled   func(rootHash []byte) error
}

AccountsDBSyncerStub -

func (*AccountsDBSyncerStub) GetSyncedTries

func (a *AccountsDBSyncerStub) GetSyncedTries() map[string]common.Trie

GetSyncedTries -

func (*AccountsDBSyncerStub) IsInterfaceNil

func (a *AccountsDBSyncerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*AccountsDBSyncerStub) SyncAccounts

func (a *AccountsDBSyncerStub) SyncAccounts(rootHash []byte) error

SyncAccounts -

type AccountsDBSyncersStub

type AccountsDBSyncersStub struct {
	GetCalled          func(key string) (update.AccountsDBSyncer, error)
	AddCalled          func(key string, val update.AccountsDBSyncer) error
	AddMultipleCalled  func(keys []string, interceptors []update.AccountsDBSyncer) error
	ReplaceCalled      func(key string, val update.AccountsDBSyncer) error
	RemoveCalled       func(key string)
	LenCalled          func() int
	StartSyncingCalled func(rootHash []byte) error
	TrieCalled         func() common.Trie
}

AccountsDBSyncersStub -

func (*AccountsDBSyncersStub) Add

Add -

func (*AccountsDBSyncersStub) AddMultiple

func (a *AccountsDBSyncersStub) AddMultiple(keys []string, interceptors []update.AccountsDBSyncer) error

AddMultiple -

func (*AccountsDBSyncersStub) Get

Get -

func (*AccountsDBSyncersStub) IsInterfaceNil

func (a *AccountsDBSyncersStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*AccountsDBSyncersStub) Len

func (a *AccountsDBSyncersStub) Len() int

Len -

func (*AccountsDBSyncersStub) Remove

func (a *AccountsDBSyncersStub) Remove(key string)

Remove -

func (*AccountsDBSyncersStub) Replace

Replace -

type AddressMock added in v1.0.115

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

AddressMock implements a mock address generator used in testing

func NewAddressMock added in v1.0.115

func NewAddressMock() *AddressMock

NewAddressMock generates a new address

func (*AddressMock) Bytes added in v1.0.115

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

Bytes returns the address' bytes

func (*AddressMock) IsInterfaceNil added in v1.0.115

func (address *AddressMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

type CloserStub added in v1.0.133

type CloserStub struct {
	CloseCalled func() error
}

CloserStub -

func (*CloserStub) Close added in v1.0.133

func (cs *CloserStub) Close() error

Close -

func (*CloserStub) IsInterfaceNil added in v1.0.133

func (cs *CloserStub) IsInterfaceNil() bool

IsInterfaceNil -

type CoordinatorStub added in v1.0.115

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

CoordinatorStub -

func (*CoordinatorStub) CommunicationIdentifier added in v1.0.115

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

CommunicationIdentifier -

func (*CoordinatorStub) ComputeId added in v1.0.115

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

ComputeId -

func (*CoordinatorStub) IsInterfaceNil added in v1.0.115

func (coordinator *CoordinatorStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*CoordinatorStub) NumberOfShards added in v1.0.115

func (coordinator *CoordinatorStub) NumberOfShards() uint32

NumberOfShards -

func (*CoordinatorStub) SameShard added in v1.0.115

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

SameShard -

func (*CoordinatorStub) SelfId added in v1.0.115

func (coordinator *CoordinatorStub) SelfId() uint32

SelfId -

type EpochHandlerStub added in v1.0.120

type EpochHandlerStub struct {
	MetaEpochCalled       func() uint32
	ForceEpochStartCalled func(round uint64)
}

EpochHandlerStub -

func (*EpochHandlerStub) ForceEpochStart added in v1.1.3

func (ehs *EpochHandlerStub) ForceEpochStart(round uint64)

ForceEpochStart -

func (*EpochHandlerStub) IsInterfaceNil added in v1.0.120

func (ehs *EpochHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*EpochHandlerStub) MetaEpoch added in v1.0.120

func (ehs *EpochHandlerStub) MetaEpoch() uint32

MetaEpoch -

type EpochStartNotifierStub added in v1.0.120

type EpochStartNotifierStub struct {
	RegisterHandlerCalled   func(handler epochStart.ActionHandler)
	UnregisterHandlerCalled func(handler epochStart.ActionHandler)
	NotifyAllCalled         func(hdr data.HeaderHandler)
	NotifyAllPrepareCalled  func(hdr data.HeaderHandler, body data.BodyHandler)

	NotifyEpochChangeConfirmedCalled      func(epoch uint32)
	RegisterForEpochChangeConfirmedCalled func(handler func(epoch uint32))
	// contains filtered or unexported fields
}

EpochStartNotifierStub -

func (*EpochStartNotifierStub) IsInterfaceNil added in v1.0.120

func (esnm *EpochStartNotifierStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*EpochStartNotifierStub) NotifyAll added in v1.0.120

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

NotifyAll -

func (*EpochStartNotifierStub) NotifyAllPrepare added in v1.0.120

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 -

func (*EpochStartNotifierStub) RegisterForEpochChangeConfirmed added in v1.0.120

func (esnm *EpochStartNotifierStub) RegisterForEpochChangeConfirmed(handler func(epoch uint32))

RegisterForEpochChangeConfirmed -

func (*EpochStartNotifierStub) RegisterHandler added in v1.0.120

func (esnm *EpochStartNotifierStub) RegisterHandler(handler epochStart.ActionHandler)

RegisterHandler -

func (*EpochStartNotifierStub) UnregisterHandler added in v1.0.120

func (esnm *EpochStartNotifierStub) UnregisterHandler(handler epochStart.ActionHandler)

UnregisterHandler -

type EpochStartPendingMiniBlocksSyncHandlerMock

type EpochStartPendingMiniBlocksSyncHandlerMock struct {
	SyncPendingMiniBlocksFromMetaCalled func(epochStart data.MetaHeaderHandler, unFinished map[string]data.MetaHeaderHandler, ctx context.Context) error
	GetMiniBlocksCalled                 func() (map[string]*block.MiniBlock, error)
}

EpochStartPendingMiniBlocksSyncHandlerMock -

func (*EpochStartPendingMiniBlocksSyncHandlerMock) GetMiniBlocks

GetMiniBlocks -

func (*EpochStartPendingMiniBlocksSyncHandlerMock) IsInterfaceNil

func (ep *EpochStartPendingMiniBlocksSyncHandlerMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*EpochStartPendingMiniBlocksSyncHandlerMock) SyncPendingMiniBlocksFromMeta

func (ep *EpochStartPendingMiniBlocksSyncHandlerMock) SyncPendingMiniBlocksFromMeta(epochStart data.MetaHeaderHandler, unFinished map[string]data.MetaHeaderHandler, ctx context.Context) error

SyncPendingMiniBlocksFromMeta -

type EpochStartTriesSyncHandlerMock

type EpochStartTriesSyncHandlerMock struct {
	SyncTriesFromCalled func(meta data.MetaHeaderHandler) error
	GetTriesCalled      func() (map[string]common.Trie, error)
}

EpochStartTriesSyncHandlerMock -

func (*EpochStartTriesSyncHandlerMock) GetTries

func (es *EpochStartTriesSyncHandlerMock) GetTries() (map[string]common.Trie, error)

GetTries -

func (*EpochStartTriesSyncHandlerMock) IsInterfaceNil

func (es *EpochStartTriesSyncHandlerMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*EpochStartTriesSyncHandlerMock) SyncTriesFrom

SyncTriesFrom -

type EpochStartTriggerStub

type EpochStartTriggerStub struct {
	ForceEpochStartCalled       func(round uint64) error
	IsEpochStartCalled          func() bool
	EpochCalled                 func() uint32
	ReceivedHeaderCalled        func(handler data.HeaderHandler)
	UpdateCalled                func(round uint64)
	ProcessedCalled             func(header data.HeaderHandler)
	EpochStartRoundCalled       func() uint64
	EpochStartMetaHdrHashCalled func() []byte
}

EpochStartTriggerStub -

func (*EpochStartTriggerStub) Epoch

func (e *EpochStartTriggerStub) Epoch() uint32

Epoch -

func (*EpochStartTriggerStub) EpochFinalityAttestingRound

func (e *EpochStartTriggerStub) EpochFinalityAttestingRound() uint64

EpochFinalityAttestingRound -

func (*EpochStartTriggerStub) EpochStartMetaHdrHash

func (e *EpochStartTriggerStub) EpochStartMetaHdrHash() []byte

EpochStartMetaHdrHash -

func (*EpochStartTriggerStub) EpochStartRound

func (e *EpochStartTriggerStub) EpochStartRound() uint64

EpochStartRound -

func (*EpochStartTriggerStub) ForceEpochStart

func (e *EpochStartTriggerStub) ForceEpochStart(round uint64) error

ForceEpochStart -

func (*EpochStartTriggerStub) GetRoundsPerEpoch

func (e *EpochStartTriggerStub) GetRoundsPerEpoch() uint64

GetRoundsPerEpoch -

func (*EpochStartTriggerStub) IsEpochStart

func (e *EpochStartTriggerStub) IsEpochStart() bool

IsEpochStart -

func (*EpochStartTriggerStub) IsInterfaceNil

func (e *EpochStartTriggerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*EpochStartTriggerStub) NotifyAll

func (e *EpochStartTriggerStub) NotifyAll(_ data.HeaderHandler)

NotifyAll -

func (*EpochStartTriggerStub) ReceivedHeader

func (e *EpochStartTriggerStub) ReceivedHeader(header data.HeaderHandler)

ReceivedHeader -

func (*EpochStartTriggerStub) Revert

func (e *EpochStartTriggerStub) Revert()

Revert -

func (*EpochStartTriggerStub) SetCurrentEpochStartRound

func (e *EpochStartTriggerStub) SetCurrentEpochStartRound(_ uint64)

SetCurrentEpochStartRound -

func (*EpochStartTriggerStub) SetEpoch added in v1.0.138

func (e *EpochStartTriggerStub) SetEpoch(_ uint32)

SetEpoch -

func (*EpochStartTriggerStub) SetFinalityAttestingRound

func (e *EpochStartTriggerStub) SetFinalityAttestingRound(_ uint64)

SetFinalityAttestingRound -

func (*EpochStartTriggerStub) SetProcessed

func (e *EpochStartTriggerStub) SetProcessed(header data.HeaderHandler)

SetProcessed -

func (*EpochStartTriggerStub) SetRoundsPerEpoch

func (e *EpochStartTriggerStub) SetRoundsPerEpoch(_ uint64)

SetRoundsPerEpoch -

func (*EpochStartTriggerStub) SetTrigger

SetTrigger -

func (*EpochStartTriggerStub) Update

func (e *EpochStartTriggerStub) Update(round uint64)

Update -

type ExportFactoryHandlerStub added in v1.0.120

type ExportFactoryHandlerStub struct {
	CreateCalled func() (update.ExportHandler, error)
}

ExportFactoryHandlerStub -

func (*ExportFactoryHandlerStub) Create added in v1.0.120

Create -

func (*ExportFactoryHandlerStub) IsInterfaceNil added in v1.0.120

func (e *ExportFactoryHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

type ExportHandlerStub added in v1.0.120

type ExportHandlerStub struct {
	ExportAllCalled func(epoch uint32) error
}

ExportHandlerStub -

func (*ExportHandlerStub) ExportAll added in v1.0.120

func (e *ExportHandlerStub) ExportAll(epoch uint32) error

ExportAll -

func (*ExportHandlerStub) IsInterfaceNil added in v1.0.120

func (e *ExportHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

type GenesisNodesSetupHandlerStub added in v1.0.149

type GenesisNodesSetupHandlerStub struct {
	InitialNodesInfoForShardCalled   func(shardId uint32) ([]nodesCoordinator.GenesisNodeInfoHandler, []nodesCoordinator.GenesisNodeInfoHandler, error)
	InitialNodesInfoCalled           func() (map[uint32][]nodesCoordinator.GenesisNodeInfoHandler, map[uint32][]nodesCoordinator.GenesisNodeInfoHandler)
	GetStartTimeCalled               func() int64
	GetRoundDurationCalled           func() uint64
	GetChainIdCalled                 func() string
	GetMinTransactionVersionCalled   func() uint32
	GetShardConsensusGroupSizeCalled func() uint32
	GetMetaConsensusGroupSizeCalled  func() uint32
	MinNumberOfShardNodesCalled      func() uint32
	MinNumberOfMetaNodesCalled       func() uint32
	GetHysteresisCalled              func() float32
	GetAdaptivityCalled              func() bool
	NumberOfShardsCalled             func() uint32
	MinNumberOfNodesCalled           func() uint32
}

GenesisNodesSetupHandlerStub -

func (*GenesisNodesSetupHandlerStub) GetAdaptivity added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetAdaptivity() bool

GetAdaptivity -

func (*GenesisNodesSetupHandlerStub) GetChainId added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetChainId() string

GetChainId -

func (*GenesisNodesSetupHandlerStub) GetHysteresis added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetHysteresis() float32

GetHysteresis -

func (*GenesisNodesSetupHandlerStub) GetMetaConsensusGroupSize added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetMetaConsensusGroupSize() uint32

GetMetaConsensusGroupSize -

func (*GenesisNodesSetupHandlerStub) GetMinTransactionVersion added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetMinTransactionVersion() uint32

GetMinTransactionVersion -

func (*GenesisNodesSetupHandlerStub) GetRoundDuration added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetRoundDuration() uint64

GetRoundDuration -

func (*GenesisNodesSetupHandlerStub) GetShardConsensusGroupSize added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetShardConsensusGroupSize() uint32

GetShardConsensusGroupSize -

func (*GenesisNodesSetupHandlerStub) GetStartTime added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) GetStartTime() int64

GetStartTime -

func (*GenesisNodesSetupHandlerStub) InitialNodesInfo added in v1.0.149

InitialNodesInfo -

func (*GenesisNodesSetupHandlerStub) InitialNodesInfoForShard added in v1.0.149

InitialNodesInfoForShard -

func (*GenesisNodesSetupHandlerStub) IsInterfaceNil added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*GenesisNodesSetupHandlerStub) MinNumberOfMetaNodes added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) MinNumberOfMetaNodes() uint32

MinNumberOfMetaNodes -

func (*GenesisNodesSetupHandlerStub) MinNumberOfNodes added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) MinNumberOfNodes() uint32

MinNumberOfNodes -

func (*GenesisNodesSetupHandlerStub) MinNumberOfShardNodes added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) MinNumberOfShardNodes() uint32

MinNumberOfShardNodes -

func (*GenesisNodesSetupHandlerStub) NumberOfShards added in v1.0.149

func (g *GenesisNodesSetupHandlerStub) NumberOfShards() uint32

NumberOfShards -

type HardForkBlockProcessor added in v1.0.115

type HardForkBlockProcessor struct {
	CreateBlockCalled func(
		body *block.Body,
		chainID string,
		round uint64,
		nonce uint64,
		epoch uint32,
	) (data.HeaderHandler, error)
	CreateBodyCalled           func() (*block.Body, []*update.MbInfo, error)
	CreatePostMiniBlocksCalled func(mbsInfo []*update.MbInfo) (*block.Body, []*update.MbInfo, error)
}

HardForkBlockProcessor -

func (*HardForkBlockProcessor) CreateBlock added in v1.1.12

func (hfbp *HardForkBlockProcessor) CreateBlock(body *block.Body, chainID string, round uint64, nonce uint64, epoch uint32) (data.HeaderHandler, error)

CreateBlock -

func (*HardForkBlockProcessor) CreateBody added in v1.1.12

func (hfbp *HardForkBlockProcessor) CreateBody() (*block.Body, []*update.MbInfo, error)

CreateBody -

func (*HardForkBlockProcessor) CreatePostMiniBlocks added in v1.1.12

func (hfbp *HardForkBlockProcessor) CreatePostMiniBlocks(mbsInfo []*update.MbInfo) (*block.Body, []*update.MbInfo, error)

CreatePostMiniBlocks -

func (*HardForkBlockProcessor) IsInterfaceNil added in v1.0.115

func (hfbp *HardForkBlockProcessor) IsInterfaceNil() bool

IsInterfaceNil returns true if underlying object is nil

type HardforkStorerStub added in v1.0.138

type HardforkStorerStub struct {
	WriteCalled              func(identifier string, key []byte, value []byte) error
	FinishedIdentifierCalled func(identifier string) error
	RangeKeysCalled          func(handler func(identifier string, keys [][]byte) bool)
	GetCalled                func(identifier string, key []byte) ([]byte, error)
	CloseCalled              func() error
}

HardforkStorerStub -

func (*HardforkStorerStub) Close added in v1.0.138

func (hss *HardforkStorerStub) Close() error

Close -

func (*HardforkStorerStub) FinishedIdentifier added in v1.0.138

func (hss *HardforkStorerStub) FinishedIdentifier(identifier string) error

FinishedIdentifier -

func (*HardforkStorerStub) Get added in v1.0.138

func (hss *HardforkStorerStub) Get(identifier string, key []byte) ([]byte, error)

Get -

func (*HardforkStorerStub) IsInterfaceNil added in v1.0.138

func (hss *HardforkStorerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*HardforkStorerStub) RangeKeys added in v1.0.138

func (hss *HardforkStorerStub) RangeKeys(handler func(identifier string, keys [][]byte) bool)

RangeKeys -

func (*HardforkStorerStub) Write added in v1.0.138

func (hss *HardforkStorerStub) Write(identifier string, key []byte, value []byte) error

Write -

type HasherStub

type HasherStub struct {
	ComputeCalled   func(s string) []byte
	EmptyHashCalled func() []byte
}

HasherStub -

func (*HasherStub) Compute

func (hash *HasherStub) Compute(s string) []byte

Compute -

func (*HasherStub) EmptyHash

func (hash *HasherStub) EmptyHash() []byte

EmptyHash -

func (*HasherStub) IsInterfaceNil

func (hash *HasherStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*HasherStub) Size

func (hash *HasherStub) Size() int

Size -

type HeaderSyncHandlerStub

type HeaderSyncHandlerStub struct {
	SyncUnFinishedMetaHeadersCalled func(epoch uint32) error
	GetEpochStartMetaBlockCalled    func() (data.MetaHeaderHandler, error)
	GetUnFinishedMetaBlocksCalled   func() (map[string]data.MetaHeaderHandler, error)
}

HeaderSyncHandlerStub -

func (*HeaderSyncHandlerStub) GetEpochStartMetaBlock

func (hsh *HeaderSyncHandlerStub) GetEpochStartMetaBlock() (data.MetaHeaderHandler, error)

GetEpochStartMetaBlock -

func (*HeaderSyncHandlerStub) GetUnFinishedMetaBlocks added in v1.1.12

func (hsh *HeaderSyncHandlerStub) GetUnFinishedMetaBlocks() (map[string]data.MetaHeaderHandler, error)

GetUnFinishedMetaBlocks -

func (*HeaderSyncHandlerStub) IsInterfaceNil

func (hsh *HeaderSyncHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*HeaderSyncHandlerStub) SyncUnFinishedMetaHeaders

func (hsh *HeaderSyncHandlerStub) SyncUnFinishedMetaHeaders(epoch uint32) error

SyncUnFinishedMetaHeaders -

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 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 ImportHandlerStub added in v1.0.115

type ImportHandlerStub struct {
	ImportAllCalled               func() error
	GetValidatorAccountsDBCalled  func() state.AccountsAdapter
	GetMiniBlocksCalled           func() map[string]*block.MiniBlock
	GetHardForkMetaBlockCalled    func() data.MetaHeaderHandler
	GetUnFinishedMetaBlocksCalled func() map[string]data.MetaHeaderHandler
	GetTransactionsCalled         func() map[string]data.TransactionHandler
	GetAccountsDBForShardCalled   func(shardID uint32) state.AccountsAdapter
	CloseCalled                   func() error
}

ImportHandlerStub -

func (*ImportHandlerStub) Close added in v1.2.0

func (ihs *ImportHandlerStub) Close() error

Close -

func (*ImportHandlerStub) GetAccountsDBForShard added in v1.0.115

func (ihs *ImportHandlerStub) GetAccountsDBForShard(shardID uint32) state.AccountsAdapter

GetAccountsDBForShard -

func (*ImportHandlerStub) GetHardForkMetaBlock added in v1.0.115

func (ihs *ImportHandlerStub) GetHardForkMetaBlock() data.MetaHeaderHandler

GetHardForkMetaBlock -

func (*ImportHandlerStub) GetMiniBlocks added in v1.0.115

func (ihs *ImportHandlerStub) GetMiniBlocks() map[string]*block.MiniBlock

GetMiniBlocks -

func (*ImportHandlerStub) GetTransactions added in v1.0.115

func (ihs *ImportHandlerStub) GetTransactions() map[string]data.TransactionHandler

GetTransactions -

func (*ImportHandlerStub) GetUnFinishedMetaBlocks added in v1.1.12

func (ihs *ImportHandlerStub) GetUnFinishedMetaBlocks() map[string]data.MetaHeaderHandler

GetUnFinishedMetaBlocks -

func (*ImportHandlerStub) GetValidatorAccountsDB added in v1.0.115

func (ihs *ImportHandlerStub) GetValidatorAccountsDB() state.AccountsAdapter

GetValidatorAccountsDB -

func (*ImportHandlerStub) ImportAll added in v1.0.115

func (ihs *ImportHandlerStub) ImportAll() error

ImportAll -

func (*ImportHandlerStub) IsInterfaceNil added in v1.0.115

func (ihs *ImportHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

type ImportStartHandlerStub added in v1.0.133

type ImportStartHandlerStub struct {
	SetStartImportCalled            func() error
	ResetStartImportCalled          func() error
	IsAfterExportBeforeImportCalled func() bool
	ShouldStartImportCalled         func() bool
}

ImportStartHandlerStub -

func (*ImportStartHandlerStub) IsAfterExportBeforeImport added in v1.0.133

func (ish *ImportStartHandlerStub) IsAfterExportBeforeImport() bool

IsAfterExportBeforeImport -

func (*ImportStartHandlerStub) IsInterfaceNil added in v1.0.133

func (ish *ImportStartHandlerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*ImportStartHandlerStub) ResetStartImport added in v1.0.133

func (ish *ImportStartHandlerStub) ResetStartImport() error

ResetStartImport -

func (*ImportStartHandlerStub) SetStartImport added in v1.0.133

func (ish *ImportStartHandlerStub) SetStartImport() error

SetStartImport -

func (*ImportStartHandlerStub) ShouldStartImport added in v1.0.133

func (ish *ImportStartHandlerStub) ShouldStartImport() bool

ShouldStartImport -

type MarshalizerFake

type MarshalizerFake struct {
	Fail bool
}

MarshalizerFake that will be used for testing

func (*MarshalizerFake) IsInterfaceNil

func (mm *MarshalizerFake) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*MarshalizerFake) Marshal

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

Marshal converts the input object in a slice of bytes

func (*MarshalizerFake) Unmarshal

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

Unmarshal applies the serialized values over an instantiated object

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 PendingTransactionProcessorStub added in v1.0.115

type PendingTransactionProcessorStub struct {
	ProcessTransactionsDstMeCalled func(mbInfo *update.MbInfo) (*block.MiniBlock, error)
	RootHashCalled                 func() ([]byte, error)
	CommitCalled                   func() ([]byte, error)
}

PendingTransactionProcessorStub -

func (*PendingTransactionProcessorStub) Commit added in v1.1.12

func (ptps *PendingTransactionProcessorStub) Commit() ([]byte, error)

Commit -

func (*PendingTransactionProcessorStub) IsInterfaceNil added in v1.0.115

func (ptps *PendingTransactionProcessorStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*PendingTransactionProcessorStub) ProcessTransactionsDstMe added in v1.0.115

func (ptps *PendingTransactionProcessorStub) ProcessTransactionsDstMe(mbInfo *update.MbInfo) (*block.MiniBlock, error)

ProcessTransactionsDstMe -

func (*PendingTransactionProcessorStub) RootHash added in v1.0.115

func (ptps *PendingTransactionProcessorStub) RootHash() ([]byte, error)

RootHash -

type PubkeyConverterStub added in v1.0.115

type PubkeyConverterStub struct {
	LenCalled    func() int
	DecodeCalled func(humanReadable string) ([]byte, error)
	EncodeCalled func(pkBytes []byte) string
}

PubkeyConverterStub -

func (*PubkeyConverterStub) Decode added in v1.0.115

func (pcs *PubkeyConverterStub) Decode(humanReadable string) ([]byte, error)

Decode -

func (*PubkeyConverterStub) Encode added in v1.0.115

func (pcs *PubkeyConverterStub) Encode(pkBytes []byte) string

Encode -

func (*PubkeyConverterStub) IsInterfaceNil added in v1.0.115

func (pcs *PubkeyConverterStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*PubkeyConverterStub) Len added in v1.0.115

func (pcs *PubkeyConverterStub) Len() int

Len -

type RoundHandlerStub added in v1.1.12

type RoundHandlerStub 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
}

RoundHandlerStub -

func (*RoundHandlerStub) Index added in v1.1.12

func (rhs *RoundHandlerStub) Index() int64

Index -

func (*RoundHandlerStub) IsInterfaceNil added in v1.1.12

func (rhs *RoundHandlerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*RoundHandlerStub) RemainingTime added in v1.1.12

func (rhs *RoundHandlerStub) RemainingTime(startTime time.Time, maxTime time.Duration) time.Duration

RemainingTime -

func (*RoundHandlerStub) TimeDuration added in v1.1.12

func (rhs *RoundHandlerStub) TimeDuration() time.Duration

TimeDuration -

func (*RoundHandlerStub) TimeStamp added in v1.1.12

func (rhs *RoundHandlerStub) TimeStamp() time.Time

TimeStamp -

func (*RoundHandlerStub) UpdateRound added in v1.1.12

func (rhs *RoundHandlerStub) UpdateRound(genesisRoundTimeStamp time.Time, timeStamp time.Time)

UpdateRound -

type StateSyncStub added in v1.2.10

type StateSyncStub struct {
	GetEpochStartMetaBlockCalled  func() (data.MetaHeaderHandler, error)
	GetUnFinishedMetaBlocksCalled func() (map[string]data.MetaHeaderHandler, error)
	SyncAllStateCalled            func(epoch uint32) error
	GetAllTriesCalled             func() (map[string]common.Trie, error)
	GetAllTransactionsCalled      func() (map[string]data.TransactionHandler, error)
	GetAllValidatorsInfoCalled    func() (map[string]*state.ShardValidatorInfo, error)
	GetAllMiniBlocksCalled        func() (map[string]*block.MiniBlock, error)
}

StateSyncStub -

func (*StateSyncStub) GetAllMiniBlocks added in v1.2.10

func (sss *StateSyncStub) GetAllMiniBlocks() (map[string]*block.MiniBlock, error)

GetAllMiniBlocks -

func (*StateSyncStub) GetAllTransactions added in v1.2.10

func (sss *StateSyncStub) GetAllTransactions() (map[string]data.TransactionHandler, error)

GetAllTransactions -

func (*StateSyncStub) GetAllTries added in v1.2.10

func (sss *StateSyncStub) GetAllTries() (map[string]common.Trie, error)

GetAllTries -

func (*StateSyncStub) GetAllValidatorsInfo added in v1.4.0

func (sss *StateSyncStub) GetAllValidatorsInfo() (map[string]*state.ShardValidatorInfo, error)

GetAllValidatorsInfo -

func (*StateSyncStub) GetEpochStartMetaBlock added in v1.2.10

func (sss *StateSyncStub) GetEpochStartMetaBlock() (data.MetaHeaderHandler, error)

GetEpochStartMetaBlock -

func (*StateSyncStub) GetUnFinishedMetaBlocks added in v1.2.10

func (sss *StateSyncStub) GetUnFinishedMetaBlocks() (map[string]data.MetaHeaderHandler, error)

GetUnFinishedMetaBlocks -

func (*StateSyncStub) IsInterfaceNil added in v1.2.10

func (sss *StateSyncStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*StateSyncStub) SyncAllState added in v1.2.10

func (sss *StateSyncStub) SyncAllState(epoch uint32) error

SyncAllState -

type TransactionCoordinatorMock added in v1.0.115

type TransactionCoordinatorMock struct {
	ComputeTransactionTypeCalled                         func(tx data.TransactionHandler) (process.TransactionType, error)
	RequestMiniBlocksCalled                              func(header data.HeaderHandler)
	RequestBlockTransactionsCalled                       func(body *block.Body)
	IsDataPreparedForProcessingCalled                    func(haveTime func() time.Duration) error
	SaveTxsToStorageCalled                               func(body *block.Body)
	RestoreBlockDataFromStorageCalled                    func(body *block.Body) (int, error)
	RemoveBlockDataFromPoolCalled                        func(body *block.Body) error
	RemoveTxsFromPoolCalled                              func(body *block.Body) error
	ProcessBlockTransactionCalled                        func(header data.HeaderHandler, body *block.Body, haveTime func() time.Duration) error
	CreateBlockStartedCalled                             func()
	CreateMbsAndProcessCrossShardTransactionsDstMeCalled func(header data.HeaderHandler, processedMiniBlocksInfo map[string]*processedMb.ProcessedMiniBlockInfo, haveTime func() bool, haveAdditionalTime func() bool, scheduledMode bool) (block.MiniBlockSlice, uint32, bool, error)
	CreateMbsAndProcessTransactionsFromMeCalled          func(haveTime func() bool) block.MiniBlockSlice
	CreateMarshalizedDataCalled                          func(body *block.Body) map[string][][]byte
	GetCreatedInShardMiniBlocksCalled                    func() []*block.MiniBlock
	GetAllCurrentUsedTxsCalled                           func(blockType block.Type) map[string]data.TransactionHandler
	VerifyCreatedBlockTransactionsCalled                 func(hdr data.HeaderHandler, body *block.Body) error
	CreatePostProcessMiniBlocksCalled                    func() block.MiniBlockSlice
	VerifyCreatedMiniBlocksCalled                        func(hdr data.HeaderHandler, body *block.Body) error
	AddIntermediateTransactionsCalled                    func(mapSCRs map[block.Type][]data.TransactionHandler) error
	GetAllIntermediateTxsCalled                          func() map[block.Type]map[string]data.TransactionHandler
	AddTxsFromMiniBlocksCalled                           func(miniBlocks block.MiniBlockSlice)
	AddTransactionsCalled                                func(txHandlers []data.TransactionHandler, blockType block.Type)
}

TransactionCoordinatorMock -

func (*TransactionCoordinatorMock) AddIntermediateTransactions added in v1.3.0

func (tcm *TransactionCoordinatorMock) AddIntermediateTransactions(mapSCRs map[block.Type][]data.TransactionHandler) error

AddIntermediateTransactions -

func (*TransactionCoordinatorMock) AddTransactions added in v1.3.10

func (tcm *TransactionCoordinatorMock) AddTransactions(txHandlers []data.TransactionHandler, blockType block.Type)

AddTransactions -

func (*TransactionCoordinatorMock) AddTxsFromMiniBlocks added in v1.3.7

func (tcm *TransactionCoordinatorMock) AddTxsFromMiniBlocks(miniBlocks block.MiniBlockSlice)

AddTxsFromMiniBlocks -

func (*TransactionCoordinatorMock) CreateBlockStarted added in v1.0.115

func (tcm *TransactionCoordinatorMock) CreateBlockStarted()

CreateBlockStarted -

func (*TransactionCoordinatorMock) CreateMarshalizedData added in v1.0.115

func (tcm *TransactionCoordinatorMock) CreateMarshalizedData(body *block.Body) map[string][][]byte

CreateMarshalizedData -

func (*TransactionCoordinatorMock) CreateMbsAndProcessCrossShardTransactionsDstMe added in v1.0.115

func (tcm *TransactionCoordinatorMock) CreateMbsAndProcessCrossShardTransactionsDstMe(
	header data.HeaderHandler,
	processedMiniBlocksInfo map[string]*processedMb.ProcessedMiniBlockInfo,
	haveTime func() bool,
	haveAdditionalTime func() bool,
	scheduledMode bool,
) (block.MiniBlockSlice, uint32, bool, error)

CreateMbsAndProcessCrossShardTransactionsDstMe -

func (*TransactionCoordinatorMock) CreateMbsAndProcessTransactionsFromMe added in v1.0.115

func (tcm *TransactionCoordinatorMock) CreateMbsAndProcessTransactionsFromMe(haveTime func() bool, _ []byte) block.MiniBlockSlice

CreateMbsAndProcessTransactionsFromMe -

func (*TransactionCoordinatorMock) CreatePostProcessMiniBlocks added in v1.0.115

func (tcm *TransactionCoordinatorMock) CreatePostProcessMiniBlocks() block.MiniBlockSlice

CreatePostProcessMiniBlocks -

func (*TransactionCoordinatorMock) CreateReceiptsHash added in v1.0.115

func (tcm *TransactionCoordinatorMock) CreateReceiptsHash() ([]byte, error)

CreateReceiptsHash -

func (*TransactionCoordinatorMock) GetAllCurrentLogs added in v1.2.3

func (tcm *TransactionCoordinatorMock) GetAllCurrentLogs() []*data.LogData

GetAllCurrentLogs -

func (*TransactionCoordinatorMock) GetAllCurrentUsedTxs added in v1.0.115

func (tcm *TransactionCoordinatorMock) GetAllCurrentUsedTxs(blockType block.Type) map[string]data.TransactionHandler

GetAllCurrentUsedTxs -

func (*TransactionCoordinatorMock) GetAllIntermediateTxs added in v1.3.0

func (tcm *TransactionCoordinatorMock) GetAllIntermediateTxs() map[block.Type]map[string]data.TransactionHandler

GetAllIntermediateTxs -

func (*TransactionCoordinatorMock) GetCreatedInShardMiniBlocks added in v1.3.37

func (tcm *TransactionCoordinatorMock) GetCreatedInShardMiniBlocks() []*block.MiniBlock

GetCreatedInShardMiniBlocks -

func (*TransactionCoordinatorMock) IsDataPreparedForProcessing added in v1.0.115

func (tcm *TransactionCoordinatorMock) IsDataPreparedForProcessing(haveTime func() time.Duration) error

IsDataPreparedForProcessing -

func (*TransactionCoordinatorMock) IsInterfaceNil added in v1.0.115

func (tcm *TransactionCoordinatorMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*TransactionCoordinatorMock) ProcessBlockTransaction added in v1.0.115

func (tcm *TransactionCoordinatorMock) ProcessBlockTransaction(header data.HeaderHandler, body *block.Body, haveTime func() time.Duration) error

ProcessBlockTransaction -

func (*TransactionCoordinatorMock) RemoveBlockDataFromPool added in v1.0.115

func (tcm *TransactionCoordinatorMock) RemoveBlockDataFromPool(body *block.Body) error

RemoveBlockDataFromPool -

func (*TransactionCoordinatorMock) RemoveTxsFromPool added in v1.1.7

func (tcm *TransactionCoordinatorMock) RemoveTxsFromPool(body *block.Body) error

RemoveTxsFromPool -

func (*TransactionCoordinatorMock) RequestBlockTransactions added in v1.0.115

func (tcm *TransactionCoordinatorMock) RequestBlockTransactions(body *block.Body)

RequestBlockTransactions -

func (*TransactionCoordinatorMock) RequestMiniBlocks added in v1.0.115

func (tcm *TransactionCoordinatorMock) RequestMiniBlocks(header data.HeaderHandler)

RequestMiniBlocks -

func (*TransactionCoordinatorMock) RestoreBlockDataFromStorage added in v1.0.115

func (tcm *TransactionCoordinatorMock) RestoreBlockDataFromStorage(body *block.Body) (int, error)

RestoreBlockDataFromStorage -

func (*TransactionCoordinatorMock) SaveTxsToStorage added in v1.1.7

func (tcm *TransactionCoordinatorMock) SaveTxsToStorage(body *block.Body)

SaveTxsToStorage -

func (*TransactionCoordinatorMock) VerifyCreatedBlockTransactions added in v1.0.115

func (tcm *TransactionCoordinatorMock) VerifyCreatedBlockTransactions(hdr data.HeaderHandler, body *block.Body) error

VerifyCreatedBlockTransactions -

func (*TransactionCoordinatorMock) VerifyCreatedMiniBlocks added in v1.1.28

func (tcm *TransactionCoordinatorMock) VerifyCreatedMiniBlocks(hdr data.HeaderHandler, body *block.Body) error

VerifyCreatedMiniBlocks -

type TrieFactoryStub added in v1.0.115

type TrieFactoryStub struct {
	CreateCalled func(config config.StorageConfig, s string, b bool) (common.StorageManager, common.Trie, error)
}

TrieFactoryStub -

func (*TrieFactoryStub) Create added in v1.0.115

Create -

func (*TrieFactoryStub) IsInterfaceNil added in v1.0.115

func (t *TrieFactoryStub) IsInterfaceNil() bool

IsInterfaceNil -

type TrieSyncersStub

type TrieSyncersStub struct {
	GetCalled          func(key string) (update.TrieSyncer, error)
	AddCalled          func(key string, val update.TrieSyncer) error
	AddMultipleCalled  func(keys []string, interceptors []update.TrieSyncer) error
	ReplaceCalled      func(key string, val update.TrieSyncer) error
	RemoveCalled       func(key string)
	LenCalled          func() int
	StartSyncingCalled func(rootHash []byte, ctx context.Context) error
	TrieCalled         func() common.Trie
}

TrieSyncersStub -

func (*TrieSyncersStub) Add

func (tss *TrieSyncersStub) Add(key string, val update.TrieSyncer) error

Add -

func (*TrieSyncersStub) AddMultiple

func (tss *TrieSyncersStub) AddMultiple(keys []string, interceptors []update.TrieSyncer) error

AddMultiple -

func (*TrieSyncersStub) Get

func (tss *TrieSyncersStub) Get(key string) (update.TrieSyncer, error)

Get -

func (*TrieSyncersStub) IsInterfaceNil

func (tss *TrieSyncersStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*TrieSyncersStub) Len

func (tss *TrieSyncersStub) Len() int

Len -

func (*TrieSyncersStub) Remove

func (tss *TrieSyncersStub) Remove(key string)

Remove -

func (*TrieSyncersStub) Replace

func (tss *TrieSyncersStub) Replace(key string, val update.TrieSyncer) error

Replace -

func (*TrieSyncersStub) StartSyncing

func (tss *TrieSyncersStub) StartSyncing(rootHash []byte, ctx context.Context) error

StartSyncing -

func (*TrieSyncersStub) Trie

func (tss *TrieSyncersStub) Trie() common.Trie

Trie -

type Uint64ByteSliceConverterStub

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

Uint64ByteSliceConverterStub converts byte slice to/from uint64

func (*Uint64ByteSliceConverterStub) IsInterfaceNil

func (u *Uint64ByteSliceConverterStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*Uint64ByteSliceConverterStub) ToByteSlice

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

ToByteSlice is a mock implementation for Uint64ByteSliceConverter

func (*Uint64ByteSliceConverterStub) ToUint64

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

ToUint64 is a mock implementation for Uint64ByteSliceConverter

Jump to

Keyboard shortcuts

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