reaper

package

v1.32.2 Latest Latest Go to latest Published: Jun 3, 2026 License: Apache-2.0 Imports: 35 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/k8ssandra/k8ssandra-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddReaperSettingsToDcConfig(reaperTemplate *reaperapi.ReaperClusterTemplate, ...)
func CreateHTTPClientWithMutualTLS(tlsCert, tlsKey, caCert []byte) (*http.Client, error)
func CreateVectorConfigMap(namespace, vectorToml string, dc cassdcapi.CassandraDatacenter) *corev1.ConfigMap
func DeepCopyActualDeployment(actualDeployment client.Object) (client.Object, error)
func DefaultResourceName(dc *cassdcapi.CassandraDatacenter) string
func DefaultUiSecretName(clusterName string) string
func DefaultUserSecretName(clusterName string) string
func EnsureSingleReplica(actualReaper *api.Reaper, actualDeployment client.Object, ...) error
func GetAuthEnvironmentVars(secret *corev1.Secret, authType string) (*corev1.EnvVar, *corev1.EnvVar, error)
func GetServiceName(reaperName string) string
func MakeActualDeploymentType(actualReaper *api.Reaper) (client.Object, error)
func MakeDesiredDeploymentType(actualReaper *api.Reaper, dc *cassdcapi.CassandraDatacenter, ...) (client.Object, error)
func NewDeployment(reaper *api.Reaper, dc *cassdcapi.CassandraDatacenter, ...) *appsv1.Deployment
func NewReaper(reaperKey types.NamespacedName, kc *k8ssandraapi.K8ssandraCluster, ...) (*reaperapi.Reaper, error)
func NewService(key types.NamespacedName, reaper *api.Reaper) *corev1.Service
func NewStatefulSet(reaper *api.Reaper, dc *cassdcapi.CassandraDatacenter, logger logr.Logger, ...) *appsv1.StatefulSet
func VectorAgentConfigMapName(clusterName, dcName string) string
type Manager
- func NewManager() Manager

Constants ¶

View Source

const (
	InitContainerMemRequest = "128Mi"
	InitContainerMemLimit   = "512Mi"
	InitContainerCpuRequest = "100m"
	MainContainerMemRequest = "256Mi"
	MainContainerMemLimit   = "3Gi"
	MainContainerCpuRequest = "100m"
)

View Source

const (
	DatacenterAvailabilityEach = "EACH"
	DatacenterAvailabilityAll  = "ALL"
)

View Source

const (
	MetricsPort         = 8081
	VectorContainerName = "reaper-vector-agent"
)

Variables ¶

View Source

var DisableAuthVar = &corev1.EnvVar{
	Name:  envVarEnableAuth,
	Value: "false",
}

View Source

var EnableAuthVar = &corev1.EnvVar{
	Name:  envVarEnableAuth,
	Value: "true",
}

View Source

var EnableCassAuthVar = &corev1.EnvVar{
	Name:  envVarEnableCassAuth,
	Value: "true",
}

Functions ¶

func AddReaperSettingsToDcConfig ¶

func AddReaperSettingsToDcConfig(reaperTemplate *reaperapi.ReaperClusterTemplate, dcConfig *cassandra.DatacenterConfig, authEnabled bool)

func CreateHTTPClientWithMutualTLS ¶ added in v1.30.0

func CreateHTTPClientWithMutualTLS(tlsCert, tlsKey, caCert []byte) (*http.Client, error)

func CreateVectorConfigMap ¶ added in v1.5.0

func CreateVectorConfigMap(namespace, vectorToml string, dc cassdcapi.CassandraDatacenter) *corev1.ConfigMap

func DeepCopyActualDeployment ¶ added in v1.19.0

func DeepCopyActualDeployment(actualDeployment client.Object) (client.Object, error)

func DefaultResourceName ¶

func DefaultResourceName(dc *cassdcapi.CassandraDatacenter) string

DefaultResourceName generates a name for a new Reaper resource that is derived from the Cassandra cluster and DC names.

func DefaultUiSecretName ¶

func DefaultUiSecretName(clusterName string) string

func DefaultUserSecretName ¶

func DefaultUserSecretName(clusterName string) string

DefaultUserSecretName generates a name for the Reaper CQL user, that is derived from the Cassandra cluster name.

func EnsureSingleReplica ¶ added in v1.19.0

func EnsureSingleReplica(actualReaper *api.Reaper, actualDeployment client.Object, desiredDeployment client.Object, logger logr.Logger) error

func GetAuthEnvironmentVars ¶

func GetAuthEnvironmentVars(secret *corev1.Secret, authType string) (*corev1.EnvVar, *corev1.EnvVar, error)

func GetServiceName ¶

func GetServiceName(reaperName string) string

func MakeActualDeploymentType ¶ added in v1.19.0

func MakeActualDeploymentType(actualReaper *api.Reaper) (client.Object, error)

func MakeDesiredDeploymentType ¶ added in v1.19.0

func MakeDesiredDeploymentType(actualReaper *api.Reaper, dc *cassdcapi.CassandraDatacenter, keystorePassword *string, truststorePassword *string, logger logr.Logger, registry cassimages.ImageRegistry, authVars ...*corev1.EnvVar) (client.Object, error)

func NewDeployment ¶

func NewDeployment(reaper *api.Reaper, dc *cassdcapi.CassandraDatacenter, keystorePassword *string, truststorePassword *string, logger logr.Logger, registry cassimages.ImageRegistry, authVars ...*corev1.EnvVar) *appsv1.Deployment

func NewReaper ¶

func NewReaper(
	reaperKey types.NamespacedName,
	kc *k8ssandraapi.K8ssandraCluster,
	dc *cassdcapi.CassandraDatacenter,
	reaperClusterTemplate *reaperapi.ReaperClusterTemplate,
	logger logr.Logger,
) (*reaperapi.Reaper, error)

func NewService ¶

func NewService(key types.NamespacedName, reaper *api.Reaper) *corev1.Service

func NewStatefulSet ¶ added in v1.19.0

func NewStatefulSet(reaper *api.Reaper, dc *cassdcapi.CassandraDatacenter, logger logr.Logger, registry cassimages.ImageRegistry, authVars ...*corev1.EnvVar) *appsv1.StatefulSet

func VectorAgentConfigMapName ¶ added in v1.5.0

func VectorAgentConfigMapName(clusterName, dcName string) string

VectorAgentConfigMapName generates a ConfigMap name based on the K8s sanitized cluster name and datacenter name.

Types ¶

type Manager ¶

type Manager interface {
	Connect(ctx context.Context, reaper *api.Reaper, username, password string) error
	ConnectWithReaperRef(ctx context.Context, kc *v1alpha1.K8ssandraCluster, username, password string) error
	AddClusterToReaper(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) error
	VerifyClusterIsConfigured(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) (bool, error)
	GetUiCredentials(ctx context.Context, uiUserSecretRef *corev1.LocalObjectReference, namespace string) (string, string, error)
	SetK8sClient(client.Reader)
}

func NewManager ¶

func NewManager() Manager

Source Files ¶

View all Source files

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