task

Documentation

Index

• Variables
• type PushParams
• type Task
  • func New() *Task
  • func (task *Task) GoPush()
  • func (task *Task) InitConnectRPCClient() (err error)
  • func (task *Task) InitSubscribeRedisClient() (err error)
  • func (task *Task) Push(msg string)
  • func (task *Task) Run()

Variables

var RPCConnectClientList map[int]client.XClient

RPCConnectClientList ...

var RedisClient *redis.Client

RedisClient ...

Types

type PushParams

type PushParams struct {
	ServerID int
	UserID   int
	Msg      []byte
	RoomID   int
}

PushParams ...

type Task

type Task struct {
}

Task ...

func New

func New() *Task

New ...

func (*Task) GoPush

func (task *Task) GoPush()

GoPush ...

func (*Task) InitConnectRPCClient

func (task *Task) InitConnectRPCClient() (err error)

InitConnectRPCClient ...

func (*Task) InitSubscribeRedisClient

func (task *Task) InitSubscribeRedisClient() (err error)

InitSubscribeRedisClient ...

func (*Task) Push

func (task *Task) Push(msg string)

Push ...

func (*Task) Run

func (task *Task) Run()

Run ...