Skip to content

Commit f81c24c

Browse files
committed
[chore] unexport updateCollectorStatus function
1 parent a36367b commit f81c24c

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

internal/status/collector/collector.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ import (
3030
"github.com/open-telemetry/opentelemetry-operator/internal/version"
3131
)
3232

33-
func UpdateCollectorStatus(ctx context.Context, cli client.Client, changed *v1beta1.OpenTelemetryCollector) error {
33+
func updateCollectorStatus(ctx context.Context, cli client.Client, changed *v1beta1.OpenTelemetryCollector) error {
3434
if changed.Status.Version == "" {
3535
// a version is not set, otherwise let the upgrade mechanism take care of it!
3636
changed.Status.Version = version.OpenTelemetryCollector()

internal/status/collector/collector_test.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ func TestUpdateCollectorStatusUnsupported(t *testing.T) {
4242
},
4343
}
4444

45-
err := UpdateCollectorStatus(ctx, cli, changed)
45+
err := updateCollectorStatus(ctx, cli, changed)
4646
assert.NoError(t, err)
4747

4848
assert.Equal(t, int32(0), changed.Status.Scale.Replicas, "expected replicas to be 0")
@@ -89,7 +89,7 @@ func TestUpdateCollectorStatusDeploymentMode(t *testing.T) {
8989
},
9090
}
9191

92-
err := UpdateCollectorStatus(ctx, cli, changed)
92+
err := updateCollectorStatus(ctx, cli, changed)
9393
assert.NoError(t, err)
9494

9595
assert.Equal(t, int32(1), changed.Status.Scale.Replicas, "expected replicas to be 1")
@@ -137,7 +137,7 @@ func TestUpdateCollectorStatusStatefulset(t *testing.T) {
137137
},
138138
}
139139

140-
err := UpdateCollectorStatus(ctx, cli, changed)
140+
err := updateCollectorStatus(ctx, cli, changed)
141141
assert.NoError(t, err)
142142

143143
assert.Equal(t, int32(1), changed.Status.Scale.Replicas, "expected replicas to be 1")
@@ -184,7 +184,7 @@ func TestUpdateCollectorStatusDaemonsetMode(t *testing.T) {
184184
},
185185
}
186186

187-
err := UpdateCollectorStatus(ctx, cli, changed)
187+
err := updateCollectorStatus(ctx, cli, changed)
188188
assert.NoError(t, err)
189189

190190
assert.Contains(t, changed.Status.Scale.Selector, "customLabel=customValue", "expected selector to contain customlabel=customValue")

internal/status/collector/handle.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ func HandleReconcileStatus(ctx context.Context, log logr.Logger, params manifest
5858
log.V(2).Error(upgradeErr, "failed to upgrade the OpenTelemetry CR")
5959
}
6060
changed = &upgraded
61-
statusErr := UpdateCollectorStatus(ctx, params.Client, changed)
61+
statusErr := updateCollectorStatus(ctx, params.Client, changed)
6262
if statusErr != nil {
6363
params.Recorder.Event(changed, eventTypeWarning, reasonStatusFailure, statusErr.Error())
6464
return ctrl.Result{}, statusErr

0 commit comments

Comments
 (0)