upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-06-04 22:32:57 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add missing doc in stats_message

Browse source
This commit is contained in:
Eric Lippmann 2021-06-22 14:53:52 +02:00
parent ff88cb73f7
commit bf415f2e1c
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
pkg/icingaredis/v1/stats_message.go
View file

@ -9,10 +9,12 @@ import (
// StatsMessage represents a message from the Redis stream icinga:stats.
type StatsMessage map[string]interface{}
// Raw returns the key-value pairs of the message.
func (m StatsMessage) Raw() map[string]interface{} {
return m
}
// IcingaStatus extracts Icinga status information from the message into IcingaStatus and returns it.
func (m StatsMessage) IcingaStatus() (*IcingaStatus, error) {
if s, ok := m["IcingaApplication"].(string); ok {
var envelope struct {
@ -33,6 +35,7 @@ func (m StatsMessage) IcingaStatus() (*IcingaStatus, error) {
return nil, errors.Errorf(`bad message %#v. "IcingaApplication" missing`, m)
}
// Time extracts the timestamp of the message into types.UnixMilli and returns it.
func (m StatsMessage) Time() (*types.UnixMilli, error) {
if s, ok := m["timestamp"].(string); ok {
var t types.UnixMilli