operator

type CassandraReconciler ¶

type CassandraReconciler struct {
	// contains filtered or unexported fields
}

CassandraReconciler is a controller that reconciles Cassandra resources

func NewReconciler(clusters map[types.NamespacedName]*v1alpha1.Cassandra, client client.Client, eventRecorder record.EventRecorder, eventReceiver event.Receiver, operatorConfig *Config, metricsReporter metrics.ClusterMetricsReporter) *CassandraReconciler

func (r *CassandraReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

type Config ¶

type Config struct {
	MetricPollInterval    time.Duration
	MetricRequestDuration time.Duration
	ControllerSyncPeriod  time.Duration
	Namespace             string
	Version               string
	RepositoryPath        string
}

The Config for the Operator

type Interrupter ¶

type Interrupter struct {
	// contains filtered or unexported fields
}

Interrupter is a controller whose sole purpose is to check whether any subsequent changes have been made to a cluster which is currently under modification by the Reconciler, and interrupt the Reconciler so that the newer changes can be effected.

It works by using a map of channels, keyed on a namespace-qualified cluster names, which is shared with the polling loop which waits for stateful set provisioning to complete. When the interrupter closes the channel for a cluster, the polling loop will exit early with a return value that specifies the polling was interrupted, rather than having completed successfully.

func NewInterrupter(activeReconciliations *sync.Map, client client.Client, recorder record.EventRecorder) *Interrupter

func (i *Interrupter) Reconcile(request reconcile.Request) (reconcile.Result, error)

type Operator ¶

type Operator struct {
	// contains filtered or unexported fields
}

The Operator itself.

func New(kubeClientset *kubernetes.Clientset, cassandraClientset *versioned.Clientset, operatorConfig *Config, kubeConfig *rest.Config) (*Operator, error)

func (o *Operator) Run()

type Status ¶

type Status struct {
	// CassandraCrdVersion is the CRD version supported by this Operator
	CassandraCrdVersion string
}

Status is the top level structure containing information about this Operator and the cluster it manages