Add optional tolerations for fluentd and fluentbit

Author: worr

pkg/apis/logging/v1alpha1/fluentbit_types.go

@@ -37,6 +37,7 @@ type FluentbitSpec struct {
 	Image       ImageSpec                   `json:"image"`
 	TLS         FluentbitTLS                `json:"tls"`
 	Resources   corev1.ResourceRequirements `json:"resources,omitempty"`
+	Tolerations []corev1.Toleration         `json:"tolerations,omitempty"`
 }
 
 // FluentbitTLS defines the TLS configs

pkg/apis/logging/v1alpha1/fluentd_types.go

@@ -41,6 +41,7 @@ type FluentdSpec struct {
 	ConfigReloaderImage ImageSpec                        `json:"configReloaderImage"`
 	Resources           corev1.ResourceRequirements      `json:"resources,omitempty"`
 	ServiceType         corev1.ServiceType               `json:"serviceType,omitempty"`
+	Tolerations         []corev1.Toleration              `json:"tolerations,omitempty"`
 }
 
 // FluentdTLS defines the TLS configs

pkg/apis/logging/v1alpha1/zz_generated.deepcopy.go

@@ -61,6 +61,7 @@ func (r *Reconciler) daemonSet() runtime.Object {
 							VolumeMounts:    generateVolumeMounts(r.Fluentbit),
 						},
 					},
+					Tolerations: r.Fluentbit.Spec.Tolerations,
 				},
 			},
 		},

pkg/resources/fluentbit/daemonset.go

@@ -83,6 +83,7 @@ func (r *Reconciler) deployment() runtime.Object {
 						},
 						*newConfigMapReloader(r.Fluentd.Spec.ConfigReloaderImage),
 					},
+					Tolerations: r.Fluentd.Spec.Tolerations,
 				},
 			},
 		},