transport

type DialConfig struct {
	Address        string
	CompressConfig compress.Config
	EncodingName   EncodingName
}

type Dialer interface {
	Dial(DialConfig) (Transport, error)
}

type EncodingName string

type Name string

type NegotiationParams struct {
	Encoding           EncodingName  `json:"enc,omitempty"`
	Compress           compress.Type `json:"comp,omitempty"`
	CompressLevel      *int          `json:"clevel,string,omitempty"`
	CompressWindowBits *int          `json:"cwinbits,string,omitempty"`
}

type ReadWriter interface {
	Reader
	Writer
}

type Reader interface {
	// Read は、トランスポートからメッセージを読み出します。
	Read() ([]byte, error)
	// Close は、トランスポートのコネクションを切断します。
	Close() error
	// RxBytesCounterValue は、現在の受信メッセージカウンターの値を返します。
	RxBytesCounterValue() uint64
}

type Transport interface {
	ReadWriter

	// AsUnreliable は UnreliableTransportを返します。
	//
	// もし、 Unreliableをサポートしていない場合は okはfalseを返します。
	AsUnreliable() (tr UnreliableTransport, ok bool)

	// NegotiationParams は、トランスポートで事前ネゴシエーションされたパラメーターを返します。
	NegotiationParams() NegotiationParams

	// Nameは、トランスポート名を返却します。
	Name() Name
}

type UnreliableTransport interface {
	ReadWriter
	IsUnreliable()
}

type Writer interface {
	// Write は、トランスポートへメッセージを書き込みます。
	Write([]byte) error
	// Close は、トランスポートのコネクションを切断します。
	Close() error
	// TxBytesCounterValue は、現在の送信バイトカウンターの値を返します。
	TxBytesCounterValue() uint64
}