Documentation ¶
Index ¶
- func SetLogger(l *zap.SugaredLogger)
- type MessageHandler
- type NotificationService
- type Server
- type WorkerService
- func (w *WorkerService) AddWorker(conn *websocket.Conn, name string)
- func (w *WorkerService) BroadcastMessageToWorkers(message []byte)
- func (w *WorkerService) GetMessageHandler() MessageHandler
- func (w *WorkerService) RemoveWorker(conn *websocket.Conn)
- func (w *WorkerService) SetMessageHandler(h MessageHandler)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetLogger ¶
func SetLogger(l *zap.SugaredLogger)
Types ¶
type MessageHandler ¶
type NotificationService ¶
type NotificationService struct {
// contains filtered or unexported fields
}
func NewNotificationService ¶
func NewNotificationService() *NotificationService
func (*NotificationService) AddSubscriber ¶
func (n *NotificationService) AddSubscriber(conn *websocket.Conn)
func (*NotificationService) BroadcastMessageToSubscribers ¶
func (n *NotificationService) BroadcastMessageToSubscribers(message []byte)
func (*NotificationService) RemoveSubscriber ¶
func (n *NotificationService) RemoveSubscriber(conn *websocket.Conn)
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) GetWorkerService ¶
func (s *Server) GetWorkerService() *WorkerService
GetWorkerService returns the worker service.
func (*Server) StartLoadTest ¶
func (s *Server) StartLoadTest(r *messages.StartLoadTestRequest)
func (*Server) StopLoadTest ¶
func (s *Server) StopLoadTest()
type WorkerService ¶
type WorkerService struct {
// contains filtered or unexported fields
}
func NewWorkerService ¶
func NewWorkerService() *WorkerService
func (*WorkerService) AddWorker ¶
func (w *WorkerService) AddWorker(conn *websocket.Conn, name string)
func (*WorkerService) BroadcastMessageToWorkers ¶
func (w *WorkerService) BroadcastMessageToWorkers(message []byte)
func (*WorkerService) GetMessageHandler ¶
func (w *WorkerService) GetMessageHandler() MessageHandler
func (*WorkerService) RemoveWorker ¶
func (w *WorkerService) RemoveWorker(conn *websocket.Conn)
func (*WorkerService) SetMessageHandler ¶
func (w *WorkerService) SetMessageHandler(h MessageHandler)
Click to show internal directories.
Click to hide internal directories.