operations

package
v0.0.0-...-8011f81 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2021 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation

Index

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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.