v1beta1

Nov 26, 2024

Changes in this version

+ const TrackCleanupTasksAnnotation

type CassandraDatacenter

+ func (dc *CassandraDatacenter) DatacenterNameStatus() bool

+ func (dc *CassandraDatacenter) LabelResourceName() string

type CassandraDatacenterStatus

+ MetadataVersion int64

Sep 17, 2024

Changes in this version

+ const UseClientBuilderAnnotation

type CassandraDatacenter

+ func (dc *CassandraDatacenter) ReadOnlyFs() bool

Jul 22, 2024

Changes in this version

+ const AllowParallelStartsAnnotations

+ const AllowStorageChangesAnnotation

type CassandraDatacenterSpec

+ MinReadySeconds *int32

+ ReadOnlyRootFilesystem *bool

type DatacenterConditionType

+ const DatacenterResizingVolumes

May 6, 2024

Changes in this version

+ const AllowUpdateAlways

+ const AllowUpdateOnce

+ const UpdateAllowedAnnotation

+ type AllowUpdateType string

type CassandraDatacenter

+ func (dc *CassandraDatacenter) GenerationChanged() bool

type CassandraNodeStatus

+ IP string

+ Rack string

type DatacenterConditionType

+ const DatacenterRequiresUpdate

Feb 22, 2024

Changes in this version

type CassandraDatacenterSpec

+ AdditionalAnnotations map[string]string

Sep 1, 2023

Changes in this version

type CassandraDatacenter

+ func (dc *CassandraDatacenter) UseClientImage() bool

type CassandraDatacenterSpec

+ DeprecatedDockerImageRunsAsCassandra *bool

Jun 30, 2023

Changes in this version

type CassandraDatacenterSpec

+ DeprecatedReplaceNodes []string

+ DeprecatedRollingRestartRequested bool

+ DeprecatedServiceAccount string

+ ServiceAccountName string

type Rack

+ DeprecatedZone string

Mar 10, 2023

Changes in this version

type CassandraDatacenter

+ func (dc *CassandraDatacenter) DatacenterName() string

Jan 30, 2023

Changes in this version

+ func ValidateAdditionalVolumes(dc CassandraDatacenter) error

+ func ValidateDeprecatedFieldUsage(dc CassandraDatacenter) error

type AdditionalVolumes

+ VolumeSource *corev1.VolumeSource

type CassandraDatacenter

+ func (dc *CassandraDatacenter) GetRack(rackName string) Rack

+ func (dc *CassandraDatacenter) LegacyInternodeEnabled() bool

+ func (in *CassandraDatacenter) CassDcName() string

+ func (in *CassandraDatacenter) SanitizedName() string

type CassandraDatacenterSpec

+ DatacenterName string

type CassandraDatacenterStatus

+ DatacenterName *string

type Rack

+ Affinity *corev1.Affinity

Jul 19, 2022

Changes in this version

+ const Finalizer

+ const NoFinalizerAnnotation

+ type CDCConfiguration struct

+ CDCConcurrentProcessors *int

+ CDCPollIntervalMs *int

+ CDCWorkingDir *string

+ ErrorCommitLogReprocessEnabled *bool

+ PulsarAuthParams *string

+ PulsarAuthPluginClassName *string

+ PulsarBatchDelayInMs *int

+ PulsarKeyBasedBatcher *bool

+ PulsarMaxPendingMessages *int

+ PulsarMaxPendingMessagesAcrossPartitions *int

+ PulsarServiceUrl *string

+ SSLAllowInsecureConnection *string

+ SSLCipherSuites *string

+ SSLEnabledProtocols *string

+ SSLHostnameVerificationEnable *string

+ SSLKeystorePassword *string

+ SSLKeystorePath *string

+ SSLProvider *string

+ SSLTruststorePassword *string

+ SSLTruststorePath *string

+ SSLTruststoreType *string

+ TopicPrefix *string

+ func (in *CDCConfiguration) DeepCopy() *CDCConfiguration

+ func (in *CDCConfiguration) DeepCopyInto(out *CDCConfiguration)

type CassandraDatacenterSpec

+ CDC *CDCConfiguration

Mar 29, 2023

Changes in this version

+ const NoAutomatedCleanupAnnotation

+ func CleanupSubdomain(input string) string

Jul 19, 2022

Changes in this version

