reconciliation

package

Go to main page

Versions in this module

v1

v1.6.0

Feb 25, 2021

v1.5.1

Jan 21, 2021

Changes in this version

+ func HasStartedDecommissioning(pod *v1.Pod, epData httphelper.CassMetadataEndpoints) bool

type ReconciliationContext

+ func (rc *ReconciliationContext) GetAllNodes() ([]*corev1.Node, error)

v1.5.0

Nov 23, 2020

Changes in this version

+ const CassandraContainerName

+ const DefaultTerminationGracePeriodSeconds

+ const PvcName

+ const ServerConfigContainerName

+ const SystemLoggerContainerName

+ func DatacentersForNode(nodeName string) []types.NamespacedName

+ func IsDoneDecommissioning(pod *v1.Pod, epData httphelper.CassMetadataEndpoints) bool

+ func MapPodsToEndpointDataByName(pods []*v1.Pod, epData httphelper.CassMetadataEndpoints) map[string]httphelper.EndpointState

type ReconciliationContext

+ PSPHealthUpdater psp.HealthStatusUpdater

+ func (rc *ReconciliationContext) CalculateRackInfoForDecomm(currentSize int) ([]*RackInformation, error)

+ func (rc *ReconciliationContext) CheckDecommissioningNodes(epData httphelper.CassMetadataEndpoints) result.ReconcileResult

+ func (rc *ReconciliationContext) CheckForInvalidState() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckStatefulSetControllerCaughtUp() result.ReconcileResult

+ func (rc *ReconciliationContext) DecommissionNodeOnRack(rackName string, epData httphelper.CassMetadataEndpoints, lastPodSuffix string) error

+ func (rc *ReconciliationContext) DecommissionNodes(epData httphelper.CassMetadataEndpoints) result.ReconcileResult

+ func (rc *ReconciliationContext) DeletePodPvcs(pod *v1.Pod) error

+ func (rc *ReconciliationContext) EnsurePodsCanAbsorbDecommData(decommPod *v1.Pod, epData httphelper.CassMetadataEndpoints) error

+ func (rc *ReconciliationContext) GetAllNodesInDC() ([]*corev1.Node, error)

+ func (rc *ReconciliationContext) GetAllPodsNotReadyInDC() []*corev1.Pod

+ func (rc *ReconciliationContext) GetClient() runtimeClient.Client

+ func (rc *ReconciliationContext) GetContext() context.Context

+ func (rc *ReconciliationContext) GetDCPods() []*corev1.Pod

+ func (rc *ReconciliationContext) GetDatacenter() *api.CassandraDatacenter

+ func (rc *ReconciliationContext) GetInProgressNodeReplacements() []string

+ func (rc *ReconciliationContext) GetLogger() logr.Logger

+ func (rc *ReconciliationContext) GetNotReadyPodsBootstrappedInDC() []*corev1.Pod

+ func (rc *ReconciliationContext) GetPodPVC(podNamespace string, podName string) (*corev1.PersistentVolumeClaim, error)

+ func (rc *ReconciliationContext) GetPodPVCs(pod *corev1.Pod) ([]*corev1.PersistentVolumeClaim, error)

+ func (rc *ReconciliationContext) GetUsedStorageForPods(epData httphelper.CassMetadataEndpoints) (map[string]float64, error)

+ func (rc *ReconciliationContext) IsInitialized() bool

+ func (rc *ReconciliationContext) IsStopped() bool

+ func (rc *ReconciliationContext) RemoveDcFromNodeToDcMap(dcToRemove types.NamespacedName)

+ func (rc *ReconciliationContext) RemoveDecommissionedPodFromSts(pod *v1.Pod) error

+ func (rc *ReconciliationContext) RemovePod(pod *corev1.Pod) error

+ func (rc *ReconciliationContext) SetDatacenterAsOwner(controlled metav1.Object) error

+ func (rc *ReconciliationContext) StartNodeReplace(podName string) error

+ func (rc *ReconciliationContext) UpdatePod(pod *corev1.Pod) error

v1.4.1

Sep 10, 2020

v1.4.0

Aug 25, 2020

Changes in this version

+ var DefaultsConfigInitContainer = buildResourceRequirements(256, 256)

+ var DefaultsLoggerContainer = buildResourceRequirements(100, 64)

+ var DefaultsReaperContainer = buildResourceRequirements(2000, 512)

type ReconciliationContext

+ Endpoints *corev1.Endpoints

+ func (rc *ReconciliationContext) CheckAdditionalSeedEndpoints() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckInternodeCredentialCreation() result.ReconcileResult

+ func (rc *ReconciliationContext) CreateEndpointsForAdditionalSeedService() result.ReconcileResult

v1.3.0

Jun 30, 2020

Changes in this version

+ const ReaperAdminPort

