Help us shape the future of Go! Take the 2026 Go Developer Survey

reconciliation

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 25, 2021 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Overview

Copyright DataStax, Inc. Please see the included license file for details.

Index

Constants

View Source 
const (
	DefaultTerminationGracePeriodSeconds = 120
	ServerConfigContainerName            = "server-config-init"
	CassandraContainerName               = "cassandra"
	PvcName                              = "server-data"
	SystemLoggerContainerName            = "server-system-logger"
)
View Source 
const (
	ReaperUIPort            = 7080
	ReaperAdminPort         = 7081
	ReaperDefaultPullPolicy = corev1.PullIfNotPresent
	ReaperContainerName     = "reaper"
	ReaperHealthCheckPath   = "/healthcheck"
	ReaperKeyspace          = "reaper_db"
	ReaperSchemaInitJob     = "ReaperSchemaInitJob"
	// This code currently lives at https://github.com/jsanda/create_keyspace.
	ReaperSchemaInitJobImage = "jsanda/reaper-init-keyspace:latest"
)

Variables

View Source 
var (
	// Provides reasonable defaults for the logger container.
	DefaultsLoggerContainer = buildResourceRequirements(100, 64)

	// Provides reasonable defaults for the configuration container.
	DefaultsConfigInitContainer = buildResourceRequirements(1000, 256)

	// Provides reasonable defaults for the reaper sidecar container.
	DefaultsReaperContainer = buildResourceRequirements(2000, 512)
)
View Source 
var (
	ResultShouldNotRequeue     reconcile.Result = reconcile.Result{Requeue: false}
	ResultShouldRequeueNow     reconcile.Result = reconcile.Result{Requeue: true}
	ResultShouldRequeueSoon    reconcile.Result = reconcile.Result{Requeue: true, RequeueAfter: 2 * time.Second}
	ResultShouldRequeueTenSecs reconcile.Result = reconcile.Result{Requeue: true, RequeueAfter: 10 * time.Second}
)

Functions

func DatacentersForNode added in v1.5.0 

func DatacentersForNode(nodeName string) []types.NamespacedName

Get the dcNames and dcNamespaces for a node

func FilterPodListByCassNodeState 

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

func FilterPodListByLabel 

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

func FilterPodListByLabels 

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

Takes a list of *Pod and filters down to only the pods that match every label/val in the provided label map.

func FindIpForHostId 

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

func HasStartedDecommissioning added in v1.5.1 

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

func IsDoneDecommissioning added in v1.5.0 

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

func ListAllStartedPods 

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

func MapPodsToEndpointDataByName added in v1.5.0 

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

func MockSetControllerReference 

func MockSetControllerReference() func()

MockSetControllerReference returns a method that will automatically reverse the mock

func NewReconciler 

func NewReconciler(mgr manager.Manager) reconcile.Reconciler

NewReconciler returns a new reconcile.Reconciler

func PodPtrsFromPodList 

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

Types

type RackInformation 

type RackInformation struct {
	RackName  string
	NodeCount int
	SeedCount int
}

RackInformation contains an identifying name and a node count for a logical rack

type ReconcileCassandraDatacenter 

type ReconcileCassandraDatacenter struct {

	// SecretWatches is used in the controller when setting up the watches and
	// during reconciliation where we update the mappings for the watches.
	// Putting it here allows us to get it to both places.
	SecretWatches dynamicwatch.DynamicWatches
	// contains filtered or unexported fields
}

ReconcileCassandraDatacenter reconciles a cassandraDatacenter object This is placed here to avoid a circular dependency

func (*ReconcileCassandraDatacenter) Reconcile 

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

Reconcile reads that state of the cluster for a Datacenter object and makes changes based on the state read and what is in the cassandraDatacenter.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. See: https://godoc.org/sigs.k8s.io/controller-runtime/pkg/reconcile#Result

type ReconciliationContext 

type ReconciliationContext struct {
	Request          *reconcile.Request
	Client           runtimeClient.Client
	Scheme           *runtime.Scheme
	Datacenter       *api.CassandraDatacenter
	NodeMgmtClient   httphelper.NodeMgmtClient
	Recorder         record.EventRecorder
	ReqLogger        logr.Logger
	PSPHealthUpdater psp.HealthStatusUpdater
	SecretWatches    dynamicwatch.DynamicWatches

	// According to golang recommendations the context should not be stored in a struct but given that
	// this is passed around as a parameter we feel that its a fair compromise. For further discussion
	// see: golang/go#22602
	Ctx context.Context

	Services  []*corev1.Service
	Endpoints *corev1.Endpoints
	// contains filtered or unexported fields
}

ReconciliationContext contains all of the input necessary to calculate a list of ReconciliationActions

func CreateMockReconciliationContext 

func CreateMockReconciliationContext(
	reqLogger logr.Logger) *ReconciliationContext

CreateMockReconciliationContext ...

func CreateReconciliationContext 

func CreateReconciliationContext(
	req *reconcile.Request,
	cli runtimeClient.Client,
	scheme *runtime.Scheme,
	rec record.EventRecorder,
	secretWatches dynamicwatch.DynamicWatches,
	reqLogger logr.Logger) (*ReconciliationContext, error)

CreateReconciliationContext gathers all information needed for computeReconciliationActions into a struct.

func (*ReconciliationContext) CalculateRackInfoForDecomm added in v1.5.0 

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

func (*ReconciliationContext) CalculateRackInformation 

func (rc *ReconciliationContext) CalculateRackInformation() error

CalculateRackInformation determine how many nodes per rack are needed

func (*ReconciliationContext) CheckAdditionalSeedEndpoints added in v1.4.0 

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

