ContainerImage.Pinniped/internal/controllerlib/test/integration/examplecontroller/starter/starter.go

// Copyright 2020 the Pinniped contributors. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

package starter

import (
	"context"
	"fmt"
	"time"

	"k8s.io/client-go/informers"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/rest"
	"k8s.io/client-go/tools/events"

	"go.pinniped.dev/internal/controllerlib"
	examplecontroller "go.pinniped.dev/internal/controllerlib/test/integration/examplecontroller/controller"
)

func StartExampleController(ctx context.Context, config *rest.Config, secretData string) error {
	kubeClient, err := kubernetes.NewForConfig(config)
	if err != nil {
		return fmt.Errorf("failed to build client: %w", err)
	}

	kubeInformers := informers.NewSharedInformerFactory(kubeClient, 20*time.Minute)

	recorder := events.NewEventBroadcasterAdapter(kubeClient).NewRecorder("example-controller")

	manager := controllerlib.NewManager().
		WithController(
			examplecontroller.NewExampleCreatingController(
				kubeInformers.Core().V1().Services(),
				kubeInformers.Core().V1().Secrets(),
				kubeClient.CoreV1(),
				recorder,
				secretData,
			), 5,
		).
		WithController(
			examplecontroller.NewExampleUpdatingController(
				kubeInformers.Core().V1().Services(),
				kubeInformers.Core().V1().Secrets(),
				kubeClient.CoreV1(),
				recorder,
				secretData,
			), 5,
		)

	kubeInformers.Start(ctx.Done())
	go manager.Start(ctx)

	return nil
}