mock

Documentation

Index

• type FakeNetwork
  • func CreateFakeNetwork() *FakeNetwork
  • func (n *FakeNetwork) Dial(addr string) (Socket, error)
  • func (n *FakeNetwork) Listen(addr string) (Socket, error)
• type FakeSocket
  • func (socket *FakeSocket) Receive(ctx context.Context) (p2p.Message, error)
  • func (socket *FakeSocket) Send(msg p2p.Message) error
• type MockMessenger
  • func CreateMessenger(network Network, node p2p.Node) *MockMessenger
  • func (m *MockMessenger) ListenForever(msgChan chan p2p.Message, ctx context.Context) error
  • func (m *MockMessenger) Send(msg p2p.Message, ctx context.Context) error
• type Network
• type Socket

Types

type FakeNetwork

type FakeNetwork struct {
	Hosts map[string]*FakeSocket
	// contains filtered or unexported fields
}

func CreateFakeNetwork

func CreateFakeNetwork() *FakeNetwork

func (*FakeNetwork) Dial

func (n *FakeNetwork) Dial(addr string) (Socket, error)

func (*FakeNetwork) Listen

func (n *FakeNetwork) Listen(addr string) (Socket, error)

type FakeSocket

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

func (*FakeSocket) Receive

func (socket *FakeSocket) Receive(ctx context.Context) (p2p.Message, error)

func (*FakeSocket) Send

func (socket *FakeSocket) Send(msg p2p.Message) error

type MockMessenger

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

func CreateMessenger

func CreateMessenger(network Network, node p2p.Node) *MockMessenger

func (*MockMessenger) ListenForever

func (m *MockMessenger) ListenForever(msgChan chan p2p.Message, ctx context.Context) error

func (*MockMessenger) Send

func (m *MockMessenger) Send(msg p2p.Message, ctx context.Context) error

type Network

type Network interface {
	Listen(addr string) (Socket, error)
	Dial(addr string) (Socket, error)
}

type Socket

type Socket interface {
	Send(msg p2p.Message) error
	Receive(context.Context) (p2p.Message, error)
}