k8ssandra

Documentation

Index

• func MergeTelemetrySpecs(kc *k8ssandraapi.K8ssandraCluster, ...) *v1alpha1.TelemetrySpec
• func SuperuserSecretName(kc *api.K8ssandraCluster) string
• type K8ssandraClusterReconciler
  • func (r *K8ssandraClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *K8ssandraClusterReconciler) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error
• type SystemReplicationOldFormat

Functions

func MergeTelemetrySpecs

func MergeTelemetrySpecs(kc *k8ssandraapi.K8ssandraCluster, dcTemplate k8ssandraapi.CassandraDatacenterTemplate) *v1alpha1.TelemetrySpec

MergeTelemetrySpecs merges the cluster and dc level telemetry specs, prioritizing the dc level spec.

func SuperuserSecretName

func SuperuserSecretName(kc *api.K8ssandraCluster) string

Types

type K8ssandraClusterReconciler

type K8ssandraClusterReconciler struct {
	*config.ReconcilerConfig
	client.Client
	Scheme        *runtime.Scheme
	ClientCache   *clientcache.ClientCache
	ManagementApi cassandra.ManagementApiFactory
	Recorder      record.EventRecorder
}

K8ssandraClusterReconciler reconciles a K8ssandraCluster object

func (*K8ssandraClusterReconciler) Reconcile

func (r *K8ssandraClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*K8ssandraClusterReconciler) SetupWithManager

func (r *K8ssandraClusterReconciler) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error

SetupWithManager sets up the controller with the Manager.

type SystemReplicationOldFormat

type SystemReplicationOldFormat struct {
	Datacenters       []string `json:"datacenters"`
	ReplicationFactor int      `json:"replicationFactor"`
}

an annotation is used to store the initial replication factor for system keyspaces. its schema evolved in v1.1 but we need to be able to parse the old format for upgrades.