tidbcluster

Documentation

Index

• Constants
• func CheckPeerMembersAndClusterStatus(clusterCli ctrlCli.Client, tc *v1alpha1.TidbCluster, ...) error
• func CheckStatusWhenAcrossK8s(cli versioned.Interface, tidbclusters []*v1alpha1.TidbCluster) error
• func CheckStatusWhenAcrossK8sWithTimeout(cli versioned.Interface, tidbclusters []*v1alpha1.TidbCluster, ...) error
• func DeleteCertManager(cli clientset.Interface) error
• func EnsureRecordsNotChangedForTables(db *utildb.Database, engine string, dbName string, tables []string, ...)
• func GetTCForAcrossKubernetes(ns, name, version, clusterDomain string, joinTC *v1alpha1.TidbCluster) *v1alpha1.TidbCluster
• func InstallCertManager(cli clientset.Interface) error
• func InstallDMCertificates(ns, dcName string) error
• func InstallMySQLCertificates(ns, dcName string) error
• func InstallTiDBCertificates(ns, tcName string) error
• func InstallTiDBComponentsCertificates(ns, tcName string) error
• func InstallTiDBIssuer(ns, tcName string) error
• func InstallXK8sTiDBCertificates(ns, tcName, clusterDomain string) error
• func InstallXK8sTiDBComponentsCertificates(ns, tcName, clusterDomain string, exceptPD bool) error
• func InstallXK8sTiDBIssuer(ns, tcName, clusterRef string) error
• func MustCreateTiFlashReplicationForTable(db *utildb.Database, dbName string, table string, expectCount int)
• func MustCreateXK8sTCWithComponentsReady(cli ctrlCli.Client, oa *tests.OperatorActions, ...)
• func MustGetLabelSelectorForComponents(tcName string, filterComponents ...string) labels.Selector
• func MustPrepareXK8sTLSResources(cli ctrlCli.Client, initialTC *v1alpha1.TidbCluster, ...)
• func WaitObjectToBeControlledByOrDie(c client.Client, obj client.Object, owner runtime.Object, ...)

Constants

const (
	OperatorLatestVersion    string = "v1.5.0-beta.1"
	OperatorPrevMajorVersion string = "v1.4.6"
)

Functions

func CheckPeerMembersAndClusterStatus

func CheckPeerMembersAndClusterStatus(clusterCli ctrlCli.Client, tc *v1alpha1.TidbCluster, expectNonExistedTc *v1alpha1.TidbCluster) error

func CheckStatusWhenAcrossK8s

func CheckStatusWhenAcrossK8s(cli versioned.Interface, tidbclusters []*v1alpha1.TidbCluster) error

func CheckStatusWhenAcrossK8sWithTimeout

func CheckStatusWhenAcrossK8sWithTimeout(cli versioned.Interface, tidbclusters []*v1alpha1.TidbCluster, interval time.Duration, timeout time.Duration) error

func DeleteCertManager

func DeleteCertManager(cli clientset.Interface) error

func EnsureRecordsNotChangedForTables

func EnsureRecordsNotChangedForTables(db *utildb.Database, engine string, dbName string, tables []string, expectCount int)

EnsureRecordsNotChangedForTables ensure records not changed for tables

func GetTCForAcrossKubernetes

func GetTCForAcrossKubernetes(ns, name, version, clusterDomain string, joinTC *v1alpha1.TidbCluster) *v1alpha1.TidbCluster

func InstallCertManager

func InstallCertManager(cli clientset.Interface) error

func InstallDMCertificates

func InstallDMCertificates(ns, dcName string) error

func InstallMySQLCertificates

func InstallMySQLCertificates(ns, dcName string) error

func InstallTiDBCertificates

func InstallTiDBCertificates(ns, tcName string) error

func InstallTiDBComponentsCertificates

func InstallTiDBComponentsCertificates(ns, tcName string) error

func InstallTiDBIssuer

func InstallTiDBIssuer(ns, tcName string) error

func InstallXK8sTiDBCertificates

func InstallXK8sTiDBCertificates(ns, tcName, clusterDomain string) error

func InstallXK8sTiDBComponentsCertificates

func InstallXK8sTiDBComponentsCertificates(ns, tcName, clusterDomain string, exceptPD bool) error

func InstallXK8sTiDBIssuer

func InstallXK8sTiDBIssuer(ns, tcName, clusterRef string) error

func MustCreateTiFlashReplicationForTable

func MustCreateTiFlashReplicationForTable(db *utildb.Database, dbName string, table string, expectCount int)

MustCreateTiFlashReplicationForTable create TiFLash replication and ensure it is ready

func MustCreateXK8sTCWithComponentsReady

func MustCreateXK8sTCWithComponentsReady(cli ctrlCli.Client, oa *tests.OperatorActions, tidbclusters []*v1alpha1.TidbCluster, tlsEnabled bool)

func MustGetLabelSelectorForComponents

func MustGetLabelSelectorForComponents(tcName string, filterComponents ...string) labels.Selector

func MustPrepareXK8sTLSResources

func MustPrepareXK8sTLSResources(cli ctrlCli.Client, initialTC *v1alpha1.TidbCluster, restTCs []*v1alpha1.TidbCluster)

func WaitObjectToBeControlledByOrDie

func WaitObjectToBeControlledByOrDie(c client.Client, obj client.Object, owner runtime.Object, timeout time.Duration)

WaitObjectToBeControlledByOrDie wait desired owner become the controller of the object