xnotice

package

v0.0.0-...-1798382 Latest Latest Go to latest Published: May 27, 2026 License: AGPL-3.0 Imports: 23 Imported by: 1

Details

View Source

const Day = time.Hour * 24

View Source

const FMTDateTime = `20060102150405`

This section is empty.

func EncodeClientID(clientID string, customer *dbschema.OfficialCustomer) string

func MakeSSEHandler(msgGetter NSender) func(ctx echo.Context) error

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

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

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

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

func RegisterCmder(startup ...bool)

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

func RegisterRoute(r echo.RouteRegister, cfg echo.H)

func ResetClientCount()

func SendOnlineStatusToQueue(ctx context.Context, sessionId string, customerID uint64, online bool) error

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

func (c *CustomerOnline) Apply() error

type NReceiver func(ctx echo.Context, customer *dbschema.OfficialCustomer, message []byte) ([]byte, error)

var (
	DefaultSender   = MemoryNoticeSender
	DefaultReceiver NReceiver
)

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

func GetNSenderFromConfig(cfg echo.H) NSender