controller

Documentation

Index

• Constants
• type ClusterController
  • func New(rookImage string, kubeClient kubernetes.Interface, ...) *ClusterController
  • func (cc *ClusterController) Run(threadiness int, stopCh <-chan struct{}) error
  • func (cc *ClusterController) Sync(c *cassandrav1alpha1.Cluster) error

Constants

const (
	// SuccessSynced is used as part of the Event 'reason' when a Cluster is
	// synced.
	SuccessSynced = "Synced"
	// ErrResourceExists is used as part of the Event 'reason' when a
	// Cluster fails to sync due to a resource of the same name already
	// existing.
	ErrSyncFailed = "ErrSyncFailed"

	MessageRackCreated             = "Rack %s created"
	MessageRackScaledUp            = "Rack %s scaled up to %d members"
	MessageRackScaleDownInProgress = "Rack %s scaling down to %d members"
	MessageRackScaledDown          = "Rack %s scaled down to %d members"

	// Messages to display when experiencing an error.
	MessageHeadlessServiceSyncFailed = "Failed to sync Headless Service for cluster"
	MessageMemberServicesSyncFailed  = "Failed to sync MemberServices for cluster"
	MessageUpdateStatusFailed        = "Failed to update status for cluster"
	MessageCleanupFailed             = "Failed to clean up cluster resources"
	MessageClusterSyncFailed         = "Failed to sync cluster"
)

Types

type ClusterController

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

ClusterController encapsulates all the tools the controller needs in order to talk to the Kubernetes API

func New

func New(
	rookImage string,
	kubeClient kubernetes.Interface,
	rookClient rookClientset.Interface,
	clusterInformer informersv1alpha1.ClusterInformer,
	statefulSetInformer appsinformers.StatefulSetInformer,
	serviceInformer coreinformers.ServiceInformer,
	podInformer coreinformers.PodInformer,
) *ClusterController

New returns a new ClusterController

func (*ClusterController) Run

func (cc *ClusterController) Run(threadiness int, stopCh <-chan struct{}) error

Run starts the ClusterController process loop

func (*ClusterController) Sync

func (cc *ClusterController) Sync(c *cassandrav1alpha1.Cluster) error

Sync attempts to sync the given Cassandra Cluster. NOTE: the Cluster Object is a DeepCopy. Modify at will.