Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterController ¶
type ClusterController struct {
// contains filtered or unexported fields
}
ClusterController is the director for they sync and build
func New ¶
func New(cc *v1alpha1.CassandraCluster, driver opsdk.Client) *ClusterController
New constructs a new ClusterController from an API object
func (*ClusterController) Sync ¶
func (c *ClusterController) Sync() error
Sync syncs the current state to desired TODO: Make this able to roll back on error state on first creation
type ClusterStatusManager ¶
type ClusterStatusManager struct {
// contains filtered or unexported fields
}
ClusterStatusManager updates and calculates a clusters status
func NewStatusManager ¶
func NewStatusManager(statusReporter nodeStatusReporter, listerUpdater resourceListerUpdater) *ClusterStatusManager
NewStatusManager returns a new ClusterStatusController to get the status of the cluster
func (*ClusterStatusManager) Update ¶
func (c *ClusterStatusManager) Update(cc *v1alpha1.CassandraCluster) error
Update calculates the current status and updates the k8s resource status accordingly
type PodFinalizerController ¶
type PodFinalizerController struct {
// contains filtered or unexported fields
}
PodFinalizerController is the controller for cassandra node (pod) finalizers
func NewPodFinalizerController ¶
func NewPodFinalizerController(k8sDriver k8s.Client, nodetoolDriver *nodetool.Executor) *PodFinalizerController
NewPodFinalizerController builds a new PodFinalizerController
Source Files
Click to show internal directories.
Click to hide internal directories.