meta

package

Go to main page

Versions in this module

v1

v1.0.6

Jun 21, 2020

Changes in this version

+ var ValidateErr = &validateErr

type ClusterSpecification

+ Alertmanager []AlertManagerSpec

+ CDCServers []CDCSpec

+ Drainers []DrainerSpec

+ GlobalOptions GlobalOptions

+ Grafana []GrafanaSpec

+ MonitoredOptions MonitoredOptions

+ Monitors []PrometheusSpec

+ PDServers []PDSpec

+ PumpServers []PumpSpec

+ ServerConfigs ServerConfigs

+ TiDBServers []TiDBSpec

+ TiFlashServers []TiFlashSpec

+ TiKVServers []TiKVSpec

+ func (topo *ClusterSpecification) CountDir(targetHost, dirPrefix string) int

+ func (topo *ClusterSpecification) GetEtcdClient() (*clientv3.Client, error)

+ func (topo *ClusterSpecification) GetPDList() []string

+ func (topo *ClusterSpecification) Merge(that *ClusterSpecification) *ClusterSpecification

+ func (topo *ClusterSpecification) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (topo *ClusterSpecification) Validate() error

v1.0.5

Jun 18, 2020

Changes in this version

type AlertManagerInstance

+ func (i *AlertManagerInstance) GetListenHost() string

type CDCInstance

+ func (i *CDCInstance) GetListenHost() string

type DrainerInstance

+ func (i *DrainerInstance) GetListenHost() string

type GrafanaInstance

+ func (i *GrafanaInstance) GetListenHost() string

type MonitorInstance

+ func (i *MonitorInstance) GetListenHost() string

type PDInstance

+ func (i *PDInstance) GetListenHost() string

type PDSpec

+ ListenHost string

type PumpInstance

+ func (i *PumpInstance) GetListenHost() string

type TiDBInstance

+ func (i *TiDBInstance) GetListenHost() string

type TiDBSpec

+ ListenHost string

type TiFlashInstance

+ func (i *TiFlashInstance) GetListenHost() string

type TiKVInstance

+ func (i *TiKVInstance) GetListenHost() string

type TiKVSpec

+ ListenHost string

v1.0.4

Jun 9, 2020

v1.0.3

Jun 5, 2020

v1.0.2

Jun 4, 2020

v1.0.1

Jun 1, 2020

Changes in this version

+ const AnsibleImportedConfigPath

+ const BackupDirName

+ const ComponentAlertManager

+ const ComponentBlackboxExporter

+ const ComponentCDC

+ const ComponentCheckCollector

+ const ComponentDMMaster

+ const ComponentDMPortal

+ const ComponentDMWorker

+ const ComponentDrainer

+ const ComponentGrafana

+ const ComponentNodeExporter

+ const ComponentPD

+ const ComponentPrometheus

+ const ComponentPump

+ const ComponentPushwaygate

+ const ComponentTiDB

+ const ComponentTiFlash

+ const ComponentTiKV

+ const MetaFileName

+ const PatchDirName

+ const TempConfigPath

+ const TiOpsAuditDir

+ const TiOpsClusterDir

+ const TiOpsPackageCacheDir

+ var ErrClusterCreateDirFailed = errNSCluster.NewType("create_dir_failed")

+ var ErrClusterSaveMetaFailed = errNSCluster.NewType("save_meta_failed")

+ var RoleMonitor = "monitor"

+ func AllComponentNames() (roles []string)

+ func AllDMComponentNames() (roles []string)

+ func ClusterPath(cluster string, subpath ...string) string

+ func ComponentVersion(comp, version string) string

+ func EnsureClusterDir(clusterName string) error

+ func HandleImportPathMigration(clsName string) error

+ func Initialize(base string) error

+ func PortStarted(e executor.TiOpsExecutor, port int, timeout int64) error

+ func PortStopped(e executor.TiOpsExecutor, port int, timeout int64) error

+ func ProfileDir() string

+ func ProfilePath(subpath ...string) string

+ func SaveClusterMeta(clusterName string, meta *ClusterMeta) error

