instance

Documentation

Index

• type Config
• type Instance
• type PDInstance
  • func NewPDInstance(binPath, dir, host, configPath string, id int) *PDInstance
  • func (inst *PDInstance) Addr() string
  • func (inst *PDInstance) InitCluster(pds []*PDInstance) *PDInstance
  • func (inst *PDInstance) Join(pds []*PDInstance) *PDInstance
  • func (inst *PDInstance) Pid() int
  • func (inst *PDInstance) Start(ctx context.Context, version v0manifest.Version) error
  • func (inst *PDInstance) Wait() error
• type TiDBInstance
  • func NewTiDBInstance(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *TiDBInstance
  • func (inst *TiDBInstance) Addr() string
  • func (inst *TiDBInstance) Pid() int
  • func (inst *TiDBInstance) Start(ctx context.Context, version v0manifest.Version) error
  • func (inst *TiDBInstance) Wait() error
• type TiFlashInstance
  • func NewTiFlashInstance(binPath, dir, host, configPath string, id int, pds []*PDInstance, ...) *TiFlashInstance
  • func (inst *TiFlashInstance) Pid() int
  • func (inst *TiFlashInstance) Start(ctx context.Context, version v0manifest.Version) error
  • func (inst *TiFlashInstance) StoreAddr() string
  • func (inst *TiFlashInstance) Wait() error
• type TiKVInstance
  • func NewTiKVInstance(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *TiKVInstance
  • func (inst *TiKVInstance) Pid() int
  • func (inst *TiKVInstance) Start(ctx context.Context, version v0manifest.Version) error
  • func (inst *TiKVInstance) StoreAddr() string
  • func (inst *TiKVInstance) Wait() error

Types

type Config

type Config struct {
	ConfigPath string
	BinPath    string
	Num        int
	Host       string
}

Config of the instance.

type Instance

type Instance interface {
	Pid() int
	// Start the instance process.
	Start(ctx context.Context, version v0manifest.Version) error
	Wait() error
}

Instance represent running component

type PDInstance

type PDInstance struct {
	// contains filtered or unexported fields
}

PDInstance represent a running pd-server

func NewPDInstance

func NewPDInstance(binPath, dir, host, configPath string, id int) *PDInstance

NewPDInstance return a PDInstance

func (*PDInstance) Addr

func (inst *PDInstance) Addr() string

Addr return the listen address of PD

func (*PDInstance) InitCluster

func (inst *PDInstance) InitCluster(pds []*PDInstance) *PDInstance

InitCluster set the init cluster instance.

func (*PDInstance) Join

func (inst *PDInstance) Join(pds []*PDInstance) *PDInstance

Join set endpoints field of PDInstance

func (*PDInstance) Pid

func (inst *PDInstance) Pid() int

Pid return the PID of the instance

func (*PDInstance) Start

func (inst *PDInstance) Start(ctx context.Context, version v0manifest.Version) error

Start calls set inst.cmd and Start

func (*PDInstance) Wait

func (inst *PDInstance) Wait() error

Wait calls inst.cmd.Wait

type TiDBInstance

type TiDBInstance struct {
	// contains filtered or unexported fields
}

TiDBInstance represent a running tidb-server

func NewTiDBInstance

func NewTiDBInstance(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *TiDBInstance

NewTiDBInstance return a TiDBInstance

func (*TiDBInstance) Addr

func (inst *TiDBInstance) Addr() string

Addr return the listen address of TiDB

func (*TiDBInstance) Pid

func (inst *TiDBInstance) Pid() int

Pid return the PID of the instance

func (*TiDBInstance) Start

func (inst *TiDBInstance) Start(ctx context.Context, version v0manifest.Version) error

Start calls set inst.cmd and Start

func (*TiDBInstance) Wait

func (inst *TiDBInstance) Wait() error

Wait calls inst.cmd.Wait

type TiFlashInstance

type TiFlashInstance struct {
	TCPPort         int
	ServicePort     int
	ProxyPort       int
	ProxyStatusPort int
	ProxyConfigPath string
	// contains filtered or unexported fields
}

TiFlashInstance represent a running TiFlash

func NewTiFlashInstance

func NewTiFlashInstance(binPath, dir, host, configPath string, id int, pds []*PDInstance, dbs []*TiDBInstance) *TiFlashInstance

NewTiFlashInstance return a TiFlashInstance

func (*TiFlashInstance) Pid

func (inst *TiFlashInstance) Pid() int

Pid return the PID of the instance

func (*TiFlashInstance) Start

func (inst *TiFlashInstance) Start(ctx context.Context, version v0manifest.Version) error

Start calls set inst.cmd and Start

func (*TiFlashInstance) StoreAddr

func (inst *TiFlashInstance) StoreAddr() string

StoreAddr return the store address of TiFlash

func (*TiFlashInstance) Wait

func (inst *TiFlashInstance) Wait() error

Wait calls inst.cmd.Wait

type TiKVInstance

type TiKVInstance struct {
	// contains filtered or unexported fields
}

TiKVInstance represent a running tikv-server

func NewTiKVInstance

func NewTiKVInstance(binPath string, dir, host, configPath string, id int, pds []*PDInstance) *TiKVInstance

NewTiKVInstance return a TiKVInstance

func (*TiKVInstance) Pid

func (inst *TiKVInstance) Pid() int

Pid return the PID of the instance

func (*TiKVInstance) Start

func (inst *TiKVInstance) Start(ctx context.Context, version v0manifest.Version) error

Start calls set inst.cmd and Start

func (*TiKVInstance) StoreAddr

func (inst *TiKVInstance) StoreAddr() string

StoreAddr return the store address of TiKV

func (*TiKVInstance) Wait

func (inst *TiKVInstance) Wait() error

Wait calls inst.cmd.Wait