dockercomposelogstream: reconciler scaffolding (#5761)

internal/controllers/core/dockercomposelogstream/reconciler.go

@@ -0,0 +1,49 @@
+package dockercomposelogstream
+
+import (
+	"context"
+
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
+	ctrl "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/builder"
+	ctrlclient "sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/reconcile"
+
+	"github.com/tilt-dev/tilt/internal/store"
+	"github.com/tilt-dev/tilt/pkg/apis/core/v1alpha1"
+)
+
+type Reconciler struct {
+	client ctrlclient.Client
+	store  store.RStore
+}
+
+var _ reconcile.Reconciler = &Reconciler{}
+
+func NewReconciler(client ctrlclient.Client, store store.RStore) *Reconciler {
+	return &Reconciler{
+		client: client,
+		store:  store,
+	}
+}
+
+func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
+	obj := &v1alpha1.DockerComposeLogStream{}
+	err := r.client.Get(ctx, req.NamespacedName, obj)
+	if err != nil && !apierrors.IsNotFound(err) {
+		return ctrl.Result{}, err
+	}
+
+	if apierrors.IsNotFound(err) || obj.ObjectMeta.DeletionTimestamp != nil {
+		return ctrl.Result{}, nil
+	}
+
+	return ctrl.Result{}, nil
+}
+
+func (r *Reconciler) CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error) {
+	b := ctrl.NewControllerManagedBy(mgr).
+		For(&v1alpha1.DockerComposeLogStream{})
+
+	return b, nil
+}

internal/controllers/core/dockercomposelogstream/wire.go

@@ -0,0 +1,7 @@
+package dockercomposelogstream
+
+import "github.com/google/wire"
+
+var WireSet = wire.NewSet(
+	NewReconciler,
+)

internal/controllers/wire.go

@@ -8,6 +8,7 @@ import (
 	"github.com/tilt-dev/tilt/internal/controllers/core/cmd"
 	"github.com/tilt-dev/tilt/internal/controllers/core/cmdimage"
 	"github.com/tilt-dev/tilt/internal/controllers/core/configmap"
+	"github.com/tilt-dev/tilt/internal/controllers/core/dockercomposelogstream"
 	"github.com/tilt-dev/tilt/internal/controllers/core/dockercomposeservice"
 	"github.com/tilt-dev/tilt/internal/controllers/core/dockerimage"
 	"github.com/tilt-dev/tilt/internal/controllers/core/extension"
@@ -59,6 +60,7 @@ func ProvideControllers(
 	clr *cluster.Reconciler,
 	dcr *dockercomposeservice.Reconciler,
 	imr *imagemap.Reconciler,
+	dclsr *dockercomposelogstream.Reconciler,
 ) []Controller {
 	return []Controller{
 		fileWatch,
@@ -81,6 +83,7 @@ func ProvideControllers(
 		clr,
 		dcr,
 		imr,
+		dclsr,
 	}
 }
 
@@ -109,4 +112,5 @@ var WireSet = wire.NewSet(
 	cmdimage.WireSet,
 	dockercomposeservice.WireSet,
 	imagemap.WireSet,
+	dockercomposelogstream.WireSet,
 )

internal/engine/upper_test.go

@@ -42,6 +42,7 @@ import (
 	"github.com/tilt-dev/tilt/internal/controllers/core/cmd"
 	"github.com/tilt-dev/tilt/internal/controllers/core/cmdimage"
 	"github.com/tilt-dev/tilt/internal/controllers/core/configmap"
+	"github.com/tilt-dev/tilt/internal/controllers/core/dockercomposelogstream"
 	"github.com/tilt-dev/tilt/internal/controllers/core/dockercomposeservice"
 	"github.com/tilt-dev/tilt/internal/controllers/core/dockerimage"
 	"github.com/tilt-dev/tilt/internal/controllers/core/extension"
@@ -3398,6 +3399,7 @@ func newTestFixture(t *testing.T, options ...fixtureOptions) *testFixture {
 		cluster.FakeDockerClientOrError(dockerClient, nil),
 		cluster.FakeKubernetesClientOrError(kClient, nil),
 		wsl)
+	dclsr := dockercomposelogstream.NewReconciler(cdc, st)
 
 	cb := controllers.NewControllerBuilder(tscm, controllers.ProvideControllers(
 		fwc,
@@ -3420,6 +3422,7 @@ func newTestFixture(t *testing.T, options ...fixtureOptions) *testFixture {
 		clr,
 		dcr,
 		imagemap.NewReconciler(cdc, st),
+		dclsr,
 	))
 
 	dp := dockerprune.NewDockerPruner(dockerClient)