Skip to content

Commit 0a06f76

Browse files
songy23levan-m
andauthored
Set DD_OTELCOLLECTOR_ENABLED in otel-agent container (#1888)
* Set DD_OTELCOLLECTOR_ENABLED in otel-agent container * add tests --------- Co-authored-by: levan-m <[email protected]>
1 parent af267f0 commit 0a06f76

File tree

2 files changed

+17
-2
lines changed

2 files changed

+17
-2
lines changed

internal/controller/datadogagent/feature/otelcollector/feature.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -232,10 +232,10 @@ func (o *otelCollectorFeature) ManageNodeAgent(managers feature.PodTemplateManag
232232
Name: DDOtelCollectorCoreConfigEnabled,
233233
Value: apiutils.BoolToString(o.coreAgentConfig.enabled),
234234
}
235-
managers.EnvVar().AddEnvVarToContainers([]apicommon.AgentContainerName{apicommon.CoreAgentContainerName}, enableEnvVar)
235+
managers.EnvVar().AddEnvVarToContainers([]apicommon.AgentContainerName{apicommon.CoreAgentContainerName, apicommon.OtelAgent}, enableEnvVar)
236236
}
237237
} else {
238-
managers.EnvVar().AddEnvVarToContainers([]apicommon.AgentContainerName{apicommon.CoreAgentContainerName}, &corev1.EnvVar{
238+
managers.EnvVar().AddEnvVarToContainers([]apicommon.AgentContainerName{apicommon.CoreAgentContainerName, apicommon.OtelAgent}, &corev1.EnvVar{
239239
Name: DDOtelCollectorCoreConfigEnabled,
240240
Value: "true",
241241
})

internal/controller/datadogagent/feature/otelcollector/feature_test.go

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -304,26 +304,39 @@ func testExpectedAgent(agentContainerName apicommon.AgentContainerName, expected
304304

305305
// check env vars
306306
wantEnvVars := []*corev1.EnvVar{}
307+
wantEnvVarsOTel := []*corev1.EnvVar{}
307308

308309
if expectedEnvVars.agent_ipc_port.present {
309310
wantEnvVars = append(wantEnvVars, &corev1.EnvVar{
310311
Name: DDAgentIpcPort,
311312
Value: expectedEnvVars.agent_ipc_port.value,
312313
})
314+
wantEnvVarsOTel = append(wantEnvVarsOTel, &corev1.EnvVar{
315+
Name: DDAgentIpcPort,
316+
Value: expectedEnvVars.agent_ipc_port.value,
317+
})
313318
}
314319

315320
if expectedEnvVars.agent_ipc_refresh.present {
316321
wantEnvVars = append(wantEnvVars, &corev1.EnvVar{
317322
Name: DDAgentIpcConfigRefreshInterval,
318323
Value: expectedEnvVars.agent_ipc_refresh.value,
319324
})
325+
wantEnvVarsOTel = append(wantEnvVarsOTel, &corev1.EnvVar{
326+
Name: DDAgentIpcConfigRefreshInterval,
327+
Value: expectedEnvVars.agent_ipc_refresh.value,
328+
})
320329
}
321330

322331
if expectedEnvVars.enabled.present {
323332
wantEnvVars = append(wantEnvVars, &corev1.EnvVar{
324333
Name: DDOtelCollectorCoreConfigEnabled,
325334
Value: expectedEnvVars.enabled.value,
326335
})
336+
wantEnvVarsOTel = append(wantEnvVarsOTel, &corev1.EnvVar{
337+
Name: DDOtelCollectorCoreConfigEnabled,
338+
Value: expectedEnvVars.enabled.value,
339+
})
327340
}
328341

329342
if expectedEnvVars.extension_timeout.present {
@@ -345,7 +358,9 @@ func testExpectedAgent(agentContainerName apicommon.AgentContainerName, expected
345358
}
346359

347360
agentEnvVars := mgr.EnvVarMgr.EnvVarsByC[apicommon.CoreAgentContainerName]
361+
otelAgentEnvVars := mgr.EnvVarMgr.EnvVarsByC[apicommon.OtelAgent]
348362
assert.True(t, apiutils.IsEqualStruct(agentEnvVars, wantEnvVars), "Agent envvars \ndiff = %s", cmp.Diff(agentEnvVars, wantEnvVars))
363+
assert.True(t, apiutils.IsEqualStruct(otelAgentEnvVars, wantEnvVarsOTel), "OTel Agent envvars \ndiff = %s", cmp.Diff(otelAgentEnvVars, wantEnvVarsOTel))
349364

350365
// annotations
351366
agentAnnotations := mgr.AnnotationMgr.Annotations

0 commit comments

Comments
 (0)