mocks

Jun 2, 2020

Changes in this version

type FakeMembership

+ func (m *FakeMembership) RequestCommitteeForBlockProof(ctx context.Context, prevBlockReferenceTime primitives.TimestampSeconds) ([]primitives.MemberId, error)

Apr 5, 2020

Changes in this version

type MockBlock

+ func (b *MockBlock) ReferenceTime() primitives.TimestampSeconds

Jan 29, 2020

Changes in this version

type ElectionTriggerMock

+ func (et *ElectionTriggerMock) InvokeElectionHandler()

Nov 6, 2019

Changes in this version

+ func NewMockConfigSimple() *interfaces.Config

type ElectionTriggerMock

+ func (et *ElectionTriggerMock) GetRegisteredHeight() primitives.BlockHeight

type MockKeyManager

+ func (km *MockKeyManager) DisableConsensusMessageVerification()

Aug 19, 2019

Changes in this version

+ const BLOCK_HEIGHT_DONT_CARE

+ const VIEW_DONT_CARE

+ func NewMockConfig() *interfaces.Config

type CommunicationMock

+ func (g *CommunicationMock) CountMessagesSent(messageType protocol.MessageType, height primitives.BlockHeight, ...) int

+ func (g *CommunicationMock) DisableIncomingCommunication()

+ func (g *CommunicationMock) DisableOutgoingCommunication()

+ func (g *CommunicationMock) EnableIncomingCommunication()

+ func (g *CommunicationMock) EnableOutgoingCommunication()

+ func (g *CommunicationMock) OnIncomingMessage(ctx context.Context, rawMessage *interfaces.ConsensusRawMessage)

+ func (g *CommunicationMock) RegisterIncomingMessageHandler(cb func(ctx context.Context, message *interfaces.ConsensusRawMessage))

+ func (g *CommunicationMock) ReturnAndMaybeCreateOutgoingChannelByTarget(ctx context.Context, target primitives.MemberId) chan *outgoingMessage

+ func (g *CommunicationMock) ReturnOutgoingChannelByTarget(target primitives.MemberId) chan *outgoingMessage

+ type FakeMembership struct

+ func NewFakeMembership(myMemberId primitives.MemberId, discovery *Discovery, ...) *FakeMembership

+ func (m *FakeMembership) MyMemberId() primitives.MemberId

+ func (m *FakeMembership) RequestOrderedCommittee(ctx context.Context, blockHeight primitives.BlockHeight, randomSeed uint64) ([]primitives.MemberId, error)

+ type InMemoryBlockchain struct

+ func NewInMemoryBlockchain() *InMemoryBlockchain

+ func (bs *InMemoryBlockchain) AppendBlockToChain(block interfaces.Block, blockProof []byte)

+ func (bs *InMemoryBlockchain) BlockAndProofAt(height primitives.BlockHeight) (interfaces.Block, []byte)

+ func (bs *InMemoryBlockchain) Count() int

+ func (bs *InMemoryBlockchain) LastBlock() interfaces.Block

+ func (bs *InMemoryBlockchain) LastBlockProof() []byte

+ func (bs *InMemoryBlockchain) WithMemberId(memberId primitives.MemberId) *InMemoryBlockchain

type MockBlock

+ func (b *MockBlock) String() string

+ type MockState struct

+ func NewMockState() *MockState

+ func (s *MockState) WithHeightView(h primitives.BlockHeight, v primitives.View) *MockState

+ type PausableBlockUtils struct

+ PauseOnValidateBlock bool

+ RequestNewBlockCallsLeftUntilItPausesWhenCounterIsZero int64

+ RequestNewBlockLatch *test.Latch

+ ValidationLatch *test.Latch

+ func (b *PausableBlockUtils) RequestNewBlockProposal(ctx context.Context, blockHeight primitives.BlockHeight, ...) (interfaces.Block, primitives.BlockHash)

+ func (b *PausableBlockUtils) ValidateBlockCommitment(blockHeight primitives.BlockHeight, block interfaces.Block, ...) bool

+ func (b *PausableBlockUtils) ValidateBlockProposal(ctx context.Context, blockHeight primitives.BlockHeight, ...) error

+ func (b *PausableBlockUtils) WithFailingBlockProposalValidations() *PausableBlockUtils

Jul 28, 2019

Changes in this version

+ func ABlock(previousBlock interfaces.Block) interfaces.Block

+ func CalculateBlockHash(block interfaces.Block) primitives.BlockHash

+ type BlocksPool struct

+ func NewBlocksPool(upcomingBlocks []interfaces.Block) *BlocksPool

+ func (bp *BlocksPool) PopBlock(prevBlock interfaces.Block) interfaces.Block

+ type CommunicationMock struct

+ func NewCommunication(discovery *Discovery) *CommunicationMock

+ func (g *CommunicationMock) ClearIncomingWhitelist()

+ func (g *CommunicationMock) ClearOutgoingWhitelist()

+ func (g *CommunicationMock) CountSentMessages(messageType protocol.MessageType) int

+ func (g *CommunicationMock) GetSentMessages(messageType protocol.MessageType) []*interfaces.ConsensusRawMessage

+ func (g *CommunicationMock) OnRemoteMessage(ctx context.Context, rawMessage *interfaces.ConsensusRawMessage)

+ func (g *CommunicationMock) RegisterOnMessage(cb func(ctx context.Context, message *interfaces.ConsensusRawMessage)) int

+ func (g *CommunicationMock) SendConsensusMessage(ctx context.Context, targets []primitives.MemberId, ...)

+ func (g *CommunicationMock) SendToNode(ctx context.Context, targetMemberId primitives.MemberId, ...)

+ func (g *CommunicationMock) SetIncomingWhitelist(incomingWhitelist []primitives.MemberId)

