reaper

Documentation

Index

• Constants
• Variables
• func AddReaperSettingsToDcConfig(reaperTemplate *reaperapi.ReaperClusterTemplate, ...)
• func CreateVectorConfigMap(namespace, vectorToml string, dc cassdcapi.CassandraDatacenter) *corev1.ConfigMap
• func DefaultResourceName(dc *cassdcapi.CassandraDatacenter) string
• func DefaultUiSecretName(clusterName string) string
• func DefaultUserSecretName(clusterName string) string
• func GetAuthEnvironmentVars(secret *corev1.Secret, authType string) (*corev1.EnvVar, *corev1.EnvVar, error)
• func GetServiceName(reaperName string) string
• 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 VectorAgentConfigMapName(clusterName, dcName string) string
• type Manager
  • func NewManager() Manager

Constants

const (
	DefaultImageRepository = "thelastpickle"
	DefaultImageName       = "cassandra-reaper"
	DefaultVersion         = "3.6.1"

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

const (
	DeploymentModeSingle = "SINGLE"
	DeploymentModePerDc  = "PER_DC"

	DatacenterAvailabilityEach = "EACH"
	DatacenterAvailabilityAll  = "ALL"
)

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

Variables

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

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

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

Functions

func AddReaperSettingsToDcConfig

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

func CreateVectorConfigMap

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

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 GetAuthEnvironmentVars

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

func GetServiceName

func GetServiceName(reaperName string) string

func NewDeployment

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

func NewReaper

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

func NewService

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

func VectorAgentConfigMapName

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
	AddClusterToReaper(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) error
	VerifyClusterIsConfigured(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) (bool, error)
}

func NewManager

func NewManager() Manager