controller

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2025 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppDeploymentAdapter added in v0.0.2 

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

func (*AppDeploymentAdapter) EnsureApplicationValid added in v0.0.2 

func (a *AppDeploymentAdapter) EnsureApplicationValid(ctx context.Context) (reconciler.OperationResult, error)

func (*AppDeploymentAdapter) EnsureDependenciesReady added in v0.0.2 

func (a *AppDeploymentAdapter) EnsureDependenciesReady(ctx context.Context) (reconciler.OperationResult, error)

func (*AppDeploymentAdapter) EnsureDeployingFinished added in v0.0.2 

func (a *AppDeploymentAdapter) EnsureDeployingFinished(ctx context.Context) (reconciler.OperationResult, error)

EnsureDeployingFinished checks if the provision job exists if not exist then create a new provision job if job is exist && running then requeue and waiting for the job complete if job is exist && failed then delete the job and create a new one if job is exist && succeeded then update the appdeployment status to ready

func (*AppDeploymentAdapter) EnsureFinalizer added in v0.0.2 

func (a *AppDeploymentAdapter) EnsureFinalizer(ctx context.Context) (reconciler.OperationResult, error)

func (*AppDeploymentAdapter) EnsureFinalizerDeleted added in v0.0.2 

func (a *AppDeploymentAdapter) EnsureFinalizerDeleted(ctx context.Context) (reconciler.OperationResult, error)

func (*AppDeploymentAdapter) EnsureTeardownFinished added in v0.0.2 

func (a *AppDeploymentAdapter) EnsureTeardownFinished(ctx context.Context) (reconciler.OperationResult, error)

type AppDeploymentAdapterInterface added in v0.0.2 

type AppDeploymentAdapterInterface interface {
	EnsureApplicationValid(ctx context.Context) (reconciler.OperationResult, error)
	EnsureFinalizer(ctx context.Context) (reconciler.OperationResult, error)
	EnsureFinalizerDeleted(ctx context.Context) (reconciler.OperationResult, error)
	EnsureDependenciesReady(ctx context.Context) (reconciler.OperationResult, error)
	EnsureDeployingFinished(ctx context.Context) (reconciler.OperationResult, error)
	EnsureTeardownFinished(ctx context.Context) (reconciler.OperationResult, error)
}

func NewAppDeploymentAdapter added in v0.0.2 

func NewAppDeploymentAdapter(ctx context.Context, appDeployment *appsv1.AppDeployment, logger logr.Logger, client client.Client, recorder record.EventRecorder) AppDeploymentAdapterInterface

type AppDeploymentReconciler 

type AppDeploymentReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

AppDeploymentReconciler reconciles a AppDeployment object

func (*AppDeploymentReconciler) Reconcile 

