aggregator

package
v0.63.0-rc.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2025 License: Apache-2.0 Imports: 27 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 APMStatsAggregator added in v0.52.0 

type APMStatsAggregator struct {
	Aggregator[*APMStatsPayload]
}

APMStatsAggregator is an Aggregator for APMStatsPayload

func NewAPMStatsAggregator added in v0.52.0 

func NewAPMStatsAggregator() APMStatsAggregator

NewAPMStatsAggregator returns a new APMStatsAggregator

type APMStatsPayload added in v0.52.0 

type APMStatsPayload struct {
	*pb.StatsPayload
	// contains filtered or unexported fields
}

APMStatsPayload is a payload type for APM stats It implements PayloadItem

func ParseAPMStatsPayload added in v0.52.0 

func ParseAPMStatsPayload(payload api.Payload) ([]*APMStatsPayload, error)

ParseAPMStatsPayload parses an api.Payload into a list of APMStatsPayload

func (*APMStatsPayload) GetCollectedTime added in v0.52.0 

func (p *APMStatsPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake APMStatsPayload implements PayloadItem

func (*APMStatsPayload) GetTags added in v0.52.0 

func (p *APMStatsPayload) GetTags() []string

GetTags is not implemented

type Aggregator 

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

Aggregator is a generic payload aggregator

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 parses a list of payloads and stores them in the aggregator It replaces the current payloads with the new ones

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
}

CheckRun represents a check run payload

func ParseCheckRunPayload 

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

ParseCheckRunPayload return the parsed checkRun from payload

func (*CheckRun) GetCollectedTime added in v0.49.0 

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]
}

CheckRunAggregator is an Aggregator for check run payloads

func NewCheckRunAggregator 

func NewCheckRunAggregator() CheckRunAggregator

NewCheckRunAggregator returns a new CheckRunAggregator

type Connections added in v0.49.0 

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

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

func ParseConnections added in v0.49.0 

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

ParseConnections return the Connections from payload

func (*Connections) GetCollectedTime added in v0.49.0 

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

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

func (*Connections) GetTags added in v0.49.0 

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

GetTags return tags connection

type ConnectionsAggregator added in v0.49.0 

type ConnectionsAggregator struct {
	Aggregator[*Connections]
}

ConnectionsAggregator aggregate connections

func NewConnectionsAggregator added in v0.49.0 

func NewConnectionsAggregator() ConnectionsAggregator

NewConnectionsAggregator create a new aggregator

func (*ConnectionsAggregator) ForeachConnection added in v0.50.0 

func (ca *ConnectionsAggregator) ForeachConnection(callback func(c *agentmodel.Connection, cc *agentmodel.CollectorConnections, hostname string))

ForeachConnection will call the callback for each connection per hostname/netID and CollectorConnections payloads

func (*ConnectionsAggregator) ForeachHostnameConnections added in v0.52.0 

func (ca *ConnectionsAggregator) ForeachHostnameConnections(callback func(cnx *Connections, hostname string))

ForeachHostnameConnections will call the callback for each Connections per hostname/netID payloads

type ContainerAggregator added in v0.50.0 

type ContainerAggregator struct {
	Aggregator[*ContainerPayload]
}

ContainerAggregator is an Aggregator for ContainerPayload

func NewContainerAggregator added in v0.50.0 

func NewContainerAggregator() ContainerAggregator

NewContainerAggregator returns a new ContainerAggregator

type ContainerImageAggregator added in v0.51.0 

type ContainerImageAggregator struct {
	Aggregator[*ContainerImagePayload]
}

ContainerImageAggregator is an Aggregator for ContainerImagePayload

func NewContainerImageAggregator added in v0.51.0 

func NewContainerImageAggregator() ContainerImageAggregator

NewContainerImageAggregator returns a new ContainerImageAggregator

type ContainerImagePayload added in v0.51.0 

type ContainerImagePayload struct {
	*agentmodel.ContainerImage
	// contains filtered or unexported fields
}

ContainerImagePayload is a payload type for the container image check

func ParseContainerImagePayload added in v0.51.0 

