codec

Documentation

Index

• Constants
• Variables
• func Marshal(protocol string, b interface{}) ([]byte, error)
• func RegQueryUnmarshaler(endpoint string, d *schema.Decoder)
• func StreamRead(r io.Reader) (uint8, []byte, error)
• func StreamWrite(cf uint8, buf []byte, w io.Writer) error
• func Unmarshal(protocol string, buff []byte, payload *micro.Response) error
• func UnmarshalQuery(endpoint string, src map[string][]string, dst interface{}) error

Constants

const (
	MaxMessageSize = 1024 * 1024 * 4 // 4Mb

)

Variables

var (
	DefaultQueryUnmarshaler = schema.NewDecoder()
)

var (
	ErrInvalidMessage = errors.New("invalid message")
)

Functions

func Marshal

func Marshal(protocol string, b interface{}) ([]byte, error)

func RegQueryUnmarshaler

func RegQueryUnmarshaler(endpoint string, d *schema.Decoder)

func StreamRead

func StreamRead(r io.Reader) (uint8, []byte, error)

StreamRead 流式读

func StreamWrite

func StreamWrite(cf uint8, buf []byte, w io.Writer) error

StreamWrite 流式写

func Unmarshal

func Unmarshal(protocol string, buff []byte, payload *micro.Response) error

func UnmarshalQuery

func UnmarshalQuery(endpoint string, src map[string][]string, dst interface{}) error