extendedstatefulset

Documentation

Index

• Constants
• func AddExtendedStatefulSet(ctx context.Context, config *config.Config, mgr manager.Manager) error
• func AddPod(log *zap.SugaredLogger, config *config.Config, mgr manager.Manager, ...) (*admission.Webhook, error)
• func AddStatefulSetCleanup(ctx context.Context, config *config.Config, mgr manager.Manager) error
• func NewPodMutator(log *zap.SugaredLogger, config *config.Config, mgr manager.Manager, ...) 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 Owner
• type PodMutator
  • func (m *PodMutator) Handle(ctx context.Context, req types.Request) types.Response
  • func (m *PodMutator) InjectClient(c client.Client) error
  • func (m *PodMutator) InjectDecoder(d types.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 and adds it to the Manager

func AddPod

func AddPod(log *zap.SugaredLogger, config *config.Config, mgr manager.Manager, hookServer *webhook.Server) (*admission.Webhook, error)

AddPod creates a new hook for working with Pods and adds it to the Manager

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

func NewPodMutator

func NewPodMutator(log *zap.SugaredLogger, config *config.Config, mgr manager.Manager, srf setReferenceFunc) admission.Handler

NewPodMutator returns a new reconcile.Reconciler

func NewReconciler

func NewReconciler(ctx context.Context, config *config.Config, mgr manager.Manager, srf setReferenceFunc) 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 Owner

type Owner interface {
	Update(context.Context, apis.Object, []apis.Object, []apis.Object) error
	RemoveOwnerReferences(context.Context, apis.Object, []apis.Object) error
	ListConfigs(context.Context, string, corev1.PodSpec) ([]apis.Object, error)
	ListConfigsOwnedBy(context.Context, apis.Object) ([]apis.Object, error)
}

Owner bundles funcs to manage ownership on referenced configmaps and secrets

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 types.Request) types.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 types.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