extendedstatefulset

Documentation

Index

• Constants
• func AddExtendedStatefulSet(ctx context.Context, config *config.Config, mgr manager.Manager) error
• func AddStatefulSetCleanup(ctx context.Context, config *config.Config, mgr manager.Manager) error
• func NewExtendedStatefulsetPodMutator(log *zap.SugaredLogger, config *config.Config) *wh.OperatorWebhook
• func NewPodMutator(log *zap.SugaredLogger, config *config.Config) admission.Handler
• func NewReconciler(ctx context.Context, config *config.Config, mgr manager.Manager, ...) reconcile.Reconciler
• func NewStatefulSetCleanupReconciler(ctx context.Context, config *config.Config, mgr manager.Manager) reconcile.Reconciler
• type PodMutator
  • func (m *PodMutator) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (m *PodMutator) InjectClient(c client.Client) error
  • func (m *PodMutator) InjectDecoder(d *admission.Decoder) error
• type ReconcileExtendedStatefulSet
  • func (r *ReconcileExtendedStatefulSet) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type ReconcileStatefulSetCleanup
  • func (r *ReconcileStatefulSetCleanup) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

const (
	// EnvKubeAz is set by available zone name
	EnvKubeAz = "KUBE_AZ"
	// EnvBoshAz is set by available zone name
	EnvBoshAz = "BOSH_AZ"
	// EnvReplicas describes the number of replicas in the ExtendedStatefulSet
	EnvReplicas = "REPLICAS"
	// EnvCfOperatorAz is set by available zone name
	EnvCfOperatorAz = "CF_OPERATOR_AZ"
	// EnvCFOperatorAZIndex is set by available zone index
	EnvCFOperatorAZIndex = "AZ_INDEX"
)

Functions

func AddExtendedStatefulSet

func AddExtendedStatefulSet(ctx context.Context, config *config.Config, mgr manager.Manager) error

AddExtendedStatefulSet creates a new ExtendedStatefulSet controller to watch for the custom resource and reconcile it into statefulsets.

func AddStatefulSetCleanup

func AddStatefulSetCleanup(ctx context.Context, config *config.Config, mgr manager.Manager) error

AddStatefulSetCleanup creates a new statefulset cleanup controller and adds it to the manager. The purpose of this controller is to delete the temporary statefulset used to keep the volumes alive.

func NewExtendedStatefulsetPodMutator

func NewExtendedStatefulsetPodMutator(log *zap.SugaredLogger, config *config.Config) *wh.OperatorWebhook

NewExtendedStatefulsetPodMutator creates a pod mutator for managing volumes

func NewPodMutator

func NewPodMutator(log *zap.SugaredLogger, config *config.Config) admission.Handler

NewPodMutator returns a new reconcile.Reconciler

func NewReconciler

func NewReconciler(ctx context.Context, config *config.Config, mgr manager.Manager, srf setReferenceFunc, store vss.VersionedSecretStore) reconcile.Reconciler

NewReconciler returns a new reconcile.Reconciler

func NewStatefulSetCleanupReconciler

func NewStatefulSetCleanupReconciler(ctx context.Context, config *config.Config, mgr manager.Manager) reconcile.Reconciler

NewStatefulSetCleanupReconciler returns a new reconcile.Reconciler

Types

type PodMutator

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

PodMutator changes pod definitions

func (*PodMutator) Handle

func (m *PodMutator) Handle(ctx context.Context, req admission.Request) admission.Response

Handle manages volume claims for ExtendedStatefulSet pods

func (*PodMutator) InjectClient

func (m *PodMutator) InjectClient(c client.Client) error

InjectClient injects the client.

func (*PodMutator) InjectDecoder

func (m *PodMutator) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder.

type ReconcileExtendedStatefulSet

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

ReconcileExtendedStatefulSet reconciles an ExtendedStatefulSet object

func (*ReconcileExtendedStatefulSet) Reconcile

func (r *ReconcileExtendedStatefulSet) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a ExtendedStatefulSet object and makes changes based on the state read and what is in the ExtendedStatefulSet.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

type ReconcileStatefulSetCleanup

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

ReconcileStatefulSetCleanup reconciles an ExtendedStatefulSet object when references changes

func (*ReconcileStatefulSetCleanup) Reconcile

func (r *ReconcileStatefulSetCleanup) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile cleans up old versions and volumeManagement statefulSet of the ExtendedStatefulSet