stset

Documentation

Index

• Constants
• func MebibyteQuantity(miB int64) resource.Quantity
• func StatefulSetLabelSelector(lrp *eiriniv1.LRP) *metav1.LabelSelector
• type Desirer
  • func NewDesirer(logger lager.Logger, lrpToStatefulSetConverter LRPToStatefulSetConverter, ...) *Desirer
  • func (d *Desirer) Desire(ctx context.Context, lrp *eiriniv1.LRP) error
• type LRPToStatefulSet
  • func NewLRPToStatefulSetConverter(applicationServiceAccount string, registrySecretName string, ...) *LRPToStatefulSet
  • func (c *LRPToStatefulSet) Convert(statefulSetName string, lrp *eiriniv1.LRP, ...) (*appsv1.StatefulSet, error)
• type LRPToStatefulSetConverter
• type PodDisruptionBudgetUpdater
• type ProbeCreator
• type Updater
  • func NewUpdater(logger lager.Logger, client client.Client, ...) *Updater
  • func (u *Updater) Update(ctx context.Context, lrp *eiriniv1.LRP, stSet *appsv1.StatefulSet) error

Constants

const (
	AppSourceType = "APP"

	AnnotationAppName              = "korifi.cloudfoundry.org/application-name"
	AnnotationVersion              = "korifi.cloudfoundry.org/version"
	AnnotationAppID                = "korifi.cloudfoundry.org/application-id"
	AnnotationSpaceName            = "korifi.cloudfoundry.org/space-name"
	AnnotationOrgName              = "korifi.cloudfoundry.org/org-name"
	AnnotationOrgGUID              = "korifi.cloudfoundry.org/org-guid"
	AnnotationSpaceGUID            = "korifi.cloudfoundry.org/space-guid"
	AnnotationProcessGUID          = "korifi.cloudfoundry.org/process-guid"
	AnnotationLastReportedAppCrash = "korifi.cloudfoundry.org/last-reported-app-crash"
	AnnotationLastReportedLRPCrash = "korifi.cloudfoundry.org/last-reported-lrp-crash"

	LabelGUID        = "korifi.cloudfoundry.org/guid"
	LabelOrgGUID     = AnnotationOrgGUID
	LabelOrgName     = AnnotationOrgName
	LabelSpaceGUID   = AnnotationSpaceGUID
	LabelSpaceName   = AnnotationSpaceName
	LabelVersion     = "korifi.cloudfoundry.org/version"
	LabelAppGUID     = "korifi.cloudfoundry.org/app-guid"
	LabelProcessType = "korifi.cloudfoundry.org/process-type"
	LabelSourceType  = "korifi.cloudfoundry.org/source-type"

	ApplicationContainerName = "opi"

	PdbMinAvailableInstances          = 1
	PrivateRegistrySecretGenerateName = "private-registry-"
)

const PodAffinityTermWeight = 100

Functions

func MebibyteQuantity

func MebibyteQuantity(miB int64) resource.Quantity

func StatefulSetLabelSelector

func StatefulSetLabelSelector(lrp *eiriniv1.LRP) *metav1.LabelSelector

Types

type Desirer

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

func NewDesirer

func NewDesirer(
	logger lager.Logger,
	lrpToStatefulSetConverter LRPToStatefulSetConverter,
	podDisruptionBudgetCreator PodDisruptionBudgetUpdater,
	client client.Client,
	scheme *runtime.Scheme,
) *Desirer

func (*Desirer) Desire

func (d *Desirer) Desire(ctx context.Context, lrp *eiriniv1.LRP) error

type LRPToStatefulSet

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

func NewLRPToStatefulSetConverter

func NewLRPToStatefulSetConverter(
	applicationServiceAccount string,
	registrySecretName string,
	allowAutomountServiceAccountToken bool,
	livenessProbeCreator ProbeCreator,
	readinessProbeCreator ProbeCreator,
) *LRPToStatefulSet

func (*LRPToStatefulSet) Convert

func (c *LRPToStatefulSet) Convert(statefulSetName string, lrp *eiriniv1.LRP, privateRegistrySecret *corev1.Secret) (*appsv1.StatefulSet, error)

type LRPToStatefulSetConverter

type LRPToStatefulSetConverter interface {
	Convert(statefulSetName string, lrp *eiriniv1.LRP, privateRegistrySecret *corev1.Secret) (*appsv1.StatefulSet, error)
}

type PodDisruptionBudgetUpdater

type PodDisruptionBudgetUpdater interface {
	Update(ctx context.Context, stset *appsv1.StatefulSet, lrp *eiriniv1.LRP) error
}

type ProbeCreator

type ProbeCreator func(lrp *eiriniv1.LRP) *corev1.Probe

type Updater

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

func NewUpdater

func NewUpdater(logger lager.Logger, client client.Client, pdbUpdater PodDisruptionBudgetUpdater) *Updater

func (*Updater) Update

func (u *Updater) Update(ctx context.Context, lrp *eiriniv1.LRP, stSet *appsv1.StatefulSet) error