add addressable status

Author: odacremolbap

pkg/apis/eventing/v1alpha1/redisbroker_lifecycle.go

@@ -37,8 +37,7 @@ var redisBrokerCondSet = apis.NewLivingConditionSet(
 	RedisBrokerBrokerService,
 	RedisBrokerBrokerServiceEndpointsConditionReady,
 	RedisBrokerConfigSecret,
-
-// TODO RedisBrokerConditionAddressable,
+	RedisBrokerConditionAddressable,
 )
 var redisBrokerCondSetLock = sync.RWMutex{}
 

pkg/reconciler/redisbroker/reconciler.go

@@ -9,7 +9,9 @@ import (
 	"go.uber.org/zap"
 	"k8s.io/client-go/kubernetes"
 
+	"knative.dev/pkg/apis"
 	"knative.dev/pkg/logging"
+	"knative.dev/pkg/network"
 	"knative.dev/pkg/reconciler"
 
 	eventingv1alpha1 "github.com/triggermesh/triggermesh-core/pkg/apis/eventing/v1alpha1"
@@ -32,22 +34,25 @@ func (r *Reconciler) ReconcileKind(ctx context.Context, rb *eventingv1alpha1.Red
 	logging.FromContext(ctx).Infow("Reconciling", zap.Any("Broker", *rb))
 
 	// Make sure the Redis deployment and service exists.
-	_, svc, err := r.redisReconciler.reconcile(ctx, rb)
+	_, redisSvc, err := r.redisReconciler.reconcile(ctx, rb)
 	if err != nil {
 		return err
 	}
 
-	// Iterate triggers and create secret
+	// Iterate triggers and create secret.
 	secret, err := r.secretReconciler.reconcile(ctx, rb)
 	if err != nil {
 		return err
 	}
 
 	// Make sure the Broker deployment for Redis exists and that it points to the Redis service.
-	_, _, err = r.brokerReconciler.reconcile(ctx, rb, svc, secret)
+	_, _, err = r.brokerReconciler.reconcile(ctx, rb, redisSvc, secret)
 	if err != nil {
 		return err
 	}
 
+	// Set address to the Redis service.
+	rb.Status.SetAddress(apis.HTTP(network.GetServiceHostname(redisSvc.Name, redisSvc.Namespace)))
+
 	return nil
 }