Versions in this module Expand all Collapse all v1 v1.0.0 Apr 23, 2024 Changes in this version + type Acknowledgement interface + SendUDPMessage func(int, string) error + type Broadcaster interface + Broadcast func([]byte) + type Client struct + type ClientManager interface + GetClientsInfo func() + type Config struct + DB db.ReadOnlyRedisDB + Kafka kafka.StreamProvider + Router *fiber.App + WsAddr string + type ConnectionManager interface + RegisterClient func(*websocket.Conn) + UnRegisterClient func(*websocket.Conn) + type MsgProcessor interface + ProcessMsg func([]byte) error + type Service struct + func NewService(ctx context.Context, cfg *Config) (*Service, error) + func (s *Service) Broadcast(msgData []byte) + func (s *Service) Conn() error + func (s *Service) GetClientsInfo() + func (s *Service) InitMessageChannel() + func (s *Service) InitRouter() error + func (s *Service) ProcessMsg(msgData []byte) error + func (s *Service) RegisterClient(connection *websocket.Conn) + func (s *Service) SendUDPMessage(version int, msg string) error + func (s *Service) Start() + func (s *Service) Stop() error + func (s *Service) UnRegisterClient(connection *websocket.Conn) + type Socket interface
Go to main page