polardbxcluster

Documentation

Index

• func CalculateReplicas(total int, replicas intstr.IntOrString) (int, error)
• func ExpectBeInPhase(polardbxcluster *polardbxv1.PolarDBXCluster, phase polardbxv1polardbx.Phase)
• func ListPodsShouldBeOwnedByPolarDBXCluster(ctx context.Context, c client.Client, ...) ([]corev1.Pod, error)
• func ListServicesShouldBeOwnedByPolarDBXCluster(ctx context.Context, c client.Client, ...) ([]corev1.Service, error)
• func NewPolarDBXCluster(name, namespace string, opts ...FactoryOption) *polardbxv1.PolarDBXCluster
• func ShareGMS(polardbxcluster *polardbxv1.PolarDBXCluster)
• func WaitForPolarDBXClusterToDisappear(c client.Client, name, namespace string, timeout time.Duration) error
• func WaitForPolarDBXClusterToInPhases(c client.Client, name, namespace string, phases []polardbxv1polardbx.Phase, ...) (*polardbxv1.PolarDBXCluster, error)
• func WaitUntilPolarDBXClusterToNotInPhases(c client.Client, name, namespace string, phases []polardbxv1polardbx.Phase, ...) (*polardbxv1.PolarDBXCluster, error)
• func WaitUntilPolarDBXClusterUpgradeCompleteOrFail(c client.Client, name, namespace string, timeout time.Duration) (*polardbxv1.PolarDBXCluster, error)
• type Expectation
  • func NewExpectation(f *framework.Framework, obj *polardbxv1.PolarDBXCluster) *Expectation
  • func (e *Expectation) ExpectAccessible()
  • func (e *Expectation) ExpectAccountsOk()
  • func (e *Expectation) ExpectAllOk()
  • func (e *Expectation) ExpectBasicFunctionalities()
  • func (e *Expectation) ExpectCDCDeploymentsOk()
  • func (e *Expectation) ExpectCNDeploymentsOk()
  • func (e *Expectation) ExpectCNDynamicConfigurationsOk()
  • func (e *Expectation) ExpectConfigMapsOk()
  • func (e *Expectation) ExpectConfigurationsOk()
  • func (e *Expectation) ExpectDeploymentsOk()
  • func (e *Expectation) ExpectGenerationCatchUp()
  • func (e *Expectation) ExpectObservableStatusUpdated()
  • func (e *Expectation) ExpectOwnerReferenceCorrect(subResources ...client.Object)
  • func (e *Expectation) ExpectPodsOk()
  • func (e *Expectation) ExpectQueriesOk(f func(ctx context.Context, db *sql.DB) error, explain ...interface{})
  • func (e *Expectation) ExpectRunning()
  • func (e *Expectation) ExpectSecretsOk()
  • func (e *Expectation) ExpectSecurityTLSNotOk()
  • func (e *Expectation) ExpectSecurityTLSOk()
  • func (e *Expectation) ExpectServiceMonitorsOK()
  • func (e *Expectation) ExpectServicesOk()
  • func (e *Expectation) ExpectSubResourcesOk()
  • func (e *Expectation) ExpectXStoresOk()
• type FactoryOption
  • func EnableTLS(secretName string, selfSigned bool) FactoryOption
  • func EncodeKeySecret(name, key string) FactoryOption
  • func ProtocolVersion(ver int) FactoryOption
  • func Service(name string, serviceType corev1.ServiceType) FactoryOption
  • func TopologyModeGuide(guide string) FactoryOption
  • func TopologyNode(role string, replicas int, engine, image string, hostNetwork bool, ...) FactoryOption

Functions

func CalculateReplicas

func CalculateReplicas(total int, replicas intstr.IntOrString) (int, error)

func ExpectBeInPhase

func ExpectBeInPhase(polardbxcluster *polardbxv1.PolarDBXCluster, phase polardbxv1polardbx.Phase)

func ListPodsShouldBeOwnedByPolarDBXCluster

func ListPodsShouldBeOwnedByPolarDBXCluster(ctx context.Context, c client.Client, polardbxcluster *polardbxv1.PolarDBXCluster, additionalLabels map[string]string) ([]corev1.Pod, error)

func ListServicesShouldBeOwnedByPolarDBXCluster

func ListServicesShouldBeOwnedByPolarDBXCluster(ctx context.Context, c client.Client, polardbxcluster *polardbxv1.PolarDBXCluster, additionalLabels map[string]string) ([]corev1.Service, error)

func NewPolarDBXCluster

func NewPolarDBXCluster(name, namespace string, opts ...FactoryOption) *polardbxv1.PolarDBXCluster

