codec

Documentation

Index

• Constants
• func WriteProxyMessage(tag byte, req protoc.PB, out *goetty.ByteBuf) error
• type ProxyDecoder
  • func (decoder *ProxyDecoder) Decode(in *goetty.ByteBuf) (bool, interface{}, error)
• type ProxyEncoder
  • func (encoder *ProxyEncoder) Encode(data interface{}, out *goetty.ByteBuf) error

Constants

const (
	// RedisBegin tag for redis command
	RedisBegin = 0x01
	// WatcherNotifyBegin tag for notify
	WatcherNotifyBegin = 0x02
	// WatcherNotifySyncBegin tag for notify sync
	WatcherNotifySyncBegin = 0x03
	// WatcherNotifyRspBegin tag for notify rsp
	WatcherNotifyRspBegin = 0x04
)

Functions

func WriteProxyMessage

func WriteProxyMessage(tag byte, req protoc.PB, out *goetty.ByteBuf) error

WriteProxyMessage write a proxy to the buf

Types

type ProxyDecoder

type ProxyDecoder struct {
}

ProxyDecoder proxy decoder base on goetty

func (*ProxyDecoder) Decode

func (decoder *ProxyDecoder) Decode(in *goetty.ByteBuf) (bool, interface{}, error)

Decode return a decoded msg or wait for next tcp packet

type ProxyEncoder

type ProxyEncoder struct {
}

ProxyEncoder proxy encoder base on goetty

func (*ProxyEncoder) Encode

func (encoder *ProxyEncoder) Encode(data interface{}, out *goetty.ByteBuf) error

Encode encode proxy message