initcontroller

Documentation

Overview

Package initcontroller contains a controller that, using a DynamicMultiClusterManager, starts and stop sync controllers for each of the PublishedResources.

Index

• Constants
• func Create(remoteManager mcmanager.Manager, targetProvider InitTargetProvider, ...) error
• type InitTargetProvider
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, request mcreconcile.Request) (reconcile.Result, error)

Constants

const (
	ControllerName = "initagent-init"
)

Functions

func Create

func Create(
	remoteManager mcmanager.Manager,
	targetProvider InitTargetProvider,
	sourceFactory *source.Factory,
	clusterApplier manifest.ClusterApplier,
	initializer kcpcorev1alpha1.LogicalClusterInitializer,
	log *zap.SugaredLogger,
	numWorkers int,
) error

Create creates a new controller and importantly does *not* add it to the manager, as this controller is started/stopped by the syncmanager controller instead.

Types

type InitTargetProvider

type InitTargetProvider func(ctx context.Context) (*initializationv1alpha1.InitTarget, error)

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, request mcreconcile.Request) (reconcile.Result, error)