Merge pull request #143 from theBeginner86/theBeginner86/replicasets

[chore] Support for discovering ReplicaSets
meshery · Aug 5, 2022 · ce71f2c · ce71f2c
2 parents 2c2e41d + 52bcb63
commit ce71f2c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/internal/config/default_config.go b/internal/config/default_config.go
@@ -42,6 +42,10 @@ var (
 		},
 		LocalResourceKey: []PipelineConfig{
 			// Core Resources
+			{
+				Name:      "replicasets.v1.apps",
+				PublishTo: "meshery.meshsyc.core",
+			},
 			{
 				Name:      "pods.v1.",
 				PublishTo: "meshery.meshsync.core",

diff --git a/meshsync/exec.go b/meshsync/exec.go
@@ -4,7 +4,6 @@ import (
 	"bufio"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"os"
 	"strings"
 	"time"
@@ -98,7 +97,7 @@ func (h *Handler) streamChannelPool() {
 func (h *Handler) streamSession(id string, req model.ExecRequest, cfg config.ListenerConfig) {
 	subCh := make(chan *broker.Message)
 	tstdin, putStdin := io.Pipe()
-	stdin := ioutil.NopCloser(tstdin)
+	stdin := io.NopCloser(tstdin)
 	getStdout, stdout := io.Pipe()
 
 	err := h.Broker.SubscribeWithChannel(fmt.Sprintf("input.%s", id), generateID(), subCh)