transport

type ClientTransport interface {
	Transport
	WithClientCertificate(cert tls.Certificate) error
}

type ConnectedPeer struct {
	Identity *protocol.Node
	Addr     net.Addr
	Version  string
}

type DatagramDelegate struct {
	Identity *protocol.Node
	Buffer   []byte
}

type StreamDelegate struct {
	net.Conn                         // The backing bytes stream of the delegation
	Certificate *x509.Certificate    // The verified peer certificate, if any
	Identity    *protocol.Node       // The identity that the peer claims to be. Implementation may use mTLS to verify
	Kind        protocol.Stream_Type // Type of the bytes stream of the delegation
}

type StreamHandler func(delegate *StreamDelegate)

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

type Transport interface {
	Identity() *protocol.Node

	DialStream(ctx context.Context, peer *protocol.Node, kind protocol.Stream_Type) (net.Conn, error)
	AcceptStream() <-chan *StreamDelegate

	ListConnected() []ConnectedPeer

	SupportDatagram() bool
	ReceiveDatagram() <-chan *DatagramDelegate
	SendDatagram(*protocol.Node, []byte) error
}