Documentation
¶
Index ¶
Constants ¶
View Source
const ( // Environment Variable Names EnvPodName = "POD_NAME" EnvCFInstanceIP = "CF_INSTANCE_IP" EnvCFInstanceGUID = "CF_INSTANCE_GUID" EnvCFInstanceInternalIP = "CF_INSTANCE_INTERNAL_IP" EnvCFInstanceIndex = "CF_INSTANCE_INDEX" EnvServiceBindingRoot = "SERVICE_BINDING_ROOT" // StatefulSet Keys AnnotationVersion = "korifi.cloudfoundry.org/version" AnnotationAppID = "korifi.cloudfoundry.org/application-id" AnnotationProcessGUID = "korifi.cloudfoundry.org/process-guid" LabelVersion = "korifi.cloudfoundry.org/version" LabelAppGUID = "korifi.cloudfoundry.org/app-guid" LabelAppWorkloadGUID = "korifi.cloudfoundry.org/appworkload-guid" LabelProcessType = "korifi.cloudfoundry.org/process-type" ApplicationContainerName = "application" ServiceAccountName = "korifi-app" LivenessFailureThreshold = 4 ReadinessFailureThreshold = 1 )
View Source
const PdbMinAvailableInstances = "50%"
Variables ¶
This section is empty.
Functions ¶
func NewAppWorkloadReconciler ¶
func NewAppWorkloadReconciler( c client.Client, scheme *runtime.Scheme, workloadsToStSet WorkloadToStatefulsetConverter, pdb PDB, log logr.Logger, stateCollector *state.AppWorkloadStateCollector, ) *k8s.PatchingReconciler[korifiv1alpha1.AppWorkload, *korifiv1alpha1.AppWorkload]
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 WorkloadToStatefulsetConverter ¶
type WorkloadToStatefulsetConverter interface {
Convert(appWorkload *korifiv1alpha1.AppWorkload) (*appsv1.StatefulSet, error)
}
Click to show internal directories.
Click to hide internal directories.