Documentation
¶
Index ¶
- Constants
- func GenericEventHandler() handler.EventHandler
- type Provision
- func (p *Provision) FinalizersFor(zk *cachev1alpha1.Workload) []finalizer.Finalizer
- func (p *Provision) Observer() error
- func (p *Provision) ProvisionConfigMap() error
- func (p *Provision) ProvisionMonitor() error
- func (p *Provision) ProvisionService() error
- func (p *Provision) ProvisionStatefulset() error
- func (p *Provision) Reconcile() error
- type ResourcesState
Constants ¶
View Source
const ( DefaultObservationInterval = 10 * time.Second DefaultRequestTimeout = 1 * time.Minute )
Variables ¶
This section is empty.
Functions ¶
func GenericEventHandler ¶
func GenericEventHandler() handler.EventHandler
GenericEventHandler returns an EventHandler that enqueues a reconciliation request from the generic event NamespacedName.
Types ¶
type Provision ¶
type Provision struct {
Workload *cachev1alpha1.Workload
CTX context.Context
Client k8s.Client
Recorder record.EventRecorder
Log logr.Logger
Labels map[string]string
Monitor *prometheus.GenericClientset
Scheme *runtime.Scheme
ExpectSts *appsv1.StatefulSet
ActualSts *appsv1.StatefulSet
Observers *observer.Manager
ZKClient *zk.BaseClient
ObservedState *observer.State
Finalizers finalizer.Handler
}
func (*Provision) FinalizersFor ¶
func (p *Provision) FinalizersFor( zk *cachev1alpha1.Workload, ) []finalizer.Finalizer
func (*Provision) ProvisionConfigMap ¶
func (*Provision) ProvisionMonitor ¶
func (*Provision) ProvisionService ¶
EnsureService makes sure the mongodb statefulset exists
func (*Provision) ProvisionStatefulset ¶
type ResourcesState ¶
type ResourcesState struct {
// AllPods are all the pods related to the cluster, including ones with a
// DeletionTimestamp tombstone set.
AllPods []corev1.Pod
// CurrentPods are all non-deleted pods.
CurrentPods []corev1.Pod
// CurrentPodsByPhase are all non-deleted indexed by their PodPhase
CurrentPodsByPhase map[corev1.PodPhase][]corev1.Pod
// DeletingPods are all deleted pods.
DeletingPods []corev1.Pod
}
ResourcesState contains information about a deployments resources.
Click to show internal directories.
Click to hide internal directories.