controller

package
v1.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 6, 2019 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// SuccessSynced is used as part of the Event 'reason' when a Cluster is
	// synced.
	SuccessSynced = "Synced"
	// ErrSyncFailed 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"
)

Variables

This section is empty.

Functions

This section is empty.

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL