datadogagentinternal

package
v1.26.0 Latest Latest
Warning

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

 Go to latest Published: May 4, 2026 License: Apache-2.0 Imports: 84 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckOwnerReference 

func CheckOwnerReference(owner, object metav1.Object) bool

CheckOwnerReference return true if owner is the owner of the object

func IsEqualStatus added in v1.19.0 

func IsEqualStatus(current *v1alpha1.DatadogAgentInternalStatus, newStatus *v1alpha1.DatadogAgentInternalStatus) bool

func SetOwnerReference 

func SetOwnerReference(owner, object metav1.Object, scheme *runtime.Scheme) error

SetOwnerReference sets owner as a OwnerReference.

Types

type BuilderOptions 

type BuilderOptions struct {
	AllowOverride bool
}

BuilderOptions corresponds to Builders options.

func DefaultBuilderOptions 

func DefaultBuilderOptions() BuilderOptions

DefaultBuilderOptions returns a default BuilderOptions instance.

type ClusterAgentComponent added in v1.22.0 

type ClusterAgentComponent struct {
	// contains filtered or unexported fields
}

ClusterAgentComponent implements ComponentReconciler for the Cluster Agent deployment

func NewClusterAgentComponent added in v1.22.0 

func NewClusterAgentComponent(reconciler *Reconciler) *ClusterAgentComponent

NewClusterAgentComponent creates a new ClusterAgent component

func (*ClusterAgentComponent) CleanupDependencies added in v1.25.0 

func (c *ClusterAgentComponent) CleanupDependencies(ctx context.Context, ddai *v1alpha1.DatadogAgentInternal, resourcesManager feature.ResourceManagers) (reconcile.Result, error)

func (*ClusterAgentComponent) DeleteStatus added in v1.25.0 

func (c *ClusterAgentComponent) DeleteStatus(newStatus *v1alpha1.DatadogAgentInternalStatus, conditionType string)

func (*ClusterAgentComponent) ForceDeleteComponent added in v1.25.0 

func (c *ClusterAgentComponent) ForceDeleteComponent(ddai *v1alpha1.DatadogAgentInternal, _ feature.RequiredComponents) bool

func (*ClusterAgentComponent) GetConditionType added in v1.22.0 

func (c *ClusterAgentComponent) GetConditionType() string

GetConditionType returns the condition type for status updates

func (*ClusterAgentComponent) GetGlobalSettingsFunc added in v1.25.0 

func (c *ClusterAgentComponent) GetGlobalSettingsFunc() func(logger logr.Logger, podManagers feature.PodTemplateManagers, ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec, resourceManagers feature.ResourceManagers, requiredComponents feature.RequiredComponents)

func (*ClusterAgentComponent) GetManageFeatureFunc added in v1.25.0 

func (c *ClusterAgentComponent) GetManageFeatureFunc() func(feat feature.Feature, managers feature.PodTemplateManagers, provider string) error

func (*ClusterAgentComponent) GetNewDeploymentFunc added in v1.25.0 

func (c *ClusterAgentComponent) GetNewDeploymentFunc() func(ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec) *appsv1.Deployment

func (*ClusterAgentComponent) IsEnabled added in v1.22.0 

func (c *ClusterAgentComponent) IsEnabled(requiredComponents feature.RequiredComponents, overrides map[datadoghqv2alpha1.ComponentName]*datadoghqv2alpha1.DatadogAgentComponentOverride) (enabled bool, conflict bool)

IsEnabled checks if the Cluster Agent component should be reconciled

func (*ClusterAgentComponent) Name added in v1.22.0 

func (c *ClusterAgentComponent) Name() datadoghqv2alpha1.ComponentName

Name returns the component name

func (*ClusterAgentComponent) UpdateStatus added in v1.25.0 

func (c *ClusterAgentComponent) UpdateStatus(deployment *appsv1.Deployment, newStatus *v1alpha1.DatadogAgentInternalStatus, updateTime metav1.Time, status metav1.ConditionStatus, reason, message string)

type ClusterChecksRunnerComponent added in v1.22.0 

type ClusterChecksRunnerComponent struct {
	// contains filtered or unexported fields
}

ClusterChecksRunnerComponent implements ComponentReconciler for the Cluster Checks Runner deployment

func NewClusterChecksRunnerComponent added in v1.22.0 

func NewClusterChecksRunnerComponent(reconciler *Reconciler) *ClusterChecksRunnerComponent

NewClusterChecksRunnerComponent creates a new ClusterChecksRunner component

func (*ClusterChecksRunnerComponent) CleanupDependencies added in v1.25.0 

func (c *ClusterChecksRunnerComponent) CleanupDependencies(ctx context.Context, ddai *v1alpha1.DatadogAgentInternal, resourcesManager feature.ResourceManagers) (reconcile.Result, error)

