logic

Documentation

Index

• Constants
• Variables
• func ClearUserStatus(broker string)
• func CreateBrokerClient(broker string) (pb.BrokerClient, error)
• func GetBrokerList() []string
• func RandStringBytes(n int) string
• func SendPartnerMsg(msgId, senderId, receiverId, sessionId uint64, content string)
• type BrokerChecker
  • func NewBrokerChecker() *BrokerChecker
  • func (worker *BrokerChecker) Start()
  • func (worker *BrokerChecker) Stop()
• type BrokerInfo
• type LogicGrpcWorker
  • func NewLogicGrpcWorker() *LogicGrpcWorker
  • func (w *LogicGrpcWorker) Start()
  • func (w *LogicGrpcWorker) Stop()
• type LogicServer
  • 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) Reconnect(ctx context.Context, in *pb.ReConnectRequest) (*pb.ReConnectResponse, 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()

Constants

const TokenLen = 30

Variables

var DefaultExpiredTime = time.Time{}

Functions

func ClearUserStatus

func ClearUserStatus(broker string)

func CreateBrokerClient

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

func GetBrokerList

func GetBrokerList() []string

func RandStringBytes

func RandStringBytes(n int) string

func SendPartnerMsg

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

Types

type BrokerChecker

type BrokerChecker struct {
	RunningFlag atomic.Bool   // 是否运行 true:运行 false:停止
	ExitedFlag  chan struct{} //  已经退出的标识
	ExitChan    chan struct{}
	// contains filtered or unexported fields
}

确保broker都在线 如果broker已经掉线，就将与broker连接的用户全部下线

func NewBrokerChecker

func NewBrokerChecker() *BrokerChecker

func (*BrokerChecker) Start

func (worker *BrokerChecker) Start()

func (*BrokerChecker) Stop

func (worker *BrokerChecker) Stop()

type BrokerInfo

type BrokerInfo struct {
	Broker string `gorm:"column:broker" json:"broker"`
}

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) 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) Reconnect

func (s *LogicServer) Reconnect(ctx context.Context, in *pb.ReConnectRequest) (*pb.ReConnectResponse, 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 chan struct{}
	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 atomic.Bool   // is running? true:running false:stoped
	ExitedFlag  chan struct{} //  已经退出的标识
	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()