tidb

func AreAllGroupAndInstancesReady(cli client.Client, pdg *v1alpha1.PDGroup, kvg []*v1alpha1.TiKVGroup,
	dbg []*v1alpha1.TiDBGroup, flashg []*v1alpha1.TiFlashGroup, ticdcg []*v1alpha1.TiCDCGroup,
) error

func AreAllInstancesReady(cli client.Client, pdg *v1alpha1.PDGroup, kvg []*v1alpha1.TiKVGroup,
	dbg []*v1alpha1.TiDBGroup, flashg []*v1alpha1.TiFlashGroup, ticdcg []*v1alpha1.TiCDCGroup,
) error

func AreAllPDHealthy(cli client.Client, pdg *v1alpha1.PDGroup, checkGroup bool) error

func AreAllTiCDCHealthy(cli client.Client, ticdcg *v1alpha1.TiCDCGroup, checkGroup bool) error

func AreAllTiDBHealthy(cli client.Client, dbg *v1alpha1.TiDBGroup, checkGroup bool) error

func AreAllTiFlashHealthy(cli client.Client, flashg *v1alpha1.TiFlashGroup, checkGroup bool) error

func AreAllTiKVHealthy(cli client.Client, kvg *v1alpha1.TiKVGroup, checkGroup bool) error

func GetTiDBDSN(host, user, password, database, params string, port int) string

func IsClusterReady(cli client.Client, name, ns string) (*v1alpha1.Cluster, bool)

func IsTiDBConnectable(ctx context.Context, cli client.Client, fw k8s.PortForwarder,
	ns, tcName, dbgName, user, password, tlsSecretName string,
) error

func IsTiDBInserted(fw k8s.PortForwarder, ns, tc, user, password, dbName, tableName string) wait.ConditionFunc

func PortForwardAndGetTiDBDSN(fw k8s.PortForwarder, ns, svcName,
	user, password, database, params string,
) (string, context.CancelFunc, error)