Use OffshootLabels while listing pods (#728)

Signed-off-by: Arnob kumar saha <[email protected]>
kubedb · Oct 17, 2023 · 033afa7 · 033afa7
1 parent da20a30
commit 033afa7
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/pkg/debug/elasticsearch.go b/pkg/debug/elasticsearch.go
@@ -154,7 +154,7 @@ func (opts *elasticsearchOpts) collectOperatorLogs() error {
 }
 
 func (opts *elasticsearchOpts) collectForAllDBPods() error {
-	dbLabels := labels.SelectorFromSet(opts.db.GetLabels()).String()
+	dbLabels := labels.SelectorFromSet(opts.db.OffshootLabels()).String()
 	pods, err := opts.podClient.CoreV1().Pods(opts.db.Namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: dbLabels,
 	})

diff --git a/pkg/debug/mariadb.go b/pkg/debug/mariadb.go
@@ -154,7 +154,7 @@ func (opts *mariadbOpts) collectOperatorLogs() error {
 }
 
 func (opts *mariadbOpts) collectForAllDBPods() error {
-	dbLabels := labels.SelectorFromSet(opts.db.GetLabels()).String()
+	dbLabels := labels.SelectorFromSet(opts.db.OffshootLabels()).String()
 	pods, err := opts.podClient.CoreV1().Pods(opts.db.Namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: dbLabels,
 	})

diff --git a/pkg/debug/mongodb.go b/pkg/debug/mongodb.go
@@ -154,7 +154,7 @@ func (opts *mongodbOpts) collectOperatorLogs() error {
 }
 
 func (opts *mongodbOpts) collectForAllDBPods() error {
-	dbLabels := labels.SelectorFromSet(opts.db.GetLabels()).String()
+	dbLabels := labels.SelectorFromSet(opts.db.OffshootLabels()).String()
 	pods, err := opts.podClient.CoreV1().Pods(opts.db.Namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: dbLabels,
 	})

diff --git a/pkg/debug/mysql.go b/pkg/debug/mysql.go
@@ -154,7 +154,7 @@ func (opts *mysqlOpts) collectOperatorLogs() error {
 }
 
 func (opts *mysqlOpts) collectForAllDBPods() error {
-	dbLabels := labels.SelectorFromSet(opts.db.GetLabels()).String()
+	dbLabels := labels.SelectorFromSet(opts.db.OffshootLabels()).String()
 	pods, err := opts.podClient.CoreV1().Pods(opts.db.Namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: dbLabels,
 	})

diff --git a/pkg/debug/postgres.go b/pkg/debug/postgres.go
@@ -154,7 +154,7 @@ func (opts *postgresOpts) collectOperatorLogs() error {
 }
 
 func (opts *postgresOpts) collectForAllDBPods() error {
-	dbLabels := labels.SelectorFromSet(opts.db.GetLabels()).String()
+	dbLabels := labels.SelectorFromSet(opts.db.OffshootLabels()).String()
 	pods, err := opts.podClient.CoreV1().Pods(opts.db.Namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: dbLabels,
 	})

diff --git a/pkg/debug/redis.go b/pkg/debug/redis.go
@@ -154,7 +154,7 @@ func (opts *redisOpts) collectOperatorLogs() error {
 }
 
 func (opts *redisOpts) collectForAllDBPods() error {
-	dbLabels := labels.SelectorFromSet(opts.db.GetLabels()).String()
+	dbLabels := labels.SelectorFromSet(opts.db.OffshootLabels()).String()
 	pods, err := opts.podClient.CoreV1().Pods(opts.db.Namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: dbLabels,
 	})