xnotice

Documentation

Index

• func MakeHandler(msgGetter NSender, msgSetter NReceiver) func(c *websocket.Conn, ctx echo.Context) error
• func MemoryNoticeSender(ctx context.Context, customer *dbschema.OfficialCustomer) (func(), <-chan *notice.Message, error)
• func OnlineStatusDBUpdater(ctx context.Context, customer *dbschema.OfficialCustomer) (func(), <-chan *notice.Message, error)
• func OnlineStatusQueueUpdater(ctx context.Context, customer *dbschema.OfficialCustomer) (func(), <-chan *notice.Message, error)
• func RegisterRoute(r echo.RouteRegister)
• func RegsterCmder()
• func ResetClientCount()
• func SendOnlineStatusToQueue(sessionId string, customerID uint64, online bool) error
• type CustomerOnline
  • func (c *CustomerOnline) Apply() error
• type NReceiver
• type NSender
  • func GetNSenderFromConfig(cfg echo.H) NSender

Functions

func MakeHandler

func MakeHandler(msgGetter NSender, msgSetter NReceiver) func(c *websocket.Conn, ctx echo.Context) error

func MemoryNoticeSender

func MemoryNoticeSender(ctx context.Context, customer *dbschema.OfficialCustomer) (func(), <-chan *notice.Message, error)

func OnlineStatusDBUpdater

func OnlineStatusDBUpdater(ctx context.Context, customer *dbschema.OfficialCustomer) (func(), <-chan *notice.Message, error)

func OnlineStatusQueueUpdater

func OnlineStatusQueueUpdater(ctx context.Context, customer *dbschema.OfficialCustomer) (func(), <-chan *notice.Message, error)

func RegisterRoute

func RegisterRoute(r echo.RouteRegister)

func RegsterCmder

func RegsterCmder()

./webx --config ./config/config.yaml --type queue:worker

func ResetClientCount

func ResetClientCount()

func SendOnlineStatusToQueue

func SendOnlineStatusToQueue(sessionId string, customerID uint64, online bool) error

Types

type CustomerOnline

type CustomerOnline struct {
	SessionID  string `json:"sessID"`
	CustomerID uint64 `json:"custID"`
	Online     bool   `json:"online"`
}

func (*CustomerOnline) Apply

func (c *CustomerOnline) Apply() error

type NReceiver

type NReceiver func(context.Context, *dbschema.OfficialCustomer, []byte) ([]byte, error)

var (
	DefaultSender   = MemoryNoticeSender
	DefaultReceiver NReceiver
)

type NSender

type NSender func(context.Context, *dbschema.OfficialCustomer) (close func(), msg <-chan *notice.Message, err error)

func GetNSenderFromConfig

func GetNSenderFromConfig(cfg echo.H) NSender