socket

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

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

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

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.