testnetwork

Documentation

Index

• type MockNet
  • func NewMockNetwork() *MockNet
  • func (m *MockNet) Receive(msg network.ReceivedMessage)
  • func (m *MockNet) ReceivedChannel() <-chan network.ReceivedMessage
  • func (m *MockNet) ResetSentMessages(protocol string)
  • func (m *MockNet) Send(msg network.OutputMessage, receivers []peer.ID) error
  • func (m *MockNet) SentMessages(protocol string) []PeerMessage
• type PeerMessage

Types

type MockNet

type MockNet struct {
	MessageCh chan network.ReceivedMessage
	// contains filtered or unexported fields
}

func NewMockNetwork

func NewMockNetwork() *MockNet

func (*MockNet) Receive

func (m *MockNet) Receive(msg network.ReceivedMessage)

func (*MockNet) ReceivedChannel

func (m *MockNet) ReceivedChannel() <-chan network.ReceivedMessage

func (*MockNet) ResetSentMessages

func (m *MockNet) ResetSentMessages(protocol string)

func (*MockNet) Send

func (m *MockNet) Send(msg network.OutputMessage, receivers []peer.ID) error

func (*MockNet) SentMessages

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

type PeerMessage

type PeerMessage struct {
	peer.ID
	network.OutputMessage
}