msgbroker

package
v0.0.0-...-7c02c66 Latest Latest
Warning

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

Go to latest
Published: Oct 24, 2023 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SERVER_NAME                = "MSG_BROKER_SVC"
	SERVICE_BROADCAST_RECV     = "BROADCAST_RECV"
	SERVICE_REGISTER_SESSION   = "REGISTER_SESSION"
	SERVICE_KICKOUT_DUPLICATE  = "KICKOUT_DUPLICATE"
	SERVICE_UNREGISTER_SESSION = "UNREGISTER_SESSION"
)
View Source
const (
	SendMsg   = 1
	Kickout   = 2
	Heartbeat = 3
)

Variables

This section is empty.

Functions

func NewServer

func NewServer(opts ...config.Option) *rpcxServer

Types

type Action

type Action uint8

type BroadcastArgs

type BroadcastArgs = model.Msg

type BroadcastMsgWarp

type BroadcastMsgWarp struct {
	Action     Action
	PreId      string
	MetaData   model.Msg
	ToSessions []RecvSession
}

type BroadcastReply

type BroadcastReply struct {
}

type RecvSession

type RecvSession struct {
	SessionId string
	Platform  uint8
}

type RegisterSessionInfo

type RegisterSessionInfo struct {
	Platform    uint8
	GatewayUuid string
	SessionId   string
}

type RegisterSessionReply

type RegisterSessionReply struct {
	NeedKeep bool
}

Jump to

Keyboard shortcuts

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