task

package
v0.0.0-...-5e1d9b1 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2021 License: MIT Imports: 13 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
var RedisClient *redis.Client
View Source
var RpcConnectClientList map[string]client.XClient

Functions

This section is empty.

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()

Jump to

Keyboard shortcuts

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