task

Documentation

Overview

*

• Created by lock
• Date: 2019-08-13
• Time: 10:50

*

• Created by lock
• Date: 2019-08-13
• Time: 10:13

*

• Created by lock
• Date: 2019-08-13
• Time: 10:13

*

• Created by lock
• Date: 2019-08-09
• Time: 18:22

Index

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

Variables

var RedisClient *redis.Client

var RpcConnectClientList map[string]client.XClient

Types

type PushParams

type PushParams struct {
	ServerId string
	UserId   int
	Msg      []byte
	RoomId   int
}

type Task

type Task struct {
}

func New

func New() *Task

func (*Task) GoPush

func (task *Task) GoPush()

func (*Task) InitConnectRpcClient

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

func (*Task) InitQueueRedisClient

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

func (*Task) Push

func (task *Task) Push(msg string)

func (*Task) Run

func (task *Task) Run()