Documentation ¶
Index ¶
- func SetLogger(l *zap.SugaredLogger)
- type MessageHandler
- type Worker
- func (w *Worker) AddConnectedCallback(f func())
- func (w *Worker) GetMessageHandler() MessageHandler
- func (w *Worker) LoopSendMetricsToServer()
- func (w *Worker) Run(addr string)
- func (w *Worker) SendMessageToServer(message []byte)
- func (w *Worker) SendMetricsToServer()
- func (w *Worker) SetConnectRetryInterval(d time.Duration)
- func (w *Worker) SetMessageHandler(h MessageHandler)
- func (w *Worker) SetName(name string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetLogger ¶
func SetLogger(l *zap.SugaredLogger)
Types ¶
type MessageHandler ¶
type MessageHandler interface {
HandleMessage(message []byte)
}
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) AddConnectedCallback ¶
func (w *Worker) AddConnectedCallback(f func())
func (*Worker) GetMessageHandler ¶
func (w *Worker) GetMessageHandler() MessageHandler
func (*Worker) LoopSendMetricsToServer ¶
func (w *Worker) LoopSendMetricsToServer()
func (*Worker) SendMessageToServer ¶
func (*Worker) SendMetricsToServer ¶
func (w *Worker) SendMetricsToServer()
func (*Worker) SetConnectRetryInterval ¶
func (*Worker) SetMessageHandler ¶
func (w *Worker) SetMessageHandler(h MessageHandler)
Click to show internal directories.
Click to hide internal directories.