func ParseContainerImagePayload(payload api.Payload) ([]*ContainerImagePayload, error)

ParseContainerImagePayload parses an api.Payload into a list of ContainerImagePayload

func (*ContainerImagePayload) GetCollectedTime added in v0.51.0 

func (p *ContainerImagePayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (*ContainerImagePayload) GetTags added in v0.51.0 

func (p *ContainerImagePayload) GetTags() []string

GetTags return the tags from a payload

type ContainerLifecycleAggregator added in v0.51.0 

type ContainerLifecycleAggregator struct {
	Aggregator[*ContainerLifecyclePayload]
}

ContainerLifecycleAggregator is an Aggregator for ContainerLifecyclePayload

func NewContainerLifecycleAggregator added in v0.51.0 

func NewContainerLifecycleAggregator() ContainerLifecycleAggregator

NewContainerLifecycleAggregator returns a new ContainerLifecycleAggregator

type ContainerLifecyclePayload added in v0.51.0 

type ContainerLifecyclePayload struct {
	*agentmodel.Event
	// contains filtered or unexported fields
}

ContainerLifecyclePayload is a payload type for the container lifecycle check

func ParseContainerLifecyclePayload added in v0.51.0 

func ParseContainerLifecyclePayload(payload api.Payload) ([]*ContainerLifecyclePayload, error)

ParseContainerLifecyclePayload parses an api.Payload into a list of ContainerLifecyclePayload

func (*ContainerLifecyclePayload) GetCollectedTime added in v0.51.0 

func (p *ContainerLifecyclePayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (*ContainerLifecyclePayload) GetTags added in v0.51.0 

func (p *ContainerLifecyclePayload) GetTags() []string

GetTags is not implemented for container lifecycle payloads

type ContainerPayload added in v0.50.0 

type ContainerPayload struct {
	agentmodel.CollectorContainer
	// contains filtered or unexported fields
}

ContainerPayload is a payload type for the container check

func ParseContainerPayload added in v0.50.0 

func ParseContainerPayload(payload api.Payload) ([]*ContainerPayload, error)

ParseContainerPayload parses an api.Payload into a list of ContainerPayload

func (ContainerPayload) GetCollectedTime added in v0.50.0 

func (p ContainerPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (ContainerPayload) GetTags added in v0.50.0 

func (p ContainerPayload) GetTags() []string

GetTags is not implemented for container payloads

type DatadogMetricOriginMetadata added in v0.50.0 

type DatadogMetricOriginMetadata struct {
	// OriginProduct
	Product uint32 `json:"product,omitempty"`
	// OriginCategory
	Category uint32 `json:"category,omitempty"`
	// OriginService
	Service uint32 `json:"service,omitempty"`
}

DatadogMetricOriginMetadata informations

type DatadogMetricType added in v0.50.0 

type DatadogMetricType string

DatadogMetricType represent different metrics types 

const (
	// Gauge DatadogMetricType
	Gauge DatadogMetricType = "gauge"
	// Count DatadogMetricType
	Count DatadogMetricType = "count"
	// Rate DatadogMetricType
	Rate DatadogMetricType = "rate"
)

type DatadogSeriesMetricMetadata added in v0.50.0 

type DatadogSeriesMetricMetadata struct {
	Origin DatadogMetricOriginMetadata `json:"origin,omitempty"`
}

DatadogSeriesMetricMetadata contains DatadogMetricMetadata

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:"ddsource"`
	Tags      tags   `json:"ddtags"`
	// contains filtered or unexported fields
}

Log represents a log payload

func ParseLogPayload 

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

ParseLogPayload return the parsed logs from payload

func (*Log) GetCollectedTime added in v0.49.0 

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]
}

LogAggregator is an aggregator for logs

func NewLogAggregator 

func NewLogAggregator() LogAggregator

NewLogAggregator returns a new LogAggregator

type MetadataAggregator added in v0.52.0 

type MetadataAggregator struct {
	Aggregator[*MetadataPayload]
}

MetadataAggregator is a type that represents a metadata aggregator

func NewMetadataAggregator added in v0.52.0 

func NewMetadataAggregator() MetadataAggregator

NewMetadataAggregator returns a new metadata aggregator

type MetadataPayload added in v0.52.0 

type MetadataPayload struct {
	Hostname  string                 `json:"hostname"`
	Timestamp int64                  `json:"timestamp"`
	Metadata  map[string]interface{} `json:"agent_metadata"`
	// contains filtered or unexported fields
}

A MetadataPayload is a struct that represents a metadata payload

func ParseMetadataPayload added in v0.52.0 

func ParseMetadataPayload(payload api.Payload) (metadataPayloads []*MetadataPayload, err error)

ParseMetadataPayload return the parsed metadata from payload

func (*MetadataPayload) GetCollectedTime added in v0.52.0 

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

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

func (*MetadataPayload) GetTags added in v0.52.0 

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

GetTags return the tags from a payload

type MetricAggregator 

type MetricAggregator struct {
	Aggregator[*MetricSeries]
}

MetricAggregator is an Aggregator for metric series payloads

func NewMetricAggregator 

func NewMetricAggregator() MetricAggregator

NewMetricAggregator returns a new MetricAggregator

type MetricAggregatorV1 added in v0.50.0 

type MetricAggregatorV1 struct {
	Aggregator[*MetricSeriesV1]
}

MetricAggregatorV1 Aggregator

type MetricSeries 

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

MetricSeries represents a metric series payload

func ParseMetricSeries 

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

ParseMetricSeries return the parsed metrics from payload

func (*MetricSeries) GetCollectedTime added in v0.49.0 

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 MetricSeriesV1 added in v0.50.0 

type MetricSeriesV1 struct {
	Metric         string                      `json:"metric"`
	Type           DatadogMetricType           `json:"type"`
	Interval       uint32                      `json:"interval,omitempty"`
	Points         [][2]interface{}            `json:"points"`
	Tags           []string                    `json:"tags,omitempty"`
	Host           string                      `json:"host,omitempty"`
	SourceTypeName string                      `json:"source_type_name,omitempty"`
	Device         string                      `json:"device,omitempty"`
	Metadata       DatadogSeriesMetricMetadata `json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

MetricSeriesV1 contains all information of a metric in V1 Following API specifications V1 https://docs.datadoghq.com/api/latest/metrics/#submit-metrics Agent submit implementation is https://github.com/DataDog/datadog-agent/blob/af712ce616266987e35e621f0c8f78cbc81716f9/pkg/metrics/series.go#L49-L63

func ParseV1MetricSeries added in v0.50.0 

func ParseV1MetricSeries(payload api.Payload) (metrics []*MetricSeriesV1, err error)

ParseV1MetricSeries return the parsed metrics from payload

func (*MetricSeriesV1) GetCollectedTime added in v0.50.0 

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

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

func (*MetricSeriesV1) GetTags added in v0.50.0 

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

GetTags return the tags from a payload

type MetricSeriesV1Header added in v0.50.0 

type MetricSeriesV1Header struct {
	Series []*MetricSeriesV1 `json:"series"`
}

MetricSeriesV1Header contains a MetricSeriesV1

type NDMFlow added in v0.54.0 

type NDMFlow struct {
	payload.FlowPayload
	// contains filtered or unexported fields
}

NDMFlow represents an ndmflow payload

func ParseNDMFlowPayload added in v0.54.0 

func ParseNDMFlowPayload(payload api.Payload) (ndmflows []*NDMFlow, err error)

ParseNDMFlowPayload parses an api.Payload into a list of NDMFlow

func (*NDMFlow) GetCollectedTime added in v0.54.0 

func (p *NDMFlow) GetCollectedTime() time.Time

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

func (*NDMFlow) GetTags added in v0.54.0 

func (p *NDMFlow) GetTags() []string

GetTags return the tags from a payload

type NDMFlowAggregator added in v0.54.0 

type NDMFlowAggregator struct {
	Aggregator[*NDMFlow]
}

NDMFlowAggregator is an Aggregator for ndmflow payloads

func NewNDMFlowAggregator added in v0.54.0 

func NewNDMFlowAggregator() NDMFlowAggregator

NewNDMFlowAggregator return a new NDMFlowAggregator

type OrchestratorAggregator added in v0.52.0 

type OrchestratorAggregator struct {
	Aggregator[*OrchestratorPayload]
}

OrchestratorAggregator is an Aggregator for OrchestratorPayload

func NewOrchestratorAggregator added in v0.52.0 

func NewOrchestratorAggregator() OrchestratorAggregator

NewOrchestratorAggregator returns a new OrchestratorAggregator

type OrchestratorManifestAggregator added in v0.52.0 

type OrchestratorManifestAggregator struct {
	Aggregator[*OrchestratorManifestPayload]
}

OrchestratorManifestAggregator is an Aggregator for OrchestratorManifestPayload

func NewOrchestratorManifestAggregator added in v0.52.0 

func NewOrchestratorManifestAggregator() OrchestratorManifestAggregator

NewOrchestratorManifestAggregator returns a new OrchestratorManifestAggregator

type OrchestratorManifestPayload added in v0.52.0 

type OrchestratorManifestPayload struct {
	Type          agentmodel.MessageType
	CollectedTime time.Time

	Manifest                *agentmodel.Manifest
	ManifestParentCollector *agentmodel.CollectorManifest
}

OrchestratorManifestPayload is a payload type for the OrchestratorManif check

func ParseOrchestratorManifestPayload added in v0.52.0 

func ParseOrchestratorManifestPayload(payload api.Payload) ([]*OrchestratorManifestPayload, error)

ParseOrchestratorManifestPayload parses an api.Payload into a list of OrchestratorManifestPayload

func (OrchestratorManifestPayload) GetCollectedTime added in v0.52.0 

func (p OrchestratorManifestPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (OrchestratorManifestPayload) GetTags added in v0.52.0 

func (p OrchestratorManifestPayload) GetTags() []string

GetTags is not implemented for OrchestratorManifestPayload

type OrchestratorPayload added in v0.52.0 

type OrchestratorPayload struct {
	Type          agentmodel.MessageType
	UID           string
	Name          string
	Tags          []string
	CollectedTime time.Time

	Pod                                  *agentmodel.Pod
	PodParentCollector                   *agentmodel.CollectorPod
	ReplicaSet                           *agentmodel.ReplicaSet
	ReplicaSetParentCollector            *agentmodel.CollectorReplicaSet
	Deployment                           *agentmodel.Deployment
	DeploymentParentCollector            *agentmodel.CollectorDeployment
	Service                              *agentmodel.Service
	ServiceParentCollector               *agentmodel.CollectorService
	Node                                 *agentmodel.Node
	NodeParentCollector                  *agentmodel.CollectorNode
	Cluster                              *agentmodel.Cluster
	ClusterParentCollector               *agentmodel.CollectorCluster
	Namespace                            *agentmodel.Namespace
	NamespaceParentCollector             *agentmodel.CollectorNamespace
	Job                                  *agentmodel.Job
	JobParentCollector                   *agentmodel.CollectorJob
	CronJob                              *agentmodel.CronJob
	CronJobParentCollector               *agentmodel.CollectorCronJob
	DaemonSet                            *agentmodel.DaemonSet
	DaemonSetParentCollector             *agentmodel.CollectorDaemonSet
	StatefulSet                          *agentmodel.StatefulSet
	StatefulSetParentCollector           *agentmodel.CollectorStatefulSet
	PersistentVolume                     *agentmodel.PersistentVolume
	PersistentVolumeParentCollector      *agentmodel.CollectorPersistentVolume
	PersistentVolumeClaim                *agentmodel.PersistentVolumeClaim
	PersistentVolumeClaimParentCollector *agentmodel.CollectorPersistentVolumeClaim
	Role                                 *agentmodel.Role
	RoleParentCollector                  *agentmodel.CollectorRole
	RoleBinding                          *agentmodel.RoleBinding
	RoleBindingParentCollector           *agentmodel.CollectorRoleBinding
	ClusterRole                          *agentmodel.ClusterRole
	ClusterRoleParentCollector           *agentmodel.CollectorClusterRole
	ClusterRoleBinding                   *agentmodel.ClusterRoleBinding
	ClusterRoleBindingParentCollector    *agentmodel.CollectorClusterRoleBinding
	ServiceAccount                       *agentmodel.ServiceAccount
	ServiceAccountParentCollector        *agentmodel.CollectorServiceAccount
	Ingress                              *agentmodel.Ingress
	IngressParentCollector               *agentmodel.CollectorIngress
	VerticalPodAutoscaler                *agentmodel.VerticalPodAutoscaler
	VerticalPodAutoscalerParentCollector *agentmodel.CollectorVerticalPodAutoscaler
}

OrchestratorPayload is a payload type for the orchestrator check

func ParseOrchestratorPayload added in v0.52.0 

func ParseOrchestratorPayload(payload api.Payload) ([]*OrchestratorPayload, error)

ParseOrchestratorPayload parses an api.Payload into a list of OrchestratorPayload

func (OrchestratorPayload) GetCollectedTime added in v0.52.0 

func (p OrchestratorPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (OrchestratorPayload) GetTags added in v0.52.0 

func (p OrchestratorPayload) GetTags() []string

GetTags returns the tags within the payload

type PayloadItem 

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

A PayloadItem is the interface for payload items stored in a generic aggregator

type ProcessAggregator added in v0.50.0 

type ProcessAggregator struct {
	Aggregator[*ProcessPayload]
}

ProcessAggregator is an Aggregator for ProcessPayload

func NewProcessAggregator added in v0.50.0 

func NewProcessAggregator() ProcessAggregator

NewProcessAggregator returns a new ProcessAggregator

type ProcessDiscoveryAggregator added in v0.50.0 

type ProcessDiscoveryAggregator struct {
	Aggregator[*ProcessDiscoveryPayload]
}

ProcessDiscoveryAggregator is an Aggregator for ProcessDiscoveryPayload

func NewProcessDiscoveryAggregator added in v0.50.0 

func NewProcessDiscoveryAggregator() ProcessDiscoveryAggregator

NewProcessDiscoveryAggregator returns a new ProcessDiscoveryAggregator

type ProcessDiscoveryPayload added in v0.50.0 

type ProcessDiscoveryPayload struct {
	agentmodel.CollectorProcDiscovery
	// contains filtered or unexported fields
}

ProcessDiscoveryPayload is a payload type for the process_discovery check

func ParseProcessDiscoveryPayload added in v0.50.0 

func ParseProcessDiscoveryPayload(payload api.Payload) ([]*ProcessDiscoveryPayload, error)

ParseProcessDiscoveryPayload parses an api.Payload into a list of ProcessDiscoveryPayload

func (ProcessDiscoveryPayload) GetCollectedTime added in v0.50.0 

func (p ProcessDiscoveryPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (ProcessDiscoveryPayload) GetTags added in v0.50.0 

func (p ProcessDiscoveryPayload) GetTags() []string

GetTags is not implemented for process_discovery payloads

type ProcessPayload added in v0.50.0 

type ProcessPayload struct {
	agentmodel.CollectorProc
	// contains filtered or unexported fields
}

ProcessPayload is a payload type for the process check

func ParseProcessPayload added in v0.50.0 

func ParseProcessPayload(payload api.Payload) ([]*ProcessPayload, error)

ParseProcessPayload parses an api.Payload into a list of ProcessPayload

func (ProcessPayload) GetCollectedTime added in v0.50.0 

func (p ProcessPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (ProcessPayload) GetTags added in v0.50.0 

func (p ProcessPayload) GetTags() []string

GetTags is not implemented for process payloads

type SBOMAggregator added in v0.51.0 

type SBOMAggregator struct {
	Aggregator[*SBOMPayload]
}

SBOMAggregator is an Aggregator for SbomPayload

func NewSBOMAggregator added in v0.51.0 

func NewSBOMAggregator() SBOMAggregator

NewSBOMAggregator returns a new SbomAggregator

type SBOMPayload added in v0.51.0 

type SBOMPayload struct {
	*agentmodel.SBOMEntity
	// contains filtered or unexported fields
}

SBOMPayload is a payload type for the sbom check

func ParseSbomPayload added in v0.51.0 

func ParseSbomPayload(payload api.Payload) ([]*SBOMPayload, error)

ParseSbomPayload parses an api.Payload into a list of SbomPayload

func (*SBOMPayload) GetCollectedTime added in v0.51.0 

func (p *SBOMPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake

func (*SBOMPayload) GetTags added in v0.51.0 

func (p *SBOMPayload) GetTags() []string

GetTags return the tags from a payload

type ServiceDiscoveryAggregator added in v0.58.0 

type ServiceDiscoveryAggregator struct {
	Aggregator[*ServiceDiscoveryPayload]
}

ServiceDiscoveryAggregator is an Aggregator for ServiceDiscoveryPayload.

func NewServiceDiscoveryAggregator added in v0.58.0 

func NewServiceDiscoveryAggregator() ServiceDiscoveryAggregator

NewServiceDiscoveryAggregator returns a new ServiceDiscoveryAggregator.

type ServiceDiscoveryPayload added in v0.58.0 

type ServiceDiscoveryPayload struct {
	RequestType string `json:"request_type"`
	APIVersion  string `json:"api_version"`
	Payload     struct {
		NamingSchemaVersion  string  `json:"naming_schema_version"`
		ServiceName          string  `json:"service_name"`
		GeneratedServiceName string  `json:"generated_service_name"`
		DDService            string  `json:"dd_service,omitempty"`
		HostName             string  `json:"host_name"`
		Env                  string  `json:"env"`
		ServiceLanguage      string  `json:"service_language"`
		ServiceType          string  `json:"service_type"`
		StartTime            int64   `json:"start_time"`
		LastSeen             int64   `json:"last_seen"`
		APMInstrumentation   string  `json:"apm_instrumentation"`
		ServiceNameSource    string  `json:"service_name_source,omitempty"`
		RSSMemory            uint64  `json:"rss_memory"`
		CPUCores             float64 `json:"cpu_cores"`
		ContainerID          string  `json:"container_id"`
	} `json:"payload"`
	// contains filtered or unexported fields
}

ServiceDiscoveryPayload is a payload type for the service_discovery check

func ParseServiceDiscoveryPayload added in v0.58.0 

func ParseServiceDiscoveryPayload(payload api.Payload) ([]*ServiceDiscoveryPayload, error)

ParseServiceDiscoveryPayload parses an api.Payload into a list of ServiceDiscoveryPayload.

func (*ServiceDiscoveryPayload) GetCollectedTime added in v0.58.0 

func (s *ServiceDiscoveryPayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake.

func (*ServiceDiscoveryPayload) GetTags added in v0.58.0 

func (s *ServiceDiscoveryPayload) GetTags() []string

GetTags is not implemented.

type TraceAggregator added in v0.52.0 

type TraceAggregator struct {
	Aggregator[*TracePayload]
}

TraceAggregator is an Aggregator for TracePayload

func NewTraceAggregator added in v0.52.0 

func NewTraceAggregator() TraceAggregator

NewTraceAggregator returns a new TraceAggregator

type TracePayload added in v0.52.0 

type TracePayload struct {
	*pb.AgentPayload
	// contains filtered or unexported fields
}

TracePayload is a payload type for traces It implements PayloadItem

func ParseTracePayload added in v0.52.0 

func ParseTracePayload(payload api.Payload) ([]*TracePayload, error)

ParseTracePayload parses an api.Payload into a list of TracePayload

func (*TracePayload) GetCollectedTime added in v0.52.0 

func (tp *TracePayload) GetCollectedTime() time.Time

GetCollectedTime returns the time that the payload was received by the fake intake TracePayload implements PayloadItem

func (*TracePayload) GetTags added in v0.52.0 

func (tp *TracePayload) GetTags() []string

GetTags is not implemented TracePayload implements PayloadItem

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.