applicationconfiguration

May 28, 2021

Changes in this version

type ReconcilerOption

+ func WithLogWaitTime(longWait time.Duration) ReconcilerOption

Oct 27, 2020

Changes in this version

type Trait

+ Definition v1alpha2.TraitDefinition

Sep 7, 2020

Changes in this version

type Workload

+ RevisionEnabled bool

Aug 26, 2020

Changes in this version

+ const ControllerRevisionComponentLabel

type ComponentHandler

+ RevisionLimit int

type WorkloadApplicator

+ Finalize func(ctx context.Context, ac *v1alpha2.ApplicationConfiguration) error

+ type WorkloadApplyFns struct

+ ApplyFn func(ctx context.Context, status []v1alpha2.WorkloadStatus, w []Workload, ...) error

+ FinalizeFn func(ctx context.Context, ac *v1alpha2.ApplicationConfiguration) error

+ func (fn WorkloadApplyFns) Apply(ctx context.Context, status []v1alpha2.WorkloadStatus, w []Workload, ...) error

+ func (fn WorkloadApplyFns) Finalize(ctx context.Context, ac *v1alpha2.ApplicationConfiguration) error

Jul 27, 2020

Changes in this version

type ComponentHandler

+ AppsClient clientappv1.AppsV1Interface

+ Client client.Client

+ Logger logging.Logger

+ type ControllerHooks interface

+ Exec func(ctx context.Context, ac *v1alpha2.ApplicationConfiguration, ...) (reconcile.Result, error)

+ type ControllerHooksFn func(ctx context.Context, ac *v1alpha2.ApplicationConfiguration, ...) (reconcile.Result, error)

+ func (fn ControllerHooksFn) Exec(ctx context.Context, ac *v1alpha2.ApplicationConfiguration, ...) (reconcile.Result, error)

+ type OAMApplicationReconciler struct

+ func (r *OAMApplicationReconciler) Reconcile(req reconcile.Request) (result reconcile.Result, returnErr error)

type ReconcilerOption

+ func WithPosthook(name string, hook ControllerHooks) ReconcilerOption

+ func WithPrehook(name string, hook ControllerHooks) ReconcilerOption

Jul 21, 2020

Changes in this version

+ var ErrDataOutputNotExist = errors.New("DataOutput does not exist")

+ func ConstructRevisionName(componentName string) string

+ func ExtractComponentName(revisionName string) string

+ func IsRevisionWorkload(status v1alpha2.WorkloadStatus) bool

+ func SetWorkloadInstanceName(traitDefs []v1alpha2.TraitDefinition, w *unstructured.Unstructured, ...) error

+ func Setup(mgr ctrl.Manager, l logging.Logger) error

+ func UnpackRevisionData(rev *appsv1.ControllerRevision) (*v1alpha2.Component, error)

+ type ComponentHandler struct

+ func (c *ComponentHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (c *ComponentHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (c *ComponentHandler) Generic(_ event.GenericEvent, _ workqueue.RateLimitingInterface)

+ func (c *ComponentHandler) IsRevisionDiff(mt metav1.Object, curComp *v1alpha2.Component) (bool, int64)

+ func (c *ComponentHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type ComponentRenderFn func(ctx context.Context, ac *v1alpha2.ApplicationConfiguration) ([]Workload, *v1alpha2.DependencyStatus, error)

+ func (fn ComponentRenderFn) Render(ctx context.Context, ac *v1alpha2.ApplicationConfiguration) ([]Workload, *v1alpha2.DependencyStatus, error)

+ type ComponentRenderer interface

+ Render func(ctx context.Context, ac *v1alpha2.ApplicationConfiguration) ([]Workload, *v1alpha2.DependencyStatus, error)

+ type GarbageCollector interface

+ Eligible func(namespace string, ws []v1alpha2.WorkloadStatus, w []Workload) []unstructured.Unstructured

+ type GarbageCollectorFn func(namespace string, ws []v1alpha2.WorkloadStatus, w []Workload) []unstructured.Unstructured

+ func (fn GarbageCollectorFn) Eligible(namespace string, ws []v1alpha2.WorkloadStatus, w []Workload) []unstructured.Unstructured

+ type Parameter struct

+ FieldPaths []string

+ Name string

+ Value intstr.IntOrString

+ type ParameterResolveFn func([]v1alpha2.ComponentParameter, []v1alpha2.ComponentParameterValue) ([]Parameter, error)

+ func (fn ParameterResolveFn) Resolve(cp []v1alpha2.ComponentParameter, cpv []v1alpha2.ComponentParameterValue) ([]Parameter, error)

+ type ParameterResolver interface

+ Resolve func([]v1alpha2.ComponentParameter, []v1alpha2.ComponentParameterValue) ([]Parameter, error)

+ type Reconciler struct

+ func NewReconciler(m ctrl.Manager, o ...ReconcilerOption) *Reconciler

+ func (r *Reconciler) Reconcile(req reconcile.Request) (reconcile.Result, error)

+ type ReconcilerOption func(*Reconciler)

+ func WithApplicator(a WorkloadApplicator) ReconcilerOption

+ func WithGarbageCollector(gc GarbageCollector) ReconcilerOption

+ func WithLogger(l logging.Logger) ReconcilerOption

+ func WithRecorder(er event.Recorder) ReconcilerOption

+ func WithRenderer(r ComponentRenderer) ReconcilerOption

+ type ResourceRenderFn func(data []byte, p ...Parameter) (*unstructured.Unstructured, error)

+ func (fn ResourceRenderFn) Render(data []byte, p ...Parameter) (*unstructured.Unstructured, error)

+ type ResourceRenderer interface

+ Render func(data []byte, p ...Parameter) (*unstructured.Unstructured, error)

+ type Trait struct

+ HasDep bool

+ Object unstructured.Unstructured

+ type Workload struct

+ ComponentName string

+ ComponentRevisionName string

+ HasDep bool

+ Scopes []unstructured.Unstructured

+ Traits []*Trait

+ Workload *unstructured.Unstructured

+ func (w Workload) Status() v1alpha2.WorkloadStatus

+ type WorkloadApplicator interface

+ Apply func(ctx context.Context, status []v1alpha2.WorkloadStatus, w []Workload, ...) error

+ type WorkloadApplyFn func(ctx context.Context, status []v1alpha2.WorkloadStatus, w []Workload, ...) error

+ func (fn WorkloadApplyFn) Apply(ctx context.Context, status []v1alpha2.WorkloadStatus, w []Workload, ...) error