task

package
v0.0.0-...-4e35581 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2019 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var RPCConnectClientList map[int]client.XClient

RPCConnectClientList ...

View Source
var RedisClient *redis.Client

RedisClient ...

Functions

This section is empty.

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 ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL