@@ -32,7 +32,7 @@ import (
32
32
"github.com/open-telemetry/opentelemetry-operator/pkg/collector/reconcile"
33
33
)
34
34
35
- // OpenTelemetryCollectorReconciler reconciles a OpenTelemetryCollector object
35
+ // OpenTelemetryCollectorReconciler reconciles a OpenTelemetryCollector object.
36
36
type OpenTelemetryCollectorReconciler struct {
37
37
client.Client
38
38
log logr.Logger
@@ -41,14 +41,14 @@ type OpenTelemetryCollectorReconciler struct {
41
41
tasks []Task
42
42
}
43
43
44
- // Task represents a reconciliation task to be executed by the reconciler
44
+ // Task represents a reconciliation task to be executed by the reconciler.
45
45
type Task struct {
46
46
Name string
47
47
Do func (context.Context , reconcile.Params ) error
48
48
BailOnError bool
49
49
}
50
50
51
- // Params is the set of options to build a new openTelemetryCollectorReconciler
51
+ // Params is the set of options to build a new openTelemetryCollectorReconciler.
52
52
type Params struct {
53
53
client.Client
54
54
Log logr.Logger
@@ -57,7 +57,7 @@ type Params struct {
57
57
Tasks []Task
58
58
}
59
59
60
- // NewReconciler creates a new reconciler for OpenTelemetryCollector objects
60
+ // NewReconciler creates a new reconciler for OpenTelemetryCollector objects.
61
61
func NewReconciler (p Params ) * OpenTelemetryCollectorReconciler {
62
62
if len (p .Tasks ) == 0 {
63
63
p .Tasks = []Task {
@@ -106,7 +106,7 @@ func NewReconciler(p Params) *OpenTelemetryCollectorReconciler {
106
106
// +kubebuilder:rbac:groups=opentelemetry.io,resources=opentelemetrycollectors,verbs=get;list;watch;create;update;patch;delete
107
107
// +kubebuilder:rbac:groups=opentelemetry.io,resources=opentelemetrycollectors/status,verbs=get;update;patch
108
108
109
- // Reconcile the current state of an OpenTelemetry collector resource with the desired state
109
+ // Reconcile the current state of an OpenTelemetry collector resource with the desired state.
110
110
func (r * OpenTelemetryCollectorReconciler ) Reconcile (_ context.Context , req ctrl.Request ) (ctrl.Result , error ) {
111
111
ctx := context .Background ()
112
112
log := r .log .WithValues ("opentelemetrycollector" , req .NamespacedName )
@@ -138,7 +138,7 @@ func (r *OpenTelemetryCollectorReconciler) Reconcile(_ context.Context, req ctrl
138
138
return ctrl.Result {}, nil
139
139
}
140
140
141
- // RunTasks runs all the tasks associated with this reconciler
141
+ // RunTasks runs all the tasks associated with this reconciler.
142
142
func (r * OpenTelemetryCollectorReconciler ) RunTasks (ctx context.Context , params reconcile.Params ) error {
143
143
for _ , task := range r .tasks {
144
144
if err := task .Do (ctx , params ); err != nil {
@@ -152,7 +152,7 @@ func (r *OpenTelemetryCollectorReconciler) RunTasks(ctx context.Context, params
152
152
return nil
153
153
}
154
154
155
- // SetupWithManager tells the manager what our controller is interested in
155
+ // SetupWithManager tells the manager what our controller is interested in.
156
156
func (r * OpenTelemetryCollectorReconciler ) SetupWithManager (mgr ctrl.Manager ) error {
157
157
return ctrl .NewControllerManagedBy (mgr ).
158
158
For (& v1alpha1.OpenTelemetryCollector {}).
0 commit comments