livestatus

Documentation

Index

• Constants
• type Cache
• type CacheBuilder
  • func NewLivestatusCacheBuilder(livestatusConnector *Connector) *CacheBuilder
  • func (builder CacheBuilder) IsServiceInDowntime(host, service, time string) bool
  • func (builder *CacheBuilder) Stop()
• type Collector
  • func NewLivestatusCollector(jobs collector.ResultQueues, livestatusConnector *Connector, ...) *Collector
  • func (live *Collector) Stop()
• type CommentData
  • func (comment CommentData) PrintForElasticsearch(version, index string) string
  • func (comment CommentData) PrintForInfluxDB(version string) string
• type Connector
• type Data
• type DowntimeData
  • func (downtime DowntimeData) PrintForElasticsearch(version, index string) string
  • func (downtime DowntimeData) PrintForInfluxDB(version string) string
• type NotificationData
  • func (notification NotificationData) PrintForElasticsearch(version, index string) string
  • func (notification NotificationData) PrintForInfluxDB(version string) string

Constants

const (

	//QueryForServicesInDowntime livestatusquery for services in downtime.
	QueryForServicesInDowntime = `GET services
Columns: downtimes host_name display_name
Filter: scheduled_downtime_depth > 0
OutputFormat: csv

`
	//QueryForHostsInDowntime livestatusquery for hosts in downtime
	QueryForHostsInDowntime = `GET hosts
Columns: downtimes name
Filter: scheduled_downtime_depth > 0
OutputFormat: csv

`
	//QueryForDowntimeid livestatusquery for downtime start/end
	QueryForDowntimeid = `GET downtimes
Columns: id start_time entry_time
OutputFormat: csv

`
)

const (
	QueryLivestatusVersion = `GET status
Columns: livestatus_version
OutputFormat: csv

`
	//QueryIcinga2ForNotifications livestatusquery for notifications with Icinga2 Livestatus.
	QueryIcinga2ForNotifications = `GET log
Columns: type time contact_name message
Filter: type ~ .*NOTIFICATION
Filter: time < %d
Negate:
OutputFormat: csv

`
	//QueryNagiosForNotifications livestatusquery for notifications with nagioslike Livestatus.
	QueryNagiosForNotifications = `GET log
Columns: type time contact_name message
Filter: type ~ .*NOTIFICATION
Filter: time > %d
OutputFormat: csv

`
	//QueryForComments livestatusquery for comments
	QueryForComments = `` /* 133-byte string literal not displayed */

	//QueryForDowntimes livestatusquery for downtimes
	QueryForDowntimes = `` /* 132-byte string literal not displayed */

	//Nagios nagioslike Livestatus
	Nagios = iota
	//Icinga2 icinga2like Livestatus
	Icinga2 = iota
	//Naemon naemonlike Livestatus
	Naemon = iota
)

Types

type Cache

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

Cache contains stored data

type CacheBuilder

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

CacheBuilder fetches data from livestatus.

func NewLivestatusCacheBuilder

func NewLivestatusCacheBuilder(livestatusConnector *Connector) *CacheBuilder

NewLivestatusCacheBuilder constructor, which also starts it immediately.

func (CacheBuilder) IsServiceInDowntime

func (builder CacheBuilder) IsServiceInDowntime(host, service, time string) bool

IsServiceInDowntime returns true if the host/service is in downtime

func (*CacheBuilder) Stop

func (builder *CacheBuilder) Stop()

Stop signals the cache to stop.

type Collector

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

Collector fetches data from livestatus.

func NewLivestatusCollector

func NewLivestatusCollector(jobs collector.ResultQueues, livestatusConnector *Connector, detectVersion string) *Collector

NewLivestatusCollector constructor, which also starts it immediately.

func (*Collector) Stop

func (live *Collector) Stop()

Stop signals the collector to stop.

type CommentData

type CommentData struct {
	collector.Filterable
	Data
	// contains filtered or unexported fields
}

CommentData adds Comments types to the livestatus data

func (CommentData) PrintForElasticsearch

func (comment CommentData) PrintForElasticsearch(version, index string) string

PrintForElasticsearch prints in the elasticsearch json format

func (CommentData) PrintForInfluxDB

func (comment CommentData) PrintForInfluxDB(version string) string

PrintForInfluxDB prints the data in influxdb lineformat

type Connector

type Connector struct {
	Log               *factorlog.FactorLog
	LivestatusAddress string
	ConnectionType    string
}

Connector fetches data from livestatus.

type Data

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

Data contains basic data extracted from livestatusqueries.

type DowntimeData

type DowntimeData struct {
	collector.Filterable
	Data
	// contains filtered or unexported fields
}

DowntimeData adds Comments types to the livestatus data

func (DowntimeData) PrintForElasticsearch

func (downtime DowntimeData) PrintForElasticsearch(version, index string) string

PrintForElasticsearch prints in the elasticsearch json format

func (DowntimeData) PrintForInfluxDB

func (downtime DowntimeData) PrintForInfluxDB(version string) string

PrintForInfluxDB prints the data in influxdb lineformat

type NotificationData

type NotificationData struct {
	collector.Filterable
	Data
	// contains filtered or unexported fields
}

NotificationData adds notification types to the livestatus data

func (NotificationData) PrintForElasticsearch

func (notification NotificationData) PrintForElasticsearch(version, index string) string

PrintForElasticsearch prints in the elasticsearch json format

func (NotificationData) PrintForInfluxDB

func (notification NotificationData) PrintForInfluxDB(version string) string

PrintForInfluxDB prints the data in influxdb lineformat