transport

type Conn io.ReadWriteCloser

type ConnConfig interface{}

type ErrCode int

type ErrNotMultiple struct {
	Len int
}

type Mode interface {
	WriteMsg(msg []byte) error // this is not same as the io.Writer
	ReadMsg() ([]byte, error)
}

type ModeConfig = func(Conn) (Mode, error)

type TCPConnConfig struct {
	Ctx     context.Context
	Host    string
	Timeout time.Duration
}

type Transport interface {
	Close() error
	WriteMsg(msg messages.Common, requireToAck bool) error
	ReadMsg() (messages.Common, error)
}