+ func (g *CommunicationMock) SetMessagesMaxDelay(duration time.Duration)

+ func (g *CommunicationMock) SetOutgoingWhitelist(outgoingWhitelist []primitives.MemberId)

+ func (g *CommunicationMock) UnregisterOnMessage(subscriptionToken int)

+ type Discovery struct

+ func NewDiscovery() *Discovery

+ func (d *Discovery) AllCommunicationsMemberIds() []primitives.MemberId

+ func (d *Discovery) Communications(memberIds []primitives.MemberId) []*CommunicationMock

+ func (d *Discovery) GetCommunicationById(memberId primitives.MemberId) *CommunicationMock

+ func (d *Discovery) RegisterCommunication(memberId primitives.MemberId, communication *CommunicationMock)

+ func (d *Discovery) UnregisterCommunication(memberId primitives.MemberId)

+ type ElectionTriggerMock struct

+ func NewMockElectionTrigger() *ElectionTriggerMock

+ func (et *ElectionTriggerMock) CalcTimeout(view primitives.View) time.Duration

+ func (et *ElectionTriggerMock) ElectionChannel() chan func(ctx context.Context)

+ func (et *ElectionTriggerMock) ManualTrigger(ctx context.Context)

+ func (et *ElectionTriggerMock) ManualTriggerSync(ctx context.Context)

+ func (et *ElectionTriggerMock) RegisterOnElection(ctx context.Context, blockHeight primitives.BlockHeight, view primitives.View, ...)

+ func (et *ElectionTriggerMock) Stop()

+ type InMemoryBlockChain struct

+ func NewInMemoryBlockChain() *InMemoryBlockChain

+ func (bs *InMemoryBlockChain) AppendBlockToChain(block interfaces.Block, blockProof []byte)

+ func (bs *InMemoryBlockChain) GetBlockProofAt(height primitives.BlockHeight) []byte

+ func (bs *InMemoryBlockChain) GetLastBlock() interfaces.Block

+ func (bs *InMemoryBlockChain) GetLastBlockProof() []byte

+ type MockBlock struct

+ func (b *MockBlock) Body() string

+ func (b *MockBlock) Height() primitives.BlockHeight

+ type MockBlockUtils struct

+ PauseOnRequestNewBlock bool

+ PauseOnValidation bool

+ RequestNewBlockLatch *test.Latch

+ ValidationCounter int

+ ValidationLatch *test.Latch

+ ValidationResult bool

+ func NewMockBlockUtils(blocksPool *BlocksPool) *MockBlockUtils

+ func (b *MockBlockUtils) CounterOfValidation() int

+ func (b *MockBlockUtils) RequestNewBlockProposal(ctx context.Context, blockHeight primitives.BlockHeight, ...) (interfaces.Block, primitives.BlockHash)

+ func (b *MockBlockUtils) ValidateBlockCommitment(blockHeight primitives.BlockHeight, block interfaces.Block, ...) bool

+ func (b *MockBlockUtils) ValidateBlockProposal(ctx context.Context, blockHeight primitives.BlockHeight, ...) error

+ type MockKeyManager struct

+ FailFutureVerifications bool

+ VerifyRandomSeedHistory []*VerifyRandomSeedCallParams

+ func NewMockKeyManager(memberId primitives.MemberId, rejectedMemberIds ...primitives.MemberId) *MockKeyManager

+ func (km *MockKeyManager) AggregateRandomSeed(blockHeight primitives.BlockHeight, ...) primitives.RandomSeedSignature

+ func (km *MockKeyManager) SignConsensusMessage(ctx context.Context, blockHeight primitives.BlockHeight, content []byte) primitives.Signature

+ func (km *MockKeyManager) SignRandomSeed(ctx context.Context, blockHeight primitives.BlockHeight, content []byte) primitives.RandomSeedSignature

+ func (km *MockKeyManager) VerifyConsensusMessage(blockHeight primitives.BlockHeight, content []byte, ...) error

+ func (km *MockKeyManager) VerifyRandomSeed(blockHeight primitives.BlockHeight, content []byte, ...) error

+ type MockMembership struct

+ func NewMockMembership(myMemberId primitives.MemberId, discovery *Discovery, ...) *MockMembership

+ func (m *MockMembership) MyMemberId() primitives.MemberId

+ func (m *MockMembership) RequestOrderedCommittee(ctx context.Context, blockHeight primitives.BlockHeight, randomSeed uint64) ([]primitives.MemberId, error)

+ type SubscriptionValue struct

+ type TermMessagesHandlerMock struct

+ HistoryC []*interfaces.CommitMessage

+ HistoryNV []*interfaces.NewViewMessage

+ HistoryP []*interfaces.PrepareMessage

+ HistoryPP []*interfaces.PreprepareMessage

+ HistoryVC []*interfaces.ViewChangeMessage

+ func NewTermMessagesHandlerMock() *TermMessagesHandlerMock

+ func (tmh *TermMessagesHandlerMock) HandleCommit(ctx context.Context, cm *interfaces.CommitMessage)

+ func (tmh *TermMessagesHandlerMock) HandleNewView(ctx context.Context, nvm *interfaces.NewViewMessage)

+ func (tmh *TermMessagesHandlerMock) HandlePrePrepare(ctx context.Context, ppm *interfaces.PreprepareMessage)

+ func (tmh *TermMessagesHandlerMock) HandlePrepare(ctx context.Context, pm *interfaces.PrepareMessage)

+ func (tmh *TermMessagesHandlerMock) HandleViewChange(ctx context.Context, vcm *interfaces.ViewChangeMessage)

+ type VerifyRandomSeedCallParams struct

+ BlockHeight primitives.BlockHeight

+ Content []byte

+ Sender *protocol.SenderSignature