Documentation ¶
Index ¶
- Constants
- func EnableReconcilerDryRun()
- func RefreshGlobalWorkspaceFactory(workspaceFactory chart.Factory) errordeprecated
- func RegisterReconciler(reconcilerName string, reconciler *ComponentReconciler)
- func RegisteredReconcilers() []string
- func UseGlobalWorkspaceFactory(workspaceFactory chart.Factory) error
- type Action
- type ActionContext
- type AnnotationsInterceptor
- type ClusterWideResourceInterceptor
- type ComponentReconciler
- func (r *ComponentReconciler) Collector() prometheus.Collector
- func (r *ComponentReconciler) Debug() *ComponentReconciler
- func (r *ComponentReconciler) EnableDryRun(dryRun bool)
- func (r *ComponentReconciler) StartLocal(ctx context.Context, model *reconciler.Task, logger *zap.SugaredLogger) error
- func (r *ComponentReconciler) StartRemote(ctx context.Context, reconcilerName string) (*WorkerPool, *OccupancyTracker, error)
- func (r *ComponentReconciler) WithDeleteAction(deleteAction Action) *ComponentReconciler
- func (r *ComponentReconciler) WithHeartbeatSenderConfig(interval, timeout time.Duration) *ComponentReconciler
- func (r *ComponentReconciler) WithPostDeleteAction(postDeleteAction Action) *ComponentReconciler
- func (r *ComponentReconciler) WithPostReconcileAction(postReconcileAction Action) *ComponentReconciler
- func (r *ComponentReconciler) WithPreDeleteAction(preDeleteAction Action) *ComponentReconciler
- func (r *ComponentReconciler) WithPreReconcileAction(preReconcileAction Action) *ComponentReconciler
- func (r *ComponentReconciler) WithProgressTrackerConfig(interval, timeout time.Duration) *ComponentReconciler
- func (r *ComponentReconciler) WithReconcileAction(reconcileAction Action) *ComponentReconciler
- func (r *ComponentReconciler) WithReconcilerMetricsSet(reconcilerMetricsSet *metrics.ReconcilerMetricsSet) *ComponentReconciler
- func (r *ComponentReconciler) WithRetryDelay(retryDelay time.Duration) *ComponentReconciler
- func (r *ComponentReconciler) WithWorkers(workers int, timeout time.Duration) *ComponentReconciler
- func (r *ComponentReconciler) WithWorkspace(workspace string) *ComponentReconciler
- type FinalizerInterceptor
- type HPAInterceptor
- type Install
- type LabelsInterceptor
- type NamespaceInterceptor
- type OccupancyTracker
- type Operation
- type PVCInterceptor
- type ServicesInterceptor
- type TestCleanup
- type WorkerPool
Constants ¶
View Source
const ( ManagedByLabel = "reconciler.kyma-project.io/managed-by" KymaVersionLabel = "reconciler.kyma-project.io/origin-version" LabelReconcilerValue = "reconciler" )
View Source
const ( NameLabel = "name" SidecarInjectionLabel = "istio-injection" SignifyValidationLabel = "namespaces.warden.kyma-project.io/validate" )
View Source
const (
ManagedByAnnotation = "reconciler.kyma-project.io/managed-by-reconciler-disclaimer"
)
Variables ¶
This section is empty.
Functions ¶
func EnableReconcilerDryRun ¶
func EnableReconcilerDryRun()
func RefreshGlobalWorkspaceFactory
deprecated
func RegisterReconciler ¶
func RegisterReconciler(reconcilerName string, reconciler *ComponentReconciler)
func RegisteredReconcilers ¶
func RegisteredReconcilers() []string
Types ¶
type Action ¶
type Action interface {
Run(helper *ActionContext) error
}
type ActionContext ¶
type ActionContext struct { KubeClient kubernetes.Client WorkspaceFactory chart.Factory Context context.Context Logger *zap.SugaredLogger Task *reconciler.Task ChartProvider chart.Provider }
type AnnotationsInterceptor ¶
type AnnotationsInterceptor struct { }
func (*AnnotationsInterceptor) Intercept ¶
func (l *AnnotationsInterceptor) Intercept(resources *kubernetes.ResourceCacheList, _ string) error
type ClusterWideResourceInterceptor ¶
type ClusterWideResourceInterceptor struct {
// contains filtered or unexported fields
}
func (*ClusterWideResourceInterceptor) Intercept ¶
func (c *ClusterWideResourceInterceptor) Intercept(resources *kubernetes.ResourceCacheList, _ string) error
type ComponentReconciler ¶
type ComponentReconciler struct {
// contains filtered or unexported fields
}
func GetReconciler ¶
func GetReconciler(reconcilerName string) (*ComponentReconciler, error)
func NewComponentReconciler ¶
func NewComponentReconciler(reconcilerName string) (*ComponentReconciler, error)
func (*ComponentReconciler) Collector ¶
func (r *ComponentReconciler) Collector() prometheus.Collector
func (*ComponentReconciler) Debug ¶
func (r *ComponentReconciler) Debug() *ComponentReconciler
func (*ComponentReconciler) EnableDryRun ¶
func (r *ComponentReconciler) EnableDryRun(dryRun bool)
func (*ComponentReconciler) StartLocal ¶
func (r *ComponentReconciler) StartLocal(ctx context.Context, model *reconciler.Task, logger *zap.SugaredLogger) error
func (*ComponentReconciler) StartRemote ¶
func (r *ComponentReconciler) StartRemote(ctx context.Context, reconcilerName string) (*WorkerPool, *OccupancyTracker, error)
func (*ComponentReconciler) WithDeleteAction ¶
func (r *ComponentReconciler) WithDeleteAction(deleteAction Action) *ComponentReconciler
func (*ComponentReconciler) WithHeartbeatSenderConfig ¶
func (r *ComponentReconciler) WithHeartbeatSenderConfig(interval, timeout time.Duration) *ComponentReconciler
func (*ComponentReconciler) WithPostDeleteAction ¶
func (r *ComponentReconciler) WithPostDeleteAction(postDeleteAction Action) *ComponentReconciler
func (*ComponentReconciler) WithPostReconcileAction ¶
func (r *ComponentReconciler) WithPostReconcileAction(postReconcileAction Action) *ComponentReconciler
func (*ComponentReconciler) WithPreDeleteAction ¶
func (r *ComponentReconciler) WithPreDeleteAction(preDeleteAction Action) *ComponentReconciler
func (*ComponentReconciler) WithPreReconcileAction ¶
func (r *ComponentReconciler) WithPreReconcileAction(preReconcileAction Action) *ComponentReconciler
func (*ComponentReconciler) WithProgressTrackerConfig ¶
func (r *ComponentReconciler) WithProgressTrackerConfig(interval, timeout time.Duration) *ComponentReconciler
func (*ComponentReconciler) WithReconcileAction ¶
func (r *ComponentReconciler) WithReconcileAction(reconcileAction Action) *ComponentReconciler
func (*ComponentReconciler) WithReconcilerMetricsSet ¶
func (r *ComponentReconciler) WithReconcilerMetricsSet(reconcilerMetricsSet *metrics.ReconcilerMetricsSet) *ComponentReconciler
func (*ComponentReconciler) WithRetryDelay ¶
func (r *ComponentReconciler) WithRetryDelay(retryDelay time.Duration) *ComponentReconciler
func (*ComponentReconciler) WithWorkers ¶
func (r *ComponentReconciler) WithWorkers(workers int, timeout time.Duration) *ComponentReconciler
func (*ComponentReconciler) WithWorkspace ¶
func (r *ComponentReconciler) WithWorkspace(workspace string) *ComponentReconciler
type FinalizerInterceptor ¶
type FinalizerInterceptor struct {
// contains filtered or unexported fields
}
func (*FinalizerInterceptor) Intercept ¶
func (i *FinalizerInterceptor) Intercept(resources *kubernetes.ResourceCacheList, _ string) error
Intercept preserves finalizers on all kinds in interceptableKinds or all found resources if not specified
type HPAInterceptor ¶
type HPAInterceptor struct {
// contains filtered or unexported fields
}
func (*HPAInterceptor) Intercept ¶
func (i *HPAInterceptor) Intercept(resources *kubernetes.ResourceCacheList, namespace string) error
type Install ¶
type Install struct {
// contains filtered or unexported fields
}
func NewInstall ¶
func NewInstall(logger *zap.SugaredLogger) *Install
type LabelsInterceptor ¶
type LabelsInterceptor struct {
Version string
}
func (*LabelsInterceptor) Intercept ¶
func (l *LabelsInterceptor) Intercept(resources *kubernetes.ResourceCacheList, _ string) error
type NamespaceInterceptor ¶
type NamespaceInterceptor struct { }
func (*NamespaceInterceptor) Intercept ¶
func (l *NamespaceInterceptor) Intercept(resources *kubernetes.ResourceCacheList, _ string) error
Intercept adds the name of the namespace also as label to the namespace resource to be backward compatible with Kyma 1.x
type OccupancyTracker ¶
func (*OccupancyTracker) AssignCallbackURL ¶
func (t *OccupancyTracker) AssignCallbackURL(callbackURL string)
func (*OccupancyTracker) Track ¶
func (t *OccupancyTracker) Track(ctx context.Context, pool *WorkerPool, reconcilerName string)
type Operation ¶
type Operation interface {
Invoke(ctx context.Context, chartProvider chart.Provider, model *reconciler.Task, kubeClient kubernetes.Client) error
}
type PVCInterceptor ¶
type PVCInterceptor struct {
// contains filtered or unexported fields
}
func (*PVCInterceptor) Intercept ¶
func (i *PVCInterceptor) Intercept(resources *kubernetes.ResourceCacheList, namespace string) error
type ServicesInterceptor ¶
type ServicesInterceptor struct {
// contains filtered or unexported fields
}
func (*ServicesInterceptor) Intercept ¶
func (s *ServicesInterceptor) Intercept(resources *k8s.ResourceCacheList, namespace string) error
type TestCleanup ¶
type TestCleanup struct {
// contains filtered or unexported fields
}
func NewTestCleanup ¶
func NewTestCleanup(reconciler *ComponentReconciler, kubeClient kubernetes.Client) *TestCleanup
func (*TestCleanup) RemoveKymaComponent ¶
func (c *TestCleanup) RemoveKymaComponent(t *testing.T, version, component, namespace, url string)
type WorkerPool ¶
type WorkerPool struct {
// contains filtered or unexported fields
}
func (*WorkerPool) AssignWorker ¶
func (wa *WorkerPool) AssignWorker(ctx context.Context, model *reconciler.Task) error
func (*WorkerPool) IsClosed ¶
func (wa *WorkerPool) IsClosed() bool
func (*WorkerPool) IsFull ¶
func (wa *WorkerPool) IsFull() bool
func (*WorkerPool) RunningWorkers ¶
func (wa *WorkerPool) RunningWorkers() int
func (*WorkerPool) Size ¶
func (wa *WorkerPool) Size() int
Source Files ¶
Click to show internal directories.
Click to hide internal directories.