heartbeat

Documentation

Index

• type Worker
  • func NewHeartbeatWorker(database moira.Database, metrics *graphite.FilterMetrics, logger moira.Logger) *Worker
  • func (worker *Worker) Start()
  • func (worker *Worker) Stop() error

Types

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker is heartbeat worker realization

func NewHeartbeatWorker

func NewHeartbeatWorker(database moira.Database, metrics *graphite.FilterMetrics, logger moira.Logger) *Worker

NewHeartbeatWorker creates new worker

func (*Worker) Start

func (worker *Worker) Start()

Start every 5 second takes TotalMetricsReceived metrics and save it to database, for self-checking

func (*Worker) Stop

func (worker *Worker) Stop() error

Stop heartbeat worker