[Cleanup] Remove unused variable

Summary: Simple fix. Something I spotted while documenting the data pipelines. Test Plan: Unit tests pass Reviewers: michelle, nserrino Reviewed By: michelle Signed-off-by: Phillip Kuznetsov <pkuznetsov@pixielabs.ai> Differential Revision: https://phab.corp.pixielabs.ai/D10814 GitOrigin-RevId: b33a01c
mcoron · Feb 17, 2022 · bea3b23 · bea3b23
1 parent 6339490
commit bea3b23
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/vizier/services/metadata/controllers/k8smeta/k8s_metadata_controller.go b/src/vizier/services/metadata/controllers/k8smeta/k8s_metadata_controller.go
@@ -46,7 +46,7 @@ type watcher interface {
 }
 
 // NewController creates a new Controller.
-func NewController(mds Store, updateCh chan *K8sResourceMessage) (*Controller, error) {
+func NewController(updateCh chan *K8sResourceMessage) (*Controller, error) {
 	// There is a specific config for services running in the cluster.
 	kubeConfig, err := rest.InClusterConfig()
 	if err != nil {

diff --git a/src/vizier/services/metadata/metadata_server.go b/src/vizier/services/metadata/metadata_server.go
@@ -230,7 +230,7 @@ func main() {
 	updateCh := make(chan *k8smeta.K8sResourceMessage)
 	mdh := k8smeta.NewHandler(updateCh, k8sMds, nc)
 
-	k8sMc, err := k8smeta.NewController(k8sMds, updateCh)
+	k8sMc, err := k8smeta.NewController(updateCh)
 	defer k8sMc.Stop()
 
 	ads := agent.NewDatastore(dataStore, 24*time.Hour)