Versions in this module Expand all Collapse all v1 v1.6.0 Feb 25, 2021 v1.5.1 Jan 21, 2021 Changes in this version type EMMSPI + GetAllNodes func() ([]*corev1.Node, error) v1.5.0 Nov 23, 2020 Changes in this version + const EMMFailureAnnotation + const EMMIntegratedAnnotation + const EMMTaintKey + const ExtensionIDEnv + const ExtensionIDLabel + const HealthLabel + const HealthLabelCatalogValue + const HealthLabelHealthValue + const InstanceIDLabel + const VolumeHealthAnnotation + func AddStatefulSetChanges(dc *api.CassandraDatacenter, statefulSet *appsv1.StatefulSet) *appsv1.StatefulSet + func CheckEMM(spi EMMSPI) result.ReconcileResult + func CheckNetworkPolicies(spi CheckNetworkPoliciesSPI) result.ReconcileResult + func CheckPVCHealth(spi EMMSPI) result.ReconcileResult + func GetExtensionID() string + type Catalog map[string]string + type CheckNetworkPoliciesSPI interface + GetClient func() client.Client + GetContext func() context.Context + GetDatacenter func() *api.CassandraDatacenter + GetLogger func() logr.Logger + SetDatacenterAsOwner func(controlled metav1.Object) error + type DAO interface + GetHealthData func() (*Health, error) + UpsertCatalog func(catalog Catalog) error + UpsertHealthData func(health *Health) error + func NewDao(client runtimeClient.Client, namespace string) DAO + type DAOImpl struct + func (dao *DAOImpl) GetHealthData() (*Health, error) + func (dao *DAOImpl) UpsertCatalog(catalog Catalog) error + func (dao *DAOImpl) UpsertHealthData(health *Health) error + type EMMChecks interface + IsInitialized func() bool + IsStopped func() bool + type EMMFailure string + const GenericFailure + const NotEnoughResources + const TooManyExistingFailures + type EMMOperations interface + type EMMSPI interface + GetAllNodesInDC func() ([]*corev1.Node, error) + GetAllPodsNotReadyInDC func() []*corev1.Pod + GetDCPods func() []*corev1.Pod + GetInProgressNodeReplacements func() []string + GetLogger func() logr.Logger + GetNotReadyPodsBootstrappedInDC func() []*corev1.Pod + GetPodPVCs func(pod *corev1.Pod) ([]*corev1.PersistentVolumeClaim, error) + IsInitialized func() bool + IsStopped func() bool + RemovePod func(pod *corev1.Pod) error + StartNodeReplace func(podName string) error + UpdatePod func(pod *corev1.Pod) error + type EMMService interface + type EMMServiceImpl struct + type EMMTaintValue string + const EvacuateAllData + const PlannedDowntime + type Health struct + type HealthStatus string + const HealthGreen + const HealthRed + const HealthYellow + type HealthStatusUpdater interface + Update func(dc api.CassandraDatacenter) error + func NewHealthStatusUpdater(client runtimeClient.Client, namespace string) HealthStatusUpdater + type HealthStatusUpdaterImpl struct + func (updater *HealthStatusUpdaterImpl) Update(dc api.CassandraDatacenter) error + type InstanceHealth struct + Health HealthStatus + Instance string + Namespace string + type NoOpUpdater struct + func (*NoOpUpdater) Update(dc api.CassandraDatacenter) error + type Spec map[string]interface + type Status struct + InstanceHealth []InstanceHealth + type VolumeHealth string + const VolumeHealthInaccessible
Go to main page