worker

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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 NewWorker

func NewWorker() *Worker

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) Run

func (w *Worker) Run(addr string)

func (*Worker) SendMessageToServer

func (w *Worker) SendMessageToServer(message []byte)

func (*Worker) SendMetricsToServer

func (w *Worker) SendMetricsToServer()

func (*Worker) SetConnectRetryInterval

func (w *Worker) SetConnectRetryInterval(d time.Duration)

func (*Worker) SetMessageHandler

func (w *Worker) SetMessageHandler(h MessageHandler)

func (*Worker) SetName

func (w *Worker) SetName(name string)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL