aggregator

type APMStatsAggregator struct {
	Aggregator[*APMStatsPayload]
}

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

type AgentHealthAggregator struct {
	Aggregator[*AgentHealthPayload]
}

type AgentHealthPayload struct {
	*healthplatform.HealthReport
	// 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 DeviceMetadata struct {
	ID             string   `json:"id"`
	IDTags         []string `json:"id_tags"`
	Tags           []string `json:"tags"`
	IPAddress      string   `json:"ip_address"`
	Status         int32    `json:"status"`
	PingStatus     int32    `json:"ping_status,omitempty"`
	Name           string   `json:"name,omitempty"`
	Description    string   `json:"description,omitempty"`
	SysObjectID    string   `json:"sys_object_id,omitempty"`
	Location       string   `json:"location,omitempty"`
	Profile        string   `json:"profile,omitempty"`
	ProfileVersion uint64   `json:"profile_version,omitempty"`
	Vendor         string   `json:"vendor,omitempty"`
	Subnet         string   `json:"subnet,omitempty"`
	SerialNumber   string   `json:"serial_number,omitempty"`
	Version        string   `json:"version,omitempty"`
	ProductName    string   `json:"product_name,omitempty"`
	Model          string   `json:"model,omitempty"`
	OsName         string   `json:"os_name,omitempty"`
	OsVersion      string   `json:"os_version,omitempty"`
	OsHostname     string   `json:"os_hostname,omitempty"`
	Integration    string   `json:"integration,omitempty"`
	DeviceType     string   `json:"device_type,omitempty"`
}

type Diagnosis struct {
	Severity string `json:"severity"`
	Message  string `json:"message"`
	Code     string `json:"code"`
}

type DiagnosisMetadata struct {
	ResourceType string      `json:"resource_type"`
	ResourceID   string      `json:"resource_id"`
	Diagnoses    []Diagnosis `json:"diagnoses"`
}

type Event struct {
	Source string
	*event.Event
	// contains filtered or unexported fields
}

type EventAggregator struct {
	Aggregator[*Event]
}

type HostTags struct {
	InternalHostname string
	HostTags         []string
	// contains filtered or unexported fields
}

type HostTagsAggregator struct {
	Aggregator[*HostTags]
}

type InterfaceMetadata struct {
	DeviceID      string   `json:"device_id"`
	IDTags        []string `json:"id_tags"`
	Index         int32    `json:"index"`
	RawID         string   `json:"raw_id,omitempty"`
	RawIDType     string   `json:"raw_id_type,omitempty"`
	Name          string   `json:"name,omitempty"`
	Alias         string   `json:"alias,omitempty"`
	Description   string   `json:"description,omitempty"`
	MacAddress    string   `json:"mac_address,omitempty"`
	AdminStatus   int      `json:"admin_status,omitempty"`
	OperStatus    int      `json:"oper_status,omitempty"`
	MerakiEnabled *bool    `json:"meraki_enabled,omitempty"`
	MerakiStatus  string   `json:"meraki_status,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 NCMAggregator struct {
	Aggregator[*NCMPayload]
}

type NCMPayload struct {
	Namespace        string                `json:"namespace"`
	Configs          []NetworkDeviceConfig `json:"configs"`
	CollectTimestamp int64                 `json:"collect_timestamp"`
	// contains filtered or unexported fields
}

type NDMAggregator struct {
	Aggregator[*NDMPayload]
}

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

type NDMFlowAggregator struct {
	Aggregator[*NDMFlow]
}

type NDMPayload struct {

	// We redefine NetworkDevicesMetadata from pkg/networkdevice/metadata to not have to export it
	Subnet           string              `json:"subnet,omitempty"`
	Namespace        string              `json:"namespace"`
	Integration      string              `json:"integration"`
	Devices          []DeviceMetadata    `json:"devices,omitempty"`
	Interfaces       []InterfaceMetadata `json:"interfaces,omitempty"`
	Diagnoses        []DiagnosisMetadata `json:"diagnoses,omitempty"`
	CollectTimestamp int64               `json:"collect_timestamp"`
	// contains filtered or unexported fields
}

type Netpath struct {
	payload.NetworkPath
	// contains filtered or unexported fields
}

type NetpathAggregator struct {
	Aggregator[*Netpath]
}

type NetworkDeviceConfig struct {
	DeviceID   string   `json:"device_id"`
	DeviceIP   string   `json:"device_ip"`
	ConfigType string   `json:"config_type"`
	Timestamp  int64    `json:"timestamp"`
	Tags       []string `json:"tags"`
	Content    string   `json:"content"`
}

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
	ECSTask                              *agentmodel.ECSTask
	ECSTaskParentCollector               *agentmodel.CollectorECSTask
}

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
}