Function TestAddToPod

internal/collector/instance_test.go:20–524

(t *testing.T)

)

func TestAddToPod(t *testing.T) {
	// setupContext creates a context with the given feature gates enabled.
	setupContext := func(logs, metrics bool) context.Context {
		gate := feature.NewGate()
		assert.NilError(t, gate.SetFromMap(map[string]bool{
			feature.OpenTelemetryLogs:    logs,
			feature.OpenTelemetryMetrics: metrics,
		}))
		return feature.NewContext(context.Background(), gate)
	}

	// newPodTemplate returns a minimal PodTemplateSpec for testing.
	newPodTemplate := func() *corev1.PodTemplateSpec {
		return &corev1.PodTemplateSpec{}
	}

	// newConfigMap returns a ConfigMap with a name, as used by callers.
	newConfigMap := func() *corev1.ConfigMap {
		cm := &corev1.ConfigMap{}
		cm.Name = "test-configmap"
		return cm
	}

	// findContainer returns the collector container from the template, if present.
	findContainer := func(template *corev1.PodTemplateSpec) *corev1.Container {
		for i := range template.Spec.Containers {
			if template.Spec.Containers[i].Name == naming.ContainerCollector {
				return &template.Spec.Containers[i]
			}
		}
		return nil
	}

	// findVolume returns the named volume from the template, if present.
	findVolume := func(template *corev1.PodTemplateSpec, name string) *corev1.Volume {
		for i := range template.Spec.Volumes {
			if template.Spec.Volumes[i].Name == name {
				return &template.Spec.Volumes[i]
			}
		}
		return nil
	}

	t.Run("NoOpWhenFeaturesDisabled", func(t *testing.T) {
		ctx := setupContext(false, false)
		spec := &v1beta1.InstrumentationSpec{}
		template := newPodTemplate()

		AddToPod(ctx, spec, corev1.PullIfNotPresent, newConfigMap(),
			template, nil, "", nil, false, false)

		assert.Assert(t, cmp.Len(template.Spec.Containers, 0),
			"expected no containers when features are disabled")
		assert.Assert(t, cmp.Len(template.Spec.Volumes, 0),
			"expected no volumes when features are disabled")
	})

	t.Run("NoOpWhenSpecIsNil", func(t *testing.T) {