testchain

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2021 License: Apache-2.0, BSD-2-Clause Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockedACSRunner 

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

func NewMockedACSRunner 

func NewMockedACSRunner(quorum uint16, log *logger.Logger) *MockedACSRunner

func (*MockedACSRunner) Close 

func (acs *MockedACSRunner) Close()

func (*MockedACSRunner) RunACSConsensus 

func (acs *MockedACSRunner) RunACSConsensus(value []byte, sessionID uint64, stateIndex uint32, callback func(sessionID uint64, acs [][]byte))

func (*MockedACSRunner) TryHandleMessage 

func (acs *MockedACSRunner) TryHandleMessage(recv *peering.RecvEvent) bool

type MockedChainCore 

type MockedChainCore struct {
	T *testing.T
	// contains filtered or unexported fields
}

func NewMockedChainCore 

func NewMockedChainCore(t *testing.T, chainID *iscp.ChainID, log *logger.Logger) *MockedChainCore

func (*MockedChainCore) ChainTransition 

func (m *MockedChainCore) ChainTransition() *events.Event

func (*MockedChainCore) Events 

func (m *MockedChainCore) Events() chain.ChainEvents

func (*MockedChainCore) GetCommitteeInfo 

func (m *MockedChainCore) GetCommitteeInfo() *chain.CommitteeInfo

func (*MockedChainCore) GetStateReader 

func (m *MockedChainCore) GetStateReader() state.OptimisticStateReader

func (*MockedChainCore) GlobalSolidIndex 

func (m *MockedChainCore) GlobalSolidIndex() *atomic.Uint32

func (*MockedChainCore) GlobalStateSync 

func (m *MockedChainCore) GlobalStateSync() coreutil.ChainStateSync

func (*MockedChainCore) ID 

func (m *MockedChainCore) ID() *iscp.ChainID

func (*MockedChainCore) Log 

func (m *MockedChainCore) Log() *logger.Logger

func (*MockedChainCore) OnGetStateReader 

func (m *MockedChainCore) OnGetStateReader(f func() state.OptimisticStateReader)

func (*MockedChainCore) OnGlobalStateSync 

func (m *MockedChainCore) OnGlobalStateSync(f func() coreutil.ChainStateSync)

func (*MockedChainCore) OnReceiveAsynchronousCommonSubsetMsg 

func (m *MockedChainCore) OnReceiveAsynchronousCommonSubsetMsg(f func(*messages.AsynchronousCommonSubsetMsg))

func (*MockedChainCore) OnReceiveDismissChainMsg 

func (m *MockedChainCore) OnReceiveDismissChainMsg(f func(*messages.DismissChainMsg))

func (*MockedChainCore) OnReceiveInclusionStateMsg 

func (m *MockedChainCore) OnReceiveInclusionStateMsg(f func(*messages.InclusionStateMsg))

func (*MockedChainCore) OnReceivePeerMessage 

func (m *MockedChainCore) OnReceivePeerMessage(f func(*peering.PeerMessage))

func (*MockedChainCore) OnReceiveStateCandidateMsg 

func (m *MockedChainCore) OnReceiveStateCandidateMsg(f func(*messages.StateCandidateMsg))

func (*MockedChainCore) OnReceiveStateMsg 

func (m *MockedChainCore) OnReceiveStateMsg(f func(*messages.StateMsg))

func (*MockedChainCore) OnReceiveStateTransitionMsg 

func (m *MockedChainCore) OnReceiveStateTransitionMsg(f func(*messages.StateTransitionMsg))

func (*MockedChainCore) OnReceiveTimerTick 

func (m *MockedChainCore) OnReceiveTimerTick(f func(messages.TimerTick))

func (*MockedChainCore) OnReceiveVMResultMsg 

func (m *MockedChainCore) OnReceiveVMResultMsg(f func(*messages.VMResultMsg))

func (*MockedChainCore) OnRequestProcessed 

func (m *MockedChainCore) OnRequestProcessed(f func(id iscp.RequestID))

func (*MockedChainCore) OnStateTransition 

func (m *MockedChainCore) OnStateTransition(f func(data *chain.ChainTransitionEventData))

func (*MockedChainCore) Processors 

func (m *MockedChainCore) Processors() *processors.Cache

func (*MockedChainCore) ReceiveMessage 