func (*ClusterChecksRunnerComponent) DeleteStatus added in v1.25.0 

func (c *ClusterChecksRunnerComponent) DeleteStatus(newStatus *v1alpha1.DatadogAgentInternalStatus, conditionType string)

func (*ClusterChecksRunnerComponent) ForceDeleteComponent added in v1.25.0 

func (c *ClusterChecksRunnerComponent) ForceDeleteComponent(ddai *v1alpha1.DatadogAgentInternal, requiredComponents feature.RequiredComponents) bool

func (*ClusterChecksRunnerComponent) GetConditionType added in v1.22.0 

func (c *ClusterChecksRunnerComponent) GetConditionType() string

GetConditionType returns the condition type for status updates

func (*ClusterChecksRunnerComponent) GetGlobalSettingsFunc added in v1.25.0 

func (c *ClusterChecksRunnerComponent) GetGlobalSettingsFunc() func(logger logr.Logger, podManagers feature.PodTemplateManagers, ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec, resourceManagers feature.ResourceManagers, requiredComponents feature.RequiredComponents)

func (*ClusterChecksRunnerComponent) GetManageFeatureFunc added in v1.25.0 

func (c *ClusterChecksRunnerComponent) GetManageFeatureFunc() func(feat feature.Feature, managers feature.PodTemplateManagers, provider string) error

func (*ClusterChecksRunnerComponent) GetNewDeploymentFunc added in v1.25.0 

func (c *ClusterChecksRunnerComponent) GetNewDeploymentFunc() func(ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec) *appsv1.Deployment

func (*ClusterChecksRunnerComponent) IsEnabled added in v1.22.0 

func (c *ClusterChecksRunnerComponent) IsEnabled(requiredComponents feature.RequiredComponents, overrides map[datadoghqv2alpha1.ComponentName]*datadoghqv2alpha1.DatadogAgentComponentOverride) (enabled bool, conflict bool)

IsEnabled checks if the ClusterChecksRunner component should be reconciled CCR requires the Cluster Agent to be enabled as well

func (*ClusterChecksRunnerComponent) Name added in v1.22.0 

func (c *ClusterChecksRunnerComponent) Name() datadoghqv2alpha1.ComponentName

Name returns the component name

func (*ClusterChecksRunnerComponent) UpdateStatus added in v1.25.0 

func (c *ClusterChecksRunnerComponent) UpdateStatus(deployment *appsv1.Deployment, newStatus *v1alpha1.DatadogAgentInternalStatus, updateTime metav1.Time, status metav1.ConditionStatus, reason, message string)

type ComponentReconciler added in v1.22.0 

type ComponentReconciler interface {
	// Name returns the component name (e.g., "clusterAgent", "clusterChecksRunner")
	Name() datadoghqv2alpha1.ComponentName

	// IsEnabled checks if this component should be reconciled based on requiredComponents and override settings
	// Returns (enabled, conflict) where:
	//   - enabled=true, conflict=false: component should be reconciled normally
	//   - enabled=true, conflict=true: component enabled in features but disabled via override (cleanup with conflict status)
	//   - enabled=false, conflict=*: component disabled (cleanup without conflict status if conflict=false)
	IsEnabled(requiredComponents feature.RequiredComponents, overrides map[datadoghqv2alpha1.ComponentName]*datadoghqv2alpha1.DatadogAgentComponentOverride) (enabled bool, conflict bool)

	// GetConditionType returns the condition type used for status updates
	GetConditionType() string

	// GetGlobalSettingsFunc returns the function to apply global settings to the component
	GetGlobalSettingsFunc() func(logger logr.Logger, podManagers feature.PodTemplateManagers, ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec, resourceManagers feature.ResourceManagers, requiredComponents feature.RequiredComponents)

	// GetNewDeploymentFunc returns the function to create a new deployment for the component
	GetNewDeploymentFunc() func(ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec) *appsv1.Deployment

	// GetManageFeatureFunc returns the function to manage features for the component
	GetManageFeatureFunc() func(feat feature.Feature, managers feature.PodTemplateManagers, provider string) error

	// UpdateStatus updates the status of the component
	UpdateStatus(deployment *appsv1.Deployment, newStatus *v1alpha1.DatadogAgentInternalStatus, updateTime metav1.Time, status metav1.ConditionStatus, reason, message string)

	// DeleteStatus deletes the status of the component
	DeleteStatus(newStatus *v1alpha1.DatadogAgentInternalStatus, conditionType string)

	// ForceDeleteComponent returns true if the component should be force deleted
	ForceDeleteComponent(ddai *v1alpha1.DatadogAgentInternal, requiredComponents feature.RequiredComponents) bool

	// CleanupDependencies deletes any dependencies associated with the component
	CleanupDependencies(ctx context.Context, ddai *v1alpha1.DatadogAgentInternal, resourcesManager feature.ResourceManagers) (reconcile.Result, error)
}