+ const ReaperContainerName

+ const ReaperDefaultImage

+ const ReaperDefaultPullPolicy

+ const ReaperHealthCheckPath

+ const ReaperKeyspace

+ const ReaperSchemaInitJob

+ const ReaperSchemaInitJobImage

+ const ReaperUIPort

type ReconcileCassandraDatacenter

+ SecretWatches dynamicwatch.DynamicWatches

type ReconciliationContext

+ SecretWatches dynamicwatch.DynamicWatches

+ func (rc *ReconciliationContext) CheckCassandraNodeStatuses() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckReaperSchemaInitialized() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckReaperService() result.ReconcileResult

+ func (rc *ReconciliationContext) CreateUsers() result.ReconcileResult

+ func (rc *ReconciliationContext) GetUsers() []api.CassandraUser

+ func (rc *ReconciliationContext) UpdateSecretWatches() error

v1.2.0

May 29, 2020

Changes in this version

+ var ResultShouldNotRequeue reconcile.Result = reconcile.Result

+ var ResultShouldRequeueNow reconcile.Result = reconcile.Result

+ var ResultShouldRequeueSoon reconcile.Result = reconcile.Result

+ var ResultShouldRequeueTenSecs reconcile.Result = reconcile.Result

+ func FilterPodListByCassNodeState(pods []*corev1.Pod, state string) []*corev1.Pod

+ func FilterPodListByLabel(pods []*corev1.Pod, labelName string, labelVal string) []*corev1.Pod

+ func FilterPodListByLabels(pods []*corev1.Pod, labelMap map[string]string) []*corev1.Pod

+ func FindIpForHostId(endpointData httphelper.CassMetadataEndpoints, hostId string) (string, error)

+ func ListAllStartedPods(pods []*corev1.Pod) []*corev1.Pod

+ func MockSetControllerReference() func()

+ func NewReconciler(mgr manager.Manager) reconcile.Reconciler

+ func PodPtrsFromPodList(podList *corev1.PodList) []*corev1.Pod

+ type Annotated interface

+ GetAnnotations func() map[string]string

+ SetAnnotations func(annotations map[string]string)

+ type RackInformation struct

+ NodeCount int

+ RackName string

+ SeedCount int

+ type ReconcileCassandraDatacenter struct

+ func (r *ReconcileCassandraDatacenter) Reconcile(request reconcile.Request) (reconcile.Result, error)

+ type ReconciliationContext struct

+ Client runtimeClient.Client

+ Ctx context.Context

+ Datacenter *api.CassandraDatacenter

+ NodeMgmtClient httphelper.NodeMgmtClient

+ Recorder record.EventRecorder

+ ReqLogger logr.Logger

+ Request *reconcile.Request

+ Scheme *runtime.Scheme

+ Services []*corev1.Service

+ func CreateMockReconciliationContext(reqLogger logr.Logger) *ReconciliationContext

+ func CreateReconciliationContext(req *reconcile.Request, cli runtimeClient.Client, scheme *runtime.Scheme, ...) (*ReconciliationContext, error)

+ func (rc *ReconciliationContext) CalculateRackInformation() error

+ func (rc *ReconciliationContext) CheckClearActionConditions() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckConditionInitializedAndReady() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckDcPodDisruptionBudget() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckHeadlessServices() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckPodsReady(endpointData httphelper.CassMetadataEndpoints) result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRackCreation() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRackForceUpgrade() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRackLabels() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRackPodLabels() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRackPodTemplate() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRackScale() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRackStoppedState() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckRollingRestart() result.ReconcileResult

+ func (rc *ReconciliationContext) CheckSuperuserSecretCreation() result.ReconcileResult

+ func (rc *ReconciliationContext) CreateHeadlessServices() result.ReconcileResult

+ func (rc *ReconciliationContext) CreateSuperuser() result.ReconcileResult

+ func (rc *ReconciliationContext) GetStatefulSetForRack(nextRack *RackInformation) (*appsv1.StatefulSet, bool, error)

+ func (rc *ReconciliationContext) ProcessDeletion() result.ReconcileResult

+ func (rc *ReconciliationContext) ReconcileAllRacks() (reconcile.Result, error)

+ func (rc *ReconciliationContext) ReconcileNextRack(statefulSet *appsv1.StatefulSet) error

+ func (rc *ReconciliationContext) ReconcilePods(statefulSet *appsv1.StatefulSet) error

+ func (rc *ReconciliationContext) UpdateCassandraNodeStatus() error

+ func (rc *ReconciliationContext) UpdateRackNodeCount(statefulSet *appsv1.StatefulSet, newNodeCount int32) error

+ func (rc *ReconciliationContext) UpdateStatus() result.ReconcileResult

+ func (rc *ReconciliationContext) UpdateStatusForUserActions() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL