job

Documentation

Index

• Variables
• func InitComets() (err error)
• func InitPush()
• func InitRedis() (err error)
• type CometRPC
• type NoReply
• type Operation
• type Proto
• type PushMsgArg
• type RedisMsg
• type RoomMsgArg
• type SuccessReply

Variables

var RPCClientList map[int8]client.XClient

RPCClientList is list of CometRPC

var (
	// RedisCli is Client of redis
	RedisCli *redis.Client
)

Functions

func InitComets

func InitComets() (err error)

InitComets is func to initial CometRPC client

func InitPush

func InitPush()

InitPush is func to initial push msg

func InitRedis

func InitRedis() (err error)

InitRedis is func to initial redis

Types

type CometRPC

type CometRPC int

CometRPC is comet rpc Client

type NoReply

type NoReply struct {
}

NoReply is struct of no reply

type Operation

type Operation int

Operation defines the type of operation.

const (

	// OpSingleSend 指定用户发送
	OpSingleSend Operation
	// OpRoomSend 广播到房间操作
	OpRoomSend
)

type Proto

type Proto struct {
	Ver       int16           `json:"ver"`  // protocol version
	Operation Operation       `json:"op"`   // operation for request
	Body      json.RawMessage `json:"body"` // binary body bytes(json.RawMessage is []byte)

}

Proto is struct of msg protocol

type PushMsgArg

type PushMsgArg struct {
	UID string
	P   Proto
}

PushMsgArg is struct of push msg

type RedisMsg

type RedisMsg struct {
	Carrier      []byte            `json:"carrier"` // 携带trace信息
	Op           Operation         `json:"op"`
	ServerID     int8              `json:"serverID,omitempty"`
	RoomID       string            `json:"roomID,omitempty"`
	UserID       string            `json:"userID,omitempty"`
	Msg          []byte            `json:"msg"`
	Count        int               `json:"count"`
	RoomUserInfo map[string]string `json:"RoomUserInfo"`
}

RedisMsg is struct of RedisMsg

type RoomMsgArg

type RoomMsgArg struct {
	RoomID string
	P      Proto
}

RoomMsgArg is struct of room msg arg

type SuccessReply

type SuccessReply struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
}

SuccessReply is struct of success reply