Documentation ¶
Index ¶
- Constants
- func CheckTidbMonitor(monitor *v1alpha1.TidbMonitor, cli versioned.Interface, ...) error
- func CleanReleasedCRDOrDie(version string)
- func DeployReleasedCRDOrDie(version string)
- func GetD(ns, tcName, databaseName, password string) string
- func GetDrainerSubValuesOrDie(info *DrainerConfig) string
- func GetKubeApiserverPod(kubeCli kubernetes.Interface, node string) (*corev1.Pod, error)
- func GetKubeControllerManagerPod(kubeCli kubernetes.Interface, node string) (*corev1.Pod, error)
- func GetKubeDNSPod(kubeCli kubernetes.Interface, node string) (*corev1.Pod, error)
- func GetKubeProxyPod(kubeCli kubernetes.Interface, node string) (*corev1.Pod, error)
- func GetKubeSchedulerPod(kubeCli kubernetes.Interface, node string) (*corev1.Pod, error)
- func GetPodStatus(pod *corev1.Pod) string
- func GetPodsByLabels(kubeCli kubernetes.Interface, node string, lables map[string]string) (*corev1.Pod, error)
- func GetSubValuesOrDie(clusterName, namespace, topologyKey string, pdConfig []string, ...) string
- func IntPtr(i int) *int
- func KeepOrDie(interval time.Duration, period time.Duration, fun func() error)
- func SelectNode(nodes []Nodes) string
- func StartValidatingAdmissionWebhookServerOrDie(context *apimachinery.CertContext, namespaces ...string)
- type AffinityInfo
- type BackupTarget
- type BinLogInfo
- type Config
- func (c *Config) CleanTempDirs() error
- func (c *Config) GetTiDBVersion() (string, error)
- func (c *Config) GetTiDBVersionOrDie() string
- func (c *Config) GetUpgradeTidbVersions() []string
- func (c *Config) GetUpgradeTidbVersionsOrDie() []string
- func (c *Config) MustPrettyPrintJSON() string
- func (c *Config) Parse() error
- func (c *Config) PrettyPrintJSON() (string, error)
- type CrdTestUtil
- func (ctu *CrdTestUtil) CheckDisasterTolerance(cluster *v1alpha1.TidbCluster) error
- func (ctu *CrdTestUtil) CheckDisasterToleranceOrDie(tc *v1alpha1.TidbCluster)
- func (ctu *CrdTestUtil) CleanResourcesOrDie(resource, namespace string)
- func (ctu *CrdTestUtil) CreateSecretOrDie(secret *corev1.Secret)
- func (ctu *CrdTestUtil) CreateTidbClusterOrDie(tc *v1alpha1.TidbCluster)
- func (ctu *CrdTestUtil) DeleteTidbClusterOrDie(tc *v1alpha1.TidbCluster)
- func (ctu *CrdTestUtil) GetTidbClusterOrDie(name, namespace string) *v1alpha1.TidbCluster
- func (ctu *CrdTestUtil) UpdateTidbClusterOrDie(tc *v1alpha1.TidbCluster)
- func (ctu *CrdTestUtil) WaitForTidbClusterReady(tc *v1alpha1.TidbCluster, timeout, pollInterval time.Duration) error
- func (ctu *CrdTestUtil) WaitTidbClusterReadyOrDie(tc *v1alpha1.TidbCluster, timeout time.Duration)
- type DbType
- type DrainerConfig
- type FaultTriggerActions
- type Node
- type Nodes
- type OperatorActions
- type OperatorConfig
- type RegionInfo
- type RegionsInfo
- type TidbClusterConfig
- func (tc *TidbClusterConfig) BackupHelmSetString(m map[string]string) string
- func (tc *TidbClusterConfig) BuildSubValues(path string) (string, error)
- func (tc *TidbClusterConfig) DSN(dbName string) string
- func (tc *TidbClusterConfig) FullName() string
- func (tc *TidbClusterConfig) GenerateBackupDirPodName() string
- func (tc *TidbClusterConfig) RunInHost(flag bool) *TidbClusterConfig
- func (tc *TidbClusterConfig) ScalePD(replicas uint) *TidbClusterConfig
- func (tc *TidbClusterConfig) ScaleTiDB(replicas uint) *TidbClusterConfig
- func (tc *TidbClusterConfig) ScaleTiKV(replicas uint) *TidbClusterConfig
- func (tc *TidbClusterConfig) String() string
- func (tc *TidbClusterConfig) TidbClusterHelmSetString(m map[string]string) string
- func (tc *TidbClusterConfig) UpdatePDLogLevel(logLevel string) *TidbClusterConfig
- func (tc *TidbClusterConfig) UpdatePdMaxReplicas(maxReplicas int) *TidbClusterConfig
- func (tc *TidbClusterConfig) UpdateTiDBTokenLimit(tokenLimit int) *TidbClusterConfig
- func (tc *TidbClusterConfig) UpdateTiKVGrpcConcurrency(concurrency int) *TidbClusterConfig
- func (tc *TidbClusterConfig) UpgradeAll(tag string) *TidbClusterConfig
- func (tc *TidbClusterConfig) UpgradePD(image string) *TidbClusterConfig
- func (tc *TidbClusterConfig) UpgradeTiDB(image string) *TidbClusterConfig
- func (tc *TidbClusterConfig) UpgradeTiKV(image string) *TidbClusterConfig
Constants ¶
View Source
const ( // NodeUnreachablePodReason is defined in k8s.io/kubernetes/pkg/util/node // but not in client-go and apimachinery, so we define it here NodeUnreachablePodReason = "NodeLost" WebhookServiceName = "webhook-service" )
View Source
const ( DefaultPollTimeout time.Duration = 20 * time.Minute DefaultPollInterval time.Duration = 5 * time.Second BackupAndRestorePollTimeOut time.Duration = 60 * time.Minute )
View Source
const ( DrainerReplicas int32 = 1 // TODO: better way to do incremental restore from pb files RunReparoCommandTemplate = `` /* 299-byte string literal not displayed */ )
View Source
const ( RackLabel = "rack" RackNum = 3 )
View Source
const ( PodPollInterval = 2 * time.Second // PodTimeout is how long to wait for the pod to be started or // terminated. PodTimeout = 5 * time.Minute )
Variables ¶
This section is empty.
Functions ¶
func CheckTidbMonitor ¶ added in v1.1.0
func CheckTidbMonitor(monitor *v1alpha1.TidbMonitor, cli versioned.Interface, kubeCli kubernetes.Interface, fw portforward.PortForward) error
func CleanReleasedCRDOrDie ¶ added in v1.1.0
func CleanReleasedCRDOrDie(version string)
func DeployReleasedCRDOrDie ¶ added in v1.1.0
func DeployReleasedCRDOrDie(version string)
func GetDrainerSubValuesOrDie ¶ added in v1.1.0
func GetDrainerSubValuesOrDie(info *DrainerConfig) string
func GetKubeApiserverPod ¶
func GetKubeDNSPod ¶
func GetKubeProxyPod ¶
func GetKubeSchedulerPod ¶
func GetPodStatus ¶
func GetPodsByLabels ¶
func GetSubValuesOrDie ¶
func SelectNode ¶
func StartValidatingAdmissionWebhookServerOrDie ¶
func StartValidatingAdmissionWebhookServerOrDie(context *apimachinery.CertContext, namespaces ...string)
Types ¶
type AffinityInfo ¶
type BackupTarget ¶ added in v1.1.0
type BackupTarget struct { IncrementalType DbType TargetCluster *TidbClusterConfig IsAdditional bool }
func (*BackupTarget) GetDrainerConfig ¶ added in v1.1.0
func (t *BackupTarget) GetDrainerConfig(source *TidbClusterConfig, ts string) *DrainerConfig
type BinLogInfo ¶ added in v1.0.1
type Config ¶
type Config struct { TidbVersions string `yaml:"tidb_versions" json:"tidb_versions"` InstallOperator bool `yaml:"install_opeartor" json:"install_opeartor"` OperatorTag string `yaml:"operator_tag" json:"operator_tag"` OperatorImage string `yaml:"operator_image" json:"operator_image"` BackupImage string `yaml:"backup_image" json:"backup_image"` OperatorFeatures map[string]bool `yaml:"operator_features" json:"operator_features"` UpgradeOperatorTag string `yaml:"upgrade_operator_tag" json:"upgrade_operator_tag"` UpgradeOperatorImage string `yaml:"upgrade_operator_image" json:"upgrade_operator_image"` LogDir string `yaml:"log_dir" json:"log_dir"` FaultTriggerPort int `yaml:"fault_trigger_port" json:"fault_trigger_port"` Nodes []Nodes `yaml:"nodes" json:"nodes"` ETCDs []Nodes `yaml:"etcds" json:"etcds"` APIServers []Nodes `yaml:"apiservers" json:"apiservers"` CertFile string KeyFile string PDMaxReplicas int `yaml:"pd_max_replicas" json:"pd_max_replicas"` TiKVGrpcConcurrency int `yaml:"tikv_grpc_concurrency" json:"tikv_grpc_concurrency"` TiDBTokenLimit int `yaml:"tidb_token_limit" json:"tidb_token_limit"` // old versions of reparo does not support idempotent incremental recover, so we lock the version explicitly AdditionalDrainerVersion string `yaml:"file_drainer_version" json:"file_drainer_version"` // Block writer BlockWriter blockwriter.Config `yaml:"block_writer,omitempty"` // For local test OperatorRepoUrl string `yaml:"operator_repo_url" json:"operator_repo_url"` OperatorRepoDir string `yaml:"operator_repo_dir" json:"operator_repo_dir"` // chart dir ChartDir string `yaml:"chart_dir" json:"chart_dir"` // manifest dir ManifestDir string `yaml:"manifest_dir" json:"manifest_dir"` E2EImage string `yaml:"e2e_image" json:"e2e_image"` PreloadImages bool `yaml:"preload_images" json:"preload_images"` OperatorKiller utiloperator.OperatorKillerConfig // contains filtered or unexported fields }
Config defines the config of operator tests
func NewDefaultConfig ¶ added in v1.1.0
func NewDefaultConfig() *Config
NewDefaultConfig creates a default configuration.
func ParseConfigOrDie ¶
func ParseConfigOrDie() *Config
func (*Config) CleanTempDirs ¶
func (*Config) GetTiDBVersion ¶
func (*Config) GetTiDBVersionOrDie ¶
func (*Config) GetUpgradeTidbVersions ¶
func (*Config) GetUpgradeTidbVersionsOrDie ¶
func (*Config) MustPrettyPrintJSON ¶ added in v1.1.0
func (*Config) PrettyPrintJSON ¶ added in v1.1.0
type CrdTestUtil ¶ added in v1.1.1
type CrdTestUtil struct {
// contains filtered or unexported fields
}
func NewCrdTestUtil ¶ added in v1.1.1
func NewCrdTestUtil(cli versioned.Interface, kubeCli kubernetes.Interface, asCli asclientset.Interface, stsGetter typedappsv1.StatefulSetsGetter) *CrdTestUtil
func (*CrdTestUtil) CheckDisasterTolerance ¶ added in v1.1.1
func (ctu *CrdTestUtil) CheckDisasterTolerance(cluster *v1alpha1.TidbCluster) error
func (*CrdTestUtil) CheckDisasterToleranceOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) CheckDisasterToleranceOrDie(tc *v1alpha1.TidbCluster)
func (*CrdTestUtil) CleanResourcesOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) CleanResourcesOrDie(resource, namespace string)
func (*CrdTestUtil) CreateSecretOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) CreateSecretOrDie(secret *corev1.Secret)
func (*CrdTestUtil) CreateTidbClusterOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) CreateTidbClusterOrDie(tc *v1alpha1.TidbCluster)
func (*CrdTestUtil) DeleteTidbClusterOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) DeleteTidbClusterOrDie(tc *v1alpha1.TidbCluster)
func (*CrdTestUtil) GetTidbClusterOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) GetTidbClusterOrDie(name, namespace string) *v1alpha1.TidbCluster
func (*CrdTestUtil) UpdateTidbClusterOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) UpdateTidbClusterOrDie(tc *v1alpha1.TidbCluster)
func (*CrdTestUtil) WaitForTidbClusterReady ¶ added in v1.1.1
func (ctu *CrdTestUtil) WaitForTidbClusterReady(tc *v1alpha1.TidbCluster, timeout, pollInterval time.Duration) error
func (*CrdTestUtil) WaitTidbClusterReadyOrDie ¶ added in v1.1.1
func (ctu *CrdTestUtil) WaitTidbClusterReadyOrDie(tc *v1alpha1.TidbCluster, timeout time.Duration)
type DrainerConfig ¶ added in v1.1.0
type DrainerConfig struct { DrainerName string InitialCommitTs string OperatorTag string SourceClusterName string Namespace string DbType DbType Host string User string Password string // use string type in case of empty port (db-type=file) Port string TLSCluster bool }
func (*DrainerConfig) BuildSubValues ¶ added in v1.1.0
func (d *DrainerConfig) BuildSubValues(dir string) (string, error)
func (*DrainerConfig) DrainerHelmString ¶ added in v1.1.0
func (d *DrainerConfig) DrainerHelmString(m map[string]string, source *TidbClusterConfig) string
type FaultTriggerActions ¶
type FaultTriggerActions interface { CheckAndRecoverEnv() error CheckAndRecoverEnvOrDie() StopNode() (string, string, time.Time, error) StopNodeOrDie() (string, string, time.Time) StartNode(physicalNode string, node string) error StartNodeOrDie(physicalNode string, node string) StopETCD(nodes ...string) error StopETCDOrDie(nodes ...string) StartETCD(nodes ...string) error StartETCDOrDie(nodes ...string) StopKubelet(nodes ...string) error StopKubeletOrDie(nodes ...string) StartKubelet(nodes ...string) error StartKubeletOrDie(nodes ...string) StopKubeAPIServer(node string) error StopKubeAPIServerOrDie(node string) StartKubeAPIServer(node string) error StartKubeAPIServerOrDie(node string) StopKubeControllerManager(node string) error StopKubeControllerManagerOrDie(node string) StartKubeControllerManager(node string) error StartKubeControllerManagerOrDie(node string) StartKubeScheduler(node string) error StartKubeSchedulerOrDie(node string) StopKubeScheduler(node string) error StopKubeSchedulerOrDie(node string) StopKubeProxy() error StopKubeProxyOrDie() StartKubeProxy() error StartKubeProxyOrDie() }
func NewFaultTriggerAction ¶
func NewFaultTriggerAction(cli versioned.Interface, kubeCli kubernetes.Interface, cfg *Config) FaultTriggerActions
type Nodes ¶
type Nodes struct { PhysicalNode string `yaml:"physical_node" json:"physical_node"` Nodes []Node `yaml:"nodes" json:"nodes"` }
Nodes defines a series of nodes that belong to the same physical node.
type OperatorActions ¶
type OperatorActions interface { CleanCRDOrDie() InstallCRDOrDie(info *OperatorConfig) DeployOperator(info *OperatorConfig) error DeployOperatorOrDie(info *OperatorConfig) CleanOperator(info *OperatorConfig) error CleanOperatorOrDie(info *OperatorConfig) UpgradeOperator(info *OperatorConfig) error UpgradeOperatorOrDie(info *OperatorConfig) DumpAllLogs(info *OperatorConfig, clusterInfos []*TidbClusterConfig) error DeployTidbCluster(info *TidbClusterConfig) error DeployTidbClusterOrDie(info *TidbClusterConfig) CleanTidbCluster(info *TidbClusterConfig) error CleanTidbClusterOrDie(info *TidbClusterConfig) CheckTidbClusterStatus(info *TidbClusterConfig) error CheckTidbClusterStatusOrDie(info *TidbClusterConfig) BeginInsertDataTo(info *TidbClusterConfig) error BeginInsertDataToOrDie(info *TidbClusterConfig) StopInsertDataTo(info *TidbClusterConfig) ScaleTidbCluster(info *TidbClusterConfig) error ScaleTidbClusterOrDie(info *TidbClusterConfig) CheckScaleInSafely(info *TidbClusterConfig) error CheckScaledCorrectly(info *TidbClusterConfig, podUIDsBeforeScale map[string]types.UID) error CheckUpgradeOrDie(ctx context.Context, info *TidbClusterConfig) CheckUpgrade(ctx context.Context, info *TidbClusterConfig) error UpgradeTidbCluster(info *TidbClusterConfig) error UpgradeTidbClusterOrDie(info *TidbClusterConfig) DeployAdHocBackup(info *TidbClusterConfig) error CheckAdHocBackup(info *TidbClusterConfig) (string, error) DeployScheduledBackup(info *TidbClusterConfig) error CheckScheduledBackup(info *TidbClusterConfig) error DeployIncrementalBackup(from *TidbClusterConfig, to *TidbClusterConfig, withDrainer bool, ts string) error CheckIncrementalBackup(info *TidbClusterConfig, withDrainer bool) error DeployDrainer(info *DrainerConfig, from *TidbClusterConfig) error DeployDrainerOrDie(info *DrainerConfig, from *TidbClusterConfig) CheckDrainer(info *DrainerConfig, source *TidbClusterConfig) error Restore(from *TidbClusterConfig, to *TidbClusterConfig) error CheckRestore(from *TidbClusterConfig, to *TidbClusterConfig) error RestoreIncrementalFiles(from *DrainerConfig, to *TidbClusterConfig, stopTSO int64) error ForceDeploy(info *TidbClusterConfig) error CreateSecret(info *TidbClusterConfig) error GetPodUIDMap(info *TidbClusterConfig) (map[string]types.UID, error) GetNodeMap(info *TidbClusterConfig, component string) (map[string][]string, error) TruncateSSTFileThenCheckFailover(info *TidbClusterConfig, tikvFailoverPeriod time.Duration) error TruncateSSTFileThenCheckFailoverOrDie(info *TidbClusterConfig, tikvFailoverPeriod time.Duration) DeletePDDataThenCheckFailover(info *TidbClusterConfig, tikvFailoverPeriod time.Duration) error DeletePDDataThenCheckFailoverOrDie(info *TidbClusterConfig, tikvFailoverPeriod time.Duration) CheckFailoverPending(info *TidbClusterConfig, node string, faultPoint *time.Time) (bool, error) CheckFailoverPendingOrDie(clusters []*TidbClusterConfig, node string, faultPoint *time.Time) CheckFailover(info *TidbClusterConfig, faultNode string) (bool, error) CheckFailoverOrDie(clusters []*TidbClusterConfig, faultNode string) CheckRecover(cluster *TidbClusterConfig) (bool, error) CheckRecoverOrDie(clusters []*TidbClusterConfig) CheckK8sAvailable(excludeNodes map[string]string, excludePods map[string]*corev1.Pod) error CheckK8sAvailableOrDie(excludeNodes map[string]string, excludePods map[string]*corev1.Pod) CheckOperatorAvailable(operatorConfig *OperatorConfig) error CheckTidbClustersAvailable(infos []*TidbClusterConfig) error CheckOperatorDownOrDie(infos []*TidbClusterConfig) CheckTidbClustersAvailableOrDie(infos []*TidbClusterConfig) CheckEtcdDownOrDie(operatorConfig *OperatorConfig, clusters []*TidbClusterConfig, faultNode string) CheckKubeletDownOrDie(operatorConfig *OperatorConfig, clusters []*TidbClusterConfig, faultNode string) CheckOneApiserverDownOrDie(operatorConfig *OperatorConfig, clusters []*TidbClusterConfig, faultNode string) CheckAllApiserverDownOrDie(operatorConfig *OperatorConfig, clusters []*TidbClusterConfig) CheckKubeProxyDownOrDie(operatorConfig *OperatorConfig, clusters []*TidbClusterConfig) CheckKubeSchedulerDownOrDie(operatorConfig *OperatorConfig, clusters []*TidbClusterConfig) CheckKubeControllerManagerDownOrDie(operatorConfig *OperatorConfig, clusters []*TidbClusterConfig) RegisterWebHookAndService(configName, namespace, service string, context *apimachinery.CertContext) error RegisterWebHookAndServiceOrDie(configName, namespace, service string, context *apimachinery.CertContext) CleanWebHookAndService(name string) error CleanWebHookAndServiceOrDie(name string) RunEventWorker() EmitEvent(info *TidbClusterConfig, msg string) BackupRestore(from, to *TidbClusterConfig) error BackupRestoreOrDie(from, to *TidbClusterConfig) BackupAndRestoreToMultipleClusters(source *TidbClusterConfig, targets []BackupTarget) error BackupAndRestoreToMultipleClustersOrDie(source *TidbClusterConfig, targets []BackupTarget) LabelNodes() error LabelNodesOrDie() CheckDisasterTolerance(info *TidbClusterConfig) error CheckDisasterToleranceOrDie(info *TidbClusterConfig) CheckUpgradeComplete(info *TidbClusterConfig) error CheckUpgradeCompleteOrDie(info *TidbClusterConfig) CheckInitSQL(info *TidbClusterConfig) error CheckInitSQLOrDie(info *TidbClusterConfig) DeployAndCheckPump(tc *TidbClusterConfig) error WaitForTidbClusterReady(tc *v1alpha1.TidbCluster, timeout, pollInterval time.Duration) error WaitPodOnNodeReadyOrDie(clusters []*TidbClusterConfig, faultNode string) DataIsTheSameAs(from, to *TidbClusterConfig) (bool, error) }
func NewOperatorActions ¶
func NewOperatorActions(cli versioned.Interface, kubeCli kubernetes.Interface, asCli asclientset.Interface, aggrCli aggregatorclientset.Interface, apiExtCli apiextensionsclientset.Interface, pollInterval time.Duration, operatorConfig *OperatorConfig, cfg *Config, clusters []*TidbClusterConfig, fw portforward.PortForward, f *framework.Framework) OperatorActions
type OperatorConfig ¶
type OperatorConfig struct { Namespace string ReleaseName string Image string Tag string ControllerManagerReplicas *int SchedulerImage string SchedulerTag string SchedulerReplicas *int Features []string LogLevel string WebhookServiceName string WebhookSecretName string WebhookConfigName string Context *apimachinery.CertContext ImagePullPolicy corev1.PullPolicy TestMode bool WebhookEnabled bool PodWebhookEnabled bool StsWebhookEnabled bool DefaultingEnabled bool ValidatingEnabled bool Cabundle string BackupImage string AutoFailover *bool // Additional STRING values, set via --set-string flag. StringValues map[string]string }
func (*OperatorConfig) Enabled ¶ added in v1.1.0
func (oi *OperatorConfig) Enabled(feature string) bool
func (*OperatorConfig) OperatorHelmSetBoolean ¶ added in v1.1.0
func (oi *OperatorConfig) OperatorHelmSetBoolean() string
func (*OperatorConfig) OperatorHelmSetString ¶
func (oi *OperatorConfig) OperatorHelmSetString(m map[string]string) string
type RegionInfo ¶
type RegionInfo struct { ID uint64 `json:"id"` StartKey string `json:"start_key"` EndKey string `json:"end_key"` RegionEpoch *metapb.RegionEpoch `json:"epoch,omitempty"` Peers []*metapb.Peer `json:"peers,omitempty"` Leader *metapb.Peer `json:"leader,omitempty"` DownPeers []*pdpb.PeerStats `json:"down_peers,omitempty"` PendingPeers []*metapb.Peer `json:"pending_peers,omitempty"` WrittenBytes uint64 `json:"written_bytes,omitempty"` ReadBytes uint64 `json:"read_bytes,omitempty"` ApproximateSize int64 `json:"approximate_size,omitempty"` ApproximateKeys int64 `json:"approximate_keys,omitempty"` }
RegionInfo records detail region info for api usage.
type RegionsInfo ¶
type RegionsInfo struct { Count int `json:"count"` Regions []*RegionInfo `json:"regions"` }
RegionsInfo contains some regions with the detailed region info.
type TidbClusterConfig ¶
type TidbClusterConfig struct { BackupName string Namespace string ClusterName string EnablePVReclaim bool OperatorTag string PDImage string TiKVImage string TiDBImage string PumpImage string StorageClassName string Password string RecordCount string InsertBatchSize string Resources map[string]string Args map[string]string Monitor bool UserName string InitSecretName string BackupSecretName string EnableConfigMapRollout bool ClusterVersion string PDPreStartScript string TiDBPreStartScript string TiKVPreStartScript string PDMaxReplicas int TiKVGrpcConcurrency int TiDBTokenLimit int PDLogLevel string BlockWriteConfig blockwriter.Config GrafanaClient *metrics.Client TopologyKey string Clustrer *v1alpha1.TidbCluster // contains filtered or unexported fields }
func (*TidbClusterConfig) BackupHelmSetString ¶
func (tc *TidbClusterConfig) BackupHelmSetString(m map[string]string) string
func (*TidbClusterConfig) BuildSubValues ¶
func (tc *TidbClusterConfig) BuildSubValues(path string) (string, error)
func (*TidbClusterConfig) DSN ¶
func (tc *TidbClusterConfig) DSN(dbName string) string
func (*TidbClusterConfig) FullName ¶
func (tc *TidbClusterConfig) FullName() string
func (*TidbClusterConfig) GenerateBackupDirPodName ¶ added in v1.0.4
func (tc *TidbClusterConfig) GenerateBackupDirPodName() string
func (*TidbClusterConfig) RunInHost ¶ added in v1.1.0
func (tc *TidbClusterConfig) RunInHost(flag bool) *TidbClusterConfig
func (*TidbClusterConfig) ScalePD ¶
func (tc *TidbClusterConfig) ScalePD(replicas uint) *TidbClusterConfig
func (*TidbClusterConfig) ScaleTiDB ¶
func (tc *TidbClusterConfig) ScaleTiDB(replicas uint) *TidbClusterConfig
func (*TidbClusterConfig) ScaleTiKV ¶
func (tc *TidbClusterConfig) ScaleTiKV(replicas uint) *TidbClusterConfig
func (*TidbClusterConfig) String ¶
func (tc *TidbClusterConfig) String() string
func (*TidbClusterConfig) TidbClusterHelmSetString ¶
func (tc *TidbClusterConfig) TidbClusterHelmSetString(m map[string]string) string
func (*TidbClusterConfig) UpdatePDLogLevel ¶
func (tc *TidbClusterConfig) UpdatePDLogLevel(logLevel string) *TidbClusterConfig
func (*TidbClusterConfig) UpdatePdMaxReplicas ¶
func (tc *TidbClusterConfig) UpdatePdMaxReplicas(maxReplicas int) *TidbClusterConfig
FIXME: update of PD configuration do not work now #487
func (*TidbClusterConfig) UpdateTiDBTokenLimit ¶
func (tc *TidbClusterConfig) UpdateTiDBTokenLimit(tokenLimit int) *TidbClusterConfig
func (*TidbClusterConfig) UpdateTiKVGrpcConcurrency ¶
func (tc *TidbClusterConfig) UpdateTiKVGrpcConcurrency(concurrency int) *TidbClusterConfig
func (*TidbClusterConfig) UpgradeAll ¶
func (tc *TidbClusterConfig) UpgradeAll(tag string) *TidbClusterConfig
func (*TidbClusterConfig) UpgradePD ¶
func (tc *TidbClusterConfig) UpgradePD(image string) *TidbClusterConfig
func (*TidbClusterConfig) UpgradeTiDB ¶
func (tc *TidbClusterConfig) UpgradeTiDB(image string) *TidbClusterConfig
func (*TidbClusterConfig) UpgradeTiKV ¶
func (tc *TidbClusterConfig) UpgradeTiKV(image string) *TidbClusterConfig
Source Files ¶
Click to show internal directories.
Click to hide internal directories.