memsd

Documentation

Index

• Constants
• Variables
• func NewDiscovery(config interface{}) discovery.Discovery
• func RecvLTVPacket(reader io.Reader, maxPacketSize int) (msg interface{}, err error)
• func SendLTVPacket(writer io.Writer, ctx cellnet.ContextSet, data interface{}) error
• type Config
  • func DefaultConfig() *Config
• type Option
• type TCPMessageTransmitter
  • func (TCPMessageTransmitter) OnRecvMessage(ses cellnet.Session) (msg interface{}, err error)
  • func (TCPMessageTransmitter) OnSendMessage(ses cellnet.Session, msg interface{}) (err error)

Constants

const (
	MaxValueSize = 512 * 1024
)

Variables

var (
	ErrValueNotExists = errors.New("value not exists")
	ErrValueTooLarge  = errors.New("value too large")
)

var (
	ErrMaxPacket  = errors.New("packet over size")
	ErrMinPacket  = errors.New("packet short size")
	ErrShortMsgID = errors.New("short msgid")
)

Functions

func NewDiscovery

func NewDiscovery(config interface{}) discovery.Discovery

func RecvLTVPacket

func RecvLTVPacket(reader io.Reader, maxPacketSize int) (msg interface{}, err error)

接收Length-Type-Value格式的封包流程

func SendLTVPacket

func SendLTVPacket(writer io.Writer, ctx cellnet.ContextSet, data interface{}) error

发送Length-Type-Value格式的封包流程

Types

type Config

type Config struct {
	Address        string
	RequestTimeout time.Duration
}

func DefaultConfig

func DefaultConfig() *Config

type Option

type Option struct {
	PrettyPrint bool
}

type TCPMessageTransmitter

type TCPMessageTransmitter struct {
}

func (TCPMessageTransmitter) OnRecvMessage

func (TCPMessageTransmitter) OnRecvMessage(ses cellnet.Session) (msg interface{}, err error)

func (TCPMessageTransmitter) OnSendMessage

func (TCPMessageTransmitter) OnSendMessage(ses cellnet.Session, msg interface{}) (err error)