cluster: populate local registry information in the Cluster API object (

#5632)

internal/controllers/core/cluster/cache.go

@@ -9,6 +9,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
 
+	"github.com/tilt-dev/tilt/internal/container"
 	"github.com/tilt-dev/tilt/internal/controllers/apis/cluster"
 	"github.com/tilt-dev/tilt/internal/docker"
 	"github.com/tilt-dev/tilt/internal/k8s"
@@ -41,6 +42,7 @@ type connection struct {
 	error        string
 	createdAt    time.Time
 	arch         string
+	registry     *container.Registry
 }
 
 func (k *ConnectionManager) GetK8sClient(clusterKey types.NamespacedName) (k8s.Client, metav1.MicroTime, error) {

internal/controllers/core/cluster/reconciler.go

@@ -113,6 +113,11 @@ func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (
 		}
 	}
 
+	if conn.error == "" && conn.connType == connectionTypeK8s && conn.registry == nil {
+		reg := conn.k8sClient.LocalRegistry(ctx)
+		conn.registry = &reg
+	}
+
 	r.connManager.store(nn, conn)
 
 	status := conn.toStatus()
@@ -239,9 +244,20 @@ func (c *connection) toStatus() v1alpha1.ClusterStatus {
 		connectedAt = &t
 	}
 
+	var reg *v1alpha1.RegistryHosting
+	if c.registry != nil {
+		reg = &v1alpha1.RegistryHosting{
+			Host:                     c.registry.Host,
+			HostFromContainerRuntime: c.registry.HostFromCluster(),
+			// TODO(milas+lizz): expose from the Tilt registry object
+			// Help: c.registry.Help,
+		}
+	}
+
 	return v1alpha1.ClusterStatus{
 		Error:       c.error,
 		Arch:        c.arch,
 		ConnectedAt: connectedAt,
+		Registry:    reg,
 	}
 }