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 + var SysProcAttr *syscall.SysProcAttr = nil — darwin/amd64, js/wasm, windows/amd64 + var SysProcAttr = &syscall.SysProcAttr — linux/amd64 + func AdvertiseHost(listen string) string + func CompVersion(comp string, version utils.Version) string + type Config struct + BinPath string + ConfigPath string + Host string + Num int + Port int + UpTimeout int + type Drainer struct + func NewDrainer(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *Drainer + func (d *Drainer) Addr() string + func (d *Drainer) Component() string + func (d *Drainer) LogFile() string + func (d *Drainer) NodeID() string + func (d *Drainer) Start(ctx context.Context, version utils.Version) error + func (inst *Drainer) StatusAddrs() (addrs []string) + type Instance interface + Component func() string + LogFile func() string + Pid func() int + Start func(ctx context.Context, version utils.Version) error + StatusAddrs func() []string + Uptime func() string + Wait func() error + type PDInstance struct + func NewPDInstance(binPath, dir, host, configPath string, id int) *PDInstance + func (inst *PDInstance) Addr() string + func (inst *PDInstance) Component() string + func (inst *PDInstance) InitCluster(pds []*PDInstance) *PDInstance + func (inst *PDInstance) Join(pds []*PDInstance) *PDInstance + func (inst *PDInstance) LogFile() string + func (inst *PDInstance) Name() string + func (inst *PDInstance) Start(ctx context.Context, version utils.Version) error + func (inst *PDInstance) StatusAddrs() (addrs []string) + type Process interface + Cmd func() *exec.Cmd + Pid func() int + SetOutputFile func(fname string) error + Start func() error + Uptime func() string + Wait func() error + func NewComponentProcess(ctx context.Context, dir, binPath, component string, version utils.Version, ...) (Process, error) + func NewComponentProcessWithEnvs(ctx context.Context, dir, binPath, component string, version utils.Version, ...) (Process, error) + type Pump struct + func NewPump(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *Pump + func (inst *Pump) StatusAddrs() (addrs []string) + func (p *Pump) Addr() string + func (p *Pump) Component() string + func (p *Pump) LogFile() string + func (p *Pump) NodeID() string + func (p *Pump) Ready(ctx context.Context) error + func (p *Pump) Start(ctx context.Context, version utils.Version) error + type TiCDC struct + func NewTiCDC(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *TiCDC + func (c *TiCDC) Component() string + func (c *TiCDC) LogFile() string + func (c *TiCDC) Start(ctx context.Context, version utils.Version) error + func (inst *TiCDC) StatusAddrs() (addrs []string) + type TiDBInstance struct + func NewTiDBInstance(binPath string, dir, host, configPath string, id, port int, pds []*PDInstance, ...) *TiDBInstance + func (inst *TiDBInstance) Addr() string + func (inst *TiDBInstance) Component() string + func (inst *TiDBInstance) LogFile() string + func (inst *TiDBInstance) Start(ctx context.Context, version utils.Version) error + func (inst *TiDBInstance) StatusAddrs() (addrs []string) + type TiFlashInstance struct + ProxyConfigPath string + ProxyPort int + ProxyStatusPort int + ServicePort int + TCPPort int + func NewTiFlashInstance(binPath, dir, host, configPath string, id int, pds []*PDInstance, ...) *TiFlashInstance + func (inst *TiFlashInstance) Addr() string + func (inst *TiFlashInstance) Cmd() *exec.Cmd + func (inst *TiFlashInstance) Component() string + func (inst *TiFlashInstance) LogFile() string + func (inst *TiFlashInstance) Start(ctx context.Context, version utils.Version) error + func (inst *TiFlashInstance) StatusAddrs() (addrs []string) + func (inst *TiFlashInstance) StoreAddr() string + type TiKVInstance struct + func NewTiKVInstance(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *TiKVInstance + func (inst *TiKVInstance) Addr() string + func (inst *TiKVInstance) Component() string + func (inst *TiKVInstance) LogFile() string + func (inst *TiKVInstance) Start(ctx context.Context, version utils.Version) error + func (inst *TiKVInstance) StatusAddrs() (addrs []string) + func (inst *TiKVInstance) StoreAddr() string
Go to main page