aggregator

Documentation

Index

• func AreTagsSubsetOfOtherTags(tags, otherTags []string) bool
• func FilterByTags[P PayloadItem](payloads []P, tags []string) []P
• type Aggregator
  • func (agg *Aggregator[P]) ContainsPayloadName(name string) bool
  • func (agg *Aggregator[P]) ContainsPayloadNameAndTags(name string, tags []string) bool
  • func (agg *Aggregator[P]) GetNames() []string
  • func (agg *Aggregator[P]) GetPayloadsByName(name string) []P
  • func (agg *Aggregator[P]) Reset()
  • func (agg *Aggregator[P]) UnmarshallPayloads(payloads []api.Payload) error
• type CheckRun
  • func ParseCheckRunPayload(payload api.Payload) (checks []*CheckRun, err error)
  • func (cr *CheckRun) GetCollectedTime() time.Time
  • func (cr *CheckRun) GetTags() []string
• type CheckRunAggregator
  • func NewCheckRunAggregator() CheckRunAggregator
• type Connections
  • func ParseConnections(payload api.Payload) (conns []*Connections, err error)
  • func (c *Connections) GetCollectedTime() time.Time
  • func (c *Connections) GetTags() []string
• type ConnectionsAggregator
  • func NewConnectionsAggregator() ConnectionsAggregator
• type Log
  • func ParseLogPayload(payload api.Payload) (logs []*Log, err error)
  • func (l *Log) GetCollectedTime() time.Time
  • func (l *Log) GetTags() []string
• type LogAggregator
  • func NewLogAggregator() LogAggregator
• type MetricAggregator
  • func NewMetricAggregator() MetricAggregator
• type MetricSeries
  • func ParseMetricSeries(payload api.Payload) (metrics []*MetricSeries, err error)
  • func (mp *MetricSeries) GetCollectedTime() time.Time
  • func (mp *MetricSeries) GetTags() []string
• type PayloadItem

Functions

func AreTagsSubsetOfOtherTags

func AreTagsSubsetOfOtherTags(tags, otherTags []string) bool

AreTagsSubsetOfOtherTags return true is all tags are in otherTags

func FilterByTags

func FilterByTags[P PayloadItem](payloads []P, tags []string) []P

FilterByTags return the payloads that match all the tags

Types

type Aggregator

type Aggregator[P PayloadItem] struct {
	// contains filtered or unexported fields
}

func (*Aggregator[P]) ContainsPayloadName

func (agg *Aggregator[P]) ContainsPayloadName(name string) bool

ContainsPayloadName return true if name match one of the payloads

func (*Aggregator[P]) ContainsPayloadNameAndTags

func (agg *Aggregator[P]) ContainsPayloadNameAndTags(name string, tags []string) bool

ContainsPayloadNameAndTags return true if the payload name exist and on of the payloads contains all the tags

func (*Aggregator[P]) GetNames

func (agg *Aggregator[P]) GetNames() []string

GetNames return the names of the payloads

func (*Aggregator[P]) GetPayloadsByName

func (agg *Aggregator[P]) GetPayloadsByName(name string) []P

GetPayloadsByName return the payloads for the resource name

func (*Aggregator[P]) Reset

func (agg *Aggregator[P]) Reset()

Reset the aggregation

func (*Aggregator[P]) UnmarshallPayloads

func (agg *Aggregator[P]) UnmarshallPayloads(payloads []api.Payload) error

UnmarshallPayloads aggregate the payloads

type CheckRun

type CheckRun struct {
	Check     string   `json:"check"`
	HostName  string   `json:"host_name"`
	Timestamp int      `json:"timestamp"`
	Status    int      `json:"status"`
	Message   string   `json:"message"`
	Tags      []string `json:"tags"`
	// contains filtered or unexported fields
}

func ParseCheckRunPayload

func ParseCheckRunPayload(payload api.Payload) (checks []*CheckRun, err error)

ParseCheckRunPayload return the parsed checkRun from payload

func (*CheckRun) GetCollectedTime

func (cr *CheckRun) GetCollectedTime() time.Time

GetCollectedTime return the time when the payload has been collected by the fakeintake server

func (*CheckRun) GetTags

func (cr *CheckRun) GetTags() []string

GetTags return the tags from a payload

type CheckRunAggregator

type CheckRunAggregator struct {
	Aggregator[*CheckRun]
}

func NewCheckRunAggregator

func NewCheckRunAggregator() CheckRunAggregator

type Connections

type Connections struct {
	agentmodel.CollectorConnections
	// contains filtered or unexported fields
}

Connections type contain all payload from /api/v1/connections

func ParseConnections

func ParseConnections(payload api.Payload) (conns []*Connections, err error)

ParseConnections return the Connections from payload

func (*Connections) GetCollectedTime

func (c *Connections) GetCollectedTime() time.Time

GetCollectedTime return the time when the payload has been collected by the fakeintake server

func (*Connections) GetTags

func (c *Connections) GetTags() []string

GetTags return tags connection

type ConnectionsAggregator

type ConnectionsAggregator struct {
	Aggregator[*Connections]
}

ConnectionsAggregator aggregate connections

func NewConnectionsAggregator

func NewConnectionsAggregator() ConnectionsAggregator

NewConnectionsAggregator create a new aggregator

type Log

type Log struct {
	Message   string   `json:"message"`
	Status    string   `json:"status"`
	Timestamp int      `json:"timestamp"`
	HostName  string   `json:"hostname"`
	Service   string   `json:"service"`
	Source    string   `json:"source"`
	Tags      []string `json:"tags"`
	// contains filtered or unexported fields
}

func ParseLogPayload

func ParseLogPayload(payload api.Payload) (logs []*Log, err error)

ParseLogPayload return the parsed logs from payload

func (*Log) GetCollectedTime

func (l *Log) GetCollectedTime() time.Time

GetCollectedTime return the time when the payload has been collected by the fakeintake server

func (*Log) GetTags

func (l *Log) GetTags() []string

GetTags return the tags from a payload

type LogAggregator

type LogAggregator struct {
	Aggregator[*Log]
}

func NewLogAggregator

func NewLogAggregator() LogAggregator

type MetricAggregator

type MetricAggregator struct {
	Aggregator[*MetricSeries]
}

func NewMetricAggregator

func NewMetricAggregator() MetricAggregator

type MetricSeries

type MetricSeries struct {
	// embed proto Metric Series struct
	metricspb.MetricPayload_MetricSeries
	// contains filtered or unexported fields
}

func ParseMetricSeries

func ParseMetricSeries(payload api.Payload) (metrics []*MetricSeries, err error)

ParseMetricSeries return the parsed metrics from payload

func (*MetricSeries) GetCollectedTime

func (mp *MetricSeries) GetCollectedTime() time.Time

GetCollectedTime return the time when the payload has been collected by the fakeintake server

func (*MetricSeries) GetTags

func (mp *MetricSeries) GetTags() []string

GetTags return the tags from a payload

type PayloadItem

type PayloadItem interface {
	GetTags() []string
	GetCollectedTime() time.Time
	// contains filtered or unexported methods
}