service

Documentation

Index

• Constants
• Variables
• type ServiceCallback
  • func NewDebugLogger() ServiceCallback
  • func NewMetricsReporter(m metrics.Metrics) ServiceCallback
• type Services
  • func NewServices(beiface backend.Backend, cfg config.Config, notifier notify.Notifier) Services
• type ServicesImpl
  • func (c *ServicesImpl) GetAlarm(name string) *model.Alarm
  • func (c *ServicesImpl) GetAlarms() []model.Alarm
  • func (c *ServicesImpl) GetService(name string) *model.Service
  • func (c *ServicesImpl) GetServices() []model.Service
  • func (c *ServicesImpl) GetServicesInAlarm(alarm string) []model.Service
  • func (svcs *ServicesImpl) Monitor(cfg config.Config, notifier notify.Notifier, be backend.Backend)
  • func (c *ServicesImpl) Subscribe(cb ServiceCallback)
  • func (c *ServicesImpl) Update(update *model.Update)

Constants

const (
	MAX_UNPROCESSED_PACKETS = 1000
)

const ServiceNamePattern = "[a-z0-9._-]+"

Variables

var NAME_RE = regexp.MustCompile("\\$([a-z]+)")

var (
	StateMap = map[string]int{
		model.StateNew:   0,
		model.StateOk:    1,
		model.StateError: 2,
		model.StateMuted: 3,
	}
)

var VAR_RE = regexp.MustCompile("\\\\\\$([a-z]+)")

Types

type ServiceCallback

type ServiceCallback interface {
	OnUpdate(ts int64, update model.Update)

	OnServiceAdded(ts int64, service model.Service)
	OnServiceUpdated(ts int64, oldService, newService model.Service)
	OnServiceRemoved(ts int64, service model.Service)

	OnAlarmAdded(ts int64, alarm model.Alarm, config config.ConfigAlarm)
	OnAlarmUpdated(ts int64, oldAlarm, newAlarm model.Alarm, config config.ConfigAlarm)
	OnAlarmRemoved(ts int64, alarm model.Alarm, config config.ConfigAlarm)
}

func NewDebugLogger

func NewDebugLogger() ServiceCallback

func NewMetricsReporter

func NewMetricsReporter(m metrics.Metrics) ServiceCallback

type Services

type Services interface {
	Subscribe(cb ServiceCallback)
	Update(update *model.Update)

	GetServices() []model.Service
	GetServicesInAlarm(alarm string) []model.Service
	GetService(name string) *model.Service
	GetAlarms() []model.Alarm
	GetAlarm(name string) *model.Alarm
}

func NewServices

func NewServices(beiface backend.Backend, cfg config.Config, notifier notify.Notifier) Services

type ServicesImpl

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

func (*ServicesImpl) GetAlarm

func (c *ServicesImpl) GetAlarm(name string) *model.Alarm

func (*ServicesImpl) GetAlarms

func (c *ServicesImpl) GetAlarms() []model.Alarm

func (*ServicesImpl) GetService

func (c *ServicesImpl) GetService(name string) *model.Service

func (*ServicesImpl) GetServices

func (c *ServicesImpl) GetServices() []model.Service

func (*ServicesImpl) GetServicesInAlarm

func (c *ServicesImpl) GetServicesInAlarm(alarm string) []model.Service

func (*ServicesImpl) Monitor

func (svcs *ServicesImpl) Monitor(cfg config.Config, notifier notify.Notifier, be backend.Backend)

func (*ServicesImpl) Subscribe

func (c *ServicesImpl) Subscribe(cb ServiceCallback)

func (*ServicesImpl) Update

func (c *ServicesImpl) Update(update *model.Update)