ComponentReconciler defines the interface that all deployment/daemonset components must implement

type ComponentRegistry added in v1.22.0 

type ComponentRegistry struct {
	// contains filtered or unexported fields
}

ComponentRegistry manages the registration and reconciliation of all components

func NewComponentRegistry added in v1.22.0 

func NewComponentRegistry(reconciler *Reconciler) *ComponentRegistry

NewComponentRegistry creates a new component registry

func (*ComponentRegistry) Cleanup added in v1.25.0 

func (r *ComponentRegistry) Cleanup(ctx context.Context, params *ReconcileComponentParams, component ComponentReconciler) (reconcile.Result, error)

Cleanup removes the component deployment, associated resources and updates status

func (*ComponentRegistry) GetComponent added in v1.22.0 

func (r *ComponentRegistry) GetComponent(name datadoghqv2alpha1.ComponentName) ComponentReconciler

GetComponent returns a registered component by name

func (*ComponentRegistry) ListComponents added in v1.22.0 

func (r *ComponentRegistry) ListComponents() []ComponentReconciler

ListComponents returns all registered components

func (*ComponentRegistry) ReconcileComponents added in v1.22.0 

func (r *ComponentRegistry) ReconcileComponents(ctx context.Context, params *ReconcileComponentParams) (reconcile.Result, error)

ReconcileComponents reconciles all registered components in order

func (*ComponentRegistry) Register added in v1.22.0 

func (r *ComponentRegistry) Register(component ComponentReconciler)

Register adds a component to the registry

type EnvVarBuilder 

type EnvVarBuilder struct {
	// contains filtered or unexported fields
}

EnvVarBuilder used to generate a list of EnvVar.

func NewEnvVarsBuilder 

func NewEnvVarsBuilder(envVars []corev1.EnvVar, opts *BuilderOptions) *EnvVarBuilder

NewEnvVarsBuilder returns a new EnvVarsBuilder instance.

func (*EnvVarBuilder) Add 

func (b *EnvVarBuilder) Add(iEnvVar *corev1.EnvVar) *EnvVarBuilder

Add used to add an EnvVar to the EnvVarBuilder.

func (*EnvVarBuilder) Build 

func (b *EnvVarBuilder) Build() []corev1.EnvVar

Build return the generated EnvVar list.

func (*EnvVarBuilder) Remove 

func (b *EnvVarBuilder) Remove(volumeName string) *EnvVarBuilder

Remove used to remove an EnvVar to the EnvVarBuilder.

type OtelAgentGatewayComponent added in v1.23.0 

type OtelAgentGatewayComponent struct {
	// contains filtered or unexported fields
}

OtelAgentGatewayComponent implements ComponentReconciler for the OTel Agent Gateway deployment

func NewOtelAgentGatewayComponent added in v1.23.0 

func NewOtelAgentGatewayComponent(reconciler *Reconciler) *OtelAgentGatewayComponent

NewOtelAgentGatewayComponent creates a new OtelAgentGateway component

func (*OtelAgentGatewayComponent) CleanupDependencies added in v1.25.0 

func (c *OtelAgentGatewayComponent) CleanupDependencies(ctx context.Context, ddai *v1alpha1.DatadogAgentInternal, resourcesManager feature.ResourceManagers) (reconcile.Result, error)

func (*OtelAgentGatewayComponent) DeleteStatus added in v1.25.0 

func (c *OtelAgentGatewayComponent) DeleteStatus(newStatus *v1alpha1.DatadogAgentInternalStatus, conditionType string)

func (*OtelAgentGatewayComponent) ForceDeleteComponent added in v1.25.0 

func (c *OtelAgentGatewayComponent) ForceDeleteComponent(ddai *v1alpha1.DatadogAgentInternal, requiredComponents feature.RequiredComponents) bool

func (*OtelAgentGatewayComponent) GetConditionType added in v1.23.0 

func (c *OtelAgentGatewayComponent) GetConditionType() string

GetConditionType returns the condition type for status updates

func (*OtelAgentGatewayComponent) GetGlobalSettingsFunc added in v1.25.0 

func (c *OtelAgentGatewayComponent) GetGlobalSettingsFunc() func(logger logr.Logger, podManagers feature.PodTemplateManagers, ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec, resourceManagers feature.ResourceManagers, requiredComponents feature.RequiredComponents)

func (*OtelAgentGatewayComponent) GetManageFeatureFunc added in v1.25.0 