+ func SaveDMMeta(clusterName string, meta *DMMeta) error

+ func SetTiupEnv(env *tiupmeta.Environment)

+ func TiupEnv() *tiupmeta.Environment

+ type AlertManagerComponent struct

+ func (c *AlertManagerComponent) Instances() []Instance

+ func (c *AlertManagerComponent) Name() string

+ type AlertManagerInstance struct

+ func (i *AlertManagerInstance) Arch() string

+ func (i *AlertManagerInstance) ComponentName() string

+ func (i *AlertManagerInstance) DataDir() string

+ func (i *AlertManagerInstance) DeployDir() string

+ func (i *AlertManagerInstance) GetHost() string

+ func (i *AlertManagerInstance) GetPort() int

+ func (i *AlertManagerInstance) GetSSHPort() int

+ func (i *AlertManagerInstance) ID() string

+ func (i *AlertManagerInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *AlertManagerInstance) InstanceName() string

+ func (i *AlertManagerInstance) LogDir() string

+ func (i *AlertManagerInstance) OS() string

+ func (i *AlertManagerInstance) PrepareStart() error

+ func (i *AlertManagerInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *AlertManagerInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, clusterName string, ...) error

+ func (i *AlertManagerInstance) ServiceName() string

+ func (i *AlertManagerInstance) Status(pdList ...string) string

+ func (i *AlertManagerInstance) UsedDirs() []string

+ func (i *AlertManagerInstance) UsedPorts() []int

