broker

package

v0.1.6 Latest Latest Go to latest Published: Mar 19, 2025 License: GPL-3.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func ExecuteLogout(accountId uint64)

func HandleCrtAccount(wrapper *model.SessionWrapper, data []byte)

func HandleDialogue(wrapper *model.SessionWrapper, data []byte)

func HandleDisconnect(s *melody.Session)

func HandleMatch(wrapper *model.SessionWrapper, data []byte)

func HandlePing(wrapper *model.SessionWrapper, data []byte)

func HandlePong(wrapper *model.SessionWrapper, data []byte)

func HandleReConnect(wrapper *model.SessionWrapper, data []byte)

func HandleViewedAck(wrapper *model.SessionWrapper, data []byte)

type GrpcWorker struct {
	// contains filtered or unexported fields
}

func NewGrpcWorker() *GrpcWorker

func (w *GrpcWorker) HealthCheck(ctx context.Context, req *pb.HealthCheckReq) (*pb.HealthCheckResp, error)

func (w *GrpcWorker) ReceiveMsgDialogue(ctx context.Context, in *pb.PushDialogue) (*pb.PushResp, error)

func (w *GrpcWorker) ReceiveMsgSignal(ctx context.Context, in *pb.PushSignal) (*pb.PushResp, error)

func (w *GrpcWorker) Start()

func (w *GrpcWorker) Stop()

type PingWorker struct {
	RunningFlag atomic.Bool
	ExitedFlag  chan struct{} //  已经退出的标识
	ExitChan    chan struct{}
}

func NewPingWorker() *PingWorker

func (w *PingWorker) Start()

func (w *PingWorker) Stop()

type WebsocketWorker struct {
	Server *http.Server
}

func NewWebsocketWorker() *WebsocketWorker

func (worker *WebsocketWorker) Start()

func (worker *WebsocketWorker) Stop()