Documentation ¶
Index ¶
- type AddClusterOperation
- type AddCustomConfigOperation
- type AddServiceOperation
- type AddSnapshotCleanupOperation
- type AddSnapshotOperation
- type DeleteClusterOperation
- type DeleteCustomConfigOperation
- type DeleteSnapshotCleanupOperation
- type DeleteSnapshotOperation
- type GatherMetricsOperation
- type Operation
- type OperationComposer
- type OperationFactory
- type OperationFactoryImpl
- func (o *OperationFactoryImpl) NewAddCluster(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewAddCustomConfig(cassandra *v1alpha1.Cassandra, configMap *v1.ConfigMap) Operation
- func (o *OperationFactoryImpl) NewAddService(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewAddSnapshot(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewAddSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewDeleteCluster(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewDeleteCustomConfig(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewDeleteSnapshot(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewDeleteSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewGatherMetrics(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewUpdateCluster(oldCassandra, newCassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewUpdateCustomConfig(cassandra *v1alpha1.Cassandra, configMap *v1.ConfigMap) Operation
- func (o *OperationFactoryImpl) NewUpdateSnapshot(cassandra *v1alpha1.Cassandra) Operation
- func (o *OperationFactoryImpl) NewUpdateSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation
- type UpdateClusterOperation
- type UpdateCustomConfigOperation
- type UpdateSnapshotCleanupOperation
- type UpdateSnapshotOperation
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddClusterOperation ¶
type AddClusterOperation struct {
// contains filtered or unexported fields
}
AddClusterOperation describes what the operator does when creating a cluster
func (*AddClusterOperation) Execute ¶
func (o *AddClusterOperation) Execute() (bool, error)
Execute performs the operation
func (*AddClusterOperation) String ¶
func (o *AddClusterOperation) String() string
type AddCustomConfigOperation ¶
type AddCustomConfigOperation struct {
// contains filtered or unexported fields
}
AddCustomConfigOperation describes what the operator does when a configmap is added
func (*AddCustomConfigOperation) Execute ¶
func (o *AddCustomConfigOperation) Execute() (bool, error)
Execute performs the operation
func (*AddCustomConfigOperation) String ¶
func (o *AddCustomConfigOperation) String() string
type AddServiceOperation ¶
type AddServiceOperation struct {
// contains filtered or unexported fields
}
AddServiceOperation describes what the operator does when creating a cluster
func (*AddServiceOperation) Execute ¶
func (o *AddServiceOperation) Execute() (bool, error)
Execute performs the operation
func (*AddServiceOperation) String ¶
func (o *AddServiceOperation) String() string
type AddSnapshotCleanupOperation ¶
type AddSnapshotCleanupOperation struct {
// contains filtered or unexported fields
}
AddSnapshotCleanupOperation describes what the operator does when a snapshot cleanup definition is added
func (*AddSnapshotCleanupOperation) Execute ¶
func (o *AddSnapshotCleanupOperation) Execute() (bool, error)
Execute performs the operation
func (*AddSnapshotCleanupOperation) String ¶
func (o *AddSnapshotCleanupOperation) String() string
type AddSnapshotOperation ¶
type AddSnapshotOperation struct {
// contains filtered or unexported fields
}
AddSnapshotOperation describes what the operator does when a snapshot schedule is added for a cluster
func (*AddSnapshotOperation) Execute ¶
func (o *AddSnapshotOperation) Execute() (bool, error)
Execute performs the operation
func (*AddSnapshotOperation) String ¶
func (o *AddSnapshotOperation) String() string
type DeleteClusterOperation ¶
type DeleteClusterOperation struct {
// contains filtered or unexported fields
}
DeleteClusterOperation describes what the operator does when deleting a cluster
func (*DeleteClusterOperation) Execute ¶
func (o *DeleteClusterOperation) Execute() (bool, error)
Execute performs the operation
func (*DeleteClusterOperation) String ¶
func (o *DeleteClusterOperation) String() string
type DeleteCustomConfigOperation ¶
type DeleteCustomConfigOperation struct {
// contains filtered or unexported fields
}
DeleteCustomConfigOperation describes what the operator does when a configmap is removed for a cluster
func (*DeleteCustomConfigOperation) Execute ¶
func (o *DeleteCustomConfigOperation) Execute() (bool, error)
Execute performs the operation
func (*DeleteCustomConfigOperation) String ¶
func (o *DeleteCustomConfigOperation) String() string
type DeleteSnapshotCleanupOperation ¶
type DeleteSnapshotCleanupOperation struct {
// contains filtered or unexported fields
}
DeleteSnapshotCleanupOperation describes what the operator does when a snapshot cleanup definition is removed
func (*DeleteSnapshotCleanupOperation) Execute ¶
func (o *DeleteSnapshotCleanupOperation) Execute() (bool, error)
Execute performs the operation
func (*DeleteSnapshotCleanupOperation) String ¶
func (o *DeleteSnapshotCleanupOperation) String() string
type DeleteSnapshotOperation ¶
type DeleteSnapshotOperation struct {
// contains filtered or unexported fields
}
DeleteSnapshotOperation describes what the operator does when a Snapshot schedule is removed for a cluster
func (*DeleteSnapshotOperation) Execute ¶
func (o *DeleteSnapshotOperation) Execute() (bool, error)
Execute performs the operation
func (*DeleteSnapshotOperation) String ¶
func (o *DeleteSnapshotOperation) String() string
type GatherMetricsOperation ¶
type GatherMetricsOperation struct {
// contains filtered or unexported fields
}
GatherMetricsOperation describes what the operator does when gathering metrics
func (*GatherMetricsOperation) Execute ¶
func (o *GatherMetricsOperation) Execute() (bool, error)
Execute performs the operation
func (*GatherMetricsOperation) String ¶
func (o *GatherMetricsOperation) String() string
type Operation ¶
type Operation interface { // Execute actually performs the operation. // stop will be true if subsequent operations should not be performed as a consequence of something which happened // during this operation. Execute() (stop bool, err error) // Human-readable description of the operation String() string }
Operation describes a single unit of work
type OperationComposer ¶
type OperationComposer interface { // Execute the supplied operations in order. // stopped will be true upon return if not all operations were executed. // err wraps all errors which arose in the execution of the operations. Execute(operations []Operation) (stopped bool, err error) }
OperationComposer takes a sequence of Operations and executes them one by one.
func NewOperationComposer ¶
func NewOperationComposer() OperationComposer
NewOperationComposer returns an OperationComposer
type OperationFactory ¶
type OperationFactory interface { NewAddCluster(cassandra *v1alpha1.Cassandra) Operation NewAddService(cassandra *v1alpha1.Cassandra) Operation NewDeleteCluster(cassandra *v1alpha1.Cassandra) Operation NewDeleteSnapshot(cassandra *v1alpha1.Cassandra) Operation NewDeleteSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation NewAddSnapshot(cassandra *v1alpha1.Cassandra) Operation NewAddSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation NewUpdateCluster(oldCassandra, newCassandra *v1alpha1.Cassandra) Operation NewUpdateSnapshot(cassandra *v1alpha1.Cassandra) Operation NewUpdateSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation NewGatherMetrics(cassandra *v1alpha1.Cassandra) Operation NewUpdateCustomConfig(cassandra *v1alpha1.Cassandra, configMap *v1.ConfigMap) Operation NewAddCustomConfig(cassandra *v1alpha1.Cassandra, configMap *v1.ConfigMap) Operation NewDeleteCustomConfig(cassandra *v1alpha1.Cassandra) Operation }
OperationFactory creates Operation for each operation supported by the operator
func NewOperationFactory ¶
func NewOperationFactory(clusterAccessor cluster.Accessor, metricsReporter metrics.ClusterMetricsReporter, eventRecorder record.EventRecorder, adjuster *adjuster.Adjuster) OperationFactory
NewOperationFactory creates a new OperationFactory
type OperationFactoryImpl ¶
type OperationFactoryImpl struct {
// contains filtered or unexported fields
}
OperationFactoryImpl implements OperationFactory
func (*OperationFactoryImpl) NewAddCluster ¶
func (o *OperationFactoryImpl) NewAddCluster(cassandra *v1alpha1.Cassandra) Operation
NewAddCluster creates a AddCluster Operation
func (*OperationFactoryImpl) NewAddCustomConfig ¶
func (o *OperationFactoryImpl) NewAddCustomConfig(cassandra *v1alpha1.Cassandra, configMap *v1.ConfigMap) Operation
NewAddCustomConfig creates a AddCustomConfig Operation
func (*OperationFactoryImpl) NewAddService ¶
func (o *OperationFactoryImpl) NewAddService(cassandra *v1alpha1.Cassandra) Operation
NewAddService creates a AddService Operation
func (*OperationFactoryImpl) NewAddSnapshot ¶
func (o *OperationFactoryImpl) NewAddSnapshot(cassandra *v1alpha1.Cassandra) Operation
NewAddSnapshot creates a AddSnapshot Operation
func (*OperationFactoryImpl) NewAddSnapshotCleanup ¶
func (o *OperationFactoryImpl) NewAddSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation
NewAddSnapshotCleanup creates a AddSnapshotCleanup Operation
func (*OperationFactoryImpl) NewDeleteCluster ¶
func (o *OperationFactoryImpl) NewDeleteCluster(cassandra *v1alpha1.Cassandra) Operation
NewDeleteCluster creates a DeleteCluster Operation
func (*OperationFactoryImpl) NewDeleteCustomConfig ¶
func (o *OperationFactoryImpl) NewDeleteCustomConfig(cassandra *v1alpha1.Cassandra) Operation
NewDeleteCustomConfig creates a DeleteCustomConfig Operation
func (*OperationFactoryImpl) NewDeleteSnapshot ¶
func (o *OperationFactoryImpl) NewDeleteSnapshot(cassandra *v1alpha1.Cassandra) Operation
NewDeleteSnapshot creates a DeleteSnapshot Operation
func (*OperationFactoryImpl) NewDeleteSnapshotCleanup ¶
func (o *OperationFactoryImpl) NewDeleteSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation
NewDeleteSnapshotCleanup creates a DeleteSnapshotCleanup Operation
func (*OperationFactoryImpl) NewGatherMetrics ¶
func (o *OperationFactoryImpl) NewGatherMetrics(cassandra *v1alpha1.Cassandra) Operation
NewGatherMetrics creates a GatherMetrics Operation
func (*OperationFactoryImpl) NewUpdateCluster ¶
func (o *OperationFactoryImpl) NewUpdateCluster(oldCassandra, newCassandra *v1alpha1.Cassandra) Operation
NewUpdateCluster creates a UpdateCluster Operation
func (*OperationFactoryImpl) NewUpdateCustomConfig ¶
func (o *OperationFactoryImpl) NewUpdateCustomConfig(cassandra *v1alpha1.Cassandra, configMap *v1.ConfigMap) Operation
NewUpdateCustomConfig creates a UpdateCustomConfig Operation
func (*OperationFactoryImpl) NewUpdateSnapshot ¶
func (o *OperationFactoryImpl) NewUpdateSnapshot(cassandra *v1alpha1.Cassandra) Operation
NewUpdateSnapshot creates a UpdateSnapshot Operation
func (*OperationFactoryImpl) NewUpdateSnapshotCleanup ¶
func (o *OperationFactoryImpl) NewUpdateSnapshotCleanup(cassandra *v1alpha1.Cassandra) Operation
NewUpdateSnapshotCleanup creates a UpdateSnapshotCleanup Operation
type UpdateClusterOperation ¶
type UpdateClusterOperation struct {
// contains filtered or unexported fields
}
UpdateClusterOperation describes what the operator does when the Cassandra spec is updated for a cluster
func (*UpdateClusterOperation) Execute ¶
func (o *UpdateClusterOperation) Execute() (bool, error)
Execute performs the operation
func (*UpdateClusterOperation) String ¶
func (o *UpdateClusterOperation) String() string
type UpdateCustomConfigOperation ¶
type UpdateCustomConfigOperation struct {
// contains filtered or unexported fields
}
UpdateCustomConfigOperation describes what the operator does when a configmap is updated for a cluster
func (*UpdateCustomConfigOperation) Execute ¶
func (o *UpdateCustomConfigOperation) Execute() (bool, error)
Execute performs the operation
func (*UpdateCustomConfigOperation) String ¶
func (o *UpdateCustomConfigOperation) String() string
type UpdateSnapshotCleanupOperation ¶
type UpdateSnapshotCleanupOperation struct {
// contains filtered or unexported fields
}
UpdateSnapshotCleanupOperation describes what the operator does when the retention policy is updated for a cluster
func (*UpdateSnapshotCleanupOperation) Execute ¶
func (o *UpdateSnapshotCleanupOperation) Execute() (bool, error)
Execute performs the operation
func (*UpdateSnapshotCleanupOperation) String ¶
func (o *UpdateSnapshotCleanupOperation) String() string
type UpdateSnapshotOperation ¶
type UpdateSnapshotOperation struct {
// contains filtered or unexported fields
}
UpdateSnapshotOperation describes what the operator does when the Snapshot spec is updated for a cluster
func (*UpdateSnapshotOperation) Execute ¶
func (o *UpdateSnapshotOperation) Execute() (bool, error)
Execute performs the operation
func (*UpdateSnapshotOperation) String ¶
func (o *UpdateSnapshotOperation) String() string
Source Files ¶
- add_cleanup_snapshot.go
- add_cluster.go
- add_configmap.go
- add_service.go
- add_snapshot.go
- delete_cluster.go
- delete_configmap.go
- delete_snapshot.go
- delete_snapshot_cleanup.go
- gather_metrics.go
- operations.go
- statefulset_accessor.go
- update_cluster.go
- update_configmap.go
- update_snapshot.go
- update_snapshot_cleanup.go