View Source

const (
	
	
	EnvRuntimeNamespace = "RUNTIME_NAMESPACE"

	
	
	EnvSourceLocalhost = "SOURCE_CONTROLLER_LOCALHOST"
)

View Source

const (
	
	
	
	FeatureGateAdditiveCELDependencyCheck = "AdditiveCELDependencyCheck"

	
	
	
	
	FeatureGateCacheSecretsAndConfigMaps = "CacheSecretsAndConfigMaps"

	
	
	FeatureGateExternalArtifact = "ExternalArtifact"

	
	
	FeatureGateDisableConfigWatchers = "DisableConfigWatchers"

	
	
	
	
	
	FeatureGateDirectSourceFetch = "DirectSourceFetch"
)

View Source

var ErrInsecureHTTPBlocked = errors.New("use of insecure plain HTTP connections is blocked")

GetDefaultRateLimiter returns a new exponential failure workqueue.TypedRateLimiter with the default configuration.

GetInterruptContext returns a context that will be canceled when the object associated with a call to Reconcile() is requeued, or the input context itself if this input context is not associated with a call to Reconcile().

GetRateLimiter returns a new exponential failure workqueue.TypedRateLimiter based on RateLimiterOptions.

GetWatchConfigsPredicate parses the label selector option from WatchOptions and returns the controller-runtime predicate ready for setting up the watch.

GetWatchLabelSelector parses the label selector option from WatchOptions and returns an error if the expression is invalid.

GetWatchSelector parses the label selector option from WatchOptions and returns the label selector. If the WatchOptions contain no selectors, then a match everything is returned.

func NewControllerManagedBy(mgr manager.Manager, r *reconcilerWrapper) *controllerBuilder

NewControllerManagedBy returns a wrapped *builder.Builder that facilitates building a controller for a specific object type harvesting the capabilities of the reconciler wrapper.

WrapReconciler wraps a reconcile.TypedReconciler[ctrl.Request] to enhance it with additional functionality.

ConnectionOptions defines the configurable options for outbound connections opened by reconcilers. Consumers are expected to check for compatibility via `CheckEnvironmentCompatibility()` before using its values.

func (o *ConnectionOptions) CheckEnvironmentCompatibility() error

Metrics is a helper struct that adds the capability for recording GitOps Toolkit standard metrics to a reconciler.

Use it by embedding it in your reconciler struct:

	type MyTypeReconciler {
 	client.Client
     // ... etc.
     controller.Metrics
	}

Following the GitOps Toolkit conventions, API types used in GOTK SHOULD implement conditions.Getter to work with status condition types, and this convention MUST be followed to be able to record metrics using this helper.

Use MustMakeMetrics to create a working Metrics value; you can supply the same value to all reconcilers.

Once initialised, metrics can be recorded by calling one of the available `Record*` methods.

type QueueEventSource struct {
	Kind            string    `json:"kind"`
	Name            string    `json:"name"`
	Namespace       string    `json:"namespace"`
	UID             types.UID `json:"uid"`
	ResourceVersion string    `json:"resourceVersion"`
}

QueueEventSource holds enough tracking information about the source object that triggered a queue event and implements the error interface.

RateLimiterOptions defines the configurable options for rate limiters used on reconcilers.

type WatchOptions struct {
	
	
	AllNamespaces bool

	
	
	
	LabelSelector string

	
	
	
	ConfigsLabelSelector string
}

WatchOptions defines the configurable options for reconciler resources watcher.