+ func CleanLabelValue(value string) string

+ func ValidateServiceLabelsAndAnnotations(dc CassandraDatacenter) error

type DatacenterConditionType

+ const DatacenterHealthy

Feb 17, 2022

Changes in this version

+ const DecommissionOnDeleteAnnotation

+ const SkipUserCreationAnnotation

type CassandraDatacenterSpec

+ AdditionalLabels map[string]string

type CassandraDatacenterStatus

+ TrackedTasks []corev1.ObjectReference

+ func (status *CassandraDatacenterStatus) AddTaskToTrack(objectMeta metav1.ObjectMeta)

+ func (status *CassandraDatacenterStatus) RemoveTrackedTask(objectMeta metav1.ObjectMeta)

type DatacenterConditionType

+ const DatacenterDecommission

Nov 18, 2021

Changes in this version

+ var ErrFQLNotSupported = fmt.Errorf("full query logging is only supported on OSS Cassandra 4.0+")

+ func CleanupForKubernetes(input string) string

+ func ValidateFQLConfig(dc CassandraDatacenter) error

type CassandraDatacenter

+ func (dc *CassandraDatacenter) DeploymentSupportsFQL() bool

+ func (dc *CassandraDatacenter) FullQueryEnabled() (bool, error)

Oct 3, 2021

Changes in this version

+ const CassNodeState

+ const CassOperatorProgressLabel

+ const ClusterLabel

+ const ConfigHashAnnotation

+ const DatacenterAnnotation

+ const DatacenterLabel

+ const DefaultInternodePort

+ const DefaultNativePort

+ const ProgressReady

+ const ProgressUpdating

+ const PromMetricsLabel

+ const RackLabel

+ const SeedNodeLabel

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ func SplitRacks(nodeCount, rackCount int) []int

+ func ValidateDatacenterFieldChanges(oldDc CassandraDatacenter, newDc CassandraDatacenter) error

+ func ValidateSingleDatacenter(dc CassandraDatacenter) error

+ type AdditionalVolumes struct

+ MountPath string

+ Name string

+ PVCSpec corev1.PersistentVolumeClaimSpec

+ func (in *AdditionalVolumes) DeepCopy() *AdditionalVolumes

+ func (in *AdditionalVolumes) DeepCopyInto(out *AdditionalVolumes)

+ type AdditionalVolumesSlice []AdditionalVolumes

+ func (in AdditionalVolumesSlice) DeepCopy() AdditionalVolumesSlice

+ func (in AdditionalVolumesSlice) DeepCopyInto(out *AdditionalVolumesSlice)

+ type CassandraDatacenter struct

+ Spec CassandraDatacenterSpec

+ Status CassandraDatacenterStatus

+ func (dc *CassandraDatacenter) GetAdditionalSeedsServiceName() string

+ func (dc *CassandraDatacenter) GetAllPodsServiceName() string

+ func (dc *CassandraDatacenter) GetClusterLabels() map[string]string

+ func (dc *CassandraDatacenter) GetCondition(conditionType DatacenterConditionType) (DatacenterCondition, bool)

+ func (dc *CassandraDatacenter) GetConditionStatus(conditionType DatacenterConditionType) corev1.ConditionStatus

+ func (dc *CassandraDatacenter) GetConfigAsJSON(config []byte) (string, error)

+ func (dc *CassandraDatacenter) GetConfigBuilderImage() string

+ func (dc *CassandraDatacenter) GetContainerPorts() ([]corev1.ContainerPort, error)

+ func (dc *CassandraDatacenter) GetDatacenterLabels() map[string]string

+ func (dc *CassandraDatacenter) GetDatacenterServiceName() string

+ func (dc *CassandraDatacenter) GetNodePortInternodePort() int

+ func (dc *CassandraDatacenter) GetNodePortNativePort() int

+ func (dc *CassandraDatacenter) GetNodePortServiceName() string

+ func (dc *CassandraDatacenter) GetRackLabels(rackName string) map[string]string

+ func (dc *CassandraDatacenter) GetRacks() []Rack

+ func (dc *CassandraDatacenter) GetSeedServiceName() string

+ func (dc *CassandraDatacenter) GetServerImage() string

+ func (dc *CassandraDatacenter) GetSuperuserSecretNamespacedName() types.NamespacedName

+ func (dc *CassandraDatacenter) IsHostNetworkEnabled() bool

