cassandra

Documentation

Index

• Constants
• func NextAction(c *v1alpha1.CassandraCluster) controllers.Action
• type CassandraController
  • func CassandraControllerFromContext(ctx *controllers.Context) *CassandraController
  • func NewCassandra(naviClient navigatorclientset.Interface, kubeClient kubernetes.Interface, ...) *CassandraController
  • func (e *CassandraController) Run(workers int, stopCh <-chan struct{}) error
• type ControlInterface
  • func NewControl(seedProviderServiceControl service.Interface, ...) ControlInterface

Constants

const (
	ErrorSync = "ErrSync"

	SuccessSync = "SuccessSync"

	MessageErrorSyncServiceAccount = "Error syncing service account: %s"
	MessageErrorSyncRole           = "Error syncing role: %s"
	MessageErrorSyncRoleBinding    = "Error syncing role binding: %s"
	MessageErrorSyncConfigMap      = "Error syncing config map: %s"
	MessageErrorSyncService        = "Error syncing service: %s"
	MessageErrorSyncNodePools      = "Error syncing node pools: %s"
	MessageErrorSyncPilots         = "Error syncing pilots: %s"
	MessageErrorSyncSeedLabels     = "Error syncing seed labels: %s"
	MessageErrorSync               = "Error syncing: %s"
	MessageSuccessSync             = "Successfully synced CassandraCluster"
)

Functions

func NextAction

func NextAction(c *v1alpha1.CassandraCluster) controllers.Action

Types

type CassandraController

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

NewCassandra returns a new CassandraController that can be used to monitor for CassandraCluster resources and create clusters in a target Kubernetes cluster.

It accepts a list of informers that are then used to monitor the state of the target cluster.

func CassandraControllerFromContext

func CassandraControllerFromContext(ctx *controllers.Context) *CassandraController

func NewCassandra

func NewCassandra(
	naviClient navigatorclientset.Interface,
	kubeClient kubernetes.Interface,
	cassClusters navigatorinformers.CassandraClusterInformer,
	services coreinformers.ServiceInformer,
	statefulSets appsinformers.StatefulSetInformer,
	pilots navigatorinformers.PilotInformer,
	pods coreinformers.PodInformer,
	serviceAccounts coreinformers.ServiceAccountInformer,
	roles rbacinformers.RoleInformer,
	roleBindings rbacinformers.RoleBindingInformer,
	recorder record.EventRecorder,
) *CassandraController

func (*CassandraController) Run

func (e *CassandraController) Run(workers int, stopCh <-chan struct{}) error

Run is the main event loop

type ControlInterface

type ControlInterface interface {
	Sync(*v1alpha1.CassandraCluster) error
}

func NewControl

func NewControl(
	seedProviderServiceControl service.Interface,
	nodesServiceControl service.Interface,
	nodepoolControl nodepool.Interface,
	pilotControl pilot.Interface,
	serviceAccountControl serviceaccount.Interface,
	roleControl role.Interface,
	roleBindingControl rolebinding.Interface,
	seedlabellerControl seedlabeller.Interface,
	recorder record.EventRecorder,
	state *controllers.State,
) ControlInterface