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) (webhook.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 PodMutator
- type ReconcileExtendedStatefulSet
- type ReconcileStatefulSetCleanup
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" )
Variables ¶
This section is empty.
Functions ¶
func AddExtendedStatefulSet ¶ added in v0.3.0
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) (webhook.Webhook, error)
AddPod creates a new hook for working with Pods and adds it to the Manager
func AddStatefulSetCleanup ¶ added in v0.3.0
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
Types ¶
type PodMutator ¶
type PodMutator struct {
// contains filtered or unexported fields
}
PodMutator changes pod definitions
func (*PodMutator) Handle ¶
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 ¶ added in v0.3.0
type ReconcileStatefulSetCleanup struct {
// contains filtered or unexported fields
}
ReconcileStatefulSetCleanup reconciles an ExtendedStatefulSet object when references changes
Source Files
¶
- extendedstatefulset_controller.go
- extendedstatefulset_reconciler.go
- pod_mutator.go
- pod_webhook.go
- statefulset_cleanup_controller.go
- statefulset_cleanup_reconciler.go
- util.go
- volumes.go