extendedstatefulset

Documentation

Index

• Constants
• func Add(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 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
• 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)

Constants

const (
	// OptimisticLockErrorMsg is an error message shown when locking fails
	OptimisticLockErrorMsg = "the object has been modified; please apply your changes to the latest version and try again"
	// 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 = "CF_OPERATOR_AZ_INDEX"
)

Functions

func Add

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

Add 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 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

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.