codec

Documentation

Index

• Variables
• func Bufio(base link.Protocol, readBuf, writeBuf int) link.Protocol
• type FixLenProtocol
  • func FixLen(base link.Protocol, n int, byteOrder binary.ByteOrder, maxRecv, maxSend int) *FixLenProtocol
  • func (p *FixLenProtocol) NewCodec(rw io.ReadWriter) (cc link.Codec, err error)
• type JsonProtocol
  • func Json() *JsonProtocol
  • func (j *JsonProtocol) NewCodec(rw io.ReadWriter) (link.Codec, error)
  • func (j *JsonProtocol) Register(t interface{})
  • func (j *JsonProtocol) RegisterName(name string, t interface{})

Variables

var ErrTooLargePacket = errors.New("Too Large Packet")

Functions

func Bufio

func Bufio(base link.Protocol, readBuf, writeBuf int) link.Protocol

Types

type FixLenProtocol

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

func FixLen

func FixLen(base link.Protocol, n int, byteOrder binary.ByteOrder, maxRecv, maxSend int) *FixLenProtocol

func (*FixLenProtocol) NewCodec

func (p *FixLenProtocol) NewCodec(rw io.ReadWriter) (cc link.Codec, err error)

type JsonProtocol

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

func Json

func Json() *JsonProtocol

func (*JsonProtocol) NewCodec

func (j *JsonProtocol) NewCodec(rw io.ReadWriter) (link.Codec, error)

func (*JsonProtocol) Register

func (j *JsonProtocol) Register(t interface{})

func (*JsonProtocol) RegisterName

func (j *JsonProtocol) RegisterName(name string, t interface{})