codec

Documentation

Index

• Constants
• Variables
• type Codec
• type CodecType
  • func GetCodecType(t string) CodecType
  • func (c CodecType) String() string
• type Message
• type MessageType
• type NewCodec
• type TransportType
  • func GetTransportType(t string) TransportType
  • func (t TransportType) String() string

Constants

const (
	Error     MessageType = 0x01
	Request               = 0x02
	Response              = 0x04
	Heartbeat             = 0x08
)

Variables

var (
	ErrHeaderNotEnough = errors.New("header buffer too short")
	ErrBodyNotEnough   = errors.New("body buffer too short")
	ErrJavaException   = errors.New("got java exception")
	ErrIllegalPackage  = errors.New("illegal package!")
)

Types

type Codec

type Codec interface {
	ReadHeader(*Message, MessageType) error
	ReadBody(interface{}) error
	Write(m *Message, args interface{}) error
	Close() error
	String() string
}

type CodecType

type CodecType int

const (
	CODECTYPE_BEGIN CodecType = iota
	CODECTYPE_JSONRPC
	CODECTYPE_DUBBO
	CODECTYPE_UNKNOWN
)

func GetCodecType

func GetCodecType(t string) CodecType

func (CodecType) String

func (c CodecType) String() string

type Message

type Message struct {
	ID          int64
	Version     string
	Type        MessageType
	ServicePath string // service path
	Target      string // Service
	Method      string
	Timeout     time.Duration // request timeout
	Error       string
	Header      map[string]string
	BodyLen     int
}

type MessageType

type MessageType int

type NewCodec

type NewCodec func(io.ReadWriteCloser) Codec

Takes in a connection/buffer and returns a new Codec

type TransportType

type TransportType int

const (
	TRANSPORTTYPE_BEGIN TransportType = iota
	TRANSPORT_TCP
	TRANSPORT_HTTP
	TRANSPORTTYPE_UNKNOWN
)

func GetTransportType

func GetTransportType(t string) TransportType

func (TransportType) String

func (t TransportType) String() string