6
6
"time"
7
7
8
8
parcav1alpha1 "github.com/ricoberger/parca-operator/api/v1alpha1"
9
- "github.com/ricoberger/parca-operator/controllers/scrapeconfigs "
9
+ "github.com/ricoberger/parca-operator/controllers/parcascrapeconfig "
10
10
11
11
corev1 "k8s.io/api/core/v1"
12
12
"k8s.io/apimachinery/pkg/api/errors"
@@ -50,7 +50,7 @@ type ParcaScrapeConfigReconciler struct {
50
50
// - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile
51
51
func (r * ParcaScrapeConfigReconciler ) Reconcile (ctx context.Context , req ctrl.Request ) (ctrl.Result , error ) {
52
52
reqLogger := log .FromContext (ctx )
53
- reconciliationInterval := scrapeconfigs .GetReconciliationInterval ()
53
+ reconciliationInterval := parcascrapeconfig .GetReconciliationInterval ()
54
54
55
55
parcaScrapeConfig := & parcav1alpha1.ParcaScrapeConfig {}
56
56
err := r .Get (ctx , req .NamespacedName , parcaScrapeConfig )
@@ -73,14 +73,14 @@ func (r *ParcaScrapeConfigReconciler) Reconcile(ctx context.Context, req ctrl.Re
73
73
if controllerutil .ContainsFinalizer (parcaScrapeConfig , parcaScrapeConfigFinalizer ) {
74
74
// Remove the ParcaScrapeConfig from the Parca configuration and update the Parca configuration secret. So
75
75
// that it doesn't contain the ParcaScrapeConfig anymore.
76
- err := scrapeconfigs .DeleteScrapeConfig (* parcaScrapeConfig )
76
+ err := parcascrapeconfig .DeleteScrapeConfig (* parcaScrapeConfig )
77
77
if err != nil {
78
78
reqLogger .Error (err , "Failed to delete ParcaScrapeConfig." )
79
79
r .updateConditions (ctx , parcaScrapeConfig , parcaScrapeConfigDeleteFailed , err .Error (), metav1 .ConditionFalse , nil )
80
80
return ctrl.Result {RequeueAfter : reconciliationInterval }, err
81
81
}
82
82
83
- finalConfig , err := scrapeconfigs .GetConfig ()
83
+ finalConfig , err := parcascrapeconfig .GetConfig ()
84
84
if err != nil {
85
85
reqLogger .Error (err , "Failed to get Parca configuration." )
86
86
r .updateConditions (ctx , parcaScrapeConfig , parcaScrapeConfigUpdateFailed , err .Error (), metav1 .ConditionFalse , nil )
@@ -135,7 +135,7 @@ func (r *ParcaScrapeConfigReconciler) Reconcile(ctx context.Context, req ctrl.Re
135
135
return ctrl.Result {RequeueAfter : reconciliationInterval }, err
136
136
}
137
137
138
- podIPs , err := scrapeconfigs .SetScrapeConfig (* parcaScrapeConfig , pods .Items )
138
+ podIPs , err := parcascrapeconfig .SetScrapeConfig (* parcaScrapeConfig , pods .Items )
139
139
if err != nil {
140
140
reqLogger .Error (err , "Failed to update internal Parca configuration." )
141
141
r .updateConditions (ctx , parcaScrapeConfig , parcaScrapeConfigUpdateFailed , err .Error (), metav1 .ConditionFalse , nil )
@@ -144,7 +144,7 @@ func (r *ParcaScrapeConfigReconciler) Reconcile(ctx context.Context, req ctrl.Re
144
144
145
145
// When the Parca configuration was updated, we can update the Parca configuration secret to include the new scrape
146
146
// configuration.
147
- finalConfig , err := scrapeconfigs .GetConfig ()
147
+ finalConfig , err := parcascrapeconfig .GetConfig ()
148
148
if err != nil {
149
149
reqLogger .Error (err , "Failed to get Parca configuration." )
150
150
r .updateConditions (ctx , parcaScrapeConfig , parcaScrapeConfigUpdateFailed , err .Error (), metav1 .ConditionFalse , nil )
0 commit comments