packet

Documentation

Index

• Constants
• func NewRequest(content []byte, num BigcacheProtocol) []byte
• func NewResponse(msg string, errcode errcode.BigcacheError) []byte
• type BigcacheProtocol
• type Request
  • func ParseRequest(conn net.Conn) (pkt Request, err error)
• type Response
  • func ParseResponse(conn net.Conn) (pkt Response, err error)

Constants

const HEADER_LEN = 4

const PROROCOL_LEN = 4

Functions

func NewRequest

func NewRequest(content []byte, num BigcacheProtocol) []byte

func NewResponse

func NewResponse(msg string, errcode errcode.BigcacheError) []byte

Types

type BigcacheProtocol

type BigcacheProtocol int

BigcacheProtocol 传输协议号.

const (
	CONN_AUTH            BigcacheProtocol = 1000 //连接授权.
	READ                 BigcacheProtocol = 1001 //获取一条记录.
	WRITE                BigcacheProtocol = 1002 //写入一条记录.
	DELETE               BigcacheProtocol = 1003 //删除一条记录.
	MSG                  BigcacheProtocol = 1004 //发生一条状态消息.
	ADD_NODE             BigcacheProtocol = 1005 //新增加节点.
	REMOVE_NODE          BigcacheProtocol = 1006 //删除节点.
	GET_CACHE_SERVER_ALL BigcacheProtocol = 1007 //获取所有的cache server 节点.
)

type Request

type Request struct {
	Protocol BigcacheProtocol
	Size     int64
	Body     []byte
}

func ParseRequest

func ParseRequest(conn net.Conn) (pkt Request, err error)

ParseRequest 解析网络请求数据包.

type Response

type Response struct {
	Protocol BigcacheProtocol
	Size     int64
	Body     []byte
	Msg      string
	Err      errcode.BigcacheError
}

func ParseResponse

func ParseResponse(conn net.Conn) (pkt Response, err error)

ParseRequest 解析网络返回数据包.