cluster

Documentation

Index

• func ClusterNameFromURI(uri string) string
• func Difference(a, b schemav1alpha1.ClusterTargets) schemav1alpha1.ClusterTargets
• func Union(a, b schemav1alpha1.ClusterTargets) schemav1alpha1.ClusterTargets
• type Cluster
  • func NewCluster(clusterType schemav1alpha1.DBTypeEnum, uri string, c client.Client, ...) Cluster

Functions

func ClusterNameFromURI

func ClusterNameFromURI(uri string) string

ClusterNameFromURI extracts the server name from the uri (removing prefix/suffix)

func Difference

func Difference(a, b schemav1alpha1.ClusterTargets) schemav1alpha1.ClusterTargets

Difference returns the difference of the DB & Schema slices i.e. elemnts in a not found in b. in the case of multiple Schemas we only diff them.

func Union

func Union(a, b schemav1alpha1.ClusterTargets) schemav1alpha1.ClusterTargets

Union returns a union of the DB & Schema slices

Types

type Cluster

type Cluster interface {
	AquireTargets(filter schemav1alpha1.TargetFilter) (schemav1alpha1.ClusterTargets, error)
	Execute(targets schemav1alpha1.ClusterTargets, config schemav1alpha1.ExecutionConfiguration) (schemav1alpha1.ClusterTargets, error)
	CreateExecConfiguration(targets schemav1alpha1.ClusterTargets, cfgMap *v1.ConfigMap, failIfDataLoss bool) (schemav1alpha1.ExecutionConfiguration, error)
}

Cluster interaface represents a DB cluster type that we can execute upon

func NewCluster

func NewCluster(clusterType schemav1alpha1.DBTypeEnum, uri string, c client.Client, notifier utils.NotifyProgressFunc) Cluster

NewCluster will create an appropriate cluster implementation for the given type.