multiplexer

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

type Config struct {
	Logger    *zap.Logger
	Conn      interface{}
	Peer      uint64
	Initiator bool
	Wait      time.Duration
}

type Constructor func(Config) (Peer, error)

type DialFunc func(addr string, c *tls.Config) (connector interface{}, handshake net.Conn, closer func(), err error)

type Link struct {
	Source      uint64
	Destination uint64
	Protocol    protocol.Protocol // used for initial multiplexer handshake only
	ALPN        alpn.ALPN         // used to specify the expected application protocol
}

type LinkConnection struct {
	Conn net.Conn
	Link Link
}

type Peer interface {
	// Start will accept incoming connections from another Peer
	Start(context.Context)
	// Null should disconnect the incoming Peer if an incoming connection is accepted
	Null(context.Context)
	// Addr should return the Peer's net.Addr
	Addr() net.Addr
	// Initiator should return if the Peer initiated the connection
	Initiator() bool
	// Protocol returns the multiplexer protocol in used with the peer
	Protocol() protocol.Protocol
	// Peer returns the uint64 identifier of the connected Peer
	Peer() uint64
	// Messaging opens a dedicated bidirectional stream to handle in-band control messages
	Messaging(context.Context) (net.Conn, error)
	// Bidirectional establishs a virtual link between the Source and Destination via this Peer
	Bidirectional(context.Context, net.Conn, Link) (<-chan error, error)
	// Direct requests a direct link to destination without automatic bidirectional handling
	Direct(context.Context, Link) (net.Conn, error)
	// Handle returns a receving channel where Bidirectional request is made from a connected peer
	Handle() <-chan LinkConnection
	// NotifyClose returns a notifying channel, unblocks when the Peer disconnects
	NotifyClose() <-chan struct{}
	// Bye closes the session and LinkConnection channel
	Bye() error
}