Skip to content

Commit 4911e35

Browse files
fengshunlifengshunli
committed
Fix Code format (including comment)
Signed-off-by: fengshunli <[email protected]>
1 parent f94c976 commit 4911e35

25 files changed

+74
-71
lines changed

‎apis/fluentbit/v1alpha2/clusterfilter_types.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -63,11 +63,11 @@ type FilterItem struct {
6363
Throttle *filter.Throttle `json:"throttle,omitempty"`
6464
// RewriteTag defines a RewriteTag configuration.
6565
RewriteTag *filter.RewriteTag `json:"rewriteTag,omitempty"`
66-
//Aws defines a Aws configuration.
66+
// Aws defines a Aws configuration.
6767
AWS *filter.AWS `json:"aws,omitempty"`
68-
//Multiline defines a Multiline configuration.
68+
// Multiline defines a Multiline configuration.
6969
Multiline *filter.Multiline `json:"multiline,omitempty"`
70-
//CustomPlugin defines a Custom plugin configuration.
70+
// CustomPlugin defines a Custom plugin configuration.
7171
CustomPlugin *custom.CustomPlugin `json:"customPlugin,omitempty"`
7272
}
7373

‎apis/fluentbit/v1alpha2/clusterfluentbitconfig_types.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,8 @@ type FluentBitConfigSpec struct {
4141
OutputSelector metav1.LabelSelector `json:"outputSelector,omitempty"`
4242
// Select parser plugins
4343
ParserSelector metav1.LabelSelector `json:"parserSelector,omitempty"`
44-
//If namespace is defined, then the configmap and secret for fluent-bit is in this namespace.
45-
//If it is not defined, it is in the namespace of the fluentd-operator
44+
// If namespace is defined, then the configmap and secret for fluent-bit is in this namespace.
45+
// If it is not defined, it is in the namespace of the fluentd-operator
4646
Namespace *string `json:"namespace,omitempty"`
4747
}
4848

@@ -179,12 +179,14 @@ func (cfg ClusterFluentBitConfig) RenderParserConfig(sl plugins.SecretLoader, pa
179179
}
180180

181181
// +kubebuilder:object:generate:=false
182+
182183
type Script struct {
183184
Name string
184185
Content string
185186
}
186187

187188
// +kubebuilder:object:generate:=false
189+
188190
// ByName implements sort.Interface for []Script based on the Name field.
189191
type ByName []Script
190192

