controllers

Documentation

Index

• Constants
• func NewAppWorkloadReconciler(c client.Client, scheme *runtime.Scheme, ...) ...
• func NewRunnerInfoReconciler(c client.Client, scheme *runtime.Scheme, log logr.Logger) *k8s.PatchingReconciler[korifiv1alpha1.RunnerInfo, *korifiv1alpha1.RunnerInfo]
• type AppWorkloadReconciler
  • func (r *AppWorkloadReconciler) ReconcileResource(ctx context.Context, appWorkload *korifiv1alpha1.AppWorkload) (ctrl.Result, error)
  • func (r *AppWorkloadReconciler) SetupWithManager(mgr ctrl.Manager) *builder.Builder
• type AppWorkloadToStatefulsetConverter
  • func NewAppWorkloadToStatefulsetConverter(scheme *runtime.Scheme) *AppWorkloadToStatefulsetConverter
  • func (r *AppWorkloadToStatefulsetConverter) Convert(appWorkload *korifiv1alpha1.AppWorkload) (*appsv1.StatefulSet, error)
• type PDB
• type PDBUpdater
  • func NewPDBUpdater(client client.Client) *PDBUpdater
  • func (c *PDBUpdater) Update(ctx context.Context, statefulSet *appsv1.StatefulSet) error
• type RunnerInfoReconciler
  • func (r *RunnerInfoReconciler) ReconcileResource(ctx context.Context, runnerInfo *korifiv1alpha1.RunnerInfo) (ctrl.Result, error)
  • func (r *RunnerInfoReconciler) SetupWithManager(mgr ctrl.Manager) *builder.Builder
• type WorkloadToStatefulsetConverter

Constants

const (
	// Environment Variable Names
	EnvPodName              = "POD_NAME"
	EnvCFInstanceIP         = "CF_INSTANCE_IP"
	EnvCFInstanceGUID       = "CF_INSTANCE_GUID"
	EnvCFInstanceInternalIP = "CF_INSTANCE_INTERNAL_IP"
	EnvCFInstanceIndex      = "CF_INSTANCE_INDEX"

	// StatefulSet Keys
	AnnotationVersion     = "korifi.cloudfoundry.org/version"
	AnnotationAppID       = "korifi.cloudfoundry.org/application-id"
	AnnotationProcessGUID = "korifi.cloudfoundry.org/process-guid"

	LabelGUID                   = "korifi.cloudfoundry.org/guid"
	LabelVersion                = "korifi.cloudfoundry.org/version"
	LabelAppGUID                = "korifi.cloudfoundry.org/app-guid"
	LabelAppWorkloadGUID        = "korifi.cloudfoundry.org/appworkload-guid"
	LabelProcessType            = "korifi.cloudfoundry.org/process-type"
	LabelStatefulSetRunnerIndex = "korifi.cloudfoundry.org/add-stsr-index"

	ApplicationContainerName  = "application"
	AppWorkloadReconcilerName = "statefulset-runner"
	ServiceAccountName        = "korifi-app"

	LivenessFailureThreshold  = 4
	ReadinessFailureThreshold = 1

	PodAffinityTermWeight = 100
)

const PdbMinAvailableInstances = "50%"

Functions

func NewAppWorkloadReconciler

func NewAppWorkloadReconciler(
	c client.Client,
	scheme *runtime.Scheme,
	workloadsToStSet WorkloadToStatefulsetConverter,
	pdb PDB,
	log logr.Logger,
) *k8s.PatchingReconciler[korifiv1alpha1.AppWorkload, *korifiv1alpha1.AppWorkload]

func NewRunnerInfoReconciler

func NewRunnerInfoReconciler(
	c client.Client,
	scheme *runtime.Scheme,
	log logr.Logger,
) *k8s.PatchingReconciler[korifiv1alpha1.RunnerInfo, *korifiv1alpha1.RunnerInfo]

Types

type AppWorkloadReconciler

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

AppWorkloadReconciler reconciles a AppWorkload object

func (*AppWorkloadReconciler) ReconcileResource

func (r *AppWorkloadReconciler) ReconcileResource(ctx context.Context, appWorkload *korifiv1alpha1.AppWorkload) (ctrl.Result, error)

func (*AppWorkloadReconciler) SetupWithManager

func (r *AppWorkloadReconciler) SetupWithManager(mgr ctrl.Manager) *builder.Builder

type AppWorkloadToStatefulsetConverter

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

func NewAppWorkloadToStatefulsetConverter

func NewAppWorkloadToStatefulsetConverter(scheme *runtime.Scheme) *AppWorkloadToStatefulsetConverter

func (*AppWorkloadToStatefulsetConverter) Convert

func (r *AppWorkloadToStatefulsetConverter) Convert(appWorkload *korifiv1alpha1.AppWorkload) (*appsv1.StatefulSet, error)

type PDB

type PDB interface {
	Update(ctx context.Context, statefulSet *appsv1.StatefulSet) error
}

type PDBUpdater

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

func NewPDBUpdater

func NewPDBUpdater(client client.Client) *PDBUpdater

func (*PDBUpdater) Update

func (c *PDBUpdater) Update(ctx context.Context, statefulSet *appsv1.StatefulSet) error

type RunnerInfoReconciler

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

RunnerInfoReconciler reconciles a RunnerInfo object

func (*RunnerInfoReconciler) ReconcileResource

func (r *RunnerInfoReconciler) ReconcileResource(ctx context.Context, runnerInfo *korifiv1alpha1.RunnerInfo) (ctrl.Result, error)

func (*RunnerInfoReconciler) SetupWithManager

func (r *RunnerInfoReconciler) SetupWithManager(mgr ctrl.Manager) *builder.Builder

type WorkloadToStatefulsetConverter

type WorkloadToStatefulsetConverter interface {
	Convert(appWorkload *korifiv1alpha1.AppWorkload) (*appsv1.StatefulSet, error)
}