Versions in this module Expand all Collapse all v0 v0.0.6 Aug 5, 2023 v0.0.5 Aug 5, 2023 v0.0.4 Aug 4, 2023 v0.0.3 Aug 4, 2023 v0.0.2 Aug 4, 2023 Changes in this version + func GetScript(filename string) ([]byte, error) + type AlertManagerScript struct + ClusterPort int + DataDir string + DeployDir string + EndPoints []*AlertManagerScript + IP string + LogDir string + NumaNode string + TLSEnabled bool + WebPort int + func NewAlertManagerScript(ip, deployDir, dataDir, logDir string, enableTLS bool) *AlertManagerScript + func (c *AlertManagerScript) AppendEndpoints(ends []*AlertManagerScript) *AlertManagerScript + func (c *AlertManagerScript) Config() ([]byte, error) + func (c *AlertManagerScript) ConfigToFile(file string) error + func (c *AlertManagerScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *AlertManagerScript) WithClusterPort(port int) *AlertManagerScript + func (c *AlertManagerScript) WithNumaNode(numa string) *AlertManagerScript + func (c *AlertManagerScript) WithWebPort(port int) *AlertManagerScript + type BlackboxExporterScript struct + DeployDir string + LogDir string + NumaNode string + Port uint64 + func NewBlackboxExporterScript(deployDir, logDir string) *BlackboxExporterScript + func (c *BlackboxExporterScript) Config() ([]byte, error) + func (c *BlackboxExporterScript) ConfigToFile(file string) error + func (c *BlackboxExporterScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *BlackboxExporterScript) WithNumaNode(numa string) *BlackboxExporterScript + func (c *BlackboxExporterScript) WithPort(port uint64) *BlackboxExporterScript + type CDCScript struct + ConfigFileEnabled bool + DataDir string + DataDirEnabled bool + DeployDir string + Endpoints []*PDScript + GCTTL int64 + IP string + LogDir string + NumaNode string + Port int + TLSEnabled bool + TZ string + func NewCDCScript(ip, deployDir, logDir string, enableTLS bool, gcTTL int64, tz string) *CDCScript + func (c *CDCScript) AppendEndpoints(ends ...*PDScript) *CDCScript + func (c *CDCScript) Config() ([]byte, error) + func (c *CDCScript) ConfigToFile(file string) error + func (c *CDCScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *CDCScript) PatchByVersion(clusterVersion, dataDir string) *CDCScript + func (c *CDCScript) WithConfigFileEnabled() *CDCScript + func (c *CDCScript) WithDataDir(dataDir string) *CDCScript + func (c *CDCScript) WithDataDirEnabled() *CDCScript + func (c *CDCScript) WithNumaNode(numa string) *CDCScript + func (c *CDCScript) WithPort(port int) *CDCScript + type DMMasterScaleScript struct + func NewDMMasterScaleScript(name, ip, deployDir, dataDir, logDir string) *DMMasterScaleScript + func (c *DMMasterScaleScript) AppendEndpoints(ends ...*DMMasterScript) *DMMasterScaleScript + func (c *DMMasterScaleScript) Config() ([]byte, error) + func (c *DMMasterScaleScript) ConfigToFile(file string) error + func (c *DMMasterScaleScript) WithNumaNode(numa string) *DMMasterScaleScript + func (c *DMMasterScaleScript) WithPeerPort(port int) *DMMasterScaleScript + func (c *DMMasterScaleScript) WithPort(port int) *DMMasterScaleScript + func (c *DMMasterScaleScript) WithScheme(scheme string) *DMMasterScaleScript + type DMMasterScript struct + DataDir string + DeployDir string + Endpoints []*DMMasterScript + IP string + LogDir string + Name string + NumaNode string + PeerPort int + Port int + Scheme string + V1SourcePath string + func NewDMMasterScript(name, ip, deployDir, dataDir, logDir string) *DMMasterScript + func (c *DMMasterScript) AppendEndpoints(ends ...*DMMasterScript) *DMMasterScript + func (c *DMMasterScript) Config() ([]byte, error) + func (c *DMMasterScript) ConfigToFile(file string) error + func (c *DMMasterScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *DMMasterScript) WithNumaNode(numa string) *DMMasterScript + func (c *DMMasterScript) WithPeerPort(port int) *DMMasterScript + func (c *DMMasterScript) WithPort(port int) *DMMasterScript + func (c *DMMasterScript) WithScheme(scheme string) *DMMasterScript + func (c *DMMasterScript) WithV1SourcePath(path string) *DMMasterScript + type DMWorkerScript struct + DeployDir string + Endpoints []*DMMasterScript + IP string + LogDir string + Name string + NumaNode string + Port int + func NewDMWorkerScript(name, ip, deployDir, logDir string) *DMWorkerScript + func (c *DMWorkerScript) AppendEndpoints(ends ...*DMMasterScript) *DMWorkerScript + func (c *DMWorkerScript) Config() ([]byte, error) + func (c *DMWorkerScript) ConfigToFile(file string) error + func (c *DMWorkerScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *DMWorkerScript) WithNumaNode(numa string) *DMWorkerScript + func (c *DMWorkerScript) WithPort(port int) *DMWorkerScript + type DrainerScript struct + CommitTs int64 + DataDir string + DeployDir string + Endpoints []*PDScript + IP string + LogDir string + NodeID string + NumaNode string + Port int + func NewDrainerScript(nodeID, ip, deployDir, dataDir, logDir string) *DrainerScript + func (c *DrainerScript) AppendEndpoints(ends ...*PDScript) *DrainerScript + func (c *DrainerScript) Config() ([]byte, error) + func (c *DrainerScript) ConfigToFile(file string) error + func (c *DrainerScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *DrainerScript) WithCommitTs(ts int64) *DrainerScript + func (c *DrainerScript) WithNumaNode(numa string) *DrainerScript + func (c *DrainerScript) WithPort(port int) *DrainerScript + type GrafanaScript struct + ClusterName string + DeployDir string + NumaNode string + func NewGrafanaScript(cluster, deployDir string) *GrafanaScript + func (c *GrafanaScript) Config() ([]byte, error) + func (c *GrafanaScript) ConfigToFile(file string) error + func (c *GrafanaScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *GrafanaScript) WithNumaNode(numa string) *GrafanaScript + func (c *GrafanaScript) WithTPLFile(file string) *GrafanaScript + type NodeExporterScript struct + DeployDir string + LogDir string + NumaNode string + Port uint64 + func NewNodeExporterScript(deployDir, logDir string) *NodeExporterScript + func (c *NodeExporterScript) Config() ([]byte, error) + func (c *NodeExporterScript) ConfigToFile(file string) error + func (c *NodeExporterScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *NodeExporterScript) WithNumaNode(numa string) *NodeExporterScript + func (c *NodeExporterScript) WithPort(port uint64) *NodeExporterScript + type PDScaleScript struct + func NewPDScaleScript(pdScript *PDScript) *PDScaleScript + func (c *PDScaleScript) Config() ([]byte, error) + func (c *PDScaleScript) ConfigToFile(file string) error + type PDScript struct + AdvertiseClientAddr string + AdvertisePeerAddr string + ClientPort int + DataDir string + DeployDir string + Endpoints []*PDScript + IP string + ListenHost string + LogDir string + Name string + NumaNode string + PeerPort int + Scheme string + func NewPDScript(name, ip, deployDir, dataDir, logDir string) *PDScript + func (c *PDScript) AppendEndpoints(ends ...*PDScript) *PDScript + func (c *PDScript) Config() ([]byte, error) + func (c *PDScript) ConfigToFile(file string) error + func (c *PDScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *PDScript) WithAdvertiseClientAddr(addr string) *PDScript + func (c *PDScript) WithAdvertisePeerAddr(addr string) *PDScript + func (c *PDScript) WithClientPort(port int) *PDScript + func (c *PDScript) WithListenHost(listenHost string) *PDScript + func (c *PDScript) WithNumaNode(numa string) *PDScript + func (c *PDScript) WithPeerPort(port int) *PDScript + func (c *PDScript) WithScheme(scheme string) *PDScript + type PrometheusScript struct + DataDir string + DeployDir string + IP string + LogDir string + NumaNode string + Port int + Retention string + func NewPrometheusScript(ip, deployDir, dataDir, logDir string) *PrometheusScript + func (c *PrometheusScript) Config() ([]byte, error) + func (c *PrometheusScript) ConfigToFile(file string) error + func (c *PrometheusScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *PrometheusScript) WithNumaNode(numa string) *PrometheusScript + func (c *PrometheusScript) WithPort(port int) *PrometheusScript + func (c *PrometheusScript) WithRetention(retention string) *PrometheusScript + func (c *PrometheusScript) WithTPLFile(fname string) *PrometheusScript + type PumpScript struct + CommitTs int64 + DataDir string + DeployDir string + Endpoints []*PDScript + Host string + LogDir string + NodeID string + NumaNode string + Port int + func NewPumpScript(nodeID, host, deployDir, dataDir, logDir string) *PumpScript + func (c *PumpScript) AppendEndpoints(ends ...*PDScript) *PumpScript + func (c *PumpScript) Config() ([]byte, error) + func (c *PumpScript) ConfigToFile(file string) error + func (c *PumpScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *PumpScript) WithNumaNode(numa string) *PumpScript + func (c *PumpScript) WithPort(port int) *PumpScript + type TiDBScript struct + AdvertiseAddr string + DeployDir string + Endpoints []*PDScript + IP string + ListenHost string + LogDir string + NumaNode string + Port int + StatusPort int + func NewTiDBScript(ip, deployDir, logDir string) *TiDBScript + func (c *TiDBScript) AppendEndpoints(ends ...*PDScript) *TiDBScript + func (c *TiDBScript) Config() ([]byte, error) + func (c *TiDBScript) ConfigToFile(file string) error + func (c *TiDBScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *TiDBScript) WithAdvertiseAddr(addr string) *TiDBScript + func (c *TiDBScript) WithListenHost(listenHost string) *TiDBScript + func (c *TiDBScript) WithNumaNode(numa string) *TiDBScript + func (c *TiDBScript) WithPort(port int) *TiDBScript + func (c *TiDBScript) WithStatusPort(port int) *TiDBScript + type TiFlashScript struct + DataDir string + DeployDir string + Endpoints []*PDScript + FlashProxyPort int + FlashProxyStatusPort int + FlashServicePort int + HTTPPort int + IP string + LogDir string + NumaNode string + PDAddrs string + StatusPort int + TCPPort int + TiDBStatusAddrs string + TmpDir string + func NewTiFlashScript(ip, deployDir, dataDir string, logDir string, tidbStatusAddrs string, ...) *TiFlashScript + func (c *TiFlashScript) AppendEndpoints(ends ...*PDScript) *TiFlashScript + func (c *TiFlashScript) Config() ([]byte, error) + func (c *TiFlashScript) ConfigToFile(file string) error + func (c *TiFlashScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *TiFlashScript) WithFlashProxyPort(port int) *TiFlashScript + func (c *TiFlashScript) WithFlashProxyStatusPort(port int) *TiFlashScript + func (c *TiFlashScript) WithFlashServicePort(port int) *TiFlashScript + func (c *TiFlashScript) WithHTTPPort(port int) *TiFlashScript + func (c *TiFlashScript) WithNumaNode(numa string) *TiFlashScript + func (c *TiFlashScript) WithStatusPort(port int) *TiFlashScript + func (c *TiFlashScript) WithTCPPort(port int) *TiFlashScript + func (c *TiFlashScript) WithTmpDir(tmpDir string) *TiFlashScript + type TiKVScript struct + AdvertiseAddr string + AdvertiseStatusAddr string + DataDir string + DeployDir string + Endpoints []*PDScript + IP string + ListenHost string + LogDir string + NumaNode string + Port int + StatusPort int + SupportAdvertiseStatusAddr bool + func NewTiKVScript(version, ip string, port, statusPort int, deployDir, dataDir, logDir string) *TiKVScript + func (c *TiKVScript) AppendEndpoints(ends ...*PDScript) *TiKVScript + func (c *TiKVScript) Config() ([]byte, error) + func (c *TiKVScript) ConfigToFile(file string) error + func (c *TiKVScript) ConfigWithTemplate(tpl string) ([]byte, error) + func (c *TiKVScript) WithAdvertiseAddr(addr string) *TiKVScript + func (c *TiKVScript) WithAdvertiseStatusAddr(addr string) *TiKVScript + func (c *TiKVScript) WithListenHost(listenHost string) *TiKVScript + func (c *TiKVScript) WithNumaNode(numa string) *TiKVScript + type TiSparkEnv struct + CustomEnvs map[string]string + Host string + MasterPort int + MasterUIPort int + TiSparkLocalIP string + TiSparkMaster string + WorkerPort int + WorkerUIPort int + func NewTiSparkEnv(host string) *TiSparkEnv + func (c *TiSparkEnv) Script() ([]byte, error) + func (c *TiSparkEnv) ScriptToFile(file string) error + func (c *TiSparkEnv) ScriptWithTemplate(tpl string) ([]byte, error) + func (c *TiSparkEnv) SlaveScriptWithTemplate() ([]byte, error) + func (c *TiSparkEnv) WithCustomEnv(m map[string]string) *TiSparkEnv + func (c *TiSparkEnv) WithLocalIP(ip string) *TiSparkEnv + func (c *TiSparkEnv) WithMaster(master string) *TiSparkEnv + func (c *TiSparkEnv) WithMasterPorts(port, ui int) *TiSparkEnv + func (c *TiSparkEnv) WithWorkerPorts(port, ui int) *TiSparkEnv