Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrPodNotScheduled = errors.New("One of pods is not scheduled yet") ErrRegionNotReady = errors.New("One of the regions is not ready") )
Functions ¶
func SetupCassandraReconciler ¶
func SetupCassandraReconciler(r reconcile.Reconciler, mgr manager.Manager, logr *zap.SugaredLogger, reconcileChan chan event.GenericEvent) error
Types ¶
type CassandraClusterReconciler ¶
type CassandraClusterReconciler struct {
client.Client
Log *zap.SugaredLogger
Scheme *runtime.Scheme
Cfg config.Config
Events *events.EventRecorder
Jobs *jobs.JobManager
ProberClient func(url *url.URL, user, password string) prober.ProberClient
CqlClient func(cluster *gocql.ClusterConfig) (cql.CqlClient, error)
ReaperClient func(url *url.URL, clusterName string, defaultRepairThreadCount int32) reaper.ReaperClient
NodectlClient func(jolokiaAddr, jmxUser, jmxPassword string, logr *zap.SugaredLogger) nodectl.Nodectl
}
CassandraClusterReconciler reconciles a CassandraCluster object
Source Files
¶
- admin_auth.go
- cassandra.go
- cassandra_configmap.go
- cassandra_container.go
- cassandra_icarus_container.go
- cassandra_init_containers.go
- cassandra_pod_ips.go
- cassandra_pod_labels.go
- cassandra_pods_config.go
- cassandra_rbac.go
- cassandra_scaling.go
- cassandra_service.go
- cassandra_service_monitor.go
- cassandra_statefulset.go
- cassandra_tls.go
- collectd_configmap.go
- controller.go
- cql.go
- cql_configmaps.go
- default_role.go
- defaults.go
- helpers.go
- keyspaces.go
- maintenance.go
- network_policies.go
- prober.go
- prober_ingress.go
- prober_rbac.go
- prober_service_monitor.go
- prometheus_configmap.go
- readiness.go
- reaper.go
- reaper_environment.go
- reaper_keyspace.go
- reaper_service_monitor.go
- repair_schedules.go
- role_admin.go
- roles.go
- shiro_configmap.go
Directories
Click to show internal directories.
Click to hide internal directories.