Versions in this module Expand all Collapse all v0 v0.0.1 Nov 12, 2020 v0.0.0 Nov 12, 2020 Changes in this version + const Declarative + const ManagedObjectsRecord + const ReconcileCount + const ReconcileFailure + var Options struct + func DefaultObjectOrder(ctx context.Context) func(o *manifest.Object) int + func ExtractApplication(objects *manifest.Objects) (*manifest.Object, error) + func GetMetricsDuration() int + func GetObjectFromCluster(obj *manifest.Object, r *Reconciler) (..., error) + func SetMetricsDuration(metricsDuration int) + func WatchAll(config *rest.Config, ctrl controller.Controller, recnl Source, ...) (chan struct{}, error) + func WithApplyKustomize() reconcilerOption + func WithApplyPrune() reconcilerOption + func WithApplyValidation() reconcilerOption + func WithConfigOverride(config string) reconcilerOption + func WithLabels(labelMaker LabelMaker) reconcilerOption + func WithManagedApplication(labelMaker LabelMaker) reconcilerOption + func WithManifestController(mc ManifestController) reconcilerOption + func WithObjectTransform(operations ...ObjectTransform) reconcilerOption + func WithOwner(ownerFn OwnerSelector) reconcilerOption + func WithPreserveNamespace() reconcilerOption + func WithRawManifestOperation(operations ...ManifestOperation) reconcilerOption + func WithReconcileMetrics(metricsDuration int, ot *ObjectTracker) reconcilerOption + func WithStatus(status Status) reconcilerOption + type DeclarativeObject interface + func SourceAsOwner(ctx context.Context, src DeclarativeObject, obj manifest.Object, ...) (DeclarativeObject, error) + type DynamicWatch interface + Add func(trigger schema.GroupVersionKind, options metav1.ListOptions, ...) error + type LabelMaker = func(context.Context, DeclarativeObject) map[string]string + func SourceLabel(scheme *runtime.Scheme) LabelMaker + type ManifestController interface + ResolveManifest func(ctx context.Context, object runtime.Object) (map[string]string, error) + type ManifestLoaderFunc func() (ManifestController, error) + var DefaultManifestLoader ManifestLoaderFunc + type ManifestOperation = func(context.Context, DeclarativeObject, string) (string, error) + type ObjectTracker struct + func NewObjectTracker() *ObjectTracker + func (ot *ObjectTracker) GetMetricsDuration() int + func (ot *ObjectTracker) SetMetricsDuration(metricsDuration int) + type ObjectTransform = func(context.Context, DeclarativeObject, *manifest.Objects) error + func AddLabels(labels map[string]string) ObjectTransform + func ImageRegistryTransform(registry, imagePullSecret string) ObjectTransform + type OwnerSelector = func(context.Context, DeclarativeObject, manifest.Object, manifest.Objects) (DeclarativeObject, error) + type Preflight interface + Preflight func(context.Context, DeclarativeObject) error + type Reconciled interface + Reconciled func(context.Context, DeclarativeObject, *manifest.Objects) error + type Reconciler struct + func (r *Reconciler) BuildDeploymentObjects(ctx context.Context, name types.NamespacedName, instance DeclarativeObject) (*manifest.Objects, error) + func (r *Reconciler) BuildDeploymentObjectsWithFs(ctx context.Context, name types.NamespacedName, instance DeclarativeObject, ...) (*manifest.Objects, error) + func (r *Reconciler) CollectMetrics() bool + func (r *Reconciler) Init(mgr manager.Manager, prototype DeclarativeObject, opts ...reconcilerOption) error + func (r *Reconciler) IsKustomizeOptionUsed() bool + func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (result reconcile.Result, err error) + func (r *Reconciler) SetSink(sink Sink) + type Sink interface + Notify func(ctx context.Context, dest DeclarativeObject, objs *manifest.Objects) error + type Source interface + SetSink func(sink Sink) + type Status interface + type StatusBuilder struct + PreflightImpl Preflight + ReconciledImpl Reconciled + VersionCheckImpl VersionCheck + func (s *StatusBuilder) Preflight(ctx context.Context, src DeclarativeObject) error + func (s *StatusBuilder) Reconciled(ctx context.Context, src DeclarativeObject, objs *manifest.Objects) error + func (s *StatusBuilder) VersionCheck(ctx context.Context, src DeclarativeObject, objs *manifest.Objects) (bool, error) + type VersionCheck interface + VersionCheck func(context.Context, DeclarativeObject, *manifest.Objects) (bool, error)
Go to main page