func (m *MockedChainCore) ReceiveMessage(msg interface{})

func (*MockedChainCore) ReceiveOffLedgerRequest 

func (m *MockedChainCore) ReceiveOffLedgerRequest(_ *request.OffLedger, _ string)

func (*MockedChainCore) RequestProcessed 

func (m *MockedChainCore) RequestProcessed() *events.Event

type MockedCommitteeRegistry 

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

func NewMockedCommitteeRegistry 

func NewMockedCommitteeRegistry(validators []string) *MockedCommitteeRegistry

func (*MockedCommitteeRegistry) GetCommitteeRecord 

func (m *MockedCommitteeRegistry) GetCommitteeRecord(addr ledgerstate.Address) (*registry.CommitteeRecord, error)

func (*MockedCommitteeRegistry) SaveCommitteeRecord 

func (m *MockedCommitteeRegistry) SaveCommitteeRecord(rec *registry.CommitteeRecord) error

type MockedNodeConn 

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

func NewMockedNodeConnection 

func NewMockedNodeConnection(id string) *MockedNodeConn

func (*MockedNodeConn) ID 

func (m *MockedNodeConn) ID() string

func (*MockedNodeConn) OnPostTransaction 

func (m *MockedNodeConn) OnPostTransaction(f func(tx *ledgerstate.Transaction))

func (*MockedNodeConn) OnPullBacklog 

func (m *MockedNodeConn) OnPullBacklog(f func(addr *ledgerstate.AliasAddress))

func (*MockedNodeConn) OnPullConfirmedOutput 

func (m *MockedNodeConn) OnPullConfirmedOutput(f func(addr ledgerstate.Address, outputID ledgerstate.OutputID))

func (*MockedNodeConn) OnPullConfirmedTransaction 

func (m *MockedNodeConn) OnPullConfirmedTransaction(f func(addr ledgerstate.Address, txid ledgerstate.TransactionID))

func (*MockedNodeConn) OnPullState 

func (m *MockedNodeConn) OnPullState(f func(addr *ledgerstate.AliasAddress))

func (*MockedNodeConn) OnPullTransactionInclusionState 

func (m *MockedNodeConn) OnPullTransactionInclusionState(f func(addr ledgerstate.Address, txid ledgerstate.TransactionID))

func (*MockedNodeConn) PostTransaction 

func (m *MockedNodeConn) PostTransaction(tx *ledgerstate.Transaction)

func (*MockedNodeConn) PullBacklog 

func (m *MockedNodeConn) PullBacklog(addr *ledgerstate.AliasAddress)

func (*MockedNodeConn) PullConfirmedOutput 

func (m *MockedNodeConn) PullConfirmedOutput(addr ledgerstate.Address, outputID ledgerstate.OutputID)

func (*MockedNodeConn) PullConfirmedTransaction 

func (m *MockedNodeConn) PullConfirmedTransaction(addr ledgerstate.Address, txid ledgerstate.TransactionID)

func (*MockedNodeConn) PullState 

func (m *MockedNodeConn) PullState(addr *ledgerstate.AliasAddress)

func (*MockedNodeConn) PullTransactionInclusionState 

func (m *MockedNodeConn) PullTransactionInclusionState(addr ledgerstate.Address, txid ledgerstate.TransactionID)

type MockedStateTransition 

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

func NewMockedStateTransition 

func NewMockedStateTransition(t *testing.T, chainKey *ed25519.KeyPair) *MockedStateTransition

func (*MockedStateTransition) NextState 

func (c *MockedStateTransition) NextState(vs state.VirtualStateAccess, chainOutput *ledgerstate.AliasOutput, ts time.Time, reqs ...iscp.Request)

func (*MockedStateTransition) OnNextState 

func (c *MockedStateTransition) OnNextState(f func(virtualStats state.VirtualStateAccess, tx *ledgerstate.Transaction))

func (*MockedStateTransition) OnVMResult 

func (c *MockedStateTransition) OnVMResult(f func(virtualStats state.VirtualStateAccess, tx *ledgerstate.TransactionEssence))

type MockedVMRunner 

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

func NewMockedVMRunner 

func NewMockedVMRunner(t *testing.T, log *logger.Logger) *MockedVMRunner

func (*MockedVMRunner) Run 

func (r *MockedVMRunner) Run(task *vm.VMTask)

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.