socket

package

v6.0.1+incompatible Latest Latest Go to latest Published: Nov 13, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ONG-YA/tp-micro

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func EnforceKickOffline(sessionId string) *tp.Status
func GetAgent(sessionId string) (*aproto.Agent, *tp.Status)
func GetSocketHooks() types.SocketHooks
func Init(redisWithLargeMemory *redis.Client, redisWithPublishCmd *redis.Client, ...) error
func QueryAgent(sessionIds []string) (*aproto.Agents, *tp.Status)
func Subscribe() <-chan *AgentNews
type AgentNews
- func (a *AgentNews) IsOffline() bool
- func (a *AgentNews) IsOnline() bool

Constants ¶

View Source

const (
	// EVENT_ONLINE agent online event
	EVENT_ONLINE = "ONLINE"
	// EVENT_OFFLINE agent offline event
	EVENT_OFFLINE = "OFFLINE"
)

Variables ¶

This section is empty.

Functions ¶

func EnforceKickOffline ¶

func EnforceKickOffline(sessionId string) *tp.Status

EnforceKickOffline enforches kick the user offline.

func GetAgent ¶

func GetAgent(sessionId string) (*aproto.Agent, *tp.Status)

GetAgent returns agent information.

func GetSocketHooks ¶

func GetSocketHooks() types.SocketHooks

GetSocketHooks returns the custom agent types.SocketHooks interface.

func Init ¶

func Init(redisWithLargeMemory *redis.Client, redisWithPublishCmd *redis.Client, namespace ...string) error

Init initializes agent packet.

func QueryAgent ¶

func QueryAgent(sessionIds []string) (*aproto.Agents, *tp.Status)

QueryAgent queries agent information in batches.

func Subscribe() <-chan *AgentNews

Subscribe subscribes agent news from redis.

Types ¶

type AgentNews ¶

type AgentNews struct {
	SessionId string
	Event     string
}

AgentNews agent online/offline message

func (*AgentNews) IsOffline ¶

func (a *AgentNews) IsOffline() bool

IsOffline returns whether it is an offline message.

func (*AgentNews) IsOnline ¶

func (a *AgentNews) IsOnline() bool

IsOnline returns whether it is an online message.

Source Files ¶

View all Source files

agent.go

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