broker_engine

package

v0.0.6 Latest Latest Go to latest Published: Aug 12, 2021 License: MIT Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

func ClearUserStatus()

func ExecuteLogout(accountId uint64)

func HandleCrtAccount(s *melody.Session, data []byte)

func HandleDialogue(s *melody.Session, data []byte)

func HandleDisconnect(s *melody.Session)

func HandleMatch(s *melody.Session, data []byte)

func HandlePing(s *melody.Session, data []byte)

func HandlePong(s *melody.Session, data []byte)

func HandleReConnect(s *melody.Session, data []byte)

func HandleViewedAck(s *melody.Session, 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 bool // is running? true:running false:stoped
	ExitedFlag  bool //  Exit Flag
	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()