codec

package
v0.0.0-...-a9a2a47 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 22, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
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
)

Variables

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.