transport

type ChannelTransport ¶ added in v0.0.13

type ChannelTransport struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ChannelTransport implements a basic MVDS transport using channels for basic testing purposes.

func NewChannelTransport(offline int, in <-chan Packet) *ChannelTransport

func (t *ChannelTransport) AddOutput(id state.PeerID, c chan<- Packet)

func (t *ChannelTransport) Send(group state.GroupID, sender state.PeerID, peer state.PeerID, payload protobuf.Payload) error

func (t *ChannelTransport) Watch() Packet

type Packet ¶

type Packet struct {
	Group   state.GroupID
	Sender  state.PeerID
	Payload protobuf.Payload
}

type Transport ¶

type Transport interface {
	Watch() Packet
	Send(group state.GroupID, sender state.PeerID, peer state.PeerID, payload protobuf.Payload) error
}

Transport defines an interface allowing for agnostic transport implementations.