+ func (dc *CassandraDatacenter) IsNodePortEnabled() bool

+ func (dc *CassandraDatacenter) SetCondition(condition DatacenterCondition)

+ func (dc *CassandraDatacenter) ShouldGenerateSuperuserSecret() bool

+ func (dc *CassandraDatacenter) ValidateCreate() error

+ func (dc *CassandraDatacenter) ValidateDelete() error

+ func (dc *CassandraDatacenter) ValidateUpdate(old runtime.Object) error

+ func (in *CassandraDatacenter) DeepCopy() *CassandraDatacenter

+ func (in *CassandraDatacenter) DeepCopyInto(out *CassandraDatacenter)

+ func (in *CassandraDatacenter) DeepCopyObject() runtime.Object

+ func (r *CassandraDatacenter) Default()

+ func (r *CassandraDatacenter) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type CassandraDatacenterList struct

+ Items []CassandraDatacenter

+ func (in *CassandraDatacenterList) DeepCopy() *CassandraDatacenterList

+ func (in *CassandraDatacenterList) DeepCopyInto(out *CassandraDatacenterList)

+ func (in *CassandraDatacenterList) DeepCopyObject() runtime.Object

+ type CassandraDatacenterSpec struct

+ AdditionalSeeds []string

+ AdditionalServiceConfig ServiceConfig

+ AllowMultipleNodesPerWorker bool

+ CanaryUpgrade bool

+ CanaryUpgradeCount int32

+ ClusterName string

+ Config json.RawMessage

+ ConfigBuilderImage string

+ ConfigBuilderResources corev1.ResourceRequirements

+ ConfigSecret string

+ DisableSystemLoggerSidecar bool

+ DockerImageRunsAsCassandra *bool

+ DseWorkloads *DseWorkloads

+ ForceUpgradeRacks []string

+ ManagementApiAuth ManagementApiAuthConfig

+ Networking *NetworkingConfig

+ NodeAffinityLabels map[string]string

+ NodeSelector map[string]string

+ PodTemplateSpec *corev1.PodTemplateSpec

+ Racks []Rack

+ ReplaceNodes []string

+ Resources corev1.ResourceRequirements

+ RollingRestartRequested bool

+ ServerImage string

+ ServerType string

+ ServerVersion string

+ ServiceAccount string

+ Size int32

+ Stopped bool

+ StorageConfig StorageConfig

+ SuperuserSecretName string

+ SystemLoggerImage string

+ SystemLoggerResources corev1.ResourceRequirements

+ Tolerations []corev1.Toleration

+ Users []CassandraUser

+ func (in *CassandraDatacenterSpec) DeepCopy() *CassandraDatacenterSpec

+ func (in *CassandraDatacenterSpec) DeepCopyInto(out *CassandraDatacenterSpec)

+ type CassandraDatacenterStatus struct

+ CassandraOperatorProgress ProgressState

+ Conditions []DatacenterCondition

+ LastRollingRestart metav1.Time

+ LastServerNodeStarted metav1.Time

+ NodeReplacements []string

+ NodeStatuses CassandraStatusMap

+ ObservedGeneration int64

+ QuietPeriod metav1.Time

+ SuperUserUpserted metav1.Time

+ UsersUpserted metav1.Time

+ func (in *CassandraDatacenterStatus) DeepCopy() *CassandraDatacenterStatus

+ func (in *CassandraDatacenterStatus) DeepCopyInto(out *CassandraDatacenterStatus)

+ func (status *CassandraDatacenterStatus) GetConditionStatus(conditionType DatacenterConditionType) corev1.ConditionStatus

+ func (status *CassandraDatacenterStatus) SetCondition(condition DatacenterCondition)

+ type CassandraNodeStatus struct

+ HostID string

+ func (in *CassandraNodeStatus) DeepCopy() *CassandraNodeStatus

+ func (in *CassandraNodeStatus) DeepCopyInto(out *CassandraNodeStatus)

+ type CassandraStatusMap map[string]CassandraNodeStatus

+ func (in CassandraStatusMap) DeepCopy() CassandraStatusMap

+ func (in CassandraStatusMap) DeepCopyInto(out *CassandraStatusMap)

+ type CassandraUser struct

+ SecretName string

+ Superuser bool

+ func (in *CassandraUser) DeepCopy() *CassandraUser

