Versions in this module Expand all Collapse all v0 v0.2.0 Apr 22, 2021 v0.1.0 Mar 13, 2021 Changes in this version + func SetLogger(l *zap.SugaredLogger) + type MessageHandler interface + HandleMessage func(conn *websocket.Conn, message []byte) + type NotificationService struct + func NewNotificationService() *NotificationService + func (n *NotificationService) AddSubscriber(conn *websocket.Conn) + func (n *NotificationService) BroadcastMessageToSubscribers(message []byte) + func (n *NotificationService) RemoveSubscriber(conn *websocket.Conn) + type Server struct + func NewServer() *Server + func (s *Server) Close() error + func (s *Server) GetWorkerService() *WorkerService + func (s *Server) Run(addr string) error + func (s *Server) StartLoadTest(r *messages.StartLoadTestRequest) + func (s *Server) StopLoadTest() + type WorkerService struct + func NewWorkerService() *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)