+ func (i *AlertManagerInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type AlertManagerSpec struct

+ Arch string

+ ClusterPort int

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ ResourceControl ResourceControl

+ SSHPort int

+ WebPort int

+ func (s AlertManagerSpec) GetMainPort() int

+ func (s AlertManagerSpec) IsImported() bool

+ func (s AlertManagerSpec) Role() string

+ func (s AlertManagerSpec) SSH() (string, int)

+ type CDCComponent struct

+ func (c *CDCComponent) Instances() []Instance

+ func (c *CDCComponent) Name() string

+ type CDCInstance struct

+ func (i *CDCInstance) Arch() string

+ func (i *CDCInstance) ComponentName() string

+ func (i *CDCInstance) DataDir() string

+ func (i *CDCInstance) DeployDir() string

+ func (i *CDCInstance) GetHost() string

+ func (i *CDCInstance) GetPort() int

+ func (i *CDCInstance) GetSSHPort() int

+ func (i *CDCInstance) ID() string

+ func (i *CDCInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *CDCInstance) InstanceName() string

+ func (i *CDCInstance) LogDir() string

+ func (i *CDCInstance) OS() string

+ func (i *CDCInstance) PrepareStart() error

+ func (i *CDCInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *CDCInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *CDCInstance) ServiceName() string

+ func (i *CDCInstance) Status(pdList ...string) string

+ func (i *CDCInstance) UsedDirs() []string

+ func (i *CDCInstance) UsedPorts() []int

+ func (i *CDCInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type CDCSpec struct

+ Arch string

+ Config map[string]interface{}

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ Offline bool

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ func (s CDCSpec) GetMainPort() int

+ func (s CDCSpec) IsImported() bool

+ func (s CDCSpec) Role() string

+ func (s CDCSpec) SSH() (string, int)

+ type ClusterMeta struct

+ OpsVer string

+ Topology *TopologySpecification

+ User string

+ Version string

+ func ClusterMetadata(clusterName string) (*ClusterMeta, error)

+ type ClusterSpecification = TopologySpecification

+ func (topo *ClusterSpecification) AlertManagerEndpoints(user string) []*scripts.AlertManagerScript

+ func (topo *ClusterSpecification) ComponentsByStartOrder() (comps []Component)

+ func (topo *ClusterSpecification) ComponentsByStopOrder() (comps []Component)

+ func (topo *ClusterSpecification) ComponentsByUpdateOrder() (comps []Component)

+ func (topo *ClusterSpecification) Endpoints(user string) []*scripts.PDScript

+ func (topo *ClusterSpecification) GetClusterSpecification() *ClusterSpecification

+ func (topo *ClusterSpecification) GetDMSpecification() *DMSpecification

+ func (topo *ClusterSpecification) GetGlobalOptions() GlobalOptions

+ func (topo *ClusterSpecification) GetMonitoredOptions() MonitoredOptions

+ func (topo *ClusterSpecification) IterComponent(fn func(comp Component))

+ func (topo *ClusterSpecification) IterHost(fn func(instance Instance))

+ func (topo *ClusterSpecification) IterInstance(fn func(instance Instance))

+ type Component interface

+ Instances func() []Instance

+ Name func() string

+ type DMMasterComponent struct

+ func (c *DMMasterComponent) Instances() []Instance

+ func (c *DMMasterComponent) Name() string

+ type DMMasterInstance struct

+ Name string

+ func (i *DMMasterInstance) Arch() string

+ func (i *DMMasterInstance) ComponentName() string

+ func (i *DMMasterInstance) DataDir() string

+ func (i *DMMasterInstance) DeployDir() string

+ func (i *DMMasterInstance) GetHost() string

+ func (i *DMMasterInstance) GetPort() int

+ func (i *DMMasterInstance) GetSSHPort() int

+ func (i *DMMasterInstance) ID() string

+ func (i *DMMasterInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *DMMasterInstance) InstanceName() string

+ func (i *DMMasterInstance) LogDir() string

+ func (i *DMMasterInstance) OS() string

+ func (i *DMMasterInstance) PrepareStart() error

+ func (i *DMMasterInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *DMMasterInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *DMMasterInstance) ServiceName() string

+ func (i *DMMasterInstance) Status(masterList ...string) string

+ func (i *DMMasterInstance) UsedDirs() []string

+ func (i *DMMasterInstance) UsedPorts() []int

+ func (i *DMMasterInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type DMMeta struct

+ Topology *DMTopologySpecification

+ User string

+ Version string

+ func DMMetadata(clusterName string) (*DMMeta, error)

+ type DMPortalComponent struct

+ func (c *DMPortalComponent) Instances() []Instance

+ func (c *DMPortalComponent) Name() string

+ type DMPortalInstance struct

+ func (i *DMPortalInstance) Arch() string

+ func (i *DMPortalInstance) ComponentName() string

+ func (i *DMPortalInstance) DataDir() string

+ func (i *DMPortalInstance) DeployDir() string

+ func (i *DMPortalInstance) GetHost() string

+ func (i *DMPortalInstance) GetPort() int

+ func (i *DMPortalInstance) GetSSHPort() int

+ func (i *DMPortalInstance) ID() string

+ func (i *DMPortalInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *DMPortalInstance) InstanceName() string

+ func (i *DMPortalInstance) LogDir() string

+ func (i *DMPortalInstance) OS() string

+ func (i *DMPortalInstance) PrepareStart() error

+ func (i *DMPortalInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *DMPortalInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *DMPortalInstance) ServiceName() string

+ func (i *DMPortalInstance) Status(masterList ...string) string

+ func (i *DMPortalInstance) UsedDirs() []string

+ func (i *DMPortalInstance) UsedPorts() []int

+ func (i *DMPortalInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type DMServerConfigs struct

+ Master map[string]interface{}

+ Portal map[string]interface{}

+ Worker map[string]interface{}

+ type DMSpecification = DMTopologySpecification

+ func (topo *DMSpecification) ComponentsByStartOrder() (comps []Component)

+ func (topo *DMSpecification) ComponentsByStopOrder() (comps []Component)

+ func (topo *DMSpecification) ComponentsByUpdateOrder() (comps []Component)

+ func (topo *DMSpecification) Endpoints(user string) []*scripts.DMMasterScript

+ func (topo *DMSpecification) GetClusterSpecification() *ClusterSpecification

+ func (topo *DMSpecification) GetDMSpecification() *DMSpecification

+ func (topo *DMSpecification) GetGlobalOptions() GlobalOptions

+ func (topo *DMSpecification) GetMonitoredOptions() MonitoredOptions

+ func (topo *DMSpecification) IterComponent(fn func(comp Component))

+ func (topo *DMSpecification) IterHost(fn func(instance Instance))

+ func (topo *DMSpecification) IterInstance(fn func(instance Instance))

+ type DMTopologySpecification struct

+ Alertmanager []AlertManagerSpec

+ GlobalOptions GlobalOptions

+ Grafana []GrafanaSpec

+ Masters []MasterSpec

+ MonitoredOptions MonitoredOptions

+ Monitors []PrometheusSpec

+ Portals []PortalSpec

+ ServerConfigs DMServerConfigs

+ Workers []WorkerSpec

+ func (topo *DMTopologySpecification) GetMasterList() []string

+ func (topo *DMTopologySpecification) Merge(that *DMTopologySpecification) *DMTopologySpecification

+ func (topo *DMTopologySpecification) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (topo *DMTopologySpecification) Validate() error

+ type DMWorkerComponent struct

+ func (c *DMWorkerComponent) Instances() []Instance

+ func (c *DMWorkerComponent) Name() string

+ type DMWorkerInstance struct

+ Name string

+ func (i *DMWorkerInstance) Arch() string

+ func (i *DMWorkerInstance) ComponentName() string

+ func (i *DMWorkerInstance) DataDir() string

+ func (i *DMWorkerInstance) DeployDir() string

+ func (i *DMWorkerInstance) GetHost() string

+ func (i *DMWorkerInstance) GetPort() int

+ func (i *DMWorkerInstance) GetSSHPort() int

+ func (i *DMWorkerInstance) ID() string

+ func (i *DMWorkerInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *DMWorkerInstance) InstanceName() string

+ func (i *DMWorkerInstance) LogDir() string

+ func (i *DMWorkerInstance) OS() string

+ func (i *DMWorkerInstance) PrepareStart() error

+ func (i *DMWorkerInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *DMWorkerInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *DMWorkerInstance) ServiceName() string

+ func (i *DMWorkerInstance) Status(masterList ...string) string

+ func (i *DMWorkerInstance) UsedDirs() []string

+ func (i *DMWorkerInstance) UsedPorts() []int

+ func (i *DMWorkerInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type DirPaths struct

+ Cache string

+ Data []string

+ Deploy string

+ Log string

+ func (p DirPaths) String() string

+ type DrainerComponent struct

+ func (c *DrainerComponent) Instances() []Instance

+ func (c *DrainerComponent) Name() string

+ type DrainerInstance struct

+ func (i *DrainerInstance) Arch() string

+ func (i *DrainerInstance) ComponentName() string

+ func (i *DrainerInstance) DataDir() string

+ func (i *DrainerInstance) DeployDir() string

+ func (i *DrainerInstance) GetHost() string

+ func (i *DrainerInstance) GetPort() int

+ func (i *DrainerInstance) GetSSHPort() int

+ func (i *DrainerInstance) ID() string

+ func (i *DrainerInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *DrainerInstance) InstanceName() string

+ func (i *DrainerInstance) LogDir() string

+ func (i *DrainerInstance) OS() string

+ func (i *DrainerInstance) PrepareStart() error

+ func (i *DrainerInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *DrainerInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *DrainerInstance) ServiceName() string

+ func (i *DrainerInstance) Status(pdList ...string) string

+ func (i *DrainerInstance) UsedDirs() []string

+ func (i *DrainerInstance) UsedPorts() []int

+ func (i *DrainerInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type DrainerSpec struct

+ Arch string

+ CommitTS int64

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ Offline bool

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ func (s DrainerSpec) GetMainPort() int

+ func (s DrainerSpec) IsImported() bool

+ func (s DrainerSpec) Role() string

+ func (s DrainerSpec) SSH() (string, int)

+ type GlobalOptions struct

+ Arch string

+ DataDir string

+ DeployDir string

+ LogDir string

+ OS string

+ ResourceControl ResourceControl

+ SSHPort int

+ User string

+ type GrafanaComponent struct

+ func (c *GrafanaComponent) Instances() []Instance

+ func (c *GrafanaComponent) Name() string

+ type GrafanaInstance struct

+ func (i *GrafanaInstance) Arch() string

+ func (i *GrafanaInstance) ComponentName() string

+ func (i *GrafanaInstance) DataDir() string

+ func (i *GrafanaInstance) DeployDir() string

+ func (i *GrafanaInstance) GetHost() string

+ func (i *GrafanaInstance) GetPort() int

+ func (i *GrafanaInstance) GetSSHPort() int

+ func (i *GrafanaInstance) ID() string

+ func (i *GrafanaInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *GrafanaInstance) InstanceName() string

+ func (i *GrafanaInstance) LogDir() string

+ func (i *GrafanaInstance) OS() string

+ func (i *GrafanaInstance) PrepareStart() error

+ func (i *GrafanaInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *GrafanaInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, clusterName string, ...) error

+ func (i *GrafanaInstance) ServiceName() string

+ func (i *GrafanaInstance) Status(pdList ...string) string

+ func (i *GrafanaInstance) UsedDirs() []string

+ func (i *GrafanaInstance) UsedPorts() []int

+ func (i *GrafanaInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type GrafanaSpec struct

+ Arch string

+ DeployDir string

+ Host string

+ Imported bool

+ OS string

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ func (s GrafanaSpec) GetMainPort() int

+ func (s GrafanaSpec) IsImported() bool

+ func (s GrafanaSpec) Role() string

+ func (s GrafanaSpec) SSH() (string, int)

+ type Instance interface

+ Arch func() string

+ ComponentName func() string

+ DataDir func() string

+ DeployDir func() string

+ GetHost func() string

+ GetPort func() int

+ GetSSHPort func() int

+ ID func() string

+ InitConfig func(e executor.TiOpsExecutor, clusterName string, clusterVersion string, ...) error

+ InstanceName func() string

+ LogDir func() string

+ OS func() string

+ PrepareStart func() error

+ Ready func(executor.TiOpsExecutor, int64) error

+ ScaleConfig func(e executor.TiOpsExecutor, topo Specification, clusterName string, ...) error

+ ServiceName func() string

+ Status func(pdList ...string) string

+ UsedDirs func() []string

+ UsedPorts func() []int

+ WaitForDown func(executor.TiOpsExecutor, int64) error

+ type InstanceSpec interface

+ GetMainPort func() int

+ IsImported func() bool

+ Role func() string

+ SSH func() (string, int)

+ type MasterSpec struct

+ Arch string

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ Name string

+ NumaNode string

+ OS string

+ PeerPort int

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ func (s MasterSpec) GetMainPort() int

+ func (s MasterSpec) IsImported() bool

+ func (s MasterSpec) Role() string

+ func (s MasterSpec) SSH() (string, int)

+ func (s MasterSpec) Status(masterList ...string) string

+ type MonitorComponent struct

+ func (c *MonitorComponent) Instances() []Instance

+ func (c *MonitorComponent) Name() string

+ type MonitorInstance struct

+ func (i *MonitorInstance) Arch() string

+ func (i *MonitorInstance) ComponentName() string

+ func (i *MonitorInstance) DataDir() string

+ func (i *MonitorInstance) DeployDir() string

+ func (i *MonitorInstance) GetHost() string

+ func (i *MonitorInstance) GetPort() int

+ func (i *MonitorInstance) GetSSHPort() int

+ func (i *MonitorInstance) ID() string

+ func (i *MonitorInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *MonitorInstance) InstanceName() string

+ func (i *MonitorInstance) LogDir() string

+ func (i *MonitorInstance) OS() string

+ func (i *MonitorInstance) PrepareStart() error

+ func (i *MonitorInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *MonitorInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, clusterName string, ...) error

+ func (i *MonitorInstance) ServiceName() string

+ func (i *MonitorInstance) Status(pdList ...string) string

+ func (i *MonitorInstance) UsedDirs() []string

+ func (i *MonitorInstance) UsedPorts() []int

+ func (i *MonitorInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type MonitoredOptions struct

+ BlackboxExporterPort int

+ DataDir string

+ DeployDir string

+ LogDir string

+ NodeExporterPort int

+ NumaNode string

+ ResourceControl ResourceControl

+ type PDComponent struct

+ func (c *PDComponent) Instances() []Instance

+ func (c *PDComponent) Name() string

+ type PDInstance struct

+ Name string

+ func (i *PDInstance) Arch() string

+ func (i *PDInstance) ComponentName() string

+ func (i *PDInstance) DataDir() string

+ func (i *PDInstance) DeployDir() string

+ func (i *PDInstance) GetHost() string

+ func (i *PDInstance) GetPort() int

+ func (i *PDInstance) GetSSHPort() int

+ func (i *PDInstance) ID() string

+ func (i *PDInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *PDInstance) InstanceName() string

+ func (i *PDInstance) LogDir() string

+ func (i *PDInstance) OS() string

+ func (i *PDInstance) PrepareStart() error

+ func (i *PDInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *PDInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *PDInstance) ServiceName() string

+ func (i *PDInstance) Status(pdList ...string) string

+ func (i *PDInstance) UsedDirs() []string

+ func (i *PDInstance) UsedPorts() []int

+ func (i *PDInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type PDSpec struct

+ Arch string

+ ClientPort int

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ Name string

+ NumaNode string

+ OS string

+ PeerPort int

+ ResourceControl ResourceControl

+ SSHPort int

+ func (s PDSpec) GetMainPort() int

+ func (s PDSpec) IsImported() bool

+ func (s PDSpec) Role() string

+ func (s PDSpec) SSH() (string, int)

+ func (s PDSpec) Status(pdList ...string) string

+ type PortalSpec struct

+ Arch string

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ Timeout int

+ func (s PortalSpec) GetMainPort() int

+ func (s PortalSpec) IsImported() bool

+ func (s PortalSpec) Role() string

+ func (s PortalSpec) SSH() (string, int)

+ type PrometheusSpec struct

+ Arch string

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ Port int

+ ResourceControl ResourceControl

+ Retention string

+ SSHPort int

+ func (s PrometheusSpec) GetMainPort() int

+ func (s PrometheusSpec) IsImported() bool

+ func (s PrometheusSpec) Role() string

+ func (s PrometheusSpec) SSH() (string, int)

+ type PumpComponent struct

+ func (c *PumpComponent) Instances() []Instance

+ func (c *PumpComponent) Name() string

+ type PumpInstance struct

+ func (i *PumpInstance) Arch() string

+ func (i *PumpInstance) ComponentName() string

+ func (i *PumpInstance) DataDir() string

+ func (i *PumpInstance) DeployDir() string

+ func (i *PumpInstance) GetHost() string

+ func (i *PumpInstance) GetPort() int

+ func (i *PumpInstance) GetSSHPort() int

+ func (i *PumpInstance) ID() string

+ func (i *PumpInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *PumpInstance) InstanceName() string

+ func (i *PumpInstance) LogDir() string

+ func (i *PumpInstance) OS() string

+ func (i *PumpInstance) PrepareStart() error

+ func (i *PumpInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *PumpInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *PumpInstance) ServiceName() string

+ func (i *PumpInstance) Status(pdList ...string) string

+ func (i *PumpInstance) UsedDirs() []string

+ func (i *PumpInstance) UsedPorts() []int

+ func (i *PumpInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type PumpSpec struct

+ Arch string

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ Offline bool

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ func (s PumpSpec) GetMainPort() int

+ func (s PumpSpec) IsImported() bool

+ func (s PumpSpec) Role() string

+ func (s PumpSpec) SSH() (string, int)

+ type ResourceControl struct

+ CPUQuota string

+ IOReadBandwidthMax string

+ IOWriteBandwidthMax string

+ MemoryLimit string

+ func MergeResourceControl(lhs, rhs ResourceControl) ResourceControl

+ type ServerConfigs struct

+ CDC map[string]interface{}

+ Drainer map[string]interface{}

+ PD map[string]interface{}

+ Pump map[string]interface{}

+ TiDB map[string]interface{}

+ TiFlash map[string]interface{}

+ TiFlashLearner map[string]interface{}

+ TiKV map[string]interface{}

+ type Specification interface

+ ComponentsByStartOrder func() (comps []Component)

+ ComponentsByStopOrder func() (comps []Component)

+ ComponentsByUpdateOrder func() (comps []Component)

+ GetClusterSpecification func() *ClusterSpecification

+ GetDMSpecification func() *DMSpecification

+ GetGlobalOptions func() GlobalOptions

+ GetMonitoredOptions func() MonitoredOptions

+ IterComponent func(fn func(comp Component))

+ IterHost func(fn func(instance Instance))

+ IterInstance func(fn func(instance Instance))

+ type TiDBComponent struct

+ func (c *TiDBComponent) Instances() []Instance

+ func (c *TiDBComponent) Name() string

+ type TiDBInstance struct

+ func (i *TiDBInstance) Arch() string

+ func (i *TiDBInstance) ComponentName() string

+ func (i *TiDBInstance) DataDir() string

+ func (i *TiDBInstance) DeployDir() string

+ func (i *TiDBInstance) GetHost() string

+ func (i *TiDBInstance) GetPort() int

+ func (i *TiDBInstance) GetSSHPort() int

+ func (i *TiDBInstance) ID() string

+ func (i *TiDBInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *TiDBInstance) InstanceName() string

+ func (i *TiDBInstance) LogDir() string

+ func (i *TiDBInstance) OS() string

+ func (i *TiDBInstance) PrepareStart() error

+ func (i *TiDBInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *TiDBInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *TiDBInstance) ServiceName() string

+ func (i *TiDBInstance) Status(pdList ...string) string

+ func (i *TiDBInstance) UsedDirs() []string

+ func (i *TiDBInstance) UsedPorts() []int

+ func (i *TiDBInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type TiDBSpec struct

+ Arch string

+ Config map[string]interface{}

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ StatusPort int

+ func (s TiDBSpec) GetMainPort() int

+ func (s TiDBSpec) IsImported() bool

+ func (s TiDBSpec) Role() string

+ func (s TiDBSpec) SSH() (string, int)

+ func (s TiDBSpec) Status(pdList ...string) string

+ type TiFlashComponent struct

+ func (c *TiFlashComponent) Instances() []Instance

+ func (c *TiFlashComponent) Name() string

+ type TiFlashInstance struct

+ func (i *TiFlashInstance) Arch() string

+ func (i *TiFlashInstance) ComponentName() string

+ func (i *TiFlashInstance) DataDir() string

+ func (i *TiFlashInstance) DeployDir() string

+ func (i *TiFlashInstance) GetHost() string

+ func (i *TiFlashInstance) GetPort() int

+ func (i *TiFlashInstance) GetSSHPort() int

+ func (i *TiFlashInstance) GetServicePort() int

+ func (i *TiFlashInstance) ID() string

+ func (i *TiFlashInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *TiFlashInstance) InitTiFlashConfig(cfg *scripts.TiFlashScript, src map[string]interface{}) (map[string]interface{}, error)

+ func (i *TiFlashInstance) InitTiFlashLearnerConfig(cfg *scripts.TiFlashScript, src map[string]interface{}) (map[string]interface{}, error)

+ func (i *TiFlashInstance) InstanceName() string

+ func (i *TiFlashInstance) LogDir() string

+ func (i *TiFlashInstance) OS() string

+ func (i *TiFlashInstance) PrepareStart() error

+ func (i *TiFlashInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *TiFlashInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *TiFlashInstance) ServiceName() string

+ func (i *TiFlashInstance) Status(pdList ...string) string

+ func (i *TiFlashInstance) UsedDirs() []string

+ func (i *TiFlashInstance) UsedPorts() []int

+ func (i *TiFlashInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type TiFlashSpec struct

+ Arch string

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ FlashProxyPort int

+ FlashProxyStatusPort int

+ FlashServicePort int

+ HTTPPort int

+ Host string

+ Imported bool

+ LearnerConfig map[string]interface{}

+ LogDir string

+ NumaNode string

+ OS string

+ Offline bool

+ ResourceControl ResourceControl

+ SSHPort int

+ StatusPort int

+ TCPPort int

+ TmpDir string

+ func (s TiFlashSpec) GetMainPort() int

+ func (s TiFlashSpec) IsImported() bool

+ func (s TiFlashSpec) Role() string

+ func (s TiFlashSpec) SSH() (string, int)

+ func (s TiFlashSpec) Status(pdList ...string) string

+ type TiKVComponent struct

+ func (c *TiKVComponent) Instances() []Instance

+ func (c *TiKVComponent) Name() string

+ type TiKVInstance struct

+ func (i *TiKVInstance) Arch() string

+ func (i *TiKVInstance) ComponentName() string

+ func (i *TiKVInstance) DataDir() string

+ func (i *TiKVInstance) DeployDir() string

+ func (i *TiKVInstance) GetHost() string

+ func (i *TiKVInstance) GetPort() int

+ func (i *TiKVInstance) GetSSHPort() int

+ func (i *TiKVInstance) ID() string

+ func (i *TiKVInstance) InitConfig(e executor.TiOpsExecutor, clusterName, clusterVersion, deployUser string, ...) error

+ func (i *TiKVInstance) InstanceName() string

+ func (i *TiKVInstance) LogDir() string

+ func (i *TiKVInstance) OS() string

+ func (i *TiKVInstance) PrepareStart() error

+ func (i *TiKVInstance) Ready(e executor.TiOpsExecutor, timeout int64) error

+ func (i *TiKVInstance) ScaleConfig(e executor.TiOpsExecutor, b Specification, ...) error

+ func (i *TiKVInstance) ServiceName() string

+ func (i *TiKVInstance) Status(pdList ...string) string

+ func (i *TiKVInstance) UsedDirs() []string

+ func (i *TiKVInstance) UsedPorts() []int

+ func (i *TiKVInstance) WaitForDown(e executor.TiOpsExecutor, timeout int64) error

+ type TiKVSpec struct

+ Arch string

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ NumaNode string

+ OS string

+ Offline bool

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ StatusPort int

+ func (s TiKVSpec) GetMainPort() int

+ func (s TiKVSpec) IsImported() bool

+ func (s TiKVSpec) Role() string

+ func (s TiKVSpec) SSH() (string, int)

+ func (s TiKVSpec) Status(pdList ...string) string

+ type TopologySpecification struct

+ Alertmanager []AlertManagerSpec

+ CDCServers []CDCSpec

+ Drainers []DrainerSpec

+ GlobalOptions GlobalOptions

+ Grafana []GrafanaSpec

+ MonitoredOptions MonitoredOptions

+ Monitors []PrometheusSpec

+ PDServers []PDSpec

+ PumpServers []PumpSpec

+ ServerConfigs ServerConfigs

+ TiDBServers []TiDBSpec

+ TiFlashServers []TiFlashSpec

+ TiKVServers []TiKVSpec

+ func (topo *TopologySpecification) GetEtcdClient() (*clientv3.Client, error)

+ func (topo *TopologySpecification) GetPDList() []string

+ func (topo *TopologySpecification) Merge(that *TopologySpecification) *TopologySpecification

+ func (topo *TopologySpecification) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (topo *TopologySpecification) Validate() error

+ type WorkerSpec struct

+ Arch string

+ Config map[string]interface{}

+ DataDir string

+ DeployDir string

+ Host string

+ Imported bool

+ LogDir string

+ Name string

+ NumaNode string

+ OS string

+ Port int

+ ResourceControl ResourceControl

+ SSHPort int

+ func (s WorkerSpec) GetMainPort() int

+ func (s WorkerSpec) IsImported() bool

+ func (s WorkerSpec) Role() string

+ func (s WorkerSpec) SSH() (string, int)

+ func (s WorkerSpec) Status(masterList ...string) string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL