util

package
v0.0.0-...-102792a Latest Latest
Warning

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

 Go to latest Published: May 8, 2026 License: Apache-2.0 Imports: 44 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// EnvtestK8sVersion is the version of the binaries used by envtest. Maintenance note: Keep this in sync with
	// ENVTEST_K8S_VERSION in the Makefile.
	EnvtestK8sVersion = "1.34.1"

	ClusterUidTest              = "cluster-uid-test"
	ClusterNameTest             = "cluster-name-test"
	TestNamespaceName           = "test-namespace"
	OperatorNamespace           = "test-operator-namespace"
	OTelCollectorNamePrefixTest = "unit-test"
	TargetAllocatorPrefixTest   = "unit-test"

	CronJobNamePrefix     = "cronjob"
	DaemonSetNamePrefix   = "daemonset"
	DeploymentNamePrefix  = "deployment"
	JobNamePrefix         = "job"
	PodNamePrefix         = "pod"
	ReplicaSetNamePrefix  = "replicaset"
	StatefulSetNamePrefix = "statefulset"

	OperatorVersionTest                   = "1.2.3"
	OperatorImageTest                     = "some-registry.com:1234/dash0hq/operator-controller:1.2.3"
	InitContainerImageTest                = "some-registry.com:1234/dash0hq/instrumentation:4.5.6"
	CollectorImageTest                    = "some-registry.com:1234/dash0hq/collector:7.8.9"
	TargetAllocatorImageTest              = "some-registry.com:1234/dash0hq/target-allocator:8.9.10"
	ConfigurationReloaderImageTest        = "some-registry.com:1234/dash0hq/configuration-reloader:10.11.12"
	FilelogOffsetSyncImageTest            = "some-registry.com:1234/dash0hq/filelog-offset-sync:13.14.15"
	FilelogOffsetVolumeOwnershipImageTest = "some-registry.com:1234/dash0hq/filelog-offset-volume-ownership:16.17.18"

	OTelCollectorNodeLocalBaseUrlTest = "http://$(DASH0_NODE_IP):40318"
	OTelCollectorServiceBaseUrlTest   = "http://unit-test-opentelemetry-collector-service.test-operator-namespace.svc.cluster.local:4318"
	EndpointDash0Test                 = "endpoint.dash0.com:4317"
	EndpointDash0TestAlternative      = "endpoint-alternative.dash0.com:4317"
	EndpointDash0TestQuoted           = "\"endpoint.dash0.com:4317\""
	EndpointDash0WithProtocolTest     = "https://endpoint.dash0.com:4317"
	EndpointGrpcTest                  = "endpoint.backend.com:4317"
	EndpointGrpcWithProtocolTest      = "dns://endpoint.backend.com:4317"
	EndpointHttpTest                  = "https://endpoint.backend.com:4318"

	ApiEndpointTest                        = "https://api.dash0.com"
	ApiEndpointStandardizedTest            = "https://api.dash0.com/"
	ApiEndpointTestAlternative             = "https://api-alt.dash0.com"
	ApiEndpointStandardizedTestAlternative = "https://api-alt.dash0.com/"
	DatasetCustomTest                      = "test-dataset"
	DatasetCustomTestAlternative           = "test-dataset-alt"
)
View Source 
const (
	OperatorWebhookServiceName        = "dash0-operator-webhook-service"
	OperatorConfigurationResourceName = "dash0-operator-configuration-test"
)
View Source 
const (
	MonitoringResourceName = "dash0-monitoring-test-resource"
)
View Source 
const (
	NamePrefix = "unit-test"
)

Variables

