@@ -1169,7 +1169,7 @@ func (r *Reconciler) reconcileInstance(
1169
1169
)
1170
1170
1171
1171
if err == nil {
1172
- instanceConfigMap , err = r .reconcileInstanceConfigMap (ctx , cluster , spec , instance , otelConfig )
1172
+ instanceConfigMap , err = r .reconcileInstanceConfigMap (ctx , cluster , spec , instance , otelConfig , backupsSpecFound )
1173
1173
}
1174
1174
if err == nil {
1175
1175
instanceCertificates , err = r .reconcileInstanceCertificates (
@@ -1410,7 +1410,7 @@ func addPGBackRestToInstancePodSpec(
1410
1410
// files (etc) that apply to instance of cluster.
1411
1411
func (r * Reconciler ) reconcileInstanceConfigMap (
1412
1412
ctx context.Context , cluster * v1beta1.PostgresCluster , spec * v1beta1.PostgresInstanceSetSpec ,
1413
- instance * appsv1.StatefulSet , otelConfig * collector.Config ,
1413
+ instance * appsv1.StatefulSet , otelConfig * collector.Config , backupsSpecFound bool ,
1414
1414
) (* corev1.ConfigMap , error ) {
1415
1415
instanceConfigMap := & corev1.ConfigMap {ObjectMeta : naming .InstanceConfigMap (instance )}
1416
1416
instanceConfigMap .SetGroupVersionKind (corev1 .SchemeGroupVersion .WithKind ("ConfigMap" ))
@@ -1437,11 +1437,9 @@ func (r *Reconciler) reconcileInstanceConfigMap(
1437
1437
err = collector .AddToConfigMap (ctx , otelConfig , instanceConfigMap )
1438
1438
1439
1439
// Add pgbackrest logrotate if OpenTelemetryLogs is enabled and
1440
- // local volumes are available
1440
+ // backups are enabled
1441
1441
if err == nil &&
1442
- feature .Enabled (ctx , feature .OpenTelemetryLogs ) &&
1443
- pgbackrest .RepoHostVolumeDefined (cluster ) &&
1444
- cluster .Spec .Instrumentation != nil {
1442
+ collector .OpenTelemetryLogsEnabled (ctx , cluster ) && backupsSpecFound {
1445
1443
1446
1444
collector .AddLogrotateConfigs (ctx , cluster .Spec .Instrumentation ,
1447
1445
instanceConfigMap ,
0 commit comments