‎apis/fluentbit/v1alpha2/clusteroutput_types.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ type OutputSpec struct {
7272
DataDog *output.DataDog `json:"datadog,omitempty"`
7373
// Firehose defines Firehose Output configuration.
7474
Fireose *output.Firehose `json:"firehose,omitempty"`
75-
//Splunk defines Splunk Output Configuration
75+
// Splunk defines Splunk Output Configuration
7676
Splunk *output.Splunk `json:"splunk,omitempty"`
7777
// OpenSearch defines OpenSearch Output configuration.
7878
OpenSearch *output.OpenSearch `json:"opensearch,omitempty"`
@@ -107,6 +107,7 @@ type ClusterOutputList struct {
107107
}
108108

109109
// +kubebuilder:object:generate:=false
110+
110111
// OutputByName implements sort.Interface for []ClusterOutput based on the Name field.
111112
type OutputByName []ClusterOutput
112113

‎apis/fluentbit/v1alpha2/clusterparser_types.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,7 @@ type ClusterParserList struct {
8080
}
8181

8282
// +kubebuilder:object:generate:=false
83+
8384
// ParserByName implements sort.Interface for []ClusterParser based on the Name field.
8485
type ParserByName []ClusterParser
8586

‎apis/fluentbit/v1alpha2/doc.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,4 +16,4 @@ limitations under the License.
1616
// +k8s:deepcopy-gen=package
1717
// +groupName=fluentbit.fluent.io
1818

19-
package v1alpha2 // import "github.com/fluent/fluent-operator/apis/fluentbit/v1alpha2"
19+
package v1alpha2 // Package v1alpha2 import "github.com/fluent/fluent-operator/apis/fluentbit/v1alpha2"

‎apis/fluentd/v1alpha1/clusterfilter_types.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ type ClusterFilter struct {
4747
Status ClusterFilterStatus `json:"status,omitempty"`
4848
}
4949

50-
//+kubebuilder:object:root=true
50+
// +kubebuilder:object:root=true
5151

5252
// ClusterFilterList contains a list of ClusterFilter
5353
type ClusterFilterList struct {

‎apis/fluentd/v1alpha1/clusterfluentdconfig_types.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ type ClusterFluentdConfig struct {
7575
Status ClusterFluentdConfigStatus `json:"status,omitempty"`
7676
}
7777

78-
//+kubebuilder:object:root=true
78+
// +kubebuilder:object:root=true
7979

8080
// ClusterFluentdConfigList contains a list of ClusterFluentdConfig
8181
type ClusterFluentdConfigList struct {

‎apis/fluentd/v1alpha1/clusteroutput_types.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ type ClusterOutput struct {
4747
Status ClusterOutputStatus `json:"status,omitempty"`
4848
}
4949

50-
//+kubebuilder:object:root=true
50+
// +kubebuilder:object:root=true
5151

5252
// ClusterOutputList contains a list of ClusterOutput
5353
type ClusterOutputList struct {

‎apis/fluentd/v1alpha1/filter_types.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,10 @@ type FilterStatus struct {
3232
// Important: Run "make" to regenerate code after modifying this file
3333
}
3434

35-
//+kubebuilder:object:root=true
36-
//+kubebuilder:subresource:status
37-
//+kubebuilder:resource:shortName=fdf
38-
//+genclient
35+
// +kubebuilder:object:root=true
36+
// +kubebuilder:subresource:status
37+
// +kubebuilder:resource:shortName=fdf
38+
// +genclient
3939

4040
// Filter is the Schema for the filters API
4141
type Filter struct {
@@ -46,7 +46,7 @@ type Filter struct {
4646
Status FilterStatus `json:"status,omitempty"`
4747
}
4848

49-
//+kubebuilder:object:root=true
49+
// +kubebuilder:object:root=true
5050

5151
// FilterList contains a list of Filter
5252
type FilterList struct {

‎apis/fluentd/v1alpha1/fluentd_types.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -90,10 +90,10 @@ type FluentdStatus struct {
9090
State StatusState `json:"state,omitempty"`
9191
}
9292

93-
//+kubebuilder:object:root=true
94-
//+kubebuilder:subresource:status
95-
//+kubebuilder:resource:shortName=fd
96-
//+genclient
93+
// +kubebuilder:object:root=true
94+
// +kubebuilder:subresource:status
95+
// +kubebuilder:resource:shortName=fd
96+
// +genclient
9797

9898
// Fluentd is the Schema for the fluentds API
9999
type Fluentd struct {
@@ -127,7 +127,7 @@ func (fd *Fluentd) RemoveFinalizer(finalizerName string) {
127127
fd.ObjectMeta.Finalizers = utils.RemoveString(fd.ObjectMeta.Finalizers, finalizerName)
128128
}
129129

130-
//+kubebuilder:object:root=true
130+
// +kubebuilder:object:root=true
131131

132132
// FluentdList contains a list of Fluentd
133133
type FluentdList struct {

‎apis/fluentd/v1alpha1/fluentdconfig_types.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -55,10 +55,10 @@ type FluentdConfigStatus struct {
5555
State StatusState `json:"state,omitempty"`
5656
}
5757

58-
//+kubebuilder:object:root=true
59-
//+kubebuilder:subresource:status
60-
//+kubebuilder:resource:shortName=fdc
61-
//+genclient
58+
// +kubebuilder:object:root=true
59+
// +kubebuilder:subresource:status
60+
// +kubebuilder:resource:shortName=fdc
61+
// +genclient
6262

6363
// FluentdConfig is the Schema for the fluentdconfigs API
6464
type FluentdConfig struct {
@@ -69,7 +69,7 @@ type FluentdConfig struct {
6969
Status FluentdConfigStatus `json:"status,omitempty"`
7070
}
7171

72-
//+kubebuilder:object:root=true
72+
// +kubebuilder:object:root=true
7373

7474
// FluentdConfigList contains a list of FluentdConfig
7575
type FluentdConfigList struct {

‎apis/fluentd/v1alpha1/output_types.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,10 +35,10 @@ type OutputStatus struct {
3535
// Important: Run "make" to regenerate code after modifying this file
3636
}
3737

38-
//+kubebuilder:object:root=true
39-
//+kubebuilder:subresource:status
40-
//+kubebuilder:resource:shortName=fdo
41-
//+genclient
38+
// +kubebuilder:object:root=true
39+
// +kubebuilder:subresource:status
40+
// +kubebuilder:resource:shortName=fdo
41+
// +genclient
4242

4343
// Output is the Schema for the outputs API
4444
type Output struct {
@@ -49,7 +49,7 @@ type Output struct {
4949
Status OutputStatus `json:"status,omitempty"`
5050
}
5151

52-
//+kubebuilder:object:root=true
52+
// +kubebuilder:object:root=true
5353

5454
// OutputList contains a list of Output
5555
type OutputList struct {

‎cmd/fluent-manager/main.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ import (
3939
fluentdv1alpha1 "github.com/fluent/fluent-operator/apis/fluentd/v1alpha1"
4040

4141
"github.com/fluent/fluent-operator/controllers"
42-
//+kubebuilder:scaffold:imports
42+
// +kubebuilder:scaffold:imports
4343
)
4444

4545
var (
@@ -52,7 +52,7 @@ func init() {
5252

5353
utilruntime.Must(fluentbitv1alpha2.AddToScheme(scheme))
5454
utilruntime.Must(fluentdv1alpha1.AddToScheme(scheme))
55-
//+kubebuilder:scaffold:scheme
55+
// +kubebuilder:scaffold:scheme
5656
}
5757

5858
func main() {
@@ -131,7 +131,7 @@ func main() {
131131
setupLog.Error(err, "unable to create controller", "controller", "FluentBit")
132132
os.Exit(1)
133133
}
134-
//+kubebuilder:scaffold:builder
134+
// +kubebuilder:scaffold:builder
135135

136136
if err = (&controllers.FluentdConfigReconciler{
137137
Client: mgr.GetClient(),
@@ -150,7 +150,7 @@ func main() {
150150
setupLog.Error(err, "unable to create controller", "controller", "Fluentd")
151151
os.Exit(1)
152152
}
153-
//+kubebuilder:scaffold:builder
153+
// +kubebuilder:scaffold:builder
154154

155155
if err := mgr.AddHealthzCheck("healthz", healthz.Ping); err != nil {
156156
setupLog.Error(err, "unable to set up health check")

‎controllers/collector_controller.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -41,12 +41,12 @@ type CollectorReconciler struct {
4141
Scheme *runtime.Scheme
4242
}
4343

44-
//+kubebuilder:rbac:groups=fluentbit.fluent.io,resources=fluentbits;fluentbitconfigs;collectors;inputs;filters;outputs,verbs=get;list;watch;create;update;patch;delete
45-
//+kubebuilder:rbac:groups=apps,resources=statefulsets,verbs=get;list;watch;create;update;patch;delete
46-
//+kubebuilder:rbac:groups=core,resources=serviceaccounts,verbs=get;list;watch;create;update;patch;delete
47-
//+kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterroles,verbs=create
48-
//+kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterrolebindings,verbs=create
49-
//+kubebuilder:rbac:groups=core,resources=pods,verbs=get
44+
// +kubebuilder:rbac:groups=fluentbit.fluent.io,resources=fluentbits;fluentbitconfigs;collectors;inputs;filters;outputs,verbs=get;list;watch;create;update;patch;delete
45+
// +kubebuilder:rbac:groups=apps,resources=statefulsets,verbs=get;list;watch;create;update;patch;delete
46+
// +kubebuilder:rbac:groups=core,resources=serviceaccounts,verbs=get;list;watch;create;update;patch;delete
47+
// +kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterroles,verbs=create
48+
// +kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterrolebindings,verbs=create
49+
// +kubebuilder:rbac:groups=core,resources=pods,verbs=get
5050

5151
// Reconcile is part of the main kubernetes reconciliation loop which aims to
5252
// move the current state of the cluster closer to the desired state.

‎controllers/fluentbit_controller.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -44,12 +44,12 @@ type FluentBitReconciler struct {
4444
Namespaced bool
4545
}
4646

47-
//+kubebuilder:rbac:groups=fluentbit.fluent.io,resources=fluentbits;fluentbitconfigs;inputs;filters;outputs,verbs=get;list;watch;create;update;patch;delete
48-
//+kubebuilder:rbac:groups=apps,resources=daemonsets,verbs=get;list;watch;create;update;patch;delete
49-
//+kubebuilder:rbac:groups=core,resources=serviceaccounts,verbs=get;list;watch;create;update;patch;delete
50-
//+kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterroles,verbs=create
51-
//+kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterrolebindings,verbs=create
52-
//+kubebuilder:rbac:groups=core,resources=pods,verbs=get
47+
// +kubebuilder:rbac:groups=fluentbit.fluent.io,resources=fluentbits;fluentbitconfigs;inputs;filters;outputs,verbs=get;list;watch;create;update;patch;delete
48+
// +kubebuilder:rbac:groups=apps,resources=daemonsets,verbs=get;list;watch;create;update;patch;delete
49+
// +kubebuilder:rbac:groups=core,resources=serviceaccounts,verbs=get;list;watch;create;update;patch;delete
50+
// +kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterroles,verbs=create
51+
// +kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=clusterrolebindings,verbs=create
52+
// +kubebuilder:rbac:groups=core,resources=pods,verbs=get
5353

5454
// Reconcile is part of the main kubernetes reconciliation loop which aims to
5555
// move the current state of the cluster closer to the desired state.

‎controllers/fluentbitconfig_controller.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,9 @@ type FluentBitConfigReconciler struct {
4343
Scheme *runtime.Scheme
4444
}
4545

46-
//+kubebuilder:rbac:groups=fluentbit.fluent.io,resources=clusterfluentbitconfigs,verbs=get;list;watch;create;update;patch;delete
47-
//+kubebuilder:rbac:groups=fluentbit.fluent.io,resources=clusterinputs;clusterfilters;clusteroutputs;clusterparsers,verbs=list
48-
//+kubebuilder:rbac:groups=core,resources=secrets,verbs=get;list;watch;create;update;patch;delete
46+
// +kubebuilder:rbac:groups=fluentbit.fluent.io,resources=clusterfluentbitconfigs,verbs=get;list;watch;create;update;patch;delete
47+
// +kubebuilder:rbac:groups=fluentbit.fluent.io,resources=clusterinputs;clusterfilters;clusteroutputs;clusterparsers,verbs=list
48+
// +kubebuilder:rbac:groups=core,resources=secrets,verbs=get;list;watch;create;update;patch;delete
4949

5050
// Reconcile is part of the main kubernetes reconciliation loop which aims to
5151
// move the current state of the cluster closer to the desired state.

‎controllers/fluentd_controller.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,9 +42,9 @@ type FluentdReconciler struct {
4242
Scheme *runtime.Scheme
4343
}
4444

45-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds,verbs=get;list;watch;create;update;patch;delete
46-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds/status,verbs=get;update;patch
47-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds/finalizers,verbs=update
45+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds,verbs=get;list;watch;create;update;patch;delete
46+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds/status,verbs=get;update;patch
47+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds/finalizers,verbs=update
4848

4949
// Reconcile is part of the main kubernetes reconciliation loop which aims to
5050
// move the current state of the cluster closer to the desired state.

‎controllers/fluentdconfig_controller.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -82,14 +82,14 @@ type FluentdConfigReconciler struct {
8282
Scheme *runtime.Scheme
8383
}
8484

85-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentdconfigs,verbs=get;list;watch;create;update;patch;delete
86-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=clusterfluentdconfigs,verbs=get;list;watch;create;update;patch;delete
87-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=inputs;filters;outputs,verbs=list
88-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=clusterinputs;clusterfilters;clusteroutputs,verbs=list;
89-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds,verbs=list
90-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds/status,verbs=patch
91-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentdconfigs/status,verbs=get;update;patch
92-
//+kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentdconfigs/finalizers,verbs=update
85+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentdconfigs,verbs=get;list;watch;create;update;patch;delete
86+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=clusterfluentdconfigs,verbs=get;list;watch;create;update;patch;delete
87+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=inputs;filters;outputs,verbs=list
88+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=clusterinputs;clusterfilters;clusteroutputs,verbs=list;
89+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds,verbs=list
90+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentds/status,verbs=patch
91+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentdconfigs/status,verbs=get;update;patch
92+
// +kubebuilder:rbac:groups=fluentd.fluent.io,resources=fluentdconfigs/finalizers,verbs=update
9393

9494
// Reconcile is part of the main kubernetes reconciliation loop which aims to
9595
// move the current state of the cluster closer to the desired state.

‎controllers/suite_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import (
3131

3232
fluentbitv1alpha2 "github.com/fluent/fluent-operator/apis/fluentbit/v1alpha2"
3333
fluentdv1alpha1 "github.com/fluent/fluent-operator/apis/fluentd/v1alpha1"
34-
//+kubebuilder:scaffold:imports
34+
// +kubebuilder:scaffold:imports
3535
)
3636

3737
// These tests use Ginkgo (BDD-style Go testing framework). Refer to
@@ -67,7 +67,7 @@ var _ = BeforeSuite(func() {
6767
err = fluentdv1alpha1.AddToScheme(scheme.Scheme)
6868
Expect(err).NotTo(HaveOccurred())
6969

70-
//+kubebuilder:scaffold:scheme
70+
// +kubebuilder:scaffold:scheme
7171

7272
k8sClient, err = client.New(cfg, client.Options{Scheme: scheme.Scheme})
7373
Expect(err).NotTo(HaveOccurred())

‎pkg/filenotify/filenotify.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
// Adapted from https://github.com/gohugoio/hugo
22
// Apache License 2.0
33
// Copyright Hugo Authors
4-
//
4+
55
// Package filenotify provides a mechanism for watching file(s) for changes.
66
// Generally leans on fsnotify, but provides a poll-based notifier which fsnotify does not support.
77
// These are wrapped up in a common interface so that either can be used interchangeably in your code.

‎pkg/filenotify/fsnotify.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
// Adapted from https://github.com/gohugoio/hugo
22
// Apache License 2.0
33
// Copyright Hugo Authors
4-
//
4+
55
// Package filenotify is adapted from https://github.com/moby/moby/tree/master/pkg/filenotify, Apache-2.0 License.
66
// Hopefully this can be replaced with an external package sometime in the future, see https://github.com/fsnotify/fsnotify/issues/9
77
package filenotify

‎pkg/filenotify/poller.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
// Adapted from https://github.com/gohugoio/hugo
22
// Apache License 2.0
33
// Copyright Hugo Authors
4-
//
4+
55
// Package filenotify is adapted from https://github.com/moby/moby/tree/master/pkg/filenotify, Apache-2.0 License.
66
// Hopefully this can be replaced with an external package sometime in the future, see https://github.com/fsnotify/fsnotify/issues/9
77
package filenotify

‎pkg/fluentd/router/pluginstore.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ type LabelRouter struct {
3030
Routes []*Route `json:"routes,omitempty"`
3131
}
3232

33-
// Each fluentd config instance will create a route pluginstore.
33+
// NewRoutePlugin will create a route pluginstore for each fluentd config instance
3434
func (r *Route) NewRoutePlugin() (*params.PluginStore, error) {
3535
ps := params.NewPluginStore("route")
3636
childs := make([]*params.PluginStore, 0)
@@ -83,7 +83,7 @@ func (r *Route) NewRoutePlugin() (*params.PluginStore, error) {
8383
return ps, nil
8484
}
8585

86-
// The global router to store routes
86+
// NewGlobalRouter will create a global router to store routes
8787
func NewGlobalRouter(id string) *params.PluginStore {
8888
ps := params.NewPluginStore("match")
8989
ps.InsertPairs("@id", id)

‎pkg/operator/collector-statefulset.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
)
1212

1313
var (
14-
// Buffer path for single process
14+
// DefaultBufferPath defines the buffer path for single process
1515
DefaultBufferPath = "/buffers/fluentbit/log"
1616
)
1717

@@ -129,7 +129,7 @@ func MakefbStatefuset(co fluentbitv1alpha2.Collector) appsv1.StatefulSet {
129129
})
130130
}
131131

132-
//Bind pvc
132+
// Bind pvc
133133
statefulset.Spec.VolumeClaimTemplates = append(statefulset.Spec.VolumeClaimTemplates, MakeFluentbitPVC(co))
134134
statefulset.Spec.Template.Spec.Containers[0].VolumeMounts = append(statefulset.Spec.Template.Spec.Containers[0].VolumeMounts, corev1.VolumeMount{
135135
Name: fmt.Sprintf("%s-buffer-pvc", co.Name),

0 commit comments

Comments
 (0)