session

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

type AddressFactory struct {
	serde.Factory
}

type ConnectionManager interface {
	Len() int
	Acquire(mino.Address) (grpc.ClientConnInterface, error)
	Release(mino.Address)
}

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

type PacketStream interface {
	Context() context.Context
	Send(*ptypes.Packet) error
	Recv() (*ptypes.Packet, error)
}

type Queue interface {
	Channel() <-chan router.Packet
	Push(router.Packet) error
}

type Relay interface {
	// GetDistantAddress returns the address of the peer at the other end of the
	// relay.
	GetDistantAddress() mino.Address

	// Stream returns the stream that is holding the relay.
	Stream() PacketStream

	// Send sends a packet through the relay.
	Send(ctx context.Context, p router.Packet) (*ptypes.Ack, error)

	// Close closes the relay and clean the resources.
	Close() error
}

type Session interface {
	mino.Sender
	mino.Receiver

	// GetNumParents returns the number of active parents for the session.
	GetNumParents() int

	// Listen takes a stream that will determine when to close the session.
	Listen(parent Relay, table router.RoutingTable, ready chan struct{})

	// SetPassive sets a new passive parent. A passive parent is part of the
	// parent relays, but the stream does not listen to, and thus it is not
	// removed from the map if it closed.
	SetPassive(parent Relay, table router.RoutingTable)

	// Close shutdowns the session so that future calls to receive will return
	// an error.
	Close()

	// RecvPacket takes a packet and the address of the distant peer that have
	// sent it, then pass it to the correct relay according to the routing
	// table.
	RecvPacket(from mino.Address, p *ptypes.Packet) (*ptypes.Ack, error)
}