func (c *OtelAgentGatewayComponent) GetManageFeatureFunc() func(feat feature.Feature, managers feature.PodTemplateManagers, provider string) error

func (*OtelAgentGatewayComponent) GetNewDeploymentFunc added in v1.25.0 

func (c *OtelAgentGatewayComponent) GetNewDeploymentFunc() func(ddai metav1.Object, spec *datadoghqv2alpha1.DatadogAgentSpec) *appsv1.Deployment

func (*OtelAgentGatewayComponent) IsEnabled added in v1.23.0 

func (c *OtelAgentGatewayComponent) IsEnabled(requiredComponents feature.RequiredComponents, overrides map[datadoghqv2alpha1.ComponentName]*datadoghqv2alpha1.DatadogAgentComponentOverride) (enabled bool, conflict bool)

IsEnabled checks if the OtelAgentGateway component should be reconciled

func (*OtelAgentGatewayComponent) Name added in v1.23.0 

func (c *OtelAgentGatewayComponent) Name() datadoghqv2alpha1.ComponentName

Name returns the component name

func (*OtelAgentGatewayComponent) UpdateStatus added in v1.25.0 

func (c *OtelAgentGatewayComponent) UpdateStatus(deployment *appsv1.Deployment, newStatus *v1alpha1.DatadogAgentInternalStatus, updateTime metav1.Time, status metav1.ConditionStatus, reason, message string)

type ReconcileComponentParams added in v1.22.0 

type ReconcileComponentParams struct {
	DDAI               *v1alpha1.DatadogAgentInternal
	RequiredComponents feature.RequiredComponents
	Features           []feature.Feature
	ResourceManagers   feature.ResourceManagers
	Status             *v1alpha1.DatadogAgentInternalStatus
	Provider           string
}

ReconcileComponentParams bundles common parameters needed by all components

type Reconciler 

type Reconciler struct {
	// contains filtered or unexported fields
}

Reconciler is the internal reconciler for Datadog Agent

func NewReconciler 

func NewReconciler(options ReconcilerOptions, client client.Client, platformInfo kubernetes.PlatformInfo,
	scheme *runtime.Scheme, recorder record.EventRecorder, metricForwardersMgr datadog.MetricsForwardersManager,
) (*Reconciler, error)

NewReconciler returns a reconciler for DatadogAgent

func (*Reconciler) Reconcile 

func (r *Reconciler) Reconcile(ctx context.Context, ddai *v1alpha1.DatadogAgentInternal) (reconcile.Result, error)

Reconcile is similar to reconciler.Reconcile interface, but taking a context

type ReconcilerOptions 

type ReconcilerOptions struct {
	ExtendedDaemonsetOptions componentagent.ExtendedDaemonsetOptions
	SupportCilium            bool
	OperatorMetricsEnabled   bool
}

ReconcilerOptions provides options read from command line

type VolumeBuilder 

type VolumeBuilder struct {
	// contains filtered or unexported fields
}

VolumeBuilder used to generate a list of Volume.

func NewVolumeBuilder 

func NewVolumeBuilder(volumes []corev1.Volume, opts *BuilderOptions) *VolumeBuilder

NewVolumeBuilder returns a new VolumeBuilder instance.

func (*VolumeBuilder) Add 

func (b *VolumeBuilder) Add(iVolume *corev1.Volume) *VolumeBuilder

Add used to add an Volume to the VolumeBuilder.

func (*VolumeBuilder) Build 

func (b *VolumeBuilder) Build() []corev1.Volume

Build used to generate a list of Volume.

func (*VolumeBuilder) Remove 

func (b *VolumeBuilder) Remove(volumeName string) *VolumeBuilder

Remove used to remove an Volume from the VolumeBuilder.

type VolumeMountBuilder 

type VolumeMountBuilder struct {
	// contains filtered or unexported fields
}

VolumeMountBuilder used to generate a list of VolumeMount.

func NewVolumeMountBuilder 

func NewVolumeMountBuilder(volumeMounts []corev1.VolumeMount, opts *BuilderOptions) *VolumeMountBuilder

NewVolumeMountBuilder returns a new VolumeMountBuilder instance.

func (*VolumeMountBuilder) Add 

func (b *VolumeMountBuilder) Add(iVolumeMount *corev1.VolumeMount) *VolumeMountBuilder

Add used to add an VolumeMount to the VolumeMountBuilder.

func (*VolumeMountBuilder) Build 

func (b *VolumeMountBuilder) Build() []corev1.VolumeMount

Build used to generate a list of VolumeMount

func (*VolumeMountBuilder) Remove 

func (b *VolumeMountBuilder) Remove(volumeName string) *VolumeMountBuilder

Remove used to remove an VolumeMount from the VolumeMountBuilder.

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.