testnetwork

package

v0.2.1 Latest Latest Go to latest Published: Oct 13, 2023 License: AGPL-3.0 Imports: 12 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() *MockNet

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 struct {
	peer.ID
	Message any
}