View Source 
var (
	ExpectedDaemonSetServiceAccountName             = fmt.Sprintf("%s-opentelemetry-collector-sa", NamePrefix)
	ExpectedDaemonSetCollectorConfigMapName         = fmt.Sprintf("%s-opentelemetry-collector-agent-cm", NamePrefix)
	ExpectedDaemonSetFilelogOffsetSyncConfigMapName = fmt.Sprintf("%s-filelogoffsets-cm", NamePrefix)
	ExpectedDaemonSetClusterRoleName                = fmt.Sprintf("%s-opentelemetry-collector-cr", NamePrefix)
	ExpectedDaemonSetClusterRoleBinding             = fmt.Sprintf("%s-opentelemetry-collector-crb", NamePrefix)
	ExpectedDaemonSetRoleName                       = fmt.Sprintf("%s-opentelemetry-collector-role", NamePrefix)
	ExpectedDaemonSetRoleBindingName                = fmt.Sprintf("%s-opentelemetry-collector-rolebinding", NamePrefix)
	ExpectedDaemonSetServiceName                    = fmt.Sprintf("%s-opentelemetry-collector-service", NamePrefix)
	ExpectedDaemonSetName                           = fmt.Sprintf(
		"%s-opentelemetry-collector-agent-daemonset",
		NamePrefix,
	)
	ExpectedDeploymentServiceAccountName     = fmt.Sprintf("%s-cluster-metrics-collector-sa", NamePrefix)
	ExpectedDeploymentClusterRoleName        = fmt.Sprintf("%s-cluster-metrics-collector-cr", NamePrefix)
	ExpectedDeploymentClusterRoleBindingName = fmt.Sprintf("%s-cluster-metrics-collector-crb", NamePrefix)
	ExpectedDeploymentCollectorConfigMapName = fmt.Sprintf("%s-cluster-metrics-collector-cm", NamePrefix)
	ExpectedDeploymentName                   = fmt.Sprintf("%s-cluster-metrics-collector-deployment", NamePrefix)

	AllClusterMetricsRelatedResources = []expectedResource{
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		expectedResourceDeploymentConfigMap,
		expectedResourceDeployment,
	}
	AllDaemonSetRelatedResources = []expectedResource{
		{/* contains filtered or unexported fields */},
		expectedResourceDaemonSetConfigMap,
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		expectedResourceDaemonSet,
	}
	AllDeploymentRelatedResources = []expectedResource{
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		{/* contains filtered or unexported fields */},
		expectedResourceDeploymentConfigMap,
		expectedResourceDeployment,
	}
	AllExpectedResources = append(
		AllDaemonSetRelatedResources,
		AllDeploymentRelatedResources...,
	)
)
View Source 
var (
	AuthorizationDefaultEnvVar         = "OTELCOL_AUTH_TOKEN_DEFAULT_0"
	AuthorizationTokenTest             = "authorization-token-test"
	AuthorizationHeaderTest            = fmt.Sprintf("Bearer %s", AuthorizationTokenTest)
	AuthorizationTokenTestAlternative  = "authorization-token-test-alternative"
	AuthorizationHeaderTestAlternative = fmt.Sprintf("Bearer %s", AuthorizationTokenTestAlternative)
	AuthorizationTokenTestFromSecret   = "authorization-token-test-from-secret"
	AuthorizationHeaderTestFromSecret  = fmt.Sprintf("Bearer %s", AuthorizationTokenTestFromSecret)
	SecretRefTest                      = dash0common.SecretRef{
		Name: "secret-ref",
		Key:  "key",
	}

	ArbitraryNumer int64 = 1302

	TestImages = util.Images{
		OperatorImage:                               OperatorImageTest,
		InitContainerImage:                          InitContainerImageTest,
		InitContainerImagePullPolicy:                corev1.PullAlways,
		CollectorImage:                              CollectorImageTest,
		CollectorImagePullPolicy:                    corev1.PullAlways,
		TargetAllocatorImage:                        TargetAllocatorImageTest,
		TargetAllocatorPullPolicy:                   corev1.PullAlways,
		ConfigurationReloaderImage:                  ConfigurationReloaderImageTest,
		ConfigurationReloaderImagePullPolicy:        corev1.PullAlways,
		FilelogOffsetSyncImage:                      FilelogOffsetSyncImageTest,
		FilelogOffsetSyncImagePullPolicy:            corev1.PullAlways,
		FilelogOffsetVolumeOwnershipImage:           FilelogOffsetVolumeOwnershipImageTest,
		FilelogOffsetVolumeOwnershipImagePullPolicy: corev1.PullAlways,
	}

	OperatorManagerDeploymentUIDStr = "2f009c75-d69f-4b02-9d9d-fa17e76f5c1d"
	OperatorManagerDeploymentUID    = types.UID(OperatorManagerDeploymentUIDStr)
	OperatorManagerDeploymentName   = "unit-test-dash0-operator-controller"
	OperatorManagerDeployment       = &appsv1.Deployment{
		ObjectMeta: metav1.ObjectMeta{
			Namespace: OperatorNamespace,
			Name:      OperatorManagerDeploymentName,
			UID:       types.UID(OperatorManagerDeploymentUIDStr),
		},
	}

	DanglingEventsTimeoutsTest = util.DanglingEventsTimeouts{
		InitialTimeout: 0 * time.Second,
		Backoff: wait.Backoff{
			Steps:    1,
			Duration: 0 * time.Second,
			Factor:   1,
			Jitter:   0,
		},
	}
)
View Source 
var (
	MonitoringResourceQualifiedName = types.NamespacedName{
		Namespace: TestNamespaceName,
		Name:      MonitoringResourceName,
	}
	MonitoringResourceDefaultObjectMeta = metav1.ObjectMeta{
		Namespace: TestNamespaceName,
		Name:      MonitoringResourceName,
	}
	MonitoringResourceObjectMetaWithLabelAndAnnotation = metav1.ObjectMeta{
		Namespace: TestNamespaceName,
		Name:      MonitoringResourceName,
		Labels: map[string]string{
			"test-label": "test-value",
		},
		Annotations: map[string]string{
			"test-annotation": "test-value",
		},
	}
	MonitoringResourceDefaultSpec = dash0v1beta1.Dash0MonitoringSpec{
		InstrumentWorkloads: dash0v1beta1.InstrumentWorkloads{
			LabelSelector: util.DefaultAutoInstrumentationLabelSelector,
		},
		Exports: []dash0common.Export{
			{
				Dash0: &dash0common.Dash0Configuration{
					Endpoint: EndpointDash0Test,
					Authorization: dash0common.Authorization{
						Token: &AuthorizationTokenTest,
					},
					ApiEndpoint: ApiEndpointTest,
					Dataset:     DatasetCustomTest,
				},
			},
		},
	}
	MonitoringResourceDefaultSpecWithoutExport = dash0v1beta1.Dash0MonitoringSpec{
		InstrumentWorkloads: dash0v1beta1.InstrumentWorkloads{
			LabelSelector: util.DefaultAutoInstrumentationLabelSelector,
		},
	}

	DefaultNamespaceInstrumentationConfig = util.NamespaceInstrumentationConfig{
		InstrumentationLabelSelector: util.DefaultAutoInstrumentationLabelSelector,
		LogCollectionEnabled:         true,
		PreviousLogCollectionEnabled: true,
	}
)
View Source 
var (
	OperatorConfigurationResourceDefaultObjectMeta = metav1.ObjectMeta{
		Name: OperatorConfigurationResourceName,
	}

	OperatorConfigurationResourceWithoutExport = dash0v1alpha1.Dash0OperatorConfigurationSpec{
		SelfMonitoring: dash0v1alpha1.SelfMonitoring{
			Enabled: new(false),
		},
	}

	OperatorConfigurationResourceDash0ExportWithoutApiEndpointWithToken = dash0v1alpha1.Dash0OperatorConfigurationSpec{
		SelfMonitoring: dash0v1alpha1.SelfMonitoring{
			Enabled: new(false),
		},
		Exports: []dash0common.Export{
			{
				Dash0: &dash0common.Dash0Configuration{
					Endpoint: EndpointDash0Test,
					Authorization: dash0common.Authorization{
						Token: &AuthorizationTokenTest,
					},
				},
			},
		},
		KubernetesInfrastructureMetricsCollection: dash0v1alpha1.KubernetesInfrastructureMetricsCollection{
			Enabled: new(true),
		},
		CollectPodLabelsAndAnnotations: dash0v1alpha1.CollectPodLabelsAndAnnotations{
			Enabled: new(true),
		},
		CollectNamespaceLabelsAndAnnotations: dash0v1alpha1.CollectNamespaceLabelsAndAnnotations{
			Enabled: new(true),
		},
	}

	OperatorConfigurationResourceDash0ExportWithoutApiEndpointWithSecretRef = dash0v1alpha1.Dash0OperatorConfigurationSpec{
		SelfMonitoring: dash0v1alpha1.SelfMonitoring{
			Enabled: new(false),
		},
		Exports: []dash0common.Export{
			{
				Dash0: &dash0common.Dash0Configuration{
					Endpoint: EndpointDash0Test,
					Authorization: dash0common.Authorization{
						SecretRef: &SecretRefTest,
					},
				},
			},
		},
		KubernetesInfrastructureMetricsCollection: dash0v1alpha1.KubernetesInfrastructureMetricsCollection{
			Enabled: new(true),
		},
		CollectPodLabelsAndAnnotations: dash0v1alpha1.CollectPodLabelsAndAnnotations{
			Enabled: new(true),
		},
		CollectNamespaceLabelsAndAnnotations: dash0v1alpha1.CollectNamespaceLabelsAndAnnotations{
			Enabled: new(true),
		},
	}

	OperatorConfigurationResourceDash0ExportWithApiEndpointWithToken = dash0v1alpha1.Dash0OperatorConfigurationSpec{
		SelfMonitoring: dash0v1alpha1.SelfMonitoring{
			Enabled: new(false),
		},
		Exports: []dash0common.Export{
			{
				Dash0: &dash0common.Dash0Configuration{
					Endpoint:    EndpointDash0Test,
					ApiEndpoint: ApiEndpointTest,
					Authorization: dash0common.Authorization{
						Token: &AuthorizationTokenTest,
					},
				},
			},
		},
		KubernetesInfrastructureMetricsCollection: dash0v1alpha1.KubernetesInfrastructureMetricsCollection{
			Enabled: new(true),
		},
		CollectPodLabelsAndAnnotations: dash0v1alpha1.CollectPodLabelsAndAnnotations{
			Enabled: new(true),
		},
		CollectNamespaceLabelsAndAnnotations: dash0v1alpha1.CollectNamespaceLabelsAndAnnotations{
			Enabled: new(true),
		},
	}

	OperatorConfigurationResourceDash0ExportWithApiEndpointWithSecretRef = dash0v1alpha1.Dash0OperatorConfigurationSpec{
		SelfMonitoring: dash0v1alpha1.SelfMonitoring{
			Enabled: new(false),
		},
		Exports: []dash0common.Export{
			{
				Dash0: &dash0common.Dash0Configuration{
					Endpoint:    EndpointDash0Test,
					ApiEndpoint: ApiEndpointTest,
					Authorization: dash0common.Authorization{
						SecretRef: &SecretRefTest,
					},
				},
			},
		},
		KubernetesInfrastructureMetricsCollection: dash0v1alpha1.KubernetesInfrastructureMetricsCollection{
			Enabled: new(true),
		},
		CollectPodLabelsAndAnnotations: dash0v1alpha1.CollectPodLabelsAndAnnotations{
			Enabled: new(true),
		},
		CollectNamespaceLabelsAndAnnotations: dash0v1alpha1.CollectNamespaceLabelsAndAnnotations{
			Enabled: new(true),
		},
	}

	OperatorConfigurationResourceWithoutSelfMonitoringWithToken = dash0v1alpha1.Dash0OperatorConfigurationSpec{
		SelfMonitoring: dash0v1alpha1.SelfMonitoring{
			Enabled: new(false),
		},
		Exports: []dash0common.Export{
			{
				Dash0: &dash0common.Dash0Configuration{
					Endpoint:    EndpointDash0Test,
					ApiEndpoint: ApiEndpointTest,
					Authorization: dash0common.Authorization{
						Token: &AuthorizationTokenTest,
					},
				},
			},
		},
		KubernetesInfrastructureMetricsCollection: dash0v1alpha1.KubernetesInfrastructureMetricsCollection{
			Enabled: new(true),
		},
		CollectPodLabelsAndAnnotations: dash0v1alpha1.CollectPodLabelsAndAnnotations{
			Enabled: new(true),
		},
		CollectNamespaceLabelsAndAnnotations: dash0v1alpha1.CollectNamespaceLabelsAndAnnotations{
			Enabled: new(true),
		},
	}

	OperatorConfigurationResourceWithSelfMonitoringWithToken = dash0v1alpha1.Dash0OperatorConfigurationSpec{
		SelfMonitoring: dash0v1alpha1.SelfMonitoring{
			Enabled: new(true),
		},
		Exports: []dash0common.Export{
			{
				Dash0: &dash0common.Dash0Configuration{
					Endpoint: EndpointDash0Test,
					Authorization: dash0common.Authorization{
						Token: &AuthorizationTokenTest,
					},
				},
			},
		},
		KubernetesInfrastructureMetricsCollection: dash0v1alpha1.KubernetesInfrastructureMetricsCollection{
			Enabled: new(true),
		},
		CollectPodLabelsAndAnnotations: dash0v1alpha1.CollectPodLabelsAndAnnotations{
			Enabled: new(true),
		},
		CollectNamespaceLabelsAndAnnotations: dash0v1alpha1.CollectNamespaceLabelsAndAnnotations{
			Enabled: new(true),
		},
	}

	OperatorConfigurationResourceDefaultSpec = OperatorConfigurationResourceWithSelfMonitoringWithToken
)
View Source 
var (
	PersesDashboardCrdQualifiedName = types.NamespacedName{
		Name: "persesdashboards.perses.dev",
	}

	PrometheusRuleCrdQualifiedName = types.NamespacedName{
		Name: "prometheusrules.monitoring.coreos.com",
	}
)
View Source 
var (
	ExpectManagedFields = VerifyOpts{
		VerifyManagedFields: true,
		ExpectManagedFields: true,
	}
	IgnoreManagedFields = VerifyOpts{
		VerifyManagedFields: false,
	}
	VerifyNoManagedFields = VerifyOpts{
		VerifyManagedFields: true,
		ExpectManagedFields: false,
	}
)

