Merge pull request #1014 from rancher/etl

Prometheus Remote Read ETL tool

go.mod

@@ -66,6 +66,7 @@ require (
 	github.com/mattn/go-tty v0.0.4
 	github.com/mikefarah/yq/v4 v4.30.8
 	github.com/mitchellh/mapstructure v1.5.0
+	github.com/muesli/termenv v0.13.0
 	github.com/nats-io/nats-server/v2 v2.9.12
 	github.com/nats-io/nats.go v1.23.0
 	github.com/nats-io/nkeys v0.3.0
@@ -79,7 +80,8 @@ require (
 	github.com/phayes/freeport v0.0.0-20220201140144-74d24b5ae9f5
 	github.com/pkg/browser v0.0.0-20210911075715-681adbf594b8
 	github.com/pkg/errors v0.9.1
-	github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring v0.62.0
+	github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring v0.63.0
+	github.com/prometheus-operator/prometheus-operator/pkg/client v0.63.0
 	github.com/prometheus/alertmanager v0.25.0
 	github.com/prometheus/client_golang v1.14.0
 	github.com/prometheus/client_model v0.3.0
@@ -209,6 +211,7 @@ require (
 	github.com/cespare/xxhash v1.1.0 // indirect
 	github.com/cespare/xxhash/v2 v2.2.0 // indirect
 	github.com/chai2010/gettext-go v1.0.2 // indirect
+	github.com/charmbracelet/harmonica v0.2.0 // indirect
 	github.com/cheggaaa/pb v1.0.29 // indirect
 	github.com/cockroachdb/apd/v2 v2.0.1 // indirect
 	github.com/containerd/console v1.0.3 // indirect
@@ -236,7 +239,7 @@ require (
 	github.com/edsrzf/mmap-go v1.1.0 // indirect
 	github.com/efficientgo/core v1.0.0-rc.2 // indirect
 	github.com/elliotchance/orderedmap v1.5.0 // indirect
-	github.com/emicklei/go-restful/v3 v3.9.0 // indirect
+	github.com/emicklei/go-restful/v3 v3.10.1 // indirect
 	github.com/emicklei/proto v1.6.15 // indirect
 	github.com/emirpasic/gods v1.18.1 // indirect
 	github.com/evanphx/json-patch v5.6.0+incompatible // indirect
@@ -260,8 +263,8 @@ require (
 	github.com/go-ole/go-ole v1.2.6 // indirect
 	github.com/go-openapi/analysis v0.21.4 // indirect
 	github.com/go-openapi/errors v0.20.3 // indirect
-	github.com/go-openapi/jsonpointer v0.19.5 // indirect
-	github.com/go-openapi/jsonreference v0.20.0 // indirect
+	github.com/go-openapi/jsonpointer v0.19.6 // indirect
+	github.com/go-openapi/jsonreference v0.20.2 // indirect
 	github.com/go-openapi/loads v0.21.2 // indirect
 	github.com/go-openapi/runtime v0.25.0 // indirect
 	github.com/go-openapi/spec v0.20.7 // indirect
@@ -377,7 +380,6 @@ require (
 	github.com/muesli/ansi v0.0.0-20211018074035-2e021307bc4b // indirect
 	github.com/muesli/cancelreader v0.2.2 // indirect
 	github.com/muesli/reflow v0.3.0 // indirect
-	github.com/muesli/termenv v0.13.0 // indirect
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
 	github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f // indirect
 	github.com/nats-io/jwt/v2 v2.3.0 // indirect
@@ -493,8 +495,8 @@ require (
 	helm.sh/helm/v3 v3.10.3 // indirect
 	howett.net/plist v1.0.0 // indirect
 	k8s.io/apiserver v0.26.1 // indirect
-	k8s.io/klog/v2 v2.80.1 // indirect
-	k8s.io/kube-openapi v0.0.0-20221207184640-f3cff1453715 // indirect
+	k8s.io/klog/v2 v2.90.0 // indirect
+	k8s.io/kube-openapi v0.0.0-20230202010329-39b3636cbaa3 // indirect
 	lukechampine.com/frand v1.4.2 // indirect
 	oras.land/oras-go v1.2.0 // indirect
 	sigs.k8s.io/gateway-api v0.6.0 // indirect

pkg/agent/clientset.go

@@ -10,15 +10,22 @@ import (
 type ClientSet interface {
 	controlv1.HealthClient
 	capabilityv1.NodeClient
+	ClientConn() grpc.ClientConnInterface
 }
 
 type clientSet struct {
+	cc grpc.ClientConnInterface
 	controlv1.HealthClient
 	capabilityv1.NodeClient
 }
 
+func (c *clientSet) ClientConn() grpc.ClientConnInterface {
+	return c.cc
+}
+
 func NewClientSet(cc grpc.ClientConnInterface) ClientSet {
 	return &clientSet{
+		cc:           cc,
 		HealthClient: controlv1.NewHealthClient(cc),
 		NodeClient:   capabilityv1.NewNodeClient(cc),
 	}

pkg/apis/core/v1/metadata.go

@@ -22,6 +22,19 @@ type MetadataAccessor[T Capability[T]] interface {
 	SetResourceVersion(version string)
 }
 
+type IdReader interface {
+	GetId() string
+}
+
+type LabelReader interface {
+	GetLabels() map[string]string
+}
+
+type IdLabelReader interface {
+	IdReader
+	LabelReader
+}
+
 func (t *BootstrapToken) GetCapabilities() []*TokenCapability {
 	return t.GetMetadata().GetCapabilities()
 }