reaper

Documentation

Index

• Constants
• Variables
• func AddReaperSettingsToDcConfig(reaperTemplate *reaperapi.ReaperClusterTemplate, ...)
• func Coalesce(clusterTemplate *api.ReaperClusterTemplate, ...) *api.ReaperClusterTemplate
• func DefaultJmxUserSecretName(clusterName string) string
• 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
• func NewService(key types.NamespacedName, reaper *api.Reaper) *corev1.Service
• type Manager
  • func NewManager() Manager

Constants

const (
	DefaultImageRepository = "thelastpickle"
	DefaultImageName       = "cassandra-reaper"
	DefaultVersion         = "3.1.0"
)

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

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 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(clusterName string) string

DefaultJmxUserSecretName generates a name for the Reaper JMX user, that is derived from the Cassandra cluster name.

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, 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

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