func ShareGMS

func ShareGMS(polardbxcluster *polardbxv1.PolarDBXCluster)

func WaitForPolarDBXClusterToDisappear

func WaitForPolarDBXClusterToDisappear(c client.Client, name, namespace string, timeout time.Duration) error

func WaitForPolarDBXClusterToInPhases

func WaitForPolarDBXClusterToInPhases(c client.Client, name, namespace string, phases []polardbxv1polardbx.Phase, timeout time.Duration) (*polardbxv1.PolarDBXCluster, error)

func WaitUntilPolarDBXClusterToNotInPhases

func WaitUntilPolarDBXClusterToNotInPhases(c client.Client, name, namespace string, phases []polardbxv1polardbx.Phase, timeout time.Duration) (*polardbxv1.PolarDBXCluster, error)

func WaitUntilPolarDBXClusterUpgradeCompleteOrFail

func WaitUntilPolarDBXClusterUpgradeCompleteOrFail(c client.Client, name, namespace string, timeout time.Duration) (*polardbxv1.PolarDBXCluster, error)

Types

type Expectation

type Expectation struct {
	// contains filtered or unexported fields
}

func NewExpectation

func NewExpectation(f *framework.Framework, obj *polardbxv1.PolarDBXCluster) *Expectation

func (*Expectation) ExpectAccessible

func (e *Expectation) ExpectAccessible()

func (*Expectation) ExpectAccountsOk

func (e *Expectation) ExpectAccountsOk()

func (*Expectation) ExpectAllOk

func (e *Expectation) ExpectAllOk()

func (*Expectation) ExpectBasicFunctionalities

func (e *Expectation) ExpectBasicFunctionalities()

func (*Expectation) ExpectCDCDeploymentsOk

func (e *Expectation) ExpectCDCDeploymentsOk()

func (*Expectation) ExpectCNDeploymentsOk

func (e *Expectation) ExpectCNDeploymentsOk()

func (*Expectation) ExpectCNDynamicConfigurationsOk

func (e *Expectation) ExpectCNDynamicConfigurationsOk()

func (*Expectation) ExpectConfigMapsOk

func (e *Expectation) ExpectConfigMapsOk()

func (*Expectation) ExpectConfigurationsOk

func (e *Expectation) ExpectConfigurationsOk()

func (*Expectation) ExpectDeploymentsOk

func (e *Expectation) ExpectDeploymentsOk()

func (*Expectation) ExpectGenerationCatchUp

func (e *Expectation) ExpectGenerationCatchUp()

func (*Expectation) ExpectObservableStatusUpdated

func (e *Expectation) ExpectObservableStatusUpdated()

func (*Expectation) ExpectOwnerReferenceCorrect

func (e *Expectation) ExpectOwnerReferenceCorrect(subResources ...client.Object)

func (*Expectation) ExpectPodsOk

func (e *Expectation) ExpectPodsOk()

func (*Expectation) ExpectQueriesOk

func (e *Expectation) ExpectQueriesOk(f func(ctx context.Context, db *sql.DB) error, explain ...interface{})

func (*Expectation) ExpectRunning

func (e *Expectation) ExpectRunning()

func (*Expectation) ExpectSecretsOk

func (e *Expectation) ExpectSecretsOk()

func (*Expectation) ExpectSecurityTLSNotOk

func (e *Expectation) ExpectSecurityTLSNotOk()

func (*Expectation) ExpectSecurityTLSOk

func (e *Expectation) ExpectSecurityTLSOk()

func (*Expectation) ExpectServiceMonitorsOK

func (e *Expectation) ExpectServiceMonitorsOK()

func (*Expectation) ExpectServicesOk

func (e *Expectation) ExpectServicesOk()

func (*Expectation) ExpectSubResourcesOk

func (e *Expectation) ExpectSubResourcesOk()

func (*Expectation) ExpectXStoresOk

func (e *Expectation) ExpectXStoresOk()

type FactoryOption

type FactoryOption func(polardbxcluster *polardbxv1.PolarDBXCluster)

func EnableTLS

func EnableTLS(secretName string, selfSigned bool) FactoryOption

func EncodeKeySecret

func EncodeKeySecret(name, key string) FactoryOption

func ProtocolVersion

func ProtocolVersion(ver int) FactoryOption

func Service

func Service(name string, serviceType corev1.ServiceType) FactoryOption

func TopologyModeGuide

func TopologyModeGuide(guide string) FactoryOption

func TopologyNode

func TopologyNode(role string, replicas int, engine, image string, hostNetwork bool, resources corev1.ResourceRequirements) FactoryOption