func (*ReconciliationContext) CheckCassandraNodeStatuses added in v1.3.0 

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

func (*ReconciliationContext) CheckClearActionConditions 

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

func (*ReconciliationContext) CheckConditionInitializedAndReady 

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

func (*ReconciliationContext) CheckDcPodDisruptionBudget 

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

func (*ReconciliationContext) CheckDecommissioningNodes added in v1.5.0 

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

Wait for decommissioning nodes to finish before continuing to reconcile

func (*ReconciliationContext) CheckForInvalidState added in v1.5.0 

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

func (*ReconciliationContext) CheckHeadlessServices 

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

ReconcileHeadlessService ...

func (*ReconciliationContext) CheckInternodeCredentialCreation added in v1.4.0 

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

func (*ReconciliationContext) CheckPodsReady 

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

CheckPodsReady loops over all the server pods and starts them

func (*ReconciliationContext) CheckRackCreation 

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

func (*ReconciliationContext) CheckRackForceUpgrade 

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

func (*ReconciliationContext) CheckRackLabels 

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

func (*ReconciliationContext) CheckRackPodLabels 

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

CheckRackPodLabels checks each pod and its volume(s) and makes sure they have the proper labels

func (*ReconciliationContext) CheckRackPodTemplate 

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

func (*ReconciliationContext) CheckRackScale 

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

CheckRackScale loops over each statefulset and makes sure that it has the right amount of desired replicas. At this time we can only increase the amount of replicas.

func (*ReconciliationContext) CheckRackStoppedState 

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

func (*ReconciliationContext) CheckReaperSchemaInitialized added in v1.3.0 

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

func (*ReconciliationContext) CheckReaperService added in v1.3.0 

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

func (*ReconciliationContext) CheckRollingRestart 

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

func (*ReconciliationContext) CheckStatefulSetControllerCaughtUp added in v1.5.0 

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

func (*ReconciliationContext) CheckSuperuserSecretCreation 

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

func (*ReconciliationContext) CreateEndpointsForAdditionalSeedService added in v1.4.0 

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

func (*ReconciliationContext) CreateHeadlessServices 

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

func (*ReconciliationContext) CreateUsers added in v1.3.0 

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

func (*ReconciliationContext) DecommissionNodeOnRack added in v1.5.0 

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

func (*ReconciliationContext) DecommissionNodes added in v1.5.0 

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

func (*ReconciliationContext) DeletePodPvcs added in v1.5.0 

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

func (*ReconciliationContext) EnsurePodsCanAbsorbDecommData added in v1.5.0 

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

func (*ReconciliationContext) GetAllNodes added in v1.5.1 

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

func (*ReconciliationContext) GetAllNodesInDC added in v1.5.0 

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

func (*ReconciliationContext) GetAllPodsNotReadyInDC added in v1.5.0 

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

func (*ReconciliationContext) GetClient added in v1.5.0 

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

func (*ReconciliationContext) GetContext added in v1.5.0 

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

func (*ReconciliationContext) GetDCPods added in v1.5.0 

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

func (*ReconciliationContext) GetDatacenter added in v1.5.0 

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

func (*ReconciliationContext) GetInProgressNodeReplacements added in v1.5.0 

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

func (*ReconciliationContext) GetLogger added in v1.5.0 

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

func (*ReconciliationContext) GetNotReadyPodsBootstrappedInDC added in v1.5.0 

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

func (*ReconciliationContext) GetPodPVC added in v1.5.0 

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

func (*ReconciliationContext) GetPodPVCs added in v1.5.0 

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

func (*ReconciliationContext) GetStatefulSetForRack 

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

GetStatefulSetForRack returns the statefulset for the rack and whether it currently exists and whether an error occurred

func (*ReconciliationContext) GetUsedStorageForPods added in v1.5.0 

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

func (*ReconciliationContext) GetUsers added in v1.3.0 

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

func (*ReconciliationContext) IsInitialized added in v1.5.0 

func (rc *ReconciliationContext) IsInitialized() bool

func (*ReconciliationContext) IsStopped added in v1.5.0 

func (rc *ReconciliationContext) IsStopped() bool

func (*ReconciliationContext) ProcessDeletion 

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

ProcessDeletion ...

func (*ReconciliationContext) ReconcileAllRacks 

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

ReconcileAllRacks determines if a rack needs to be reconciled.

func (*ReconciliationContext) ReconcileNextRack 

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

ReconcileNextRack ensures that the resources for a rack have been properly created

func (*ReconciliationContext) ReconcilePods 

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

ReconcilePods ...

func (*ReconciliationContext) RemoveDcFromNodeToDcMap added in v1.5.0 

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

func (*ReconciliationContext) RemoveDecommissionedPodFromSts added in v1.5.0 

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

func (*ReconciliationContext) RemovePod added in v1.5.0 

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

func (*ReconciliationContext) SetDatacenterAsOwner added in v1.5.0 

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

func (*ReconciliationContext) StartNodeReplace added in v1.5.0 

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

func (*ReconciliationContext) UpdateCassandraNodeStatus 

func (rc *ReconciliationContext) UpdateCassandraNodeStatus() error

func (*ReconciliationContext) UpdatePod added in v1.5.0 

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

func (*ReconciliationContext) UpdateRackNodeCount 

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

Updates the node count on a rack (statefulset)

func (*ReconciliationContext) UpdateSecretWatches added in v1.3.0 

func (rc *ReconciliationContext) UpdateSecretWatches() error

func (*ReconciliationContext) UpdateStatus 

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

func (*ReconciliationContext) UpdateStatusForUserActions 

func (rc *ReconciliationContext) UpdateStatusForUserActions() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.