testchain

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2022 License: Apache-2.0, BSD-2-Clause Imports: 25 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))

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) EnqueueDismissChain added in v0.2.3 

func (m *MockedChainCore) EnqueueDismissChain(reason string)

func (*MockedChainCore) EnqueueLedgerState added in v0.2.3 

func (m *MockedChainCore) EnqueueLedgerState(chainOutput *ledgerstate.AliasOutput, timestamp time.Time)

func (*MockedChainCore) EnqueueMissingRequestIDsMsg added in v0.2.3 

func (m *MockedChainCore) EnqueueMissingRequestIDsMsg(msg *messages.MissingRequestIDsMsgIn)

func (*MockedChainCore) EnqueueMissingRequestMsg added in v0.2.3 

func (m *MockedChainCore) EnqueueMissingRequestMsg(msg *messages.MissingRequestMsg)

func (*MockedChainCore) EnqueueOffLedgerRequestMsg added in v0.2.3 

func (m *MockedChainCore) EnqueueOffLedgerRequestMsg(msg *messages.OffLedgerRequestMsgIn)

func (*MockedChainCore) EnqueueRequestAckMsg added in v0.2.3 

func (m *MockedChainCore) EnqueueRequestAckMsg(msg *messages.RequestAckMsgIn)

func (*MockedChainCore) EnqueueTimerTick added in v0.2.3 

func (m *MockedChainCore) EnqueueTimerTick(tick int)

func (*MockedChainCore) GetCandidateNodes added in v0.2.4 

func (m *MockedChainCore) GetCandidateNodes() []*governance.AccessNodeInfo

func (*MockedChainCore) GetChainNodes added in v0.2.4 

func (m *MockedChainCore) GetChainNodes() []peering.PeerStatusProvider

func (*MockedChainCore) GetCommitteeInfo 

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

func (*MockedChainCore) GetStateReader 

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

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) OnDismissChain added in v0.2.3 

func (m *MockedChainCore) OnDismissChain(fun func(reason string))

func (*MockedChainCore) OnGetStateReader 

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

func (*MockedChainCore) OnGlobalStateSync 

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

func (*MockedChainCore) OnLedgerState added in v0.2.3 

func (m *MockedChainCore) OnLedgerState(fun func(chainOutput *ledgerstate.AliasOutput, timestamp time.Time))

func (*MockedChainCore) OnMissingRequest added in v0.2.3 

func (m *MockedChainCore) OnMissingRequest(fun func(msg *messages.MissingRequestMsg))

func (*MockedChainCore) OnMissingRequestIDs added in v0.2.3 

func (m *MockedChainCore) OnMissingRequestIDs(fun func(msg *messages.MissingRequestIDsMsgIn))

func (*MockedChainCore) OnOffLedgerRequest added in v0.2.3 

func (m *MockedChainCore) OnOffLedgerRequest(fun func(msg *messages.OffLedgerRequestMsgIn))

func (*MockedChainCore) OnRequestAck added in v0.2.3 

func (m *MockedChainCore) OnRequestAck(fun func(msg *messages.RequestAckMsgIn))

func (*MockedChainCore) OnRequestProcessed 

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

func (*MockedChainCore) OnSendPeerMsg added in v0.2.3 

func (m *MockedChainCore) OnSendPeerMsg(fun func(netID string, msgReceiver byte, msgType byte, msgData []byte))

func (*MockedChainCore) OnStateCandidate added in v0.2.3 

func (m *MockedChainCore) OnStateCandidate(fun func(state state.VirtualStateAccess, outputID ledgerstate.OutputID))

func (*MockedChainCore) OnStateTransition 

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

func (*MockedChainCore) OnTimerTick added in v0.2.3 

func (m *MockedChainCore) OnTimerTick(fun func(tick int))

func (*MockedChainCore) Processors 

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

func (*MockedChainCore) StateCandidateToStateManager added in v0.2.3 

func (m *MockedChainCore) StateCandidateToStateManager(virtualState state.VirtualStateAccess, outputID ledgerstate.OutputID)

func (*MockedChainCore) TriggerChainTransition added in v0.2.3 

func (m *MockedChainCore) TriggerChainTransition(data *chain.ChainTransitionEventData)

type MockedNodeConn 

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

func NewMockedNodeConnection 

func NewMockedNodeConnection(id string) *MockedNodeConn

func (*MockedNodeConn) AttachToInclusionStateReceived added in v0.2.3 

func (m *MockedNodeConn) AttachToInclusionStateReceived(chain.NodeConnectionHandleInclusionStateFun)

func (*MockedNodeConn) AttachToOutputReceived added in v0.2.3 

func (m *MockedNodeConn) AttachToOutputReceived(chain.NodeConnectionHandleOutputFun)

func (*MockedNodeConn) AttachToTransactionReceived added in v0.2.3 

func (m *MockedNodeConn) AttachToTransactionReceived(chain.NodeConnectionHandleTransactionFun)

func (*MockedNodeConn) AttachToUnspentAliasOutputReceived added in v0.2.3 

func (m *MockedNodeConn) AttachToUnspentAliasOutputReceived(chain.NodeConnectionHandleUnspentAliasOutputFun)

func (*MockedNodeConn) Close added in v0.2.3 

func (m *MockedNodeConn) Close()

func (*MockedNodeConn) DetachFromInclusionStateReceived added in v0.2.3 

func (m *MockedNodeConn) DetachFromInclusionStateReceived()

func (*MockedNodeConn) DetachFromOutputReceived added in v0.2.3 

func (m *MockedNodeConn) DetachFromOutputReceived()

func (*MockedNodeConn) DetachFromTransactionReceived added in v0.2.3 

func (m *MockedNodeConn) DetachFromTransactionReceived()

func (*MockedNodeConn) DetachFromUnspentAliasOutputReceived added in v0.2.3 

func (m *MockedNodeConn) DetachFromUnspentAliasOutputReceived()

func (*MockedNodeConn) GetMetrics added in v0.2.3 

func (m *MockedNodeConn) GetMetrics() nodeconnmetrics.NodeConnectionMessagesMetrics

func (*MockedNodeConn) ID 

func (m *MockedNodeConn) ID() string

func (*MockedNodeConn) OnPostTransaction 

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

func (*MockedNodeConn) OnPullConfirmedOutput 

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

func (*MockedNodeConn) OnPullState 

func (m *MockedNodeConn) OnPullState(f func())

func (*MockedNodeConn) OnPullTransactionInclusionState 

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

func (*MockedNodeConn) PostTransaction 

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

func (*MockedNodeConn) PullConfirmedOutput 

func (m *MockedNodeConn) PullConfirmedOutput(outputID ledgerstate.OutputID)

func (*MockedNodeConn) PullState 

func (m *MockedNodeConn) PullState()

func (*MockedNodeConn) PullTransactionInclusionState 

func (m *MockedNodeConn) PullTransactionInclusionState(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.