testnetwork

Documentation

Index

• type MockNet
  • 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, receiver peer.ID)
  • func (m *MockNet) ProcessTransactions(ctx context.Context, txProcessor network.TxProcessor)
  • func (m *MockNet) Receive(msg any)
  • func (m *MockNet) ReceivedChannel() <-chan any
  • 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)
• type PeerMessage

Types

type MockNet

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

func NewMockNetwork

func NewMockNetwork(t *testing.T) *MockNet

func NewRootMockNetwork

func NewRootMockNetwork() *MockNet

func (*MockNet) AddTransaction

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

func (*MockNet) ForwardTransactions

func (m *MockNet) ForwardTransactions(ctx context.Context, receiver peer.ID)

func (*MockNet) ProcessTransactions

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

func (*MockNet) Receive

func (m *MockNet) Receive(msg any)

func (*MockNet) ReceivedChannel

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

func (*MockNet) ResetSentMessages

func (m *MockNet) ResetSentMessages(protocol string)

func (*MockNet) Send

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

func (*MockNet) SentMessages

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

func (*MockNet) SetErrorState

func (m *MockNet) SetErrorState(err error)

type PeerMessage

type PeerMessage struct {
	peer.ID
	Message any
}