Functions

func AddAnnotation 

func AddAnnotation(meta *metav1.ObjectMeta, key string, value string)

func AddLabel 

func AddLabel(meta *metav1.ObjectMeta, key string, value string)

func AddManagedFields 

func AddManagedFields(meta *metav1.ObjectMeta)

func AddOptOutLabel 

func AddOptOutLabel(meta *metav1.ObjectMeta)

func BasicCronJob 

func BasicCronJob(namespace string, name string) *batchv1.CronJob

func BasicDaemonSet 

func BasicDaemonSet(namespace string, name string) *appsv1.DaemonSet

func BasicDeployment 

func BasicDeployment(namespace string, name string) *appsv1.Deployment

func BasicJob 

func BasicJob(namespace string, name string) *batchv1.Job

func BasicPod 

func BasicPod(namespace string, name string) *corev1.Pod

func BasicReplicaSet 

func BasicReplicaSet(namespace string, name string) *appsv1.ReplicaSet

func BasicStatefulSet 

func BasicStatefulSet(namespace string, name string) *appsv1.StatefulSet

func CreateBasicCronJob 

func CreateBasicCronJob(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.CronJob

func CreateBasicDaemonSet 

func CreateBasicDaemonSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.DaemonSet

func CreateBasicDeployment 

func CreateBasicDeployment(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.Deployment

func CreateBasicJob 

func CreateBasicJob(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.Job

func CreateBasicPod 

func CreateBasicPod(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *corev1.Pod

func CreateBasicReplicaSet 

func CreateBasicReplicaSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.ReplicaSet

func CreateBasicStatefulSet 

func CreateBasicStatefulSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.StatefulSet

func CreateCronJobWithOptOutLabel 

func CreateCronJobWithOptOutLabel(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.CronJob

func CreateDaemonSetWithOptOutLabel 

func CreateDaemonSetWithOptOutLabel(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.DaemonSet

func CreateDefaultMonitoringResource 

func CreateDefaultMonitoringResource(
	ctx context.Context,
	k8sClient client.Client,
	monitoringResourceName types.NamespacedName,
) *dash0v1beta1.Dash0Monitoring

func CreateDefaultOperatorConfigurationResource 

func CreateDefaultOperatorConfigurationResource(
	ctx context.Context,
	k8sClient client.Client,
) *dash0v1alpha1.Dash0OperatorConfiguration

func CreateDeploymentWithOptOutLabel 

func CreateDeploymentWithOptOutLabel(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.Deployment

func CreateInstrumentedCronJob 

func CreateInstrumentedCronJob(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.CronJob

func CreateInstrumentedDaemonSet 

func CreateInstrumentedDaemonSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.DaemonSet

func CreateInstrumentedDeployment 

func CreateInstrumentedDeployment(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.Deployment

func CreateInstrumentedJob 

func CreateInstrumentedJob(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.Job

func CreateInstrumentedPod 

func CreateInstrumentedPod(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *corev1.Pod

func CreateInstrumentedReplicaSet 

func CreateInstrumentedReplicaSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.ReplicaSet

func CreateInstrumentedStatefulSet 

func CreateInstrumentedStatefulSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.StatefulSet

func CreateJobForWhichAnInstrumentationAttemptHasFailed 

func CreateJobForWhichAnInstrumentationAttemptHasFailed(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.Job

func CreateJobWithOptOutLabel 

func CreateJobWithOptOutLabel(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.Job

func CreateMonitoringResource 

func CreateMonitoringResource(
	ctx context.Context,
	k8sClient client.Client,
	monitoringResource *dash0v1beta1.Dash0Monitoring,
) *dash0v1beta1.Dash0Monitoring

func CreateMonitoringResourceWithPotentialError 

func CreateMonitoringResourceWithPotentialError(
	ctx context.Context,
	k8sClient client.Client,
	monitoringResource *dash0v1beta1.Dash0Monitoring,
) (*dash0v1beta1.Dash0Monitoring, error)

func CreateOperatorConfigurationAutoResource 

func CreateOperatorConfigurationAutoResource(
	ctx context.Context,
	k8sClient client.Client,
) *dash0v1alpha1.Dash0OperatorConfiguration

func CreateOperatorConfigurationResource 

func CreateOperatorConfigurationResource(
	ctx context.Context,
	k8sClient client.Client,
	operatorConfigurationResource *dash0v1alpha1.Dash0OperatorConfiguration,
) (*dash0v1alpha1.Dash0OperatorConfiguration, error)

func CreateOperatorConfigurationResourceWithName 

func CreateOperatorConfigurationResourceWithName(
	ctx context.Context,
	k8sClient client.Client,
	resourceName string,
	operatorConfigurationSpec dash0v1alpha1.Dash0OperatorConfigurationSpec,
) *dash0v1alpha1.Dash0OperatorConfiguration

func CreateOperatorConfigurationResourceWithSpec 

func CreateOperatorConfigurationResourceWithSpec(
	ctx context.Context,
	k8sClient client.Client,
	operatorConfigurationSpec dash0v1alpha1.Dash0OperatorConfigurationSpec,
) *dash0v1alpha1.Dash0OperatorConfiguration

func CreatePodOwnedByReplicaSet 

func CreatePodOwnedByReplicaSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *corev1.Pod

func CreatePodWithOptOutLabel 

func CreatePodWithOptOutLabel(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *corev1.Pod

func CreateReplicaSetOwnedByDeployment 

func CreateReplicaSetOwnedByDeployment(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.ReplicaSet

func CreateReplicaSetWithOptOutLabel 

func CreateReplicaSetWithOptOutLabel(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.ReplicaSet

func CreateStatefulSetWithOptOutLabel 

func CreateStatefulSetWithOptOutLabel(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.StatefulSet

func CreateWorkload 

func CreateWorkload(ctx context.Context, k8sClient client.Client, workload client.Object) client.Object

func CronJobWithOptOutLabel 

func CronJobWithOptOutLabel(namespace string, name string) *batchv1.CronJob

func DaemonSetWithOptOutLabel 

func DaemonSetWithOptOutLabel(namespace string, name string) *appsv1.DaemonSet

func Dash0ExportWithEndpointAndSecretRef 

func Dash0ExportWithEndpointAndSecretRef() *dash0common.Export

func Dash0ExportWithEndpointAndToken 

func Dash0ExportWithEndpointAndToken() *dash0common.Export

func Dash0ExportWithEndpointTokenAndCustomDataset 

func Dash0ExportWithEndpointTokenAndCustomDataset() *dash0common.Export

func Dash0ExportWithEndpointTokenAndCustomDatasetAndApiEndpoint 

func Dash0ExportWithEndpointTokenAndCustomDatasetAndApiEndpoint() *dash0common.Export

func Dash0ExportsWithEndpointAndTokenSingle 

func Dash0ExportsWithEndpointAndTokenSingle() []dash0common.Export

func DefaultMonitoringResource 

func DefaultMonitoringResource() *dash0v1beta1.Dash0Monitoring

func DefaultMonitoringResourceWithCustomApiConfigAndToken 

func DefaultMonitoringResourceWithCustomApiConfigAndToken(
	monitoringResourceName types.NamespacedName,
	endpoint string,
	dataset string,
	token string,
) *dash0v1beta1.Dash0Monitoring

func DefaultMonitoringResourceWithName 

func DefaultMonitoringResourceWithName(monitoringResourceName types.NamespacedName) *dash0v1beta1.Dash0Monitoring

func DefaultOperatorConfigurationResource 

func DefaultOperatorConfigurationResource() *dash0v1alpha1.Dash0OperatorConfiguration

func DefaultSecret 

func DefaultSecret() *corev1.Secret

func DeleteAllCreatedObjects 

func DeleteAllCreatedObjects(
	ctx context.Context,
	k8sClient client.Client,
	createdObjects []client.Object,
) []client.Object

func DeleteAllEvents 

func DeleteAllEvents(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
)

func DeleteAllOperatorConfigurationResources 

func DeleteAllOperatorConfigurationResources(
	ctx context.Context,
	k8sClient client.Client,
)

func DeleteMonitoringResource 

func DeleteMonitoringResource(ctx context.Context, k8sClient client.Client)

func DeleteMonitoringResourceByName 

func DeleteMonitoringResourceByName(
	ctx context.Context,
	k8sClient client.Client,
	monitoringResourceName types.NamespacedName,
	failOnErr bool,
)

func DeleteMonitoringResourceIfItExists 

func DeleteMonitoringResourceIfItExists(ctx context.Context, k8sClient client.Client)

func DeploymentWithExistingDash0Artifacts 

func DeploymentWithExistingDash0Artifacts(namespace string, name string) *appsv1.Deployment

func DeploymentWithMoreBellsAndWhistles 

func DeploymentWithMoreBellsAndWhistles(namespace string, name string) *appsv1.Deployment

func DeploymentWithOptOutLabel 

func DeploymentWithOptOutLabel(namespace string, name string) *appsv1.Deployment

func EnsureKubernetesObjectExists 

func EnsureKubernetesObjectExists(
	ctx context.Context,
	k8sClient client.Client,
	qualifiedName types.NamespacedName,
	receiver client.Object,
	blueprint client.Object,
) client.Object

func EnsureMonitoringResourceExists 

func EnsureMonitoringResourceExists(
	ctx context.Context,
	k8sClient client.Client,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceExistsAndIsAvailable 

func EnsureMonitoringResourceExistsAndIsAvailable(
	ctx context.Context,
	k8sClient client.Client,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceExistsAndIsDegraded 

func EnsureMonitoringResourceExistsAndIsDegraded(
	ctx context.Context,
	k8sClient client.Client,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceExistsInNamespaceAndIsAvailable 

func EnsureMonitoringResourceExistsInNamespaceAndIsAvailable(
	ctx context.Context,
	k8sClient client.Client,
	namespacesName types.NamespacedName,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceExistsWithInstrumentWorkloadsMode 

func EnsureMonitoringResourceExistsWithInstrumentWorkloadsMode(
	ctx context.Context,
	k8sClient client.Client,
	instrumentWorkloadsMode dash0common.InstrumentWorkloadsMode,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceWithSpecExistsAndIsAvailable 

func EnsureMonitoringResourceWithSpecExistsAndIsAvailable(
	ctx context.Context,
	k8sClient client.Client,
	spec dash0v1beta1.Dash0MonitoringSpec,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceWithSpecExistsInNamespace 

func EnsureMonitoringResourceWithSpecExistsInNamespace(
	ctx context.Context,
	k8sClient client.Client,
	spec dash0v1beta1.Dash0MonitoringSpec,
	namespacedName types.NamespacedName,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceWithSpecExistsInNamespaceAndIsAvailable 

func EnsureMonitoringResourceWithSpecExistsInNamespaceAndIsAvailable(
	ctx context.Context,
	k8sClient client.Client,
	spec dash0v1beta1.Dash0MonitoringSpec,
	namespacesName types.NamespacedName,
) *dash0v1beta1.Dash0Monitoring

func EnsureMonitoringResourceWithoutExportExistsAndIsAvailable 

func EnsureMonitoringResourceWithoutExportExistsAndIsAvailable(
	ctx context.Context,
	k8sClient client.Client,
) *dash0v1beta1.Dash0Monitoring

func EnsureNamespaceExists 

func EnsureNamespaceExists(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
) *corev1.Namespace

func EnsureOperatorNamespaceExists 

func EnsureOperatorNamespaceExists(ctx context.Context, k8sClient client.Client) *corev1.Namespace

func EnsurePersesDashboardCrdExists 

func EnsurePersesDashboardCrdExists(
	ctx context.Context,
	k8sClient client.Client,
) *apiextensionsv1.CustomResourceDefinition

func EnsurePrometheusRuleCrdExists 

func EnsurePrometheusRuleCrdExists(
	ctx context.Context,
	k8sClient client.Client,
) *apiextensionsv1.CustomResourceDefinition

func EnsureTestNamespaceExists 

func EnsureTestNamespaceExists(ctx context.Context, k8sClient client.Client) *corev1.Namespace

func FindContainerByName 

func FindContainerByName(containers []corev1.Container, name string) *corev1.Container

func FindEnvVarByName 

func FindEnvVarByName(envVars []corev1.EnvVar, name string) *corev1.EnvVar

func FindVolumeByName 

func FindVolumeByName(volumes []corev1.Volume, name string) *corev1.Volume

func FindVolumeMountByName 

func FindVolumeMountByName(volumeMounts []corev1.VolumeMount, name string) *corev1.VolumeMount

func GetCronJob 

func GetCronJob(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.CronJob

func GetDaemonSet 

func GetDaemonSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.DaemonSet

func GetDeployment 

func GetDeployment(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.Deployment

func GetDeploymentEventually 

func GetDeploymentEventually(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	namespace string,
	name string,
) *appsv1.Deployment

func GetJob 

func GetJob(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *batchv1.Job

func GetOTelColDaemonSet 

func GetOTelColDaemonSet(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
) *appsv1.DaemonSet

func GetOTelColDaemonSetConfigMap 

func GetOTelColDaemonSetConfigMap(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
) *corev1.ConfigMap

func GetOTelColDeployment 

func GetOTelColDeployment(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
) *appsv1.Deployment

func GetOTelColDeploymentConfigMap 

func GetOTelColDeploymentConfigMap(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
) *corev1.ConfigMap

func GetPod 

func GetPod(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *corev1.Pod

func GetReplicaSet 

func GetReplicaSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.ReplicaSet

func GetStatefulSet 

func GetStatefulSet(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	name string,
) *appsv1.StatefulSet

func GrpcExportTest 

func GrpcExportTest() *dash0common.Export

func HttpExportTest 

func HttpExportTest() *dash0common.Export

func InstrumentedCronJob 

func InstrumentedCronJob(namespace string, name string) *batchv1.CronJob

func InstrumentedDaemonSet 

func InstrumentedDaemonSet(namespace string, name string) *appsv1.DaemonSet

func InstrumentedDeployment 

func InstrumentedDeployment(namespace string, name string) *appsv1.Deployment

func InstrumentedDeploymentWithMoreBellsAndWhistles 

func InstrumentedDeploymentWithMoreBellsAndWhistles(namespace string, name string) *appsv1.Deployment

func InstrumentedJob 

func InstrumentedJob(namespace string, name string) *batchv1.Job

func InstrumentedPod 

func InstrumentedPod(namespace string, name string) *corev1.Pod

func InstrumentedReplicaSet 

func InstrumentedReplicaSet(namespace string, name string) *appsv1.ReplicaSet

func InstrumentedReplicaSetOwnedByDeployment 

func InstrumentedReplicaSetOwnedByDeployment(namespace string, name string) *appsv1.ReplicaSet

func InstrumentedStatefulSet 

func InstrumentedStatefulSet(namespace string, name string) *appsv1.StatefulSet

func JobForWhichAnInstrumentationAttemptHasFailed 

func JobForWhichAnInstrumentationAttemptHasFailed(namespace string, name string) *batchv1.Job

func JobWithOptOutLabel 

func JobWithOptOutLabel(namespace string, name string) *batchv1.Job

func LoadMonitoringResourceByName 

func LoadMonitoringResourceByName(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	monitoringResourceName types.NamespacedName,
	failTestsOnNonExists bool,
) *dash0v1beta1.Dash0Monitoring

func LoadMonitoringResourceByNameIfItExists 

func LoadMonitoringResourceByNameIfItExists(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	monitoringResourceName types.NamespacedName,
) *dash0v1beta1.Dash0Monitoring

func LoadMonitoringResourceByNameOrFail 

func LoadMonitoringResourceByNameOrFail(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	monitoringResourceName types.NamespacedName,
) *dash0v1beta1.Dash0Monitoring

func LoadMonitoringResourceOrFail 

func LoadMonitoringResourceOrFail(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
) *dash0v1beta1.Dash0Monitoring

func LoadMonitoringResourceStatusCondition 

func LoadMonitoringResourceStatusCondition(
	ctx context.Context,
	k8sClient client.Client,
	monitoringResourceName types.NamespacedName,
	conditionType dash0common.ConditionType,
) *metav1.Condition

func LoadOperatorConfigurationResourceByName 

func LoadOperatorConfigurationResourceByName(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	name string,
	failTestsOnNonExists bool,
) *dash0v1alpha1.Dash0OperatorConfiguration

func LoadOperatorConfigurationResourceByNameIfItExists 

func LoadOperatorConfigurationResourceByNameIfItExists(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	name string,
) *dash0v1alpha1.Dash0OperatorConfiguration

func LoadOperatorConfigurationResourceByNameOrFail 

func LoadOperatorConfigurationResourceByNameOrFail(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	name string,
) *dash0v1alpha1.Dash0OperatorConfiguration

func LoadOperatorConfigurationResourceOrFail 

func LoadOperatorConfigurationResourceOrFail(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
) *dash0v1alpha1.Dash0OperatorConfiguration

func LoadOperatorConfigurationResourceStatusCondition 

func LoadOperatorConfigurationResourceStatusCondition(
	ctx context.Context,
	k8sClient client.Client,
	operatorConfigurationResourceName string,
	conditionType dash0common.ConditionType,
) *metav1.Condition

func MatchContainerPort 

func MatchContainerPort(name string, port int32) gomega.OmegaMatcher

func MatchEnvVar 

func MatchEnvVar(name string, value string, args ...any) gomega.OmegaMatcher

func MatchEvent 

func MatchEvent(
	namespace string,
	resourceName string,
	eventType string,
	reason util.Reason,
	action util.Action,
	note string,
	args ...any,
) gomega.OmegaMatcher

func MatchServicePort 

func MatchServicePort(name string, port int32, targetPort intstr.IntOrString) gomega.OmegaMatcher

func MatchVolume 

func MatchVolume(name string, args ...any) gomega.OmegaMatcher

func MatchVolumeMount 

func MatchVolumeMount(name string, mountPath string, args ...any) gomega.OmegaMatcher

func Namespace 

func Namespace(name string) *corev1.Namespace

func NoExport 

func NoExport() *dash0common.Export

func ParseConfigMapContent 

func ParseConfigMapContent(configMap *corev1.ConfigMap, dataKey string) map[string]any

func PodOwnedByReplicaSet 

func PodOwnedByReplicaSet(namespace string, name string) *corev1.Pod

func PodWithOptOutLabel 

func PodWithOptOutLabel(namespace string, name string) *corev1.Pod

func ReadFromMap 

func ReadFromMap(object any, path []string) any

func RemoveExportFromMonitoringResource 

func RemoveExportFromMonitoringResource(
	ctx context.Context,
	k8sClient client.Client,
)

func RemoveLabel 

func RemoveLabel(meta *metav1.ObjectMeta, key string)

func RemoveOperatorConfigurationResource 

func RemoveOperatorConfigurationResource(ctx context.Context, k8sClient client.Client)

func RemoveOperatorConfigurationResourceByName 

func RemoveOperatorConfigurationResourceByName(
	ctx context.Context,
	k8sClient client.Client,
	name string,
)

func RemoveOptOutLabel 

func RemoveOptOutLabel(meta *metav1.ObjectMeta)

func ReplicaSetOwnedByDeployment 

func ReplicaSetOwnedByDeployment(namespace string, name string) *appsv1.ReplicaSet

func ReplicaSetWithOptOutLabel 

func ReplicaSetWithOptOutLabel(namespace string, name string) *appsv1.ReplicaSet

func StatefulSetWithOptOutLabel 

func StatefulSetWithOptOutLabel(namespace string, name string) *appsv1.StatefulSet

func TestHTTPClient 

func TestHTTPClient() *http.Client

TestHTTPClient returns an *http.Client with the dash0-api-client-go transport configured for fast retries, suitable for unit tests. Retry delays are set to milliseconds to avoid slowing down the test suite. The base transport is a proxy to http.DefaultTransport so that gock interception works.

func UniqueName 

func UniqueName(prefix string) string

func UpdateExportInMonitoringResource 

func UpdateExportInMonitoringResource(
	ctx context.Context,
	k8sClient client.Client,
	export *dash0common.Export,
)

func UpdateInstrumentWorkloadsLabelSelector 

func UpdateInstrumentWorkloadsLabelSelector(
	ctx context.Context,
	k8sClient client.Client,
	autoInstrumentationLabelSelector string,
)

func UpdateInstrumentWorkloadsMode 

func UpdateInstrumentWorkloadsMode(
	ctx context.Context,
	k8sClient client.Client,
	instrumentWorkloads dash0common.InstrumentWorkloadsMode,
)

func UpdateInstrumentWorkloadsTraceContextPropagators 

func UpdateInstrumentWorkloadsTraceContextPropagators(
	ctx context.Context,
	k8sClient client.Client,
	traceContextPropagators *string,
)

func UpdateLabel 

func UpdateLabel(meta *metav1.ObjectMeta, key string, value string)

func UpdateLogCollectionEnabled 

func UpdateLogCollectionEnabled(
	ctx context.Context,
	k8sClient client.Client,
	enabled *bool,
)

func UpdateWorkload 

func UpdateWorkload(ctx context.Context, k8sClient client.Client, workload client.Object) client.Object

func VerifyAllResourcesExist 

func VerifyAllResourcesExist(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
)

func VerifyCollectorDaemonSet 

func VerifyCollectorDaemonSet(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
	authorizationEnvVar string,
	authorizationToken string,

) *appsv1.DaemonSet

func VerifyCollectorDeployment 

func VerifyCollectorDeployment(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
)

func VerifyCollectorResources 

func VerifyCollectorResources(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
	dash0Endpoint string,
	authorizationEnvVar string,
	authorizationToken string,
)

func VerifyCollectorResourcesDoNotExist 

func VerifyCollectorResourcesDoNotExist(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
)

func VerifyCronJobWithOptOutLabel 

func VerifyCronJobWithOptOutLabel(resource *batchv1.CronJob)

func VerifyDaemonSetCollectorConfigMap 

func VerifyDaemonSetCollectorConfigMap(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
	dash0Endpoint string,
	authorizationEnvVar string,
)

func VerifyDaemonSetWithOptOutLabel 

func VerifyDaemonSetWithOptOutLabel(resource *appsv1.DaemonSet)

func VerifyDeploymentCollectorConfigMap 

func VerifyDeploymentCollectorConfigMap(
	ctx context.Context,
	k8sClient client.Client,
	operatorNamespace string,
	authorizationEnvVar string,
)

func VerifyDeploymentWithOptOutLabel 

func VerifyDeploymentWithOptOutLabel(resource *appsv1.Deployment)

func VerifyEnvVar 

func VerifyEnvVar(expectation EnvVarExpectation, actualEnvVars []corev1.EnvVar, name string, containerName string)

func VerifyEnvVarOrUnset 

func VerifyEnvVarOrUnset(
	expectation *EnvVarExpectation,
	actualEnvVars []corev1.EnvVar,
	name string,
	containerName string,
)

func VerifyEnvVarsFromMap 

func VerifyEnvVarsFromMap(
	expectedEnvVars map[string]*EnvVarExpectation,
	actualEnvVars []corev1.EnvVar,
)

func VerifyEvent 

func VerifyEvent(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
	resourceName string,
	eventType string,
	reason util.Reason,
	action util.Action,
	note string,
) *eventsv1.Event

func VerifyExpectedResourceDoesNotExist 

func VerifyExpectedResourceDoesNotExist(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	expectedResource expectedResource,
)

func VerifyExpectedResourceExists 

func VerifyExpectedResourceExists(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	expectedResource expectedResource,
) client.Object

func VerifyFailedInstrumentationEvent 

func VerifyFailedInstrumentationEvent(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
	resourceName string,
	message string,
) *eventsv1.Event

func VerifyFailedUninstrumentationEvent 

func VerifyFailedUninstrumentationEvent(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
	resourceName string,
	message string,
) *eventsv1.Event

func VerifyImmutableJobCouldNotBeModified 

func VerifyImmutableJobCouldNotBeModified(resource *batchv1.Job)

func VerifyInstrumentationViaHigherOrderWorkloadEvent 

func VerifyInstrumentationViaHigherOrderWorkloadEvent(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
	resourceName string,
	eventSource string,
) *eventsv1.Event

func VerifyJobWithOptOutLabel 

func VerifyJobWithOptOutLabel(resource *batchv1.Job)

func VerifyModifiedCronJob 

func VerifyModifiedCronJob(resource *batchv1.CronJob, expectations PodSpecExpectations, opts ...VerifyOpts)

func VerifyModifiedDaemonSet 

func VerifyModifiedDaemonSet(resource *appsv1.DaemonSet, expectations PodSpecExpectations, opts ...VerifyOpts)

func VerifyModifiedDeployment 

func VerifyModifiedDeployment(resource *appsv1.Deployment, expectations PodSpecExpectations, opts ...VerifyOpts)

func VerifyModifiedJob 

func VerifyModifiedJob(resource *batchv1.Job, expectations PodSpecExpectations, opts ...VerifyOpts)

func VerifyModifiedJobAfterUnsuccessfulOptOut 

func VerifyModifiedJobAfterUnsuccessfulOptOut(resource *batchv1.Job)

func VerifyModifiedPod 

func VerifyModifiedPod(resource *corev1.Pod, expectations PodSpecExpectations, opts ...VerifyOpts)

func VerifyModifiedReplicaSet 

func VerifyModifiedReplicaSet(resource *appsv1.ReplicaSet, expectations PodSpecExpectations, opts ...VerifyOpts)

func VerifyModifiedStatefulSet 

func VerifyModifiedStatefulSet(resource *appsv1.StatefulSet, expectations PodSpecExpectations, opts ...VerifyOpts)

func VerifyMonitoringResourceByNameDoesNotExist 

func VerifyMonitoringResourceByNameDoesNotExist(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	MonitoringResourceName types.NamespacedName,
)

func VerifyMonitoringResourceDoesNotExist 

func VerifyMonitoringResourceDoesNotExist(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
)

func VerifyNoEvents 

func VerifyNoEvents(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
)

func VerifyNoUnmatchedGockRequests 

func VerifyNoUnmatchedGockRequests()

VerifyNoUnmatchedGockRequests makes sure that gock did not silently swallow any unmatched requests during a test. Such requests indicate missing or wrong mocks and previously caused tests to be flaky, when leftover processing and/or HTTP retries wrote bogus status while the next test had already started.

func VerifyOperatorConfigurationResourceByNameDoesNotExist 

func VerifyOperatorConfigurationResourceByNameDoesNotExist(
	ctx context.Context,
	k8sClient client.Client,
	g Gomega,
	name string,
)

func VerifyPodWithOptOutLabel 

func VerifyPodWithOptOutLabel(resource *corev1.Pod)

func VerifyReplicaSetWithOptOutLabel 

func VerifyReplicaSetWithOptOutLabel(resource *appsv1.ReplicaSet)

func VerifyResourceDoesNotExist 

func VerifyResourceDoesNotExist(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	expectedName string,
	receiver client.Object,
)

func VerifyResourceExists 

func VerifyResourceExists(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	expectedName string,
	receiver client.Object,
) client.Object

func VerifyResourceStatusCondition 

func VerifyResourceStatusCondition(
	g Gomega,
	condition *metav1.Condition,
	expectedStatus metav1.ConditionStatus,
	expectedReason string,
	expectedMessage string,
)

func VerifyRevertedDeployment 

func VerifyRevertedDeployment(resource *appsv1.Deployment, expectations PodSpecExpectations)

func VerifyStatefulSetWithOptOutLabel 

func VerifyStatefulSetWithOptOutLabel(resource *appsv1.StatefulSet)

func VerifySuccessfulInstrumentationEvent 

func VerifySuccessfulInstrumentationEvent(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
	resourceName string,
	eventSource string,
) *eventsv1.Event

func VerifySuccessfulUninstrumentationEvent 

func VerifySuccessfulUninstrumentationEvent(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	namespace string,
	resourceName string,
	eventSource string,
) *eventsv1.Event

func VerifySuccessfulUninstrumentationEventEventually 

func VerifySuccessfulUninstrumentationEventEventually(
	ctx context.Context,
	clientset *kubernetes.Clientset,
	g Gomega,
	namespace string,
	resourceName string,
	eventSource string,
) *eventsv1.Event

func VerifyUnmodifiedCronJob 

func VerifyUnmodifiedCronJob(resource *batchv1.CronJob)

func VerifyUnmodifiedDaemonSet 

func VerifyUnmodifiedDaemonSet(resource *appsv1.DaemonSet)

func VerifyUnmodifiedDeployment 

func VerifyUnmodifiedDeployment(resource *appsv1.Deployment)

func VerifyUnmodifiedDeploymentEventually 

func VerifyUnmodifiedDeploymentEventually(g Gomega, resource *appsv1.Deployment)

func VerifyUnmodifiedJob 

func VerifyUnmodifiedJob(resource *batchv1.Job)

func VerifyUnmodifiedPod 

func VerifyUnmodifiedPod(resource *corev1.Pod)

func VerifyUnmodifiedReplicaSet 

func VerifyUnmodifiedReplicaSet(resource *appsv1.ReplicaSet)

func VerifyUnmodifiedStatefulSet 

func VerifyUnmodifiedStatefulSet(resource *appsv1.StatefulSet)

func VerifyWebhookIgnoreOnceLabelIsAbsent 

func VerifyWebhookIgnoreOnceLabelIsAbsent(objectMeta *metav1.ObjectMeta)

func VerifyWebhookIgnoreOnceLabelIsPresent 

func VerifyWebhookIgnoreOnceLabelIsPresent(objectMeta *metav1.ObjectMeta)

func VerifyWebhookIgnoreOnceLabelIsPresentEventually 

func VerifyWebhookIgnoreOnceLabelIsPresentEventually(g Gomega, objectMeta *metav1.ObjectMeta)

func WebhookService 

func WebhookService() corev1.Service

func WebhookServiceEndpointSlice 

func WebhookServiceEndpointSlice(withPort bool, withReadyCondition bool) discoveryv1.EndpointSlice

func WrapConfigureCronJobFnAsTestableWorkload 

func WrapConfigureCronJobFnAsTestableWorkload(
	fn func(string, string) *batchv1.CronJob,
) func(string, string) TestableWorkload

func WrapConfigureDaemonSetFnAsTestableWorkload 

func WrapConfigureDaemonSetFnAsTestableWorkload(
	fn func(string, string) *appsv1.DaemonSet,
) func(string, string) TestableWorkload

func WrapConfigureDeploymentFnAsTestableWorkload 

func WrapConfigureDeploymentFnAsTestableWorkload(
	fn func(string, string) *appsv1.Deployment,
) func(string, string) TestableWorkload

func WrapConfigureJobFnAsTestableWorkload 

func WrapConfigureJobFnAsTestableWorkload(
	fn func(string, string) *batchv1.Job,
) func(string, string) TestableWorkload

func WrapConfigurePodFnAsTestableWorkload 

func WrapConfigurePodFnAsTestableWorkload(
	fn func(string, string) *corev1.Pod,
) func(string, string) TestableWorkload

func WrapConfigureReplicaSetFnAsTestableWorkload 

func WrapConfigureReplicaSetFnAsTestableWorkload(
	fn func(string, string) *appsv1.ReplicaSet,
) func(string, string) TestableWorkload

func WrapConfigureStatefulSetFnAsTestableWorkload 

func WrapConfigureStatefulSetFnAsTestableWorkload(
	fn func(string, string) *appsv1.StatefulSet,
) func(string, string) TestableWorkload

func WrapCronJobFnAsTestableWorkload 

func WrapCronJobFnAsTestableWorkload(
	fn func(context.Context, client.Client, string, string) *batchv1.CronJob,
) func(context.Context, client.Client, string, string) TestableWorkload

func WrapDaemonSetFnAsTestableWorkload 

func WrapDaemonSetFnAsTestableWorkload(
	fn func(context.Context, client.Client, string, string) *appsv1.DaemonSet,
) func(context.Context, client.Client, string, string) TestableWorkload

func WrapDeploymentFnAsTestableWorkload 

func WrapDeploymentFnAsTestableWorkload(
	fn func(context.Context, client.Client, string, string) *appsv1.Deployment,
) func(context.Context, client.Client, string, string) TestableWorkload

func WrapJobFnAsTestableWorkload 

func WrapJobFnAsTestableWorkload(
	fn func(context.Context, client.Client, string, string) *batchv1.Job,
) func(context.Context, client.Client, string, string) TestableWorkload

func WrapPodFnAsTestableWorkload 

func WrapPodFnAsTestableWorkload(
	fn func(context.Context, client.Client, string, string) *corev1.Pod,
) func(context.Context, client.Client, string, string) TestableWorkload

func WrapReplicaSetFnAsTestableWorkload 

func WrapReplicaSetFnAsTestableWorkload(
	fn func(context.Context, client.Client, string, string) *appsv1.ReplicaSet,
) func(context.Context, client.Client, string, string) TestableWorkload

func WrapStatefulSetFnAsTestableWorkload 

func WrapStatefulSetFnAsTestableWorkload(
	fn func(context.Context, client.Client, string, string) *appsv1.StatefulSet,
) func(context.Context, client.Client, string, string) TestableWorkload

Types

type CapturingLogSink 

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

func NewCapturingLogger 

func NewCapturingLogger() (logd.Logger, *CapturingLogSink)

func (*CapturingLogSink) Enabled 

func (s *CapturingLogSink) Enabled(_ int) bool

func (*CapturingLogSink) Error 

func (s *CapturingLogSink) Error(err error, msg string, keysAndValues ...any)

func (*CapturingLogSink) HasLogMessage 

func (s *CapturingLogSink) HasLogMessage(g Gomega, message string)

func (*CapturingLogSink) HasNoLogMessages 

func (s *CapturingLogSink) HasNoLogMessages(g Gomega)

func (*CapturingLogSink) Info 

func (s *CapturingLogSink) Info(level int, msg string, keysAndValues ...any)

func (*CapturingLogSink) Init 

func (s *CapturingLogSink) Init(info logr.RuntimeInfo)

func (*CapturingLogSink) Reset 

func (s *CapturingLogSink) Reset()

func (*CapturingLogSink) WithName 

func (s *CapturingLogSink) WithName(_ string) logr.LogSink

func (*CapturingLogSink) WithValues 

func (s *CapturingLogSink) WithValues(_ ...any) logr.LogSink

type ContainerExpectations 

type ContainerExpectations struct {
	ContainerName       string
	VolumeMounts        int
	Dash0VolumeMountIdx int
	EnvVars             map[string]*EnvVarExpectation
}

type CronJobTestableWorkload 

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

func (CronJobTestableWorkload) Get 

func (w CronJobTestableWorkload) Get() client.Object

func (CronJobTestableWorkload) GetObjectMeta 

func (w CronJobTestableWorkload) GetObjectMeta() *metav1.ObjectMeta

func (CronJobTestableWorkload) GetPodSpec 

func (w CronJobTestableWorkload) GetPodSpec() *corev1.PodSpec

type DaemonSetTestableWorkload 

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

func (DaemonSetTestableWorkload) Get 

func (w DaemonSetTestableWorkload) Get() client.Object

func (DaemonSetTestableWorkload) GetObjectMeta 

func (w DaemonSetTestableWorkload) GetObjectMeta() *metav1.ObjectMeta

func (DaemonSetTestableWorkload) GetPodSpec 

func (w DaemonSetTestableWorkload) GetPodSpec() *corev1.PodSpec

type DeploymentTestableWorkload 

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

func (DeploymentTestableWorkload) Get 

func (w DeploymentTestableWorkload) Get() client.Object

func (DeploymentTestableWorkload) GetObjectMeta 

func (w DeploymentTestableWorkload) GetObjectMeta() *metav1.ObjectMeta

func (DeploymentTestableWorkload) GetPodSpec 

func (w DeploymentTestableWorkload) GetPodSpec() *corev1.PodSpec

type DummyAuthTokenClient 

type DummyAuthTokenClient struct {
	SetAuthTokenCalls    int
	RemoveAuthTokenCalls int
	AuthToken            string
}

func (*DummyAuthTokenClient) RemoveDefaultAuthToken 

func (c *DummyAuthTokenClient) RemoveDefaultAuthToken(_ context.Context, _ logd.Logger)

func (*DummyAuthTokenClient) Reset 

func (c *DummyAuthTokenClient) Reset()

func (*DummyAuthTokenClient) ResetCallCounts 

func (c *DummyAuthTokenClient) ResetCallCounts()

func (*DummyAuthTokenClient) SetDefaultAuthToken 

func (c *DummyAuthTokenClient) SetDefaultAuthToken(_ context.Context, authToken string, _ logd.Logger)

type DummyLeaderElectionAware 

type DummyLeaderElectionAware struct {
	Leader bool
}

func (*DummyLeaderElectionAware) IsLeader 

func (l *DummyLeaderElectionAware) IsLeader() bool

type DummySelfMonitoringMetricsClient 

type DummySelfMonitoringMetricsClient struct {
	InitializeSelfMonitoringMetricsCalls int
}

func (*DummySelfMonitoringMetricsClient) InitializeSelfMonitoringMetrics 

func (c *DummySelfMonitoringMetricsClient) InitializeSelfMonitoringMetrics(
	_ otelmetric.Meter,
	_ string,
	_ logd.Logger,
)

func (*DummySelfMonitoringMetricsClient) Reset 

func (c *DummySelfMonitoringMetricsClient) Reset()

func (*DummySelfMonitoringMetricsClient) ResetCallCounts 

func (c *DummySelfMonitoringMetricsClient) ResetCallCounts()

type EnvVarExpectation 

type EnvVarExpectation struct {
	Value                         string
	ValueFrom                     string
	UnorderedCommaSeparatedValues []string
}

type JobTestableWorkload 

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

func (JobTestableWorkload) Get 

func (w JobTestableWorkload) Get() client.Object

func (JobTestableWorkload) GetObjectMeta 

func (w JobTestableWorkload) GetObjectMeta() *metav1.ObjectMeta

func (JobTestableWorkload) GetPodSpec 

func (w JobTestableWorkload) GetPodSpec() *corev1.PodSpec

type LeaderElectionAwareMock 

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

func NewLeaderElectionAwareMock 

func NewLeaderElectionAwareMock(isLeader bool) *LeaderElectionAwareMock

func (*LeaderElectionAwareMock) IsLeader 

func (l *LeaderElectionAwareMock) IsLeader() bool

func (*LeaderElectionAwareMock) NeedLeaderElection 

func (l *LeaderElectionAwareMock) NeedLeaderElection() bool

func (*LeaderElectionAwareMock) SetLeader 

func (l *LeaderElectionAwareMock) SetLeader(isLeader bool)

type MatchContainerPortMatcher 

type MatchContainerPortMatcher struct {
	Name string
	Port int32
}

func (*MatchContainerPortMatcher) FailureMessage 

func (matcher *MatchContainerPortMatcher) FailureMessage(actual any) (message string)

func (*MatchContainerPortMatcher) Match 

func (matcher *MatchContainerPortMatcher) Match(actual any) (success bool, err error)

func (*MatchContainerPortMatcher) NegatedFailureMessage 

func (matcher *MatchContainerPortMatcher) NegatedFailureMessage(actual any) (message string)

type MatchEnvVarMatcher 

type MatchEnvVarMatcher struct {
	Name  string
	Value string
	Args  []any
}

func (*MatchEnvVarMatcher) FailureMessage 

func (matcher *MatchEnvVarMatcher) FailureMessage(actual any) (message string)

func (*MatchEnvVarMatcher) Match 

func (matcher *MatchEnvVarMatcher) Match(actual any) (success bool, err error)

func (*MatchEnvVarMatcher) NegatedFailureMessage 

func (matcher *MatchEnvVarMatcher) NegatedFailureMessage(actual any) (message string)

type MatchEnvVarValueFromSecretMatcher 

type MatchEnvVarValueFromSecretMatcher struct {
	Name       string
	SecretName string
	SecretKey  string
	Args       []any
}

func (*MatchEnvVarValueFromSecretMatcher) FailureMessage 

func (matcher *MatchEnvVarValueFromSecretMatcher) FailureMessage(actual any) (message string)

func (*MatchEnvVarValueFromSecretMatcher) Match 

func (matcher *MatchEnvVarValueFromSecretMatcher) Match(actual any) (success bool, err error)

func (*MatchEnvVarValueFromSecretMatcher) NegatedFailureMessage 

func (matcher *MatchEnvVarValueFromSecretMatcher) NegatedFailureMessage(actual any) (message string)

type MatchEventMatcher 

type MatchEventMatcher struct {
	Namespace    string
	ResourceName string
	EventType    string
	Reason       util.Reason
	Action       util.Action
	Note         string
	Args         []any
}

func (*MatchEventMatcher) FailureMessage 

func (matcher *MatchEventMatcher) FailureMessage(actual any) (message string)

func (*MatchEventMatcher) Match 

func (matcher *MatchEventMatcher) Match(actual any) (success bool, err error)

func (*MatchEventMatcher) NegatedFailureMessage 

func (matcher *MatchEventMatcher) NegatedFailureMessage(actual any) (message string)

type MatchServicePortMatcher 

type MatchServicePortMatcher struct {
	Name       string
	Port       int32
	TargetPort intstr.IntOrString
}

func (*MatchServicePortMatcher) FailureMessage 

func (matcher *MatchServicePortMatcher) FailureMessage(actual any) (message string)

func (*MatchServicePortMatcher) Match 

func (matcher *MatchServicePortMatcher) Match(actual any) (success bool, err error)

func (*MatchServicePortMatcher) NegatedFailureMessage 

func (matcher *MatchServicePortMatcher) NegatedFailureMessage(actual any) (message string)

type MatchVolumeMatcher 

type MatchVolumeMatcher struct {
	Name string
	Args []any
}

func (*MatchVolumeMatcher) FailureMessage 

func (matcher *MatchVolumeMatcher) FailureMessage(actual any) (message string)

func (*MatchVolumeMatcher) Match 

func (matcher *MatchVolumeMatcher) Match(actual any) (success bool, err error)

func (*MatchVolumeMatcher) NegatedFailureMessage 

func (matcher *MatchVolumeMatcher) NegatedFailureMessage(actual any) (message string)

type MatchVolumeMountMatcher 

type MatchVolumeMountMatcher struct {
	Name      string
	MountPath string
	Args      []any
}

func (*MatchVolumeMountMatcher) FailureMessage 

func (matcher *MatchVolumeMountMatcher) FailureMessage(actual any) (message string)

func (*MatchVolumeMountMatcher) Match 

func (matcher *MatchVolumeMountMatcher) Match(actual any) (success bool, err error)

func (*MatchVolumeMountMatcher) NegatedFailureMessage 

func (matcher *MatchVolumeMountMatcher) NegatedFailureMessage(actual any) (message string)

type PodSpecExpectations 

type PodSpecExpectations struct {
	Volumes               int
	Dash0VolumeIdx        int
	InitContainers        int
	Dash0InitContainerIdx int
	Containers            []ContainerExpectations
}

func BasicInstrumentedPodSpecExpectations 

func BasicInstrumentedPodSpecExpectations() PodSpecExpectations

type PodTestableWorkload 

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

func (PodTestableWorkload) Get 

func (w PodTestableWorkload) Get() client.Object

func (PodTestableWorkload) GetObjectMeta 

func (w PodTestableWorkload) GetObjectMeta() *metav1.ObjectMeta

func (PodTestableWorkload) GetPodSpec 

func (w PodTestableWorkload) GetPodSpec() *corev1.PodSpec

type ReplicaSetTestableWorkload 

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

func (ReplicaSetTestableWorkload) Get 

func (w ReplicaSetTestableWorkload) Get() client.Object

func (ReplicaSetTestableWorkload) GetObjectMeta 

func (w ReplicaSetTestableWorkload) GetObjectMeta() *metav1.ObjectMeta

func (ReplicaSetTestableWorkload) GetPodSpec 

func (w ReplicaSetTestableWorkload) GetPodSpec() *corev1.PodSpec

type StatefulSetTestableWorkload 

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

func (StatefulSetTestableWorkload) Get 

func (w StatefulSetTestableWorkload) Get() client.Object

func (StatefulSetTestableWorkload) GetObjectMeta 

func (w StatefulSetTestableWorkload) GetObjectMeta() *metav1.ObjectMeta

func (StatefulSetTestableWorkload) GetPodSpec 

func (w StatefulSetTestableWorkload) GetPodSpec() *corev1.PodSpec

type TestableWorkload 

type TestableWorkload interface {
	Get() client.Object
	GetObjectMeta() *metav1.ObjectMeta
	GetPodSpec() *corev1.PodSpec
}

type VerifyOpts 

type VerifyOpts struct {
	VerifyManagedFields bool
	ExpectManagedFields bool
}

type WorkloadTestConfig 

type WorkloadTestConfig struct {
	WorkloadNamePrefix string
	ConfigureFn        func(string, string) TestableWorkload
	CreateFn           func(context.Context, client.Client, string, string) TestableWorkload
	GetFn              func(context.Context, client.Client, string, string) TestableWorkload
	VerifyPreFn        func(TestableWorkload)
	VerifyFn           func(TestableWorkload)
}

Source Files

View all Source files

Directories

Path Synopsis

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.