Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrInvalidProtoMessage = errors.New("invalid proto message")
)
Functions ¶
This section is empty.
Types ¶
type Decoder ¶ added in v0.1.4
type Decoder interface {
Decode(reader io.Reader) (buf []byte, err error)
Encode(writer io.Writer, buf []byte) (n int, err error)
DecodeBytes(bytes []byte) (buf []byte, err error)
}
func NewDecoder ¶ added in v0.1.4
type JsonCodec ¶ added in v0.1.5
type JsonCodec struct {
}
func NewJsonCodec ¶ added in v0.1.5
func NewJsonCodec() *JsonCodec
type LineBasedFrameDecoder ¶ added in v0.1.4
type LineBasedFrameDecoder struct {
// contains filtered or unexported fields
}
func (*LineBasedFrameDecoder) Decode ¶ added in v0.1.4
func (decoder *LineBasedFrameDecoder) Decode(reader io.Reader) (buf []byte, err error)
func (*LineBasedFrameDecoder) DecodeBytes ¶ added in v0.1.5
func (decoder *LineBasedFrameDecoder) DecodeBytes(bytes []byte) (buf []byte, err error)
type Options ¶
type Options struct {
// contains filtered or unexported fields
}
Options represents options options
func DefaultOptions ¶ added in v0.1.5
func DefaultOptions() *Options
Default returns the default options implementation,the packet is composed by : |-------------- header --------------|-------- body --------| |packetLength| action | seq |-------- body --------| | 4 | 2 | 2 | n |
type ProtoCodec ¶ added in v0.1.5
type ProtoCodec struct {
}
func NewProtoCodec ¶ added in v0.1.5
func NewProtoCodec() *ProtoCodec
Source Files
Click to show internal directories.
Click to hide internal directories.