testutil_replica

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2020 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Contain 

func Contain(list []int, target int) bool

func NewMockObserver 

func NewMockObserver(store *MockPersistentStorage, isSignatory bool) replica.Observer

func NewMockValidator 

func NewMockValidator(store *MockPersistentStorage) replica.Validator

func RandomShard 

func RandomShard() replica.Shard

func SleepRandomSeconds 

func SleepRandomSeconds(min, max int)

Types

type MockBlockIterator 

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

func NewMockBlockIterator 

func NewMockBlockIterator(store *MockPersistentStorage, timeout bool) *MockBlockIterator

func (*MockBlockIterator) NextBlock 

func (m *MockBlockIterator) NextBlock(kind block.Kind, height block.Height, shard replica.Shard) (block.Txs, block.Plan, block.State)

type MockBroadcaster 

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

func NewMockBroadcaster 

func NewMockBroadcaster(keys []*ecdsa.PrivateKey, min, max int) *MockBroadcaster

func (*MockBroadcaster) Broadcast 

func (m *MockBroadcaster) Broadcast(message replica.Message)

func (*MockBroadcaster) Cast added in v0.4.2 

func (m *MockBroadcaster) Cast(to id.Signatory, message replica.Message)

func (*MockBroadcaster) DisablePeer 

func (m *MockBroadcaster) DisablePeer(sig id.Signatory)

func (*MockBroadcaster) EnablePeer 

func (m *MockBroadcaster) EnablePeer(sig id.Signatory)

func (*MockBroadcaster) Messages 

func (m *MockBroadcaster) Messages(sig id.Signatory) chan []byte

type MockObserver 

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

func (MockObserver) DidCommitBlock 

func (m MockObserver) DidCommitBlock(height block.Height, shard replica.Shard)

func (*MockObserver) DidReceiveSufficientNilPrevotes added in v0.3.2 

func (observer *MockObserver) DidReceiveSufficientNilPrevotes(process.Messages, int)

func (*MockObserver) IsSignatory 

func (observer *MockObserver) IsSignatory(replica.Shard) bool

type MockPersistentStorage 

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

func NewMockPersistentStorage 

func NewMockPersistentStorage(shards replica.Shards) *MockPersistentStorage

func (*MockPersistentStorage) Blockchain 

func (store *MockPersistentStorage) Blockchain(shard replica.Shard) process.Blockchain

func (*MockPersistentStorage) Init 

func (store *MockPersistentStorage) Init(gb block.Block)

func (*MockPersistentStorage) LatestBaseBlock 

func (store *MockPersistentStorage) LatestBaseBlock(shard replica.Shard) block.Block

func (*MockPersistentStorage) LatestBlock 

func (store *MockPersistentStorage) LatestBlock(shard replica.Shard) block.Block

func (*MockPersistentStorage) MockBlockchain 

func (store *MockPersistentStorage) MockBlockchain(shard replica.Shard) *testutil.MockBlockchain

func (*MockPersistentStorage) RestoreState added in v0.4.2 

func (store *MockPersistentStorage) RestoreState(state *process.State, shard replica.Shard)

func (*MockPersistentStorage) SaveState added in v0.4.2 

func (store *MockPersistentStorage) SaveState(state *process.State, shard replica.Shard)

type MockValidator 

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

func (*MockValidator) IsBlockValid 

func (m *MockValidator) IsBlockValid(b block.Block, checkHistory bool, shard replica.Shard) (process.NilReasons, error)

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.