reaper

Documentation

Index

• Constants
• Variables
• func AddReaperSettingsToDcConfig(reaperTemplate *reaperapi.ReaperClusterTemplate, ...)
• func Coalesce(clusterTemplate *api.ReaperClusterTemplate, ...) *api.ReaperClusterTemplate
• func DefaultJmxUserSecretName(k8cName string) string
• func DefaultUserSecretName(k8cName string) string
• func GetCassandraAuthEnvironmentVars(secret *corev1.Secret) (*corev1.EnvVar, *corev1.EnvVar, error)
• func GetJmxAuthEnvironmentVars(secret *corev1.Secret) (*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
• func NewService(key types.NamespacedName, reaper *api.Reaper) *corev1.Service
• func ResourceName(klusterName, dcName string) string
• type Manager
  • func NewManager() Manager

Constants

const (
	DatacenterAvailabilityLocal = "LOCAL"
	DatacenterAvailabilityEach  = "EACH"
)

Variables

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

Functions

func AddReaperSettingsToDcConfig

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

func Coalesce

func Coalesce(clusterTemplate *api.ReaperClusterTemplate, dcTemplate *api.ReaperDatacenterTemplate) *api.ReaperClusterTemplate

Coalesce combines the cluster and dc templates with override semantics. If a property is defined in both templates, the dc-level property takes precedence.

func DefaultJmxUserSecretName

func DefaultJmxUserSecretName(k8cName string) string

func DefaultUserSecretName

func DefaultUserSecretName(k8cName string) string

func GetCassandraAuthEnvironmentVars

func GetCassandraAuthEnvironmentVars(secret *corev1.Secret) (*corev1.EnvVar, *corev1.EnvVar, error)

func GetJmxAuthEnvironmentVars

func GetJmxAuthEnvironmentVars(secret *corev1.Secret) (*corev1.EnvVar, *corev1.EnvVar, error)

func GetServiceName

func GetServiceName(reaperName string) string

func NewDeployment

func NewDeployment(reaper *api.Reaper, dc *cassdcapi.CassandraDatacenter, authVars ...*corev1.EnvVar) *appsv1.Deployment

func NewReaper

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

func NewService

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

func ResourceName

func ResourceName(klusterName, dcName string) string

Types

type Manager

type Manager interface {
	Connect(reaper *api.Reaper) error
	AddClusterToReaper(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) error
	VerifyClusterIsConfigured(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) (bool, error)
}

func NewManager

func NewManager() Manager