func (r *AppDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the AppDeployment object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.20.4/pkg/reconcile

func (*AppDeploymentReconciler) ReconcileHandler added in v0.0.2 

func (r *AppDeploymentReconciler) ReconcileHandler(ctx context.Context, adapter AppDeploymentAdapterInterface) (ctrl.Result, error)

func (*AppDeploymentReconciler) SetupWithManager 

func (r *AppDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type CacheAdapter added in v0.0.2 

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

func (*CacheAdapter) AdjustCache added in v0.0.2 

func (c *CacheAdapter) AdjustCache(ctx context.Context) (reconciler.OperationResult, error)

func (*CacheAdapter) CalculateKeepAliveCount added in v0.0.2 

func (c *CacheAdapter) CalculateKeepAliveCount(ctx context.Context) (reconciler.OperationResult, error)

CalculateKeepAliveCount calculates the keepAliveCount for the cache cr

func (*CacheAdapter) CheckCacheExpiry added in v0.0.2 

func (c *CacheAdapter) CheckCacheExpiry(ctx context.Context) (reconciler.OperationResult, error)

CheckCacheExpiry checks if the cache cr is expired. If it is, the cr is deleted.

func (*CacheAdapter) EnsureCacheInitialized added in v0.0.2 

func (c *CacheAdapter) EnsureCacheInitialized(ctx context.Context) (reconciler.OperationResult, error)

EnsureCacheInitialized ensures the cache cr is initialized

type CacheAdapterInterface added in v0.0.2 

type CacheAdapterInterface interface {
	CheckCacheExpiry(ctx context.Context) (reconciler.OperationResult, error)
	EnsureCacheInitialized(ctx context.Context) (reconciler.OperationResult, error)
	CalculateKeepAliveCount(ctx context.Context) (reconciler.OperationResult, error)
	AdjustCache(ctx context.Context) (reconciler.OperationResult, error)
}

func NewCacheAdapter added in v0.0.2 

func NewCacheAdapter(ctx context.Context,
	cache *appsv1.Cache, logger logr.Logger, client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder,
	fn func(owner, controlled metav1.Object, scheme *runtime.Scheme, opts ...controllerutil.OwnerReferenceOption) error) CacheAdapterInterface

type CacheReconciler added in v0.0.2 

type CacheReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

CacheReconciler reconciles a Cache object

func (*CacheReconciler) Reconcile added in v0.0.2 

func (r *CacheReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Cache object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.1/pkg/reconcile

func (*CacheReconciler) SetupWithManager added in v0.0.2 

func (r *CacheReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type OperationAdapter added in v0.0.2 

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

func (*OperationAdapter) EnsureAllAppsAreDeleted added in v0.0.2 

func (o *OperationAdapter) EnsureAllAppsAreDeleted(ctx context.Context) (reconciler.OperationResult, error)

func (*OperationAdapter) EnsureAllAppsAreReady added in v0.0.2 

func (o *OperationAdapter) EnsureAllAppsAreReady(ctx context.Context) (reconciler.OperationResult, error)

func (*OperationAdapter) EnsureFinalizer added in v0.0.2 

func (o *OperationAdapter) EnsureFinalizer(ctx context.Context) (reconciler.OperationResult, error)

func (*OperationAdapter) EnsureFinalizerRemoved added in v0.0.2 

func (o *OperationAdapter) EnsureFinalizerRemoved(ctx context.Context) (reconciler.OperationResult, error)

func (*OperationAdapter) EnsureNotExpired added in v0.0.2 

func (o *OperationAdapter) EnsureNotExpired(ctx context.Context) (reconciler.OperationResult, error)

type OperationAdapterInterface added in v0.0.2 

type OperationAdapterInterface interface {
	EnsureNotExpired(ctx context.Context) (reconciler.OperationResult, error)
	EnsureFinalizer(ctx context.Context) (reconciler.OperationResult, error)
	EnsureFinalizerRemoved(ctx context.Context) (reconciler.OperationResult, error)
	EnsureAllAppsAreReady(ctx context.Context) (reconciler.OperationResult, error)
	EnsureAllAppsAreDeleted(ctx context.Context) (reconciler.OperationResult, error)
}

func NewOperationAdapter added in v0.0.2 

func NewOperationAdapter(ctx context.Context, operation *appsv1.Operation, logger logr.Logger, client client.Client, recorder record.EventRecorder) OperationAdapterInterface

type OperationReconciler added in v0.0.2 

type OperationReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

OperationReconciler reconciles a Operation object

func (*OperationReconciler) Reconcile added in v0.0.2 

func (r *OperationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Operation object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.20.4/pkg/reconcile

func (*OperationReconciler) ReconcileHandler added in v0.0.2 

func (r *OperationReconciler) ReconcileHandler(ctx context.Context, adapter OperationAdapterInterface) (ctrl.Result, error)

func (*OperationReconciler) SetupWithManager added in v0.0.2 

func (r *OperationReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RequirementAdapter added in v0.0.2 

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

func (*RequirementAdapter) EnsureCacheExisted added in v0.0.2 

func (r *RequirementAdapter) EnsureCacheExisted(ctx context.Context) (reconciler.OperationResult, error)

func (*RequirementAdapter) EnsureCachedOperationAcquired added in v0.0.2 

func (r *RequirementAdapter) EnsureCachedOperationAcquired(ctx context.Context) (reconciler.OperationResult, error)

func (*RequirementAdapter) EnsureInitialized added in v0.0.2 

func (r *RequirementAdapter) EnsureInitialized(ctx context.Context) (reconciler.OperationResult, error)

func (*RequirementAdapter) EnsureNotExpired added in v0.0.2 

func (r *RequirementAdapter) EnsureNotExpired(ctx context.Context) (reconciler.OperationResult, error)

func (*RequirementAdapter) EnsureOperationReady added in v0.0.2 

func (r *RequirementAdapter) EnsureOperationReady(ctx context.Context) (reconciler.OperationResult, error)

type RequirementAdapterInterface added in v0.0.2 

type RequirementAdapterInterface interface {
	EnsureNotExpired(ctx context.Context) (reconciler.OperationResult, error)
	EnsureInitialized(ctx context.Context) (reconciler.OperationResult, error)
	EnsureCacheExisted(ctx context.Context) (reconciler.OperationResult, error)
	EnsureCachedOperationAcquired(ctx context.Context) (reconciler.OperationResult, error)
	EnsureOperationReady(ctx context.Context) (reconciler.OperationResult, error)
}

func NewRequirementAdapter added in v0.0.2 

func NewRequirementAdapter(ctx context.Context, requirement *appsv1.Requirement, logger logr.Logger, client client.Client, recorder record.EventRecorder) RequirementAdapterInterface

type RequirementReconciler added in v0.0.2 

type RequirementReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

RequirementReconciler reconciles a Requirement object

func (*RequirementReconciler) Reconcile added in v0.0.2 

func (r *RequirementReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Requirement object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.20.4/pkg/reconcile

func (*RequirementReconciler) ReconcileHandler added in v0.0.2 

func (r *RequirementReconciler) ReconcileHandler(ctx context.Context, adapter RequirementAdapterInterface) (ctrl.Result, error)

func (*RequirementReconciler) SetupWithManager added in v0.0.2 

func (r *RequirementReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.