aggregator

type APMStatsAggregator struct {
	Aggregator[*APMStatsPayload]
}

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

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

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
}

type CheckRunAggregator struct {
	Aggregator[*CheckRun]
}

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

type ConnectionsAggregator struct {
	Aggregator[*Connections]
}

type ContainerAggregator struct {
	Aggregator[*ContainerPayload]
}

type ContainerImageAggregator struct {
	Aggregator[*ContainerImagePayload]
}

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

type ContainerLifecycleAggregator struct {
	Aggregator[*ContainerLifecyclePayload]
}

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

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

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

type DatadogMetricType string

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

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
}

type LogAggregator struct {
	Aggregator[*Log]
}

type MetadataAggregator struct {
	Aggregator[*MetadataPayload]
}

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

type MetricAggregator struct {
	Aggregator[*MetricSeries]
}

type MetricAggregatorV1 struct {
	Aggregator[*MetricSeriesV1]
}

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

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
}

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

type OrchestratorAggregator struct {
	Aggregator[*OrchestratorPayload]
}

type OrchestratorManifestAggregator struct {
	Aggregator[*OrchestratorManifestPayload]
}

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

	Manifest                *agentmodel.Manifest
	ManifestParentCollector *agentmodel.CollectorManifest
}

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
}

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

type ProcessAggregator struct {
	Aggregator[*ProcessPayload]
}

type ProcessDiscoveryAggregator struct {
	Aggregator[*ProcessDiscoveryPayload]
}

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

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

type SBOMAggregator struct {
	Aggregator[*SBOMPayload]
}

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

type TraceAggregator struct {
	Aggregator[*TracePayload]
}

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