+ func (in *CassandraUser) DeepCopyInto(out *CassandraUser)

+ type DatacenterCondition struct

+ LastTransitionTime metav1.Time

+ Message string

+ Reason string

+ Status corev1.ConditionStatus

+ Type DatacenterConditionType

+ func NewDatacenterCondition(conditionType DatacenterConditionType, status corev1.ConditionStatus) *DatacenterCondition

+ func NewDatacenterConditionWithReason(conditionType DatacenterConditionType, status corev1.ConditionStatus, ...) *DatacenterCondition

+ func (in *DatacenterCondition) DeepCopy() *DatacenterCondition

+ func (in *DatacenterCondition) DeepCopyInto(out *DatacenterCondition)

+ type DatacenterConditionType string

+ const DatacenterInitialized

+ const DatacenterReady

+ const DatacenterReplacingNodes

+ const DatacenterResuming

+ const DatacenterRollingRestart

+ const DatacenterScalingDown

+ const DatacenterScalingUp

+ const DatacenterStopped

+ const DatacenterUpdating

+ const DatacenterValid

+ type DseWorkloads struct

+ AnalyticsEnabled bool

+ GraphEnabled bool

+ SearchEnabled bool

+ func (in *DseWorkloads) DeepCopy() *DseWorkloads

+ func (in *DseWorkloads) DeepCopyInto(out *DseWorkloads)

+ type ManagementApiAuthConfig struct

+ Insecure *ManagementApiAuthInsecureConfig

+ Manual *ManagementApiAuthManualConfig

+ func (in *ManagementApiAuthConfig) DeepCopy() *ManagementApiAuthConfig

+ func (in *ManagementApiAuthConfig) DeepCopyInto(out *ManagementApiAuthConfig)

+ type ManagementApiAuthInsecureConfig struct

+ func (in *ManagementApiAuthInsecureConfig) DeepCopy() *ManagementApiAuthInsecureConfig

+ func (in *ManagementApiAuthInsecureConfig) DeepCopyInto(out *ManagementApiAuthInsecureConfig)

+ type ManagementApiAuthManualConfig struct

+ ClientSecretName string

+ ServerSecretName string

+ SkipSecretValidation bool

+ func (in *ManagementApiAuthManualConfig) DeepCopy() *ManagementApiAuthManualConfig

+ func (in *ManagementApiAuthManualConfig) DeepCopyInto(out *ManagementApiAuthManualConfig)

+ type NetworkingConfig struct

+ HostNetwork bool

+ NodePort *NodePortConfig

+ func (in *NetworkingConfig) DeepCopy() *NetworkingConfig

+ func (in *NetworkingConfig) DeepCopyInto(out *NetworkingConfig)

+ type NodePortConfig struct

+ Internode int

+ InternodeSSL int

+ Native int

+ NativeSSL int

+ func (in *NodePortConfig) DeepCopy() *NodePortConfig

+ func (in *NodePortConfig) DeepCopyInto(out *NodePortConfig)

+ type ProgressState string

+ type Rack struct

+ Name string

+ NodeAffinityLabels map[string]string

+ Zone string

+ func (in *Rack) DeepCopy() *Rack

+ func (in *Rack) DeepCopyInto(out *Rack)

+ type ServiceConfig struct

+ AdditionalSeedService ServiceConfigAdditions

+ AllPodsService ServiceConfigAdditions

+ DatacenterService ServiceConfigAdditions

+ NodePortService ServiceConfigAdditions

+ SeedService ServiceConfigAdditions

+ func (in *ServiceConfig) DeepCopy() *ServiceConfig

+ func (in *ServiceConfig) DeepCopyInto(out *ServiceConfig)

+ type ServiceConfigAdditions struct

+ Annotations map[string]string

+ Labels map[string]string

+ func (in *ServiceConfigAdditions) DeepCopy() *ServiceConfigAdditions

+ func (in *ServiceConfigAdditions) DeepCopyInto(out *ServiceConfigAdditions)

+ type StorageConfig struct

+ AdditionalVolumes AdditionalVolumesSlice

+ CassandraDataVolumeClaimSpec *corev1.PersistentVolumeClaimSpec

+ func (in *StorageConfig) DeepCopy() *StorageConfig

+ func (in *StorageConfig) DeepCopyInto(out *StorageConfig)