logic_engine

Documentation

Index

• func ClearUserStatus(broker string)
• func CreateBrokerClient(broker string) (pb.BrokerClient, error)
• func SendPartnerMsg(msgId, senderId, receiverId, sessionId uint64, content string)
• type LogicGrpcWorker
  • func NewLogicGrpcWorker() *LogicGrpcWorker
  • func (w *LogicGrpcWorker) Start()
  • func (w *LogicGrpcWorker) Stop()
• type LogicServer
  • func (s *LogicServer) BrokerOnline(cxt context.Context, in *pb.OnlineRequest) (*pb.OnlineResponse, error)
  • func (s *LogicServer) CreateAccount(ctx context.Context, req *pb.CreateAccountRequest) (*pb.CreateAccountResponse, error)
  • func (s *LogicServer) Logout(ctx context.Context, req *pb.LogoutRequest) (*pb.LogoutResponse, error)
  • func (s *LogicServer) Match(ctx context.Context, req *pb.MatchRequest) (*pb.MatchResponse, error)
  • func (s *LogicServer) SendMsg(ctx context.Context, req *pb.SendMsgRequest) (*pb.SendMsgResponse, error)
  • func (s *LogicServer) ViewedAck(ctx context.Context, req *pb.ViewedAckRequest) (*pb.ViewedAckResponse, error)
• type PumpDialogueLoopWorker
  • func NewPumpDialogueLoopWorker(minCount, maxCount int) *PumpDialogueLoopWorker
  • func (w *PumpDialogueLoopWorker) PumpDialogueLoop()
  • func (w *PumpDialogueLoopWorker) Start()
  • func (w *PumpDialogueLoopWorker) Stop()
• type PumpSignalLoopWorker
  • func NewPumpSignalLoopWorker() *PumpSignalLoopWorker
  • func (w *PumpSignalLoopWorker) PumpSignalLoop()
  • func (w *PumpSignalLoopWorker) Start()
  • func (w *PumpSignalLoopWorker) Stop()

Functions

func ClearUserStatus

func ClearUserStatus(broker string)

func CreateBrokerClient

func CreateBrokerClient(broker string) (pb.BrokerClient, error)

func SendPartnerMsg

func SendPartnerMsg(msgId, senderId, receiverId, sessionId uint64, content string)

Types

type LogicGrpcWorker

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

func NewLogicGrpcWorker

func NewLogicGrpcWorker() *LogicGrpcWorker

func (*LogicGrpcWorker) Start

func (w *LogicGrpcWorker) Start()

func (*LogicGrpcWorker) Stop

func (w *LogicGrpcWorker) Stop()

type LogicServer

type LogicServer struct{}

func (*LogicServer) BrokerOnline

func (s *LogicServer) BrokerOnline(cxt context.Context, in *pb.OnlineRequest) (*pb.OnlineResponse, error)

func (*LogicServer) CreateAccount

func (s *LogicServer) CreateAccount(ctx context.Context,
	req *pb.CreateAccountRequest) (*pb.CreateAccountResponse, error)

func (*LogicServer) Logout

func (s *LogicServer) Logout(ctx context.Context, req *pb.LogoutRequest) (*pb.LogoutResponse, error)

func (*LogicServer) Match

func (s *LogicServer) Match(ctx context.Context, req *pb.MatchRequest) (*pb.MatchResponse, error)

func (*LogicServer) SendMsg

func (s *LogicServer) SendMsg(ctx context.Context, req *pb.SendMsgRequest) (*pb.SendMsgResponse, error)

func (*LogicServer) ViewedAck

func (s *LogicServer) ViewedAck(ctx context.Context, req *pb.ViewedAckRequest) (*pb.ViewedAckResponse, error)

type PumpDialogueLoopWorker

type PumpDialogueLoopWorker struct {
	//RunningFlag bool // is running? true:running false:stoped
	ExitedFlag bool //  Exit Flag
	ExitChan   chan struct{}
	// contains filtered or unexported fields
}

func NewPumpDialogueLoopWorker

func NewPumpDialogueLoopWorker(minCount, maxCount int) *PumpDialogueLoopWorker

func (*PumpDialogueLoopWorker) PumpDialogueLoop

func (w *PumpDialogueLoopWorker) PumpDialogueLoop()

func (*PumpDialogueLoopWorker) Start

func (w *PumpDialogueLoopWorker) Start()

func (*PumpDialogueLoopWorker) Stop

func (w *PumpDialogueLoopWorker) Stop()

type PumpSignalLoopWorker

type PumpSignalLoopWorker struct {
	RunningFlag bool // is running? true:running false:stoped
	ExitedFlag  bool //  Exit Flag
	ExitChan    chan struct{}
}

func NewPumpSignalLoopWorker

func NewPumpSignalLoopWorker() *PumpSignalLoopWorker

func (*PumpSignalLoopWorker) PumpSignalLoop

func (w *PumpSignalLoopWorker) PumpSignalLoop()

func (*PumpSignalLoopWorker) Start

func (w *PumpSignalLoopWorker) Start()

func (*PumpSignalLoopWorker) Stop

func (w *PumpSignalLoopWorker) Stop()