codec

type Codec ¶

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

Codec encodes/decodes various types of messages used within dubbogo. ReadHeader and ReadBody are called in pairs to read requests/responses from the connection. Close is called when finished with the connection. ReadBody may be called with a nil argument to force the body to be read and discarded.

type CodecType ¶

type CodecType int

const (
	JSONRPC CodecType = iota
)

func (c CodecType) String() string

type Message ¶

type Message struct {
	Id     uint64
	Type   MessageType
	Target string // Service
	// Service string
	Method string
	Error  string
	Header map[string]string
}

Message represents detailed information about the communication, likely followed by the body. In the case of an error, body may be nil.

type MessageType ¶

type MessageType int

const (
	Error MessageType = iota
	Request
	Response
)

type NetworkType ¶

type NetworkType int

const (
	NETWORK_TYPE_BEGIN NetworkType = iota
	TCP
	HTTP
	NETWORK_TYPE_END
)

func (this NetworkType) String() string

type NewCodec ¶

type NewCodec func(io.ReadWriteCloser) Codec

Takes in a connection/buffer and returns a new Codec