testnetwork

package

v1.0.1 Latest Latest Go to latest Published: Apr 29, 2025 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MockNet struct {
	MessageCh chan any
	// contains filtered or unexported fields
}

func NewMockNetwork(t *testing.T) *MockNet

func NewRootMockNetwork() *MockNet

func (m *MockNet) AddTransaction(ctx context.Context, tx *types.TransactionOrder) ([]byte, error)

func (m *MockNet) ForwardTransactions(ctx context.Context, receiverFunc network.TxReceiver)

func (m *MockNet) ProcessTransactions(ctx context.Context, txProcessor network.TxProcessor)

func (m *MockNet) PublishBlock(ctx context.Context, block *types.Block) error

func (m *MockNet) Receive(msg any)

func (m *MockNet) ReceivedChannel() <-chan any

func (n *MockNet) RegisterValidatorProtocols() error

func (m *MockNet) ResetSentMessages(protocol string)

func (m *MockNet) Send(ctx context.Context, msg any, receivers ...peer.ID) error

func (m *MockNet) SentMessages(protocol string) []PeerMessage

func (m *MockNet) SetErrorState(err error)

func (m *MockNet) SubscribeToBlocks(ctx context.Context) error

func (n *MockNet) UnregisterValidatorProtocols()

func (m *MockNet) UnsubscribeFromBlocks()

func (m *MockNet) WaitReceive(t *testing.T, msg any)

func (m *MockNet) WaitRootProposal(t *testing.T) *abdrc.ProposalMsg

type PeerMessage struct {
	peer.ID
	Message any
}