Versions in this module Expand all Collapse all v1 v1.0.0 Dec 17, 2020 Changes in this version + type Client struct + ClusterName string + Namespace string + PDMemberFunc func(ns, name string) (string, []string, error) + func (c *Client) PDMember() (string, []string, error) + type ClientNode struct + ClusterName string + Component Component + IP string + Namespace string + Port int32 + func (clientNode ClientNode) Address() string + func (clientNode ClientNode) String() string + type Cluster interface + Apply func() error + Delete func() error + GetClientNodes func() ([]ClientNode, error) + GetNodes func() ([]Node, error) + type Component string + const CDC + const DM + const Drainer + const Monitor + const MySQL + const PD + const Pump + const TiDB + const TiFlash + const TiKV + const Unknown + type K8sProvider struct + func (k *K8sProvider) SetUp(_ context.Context, spec Specs) ([]Node, []ClientNode, error) + func (k *K8sProvider) TearDown(_ context.Context, spec Specs) error + type LocalClusterProvider struct + DBs []string + KVs []string + PDs []string + func (l *LocalClusterProvider) SetUp(ctx context.Context, _ Specs) ([]Node, []ClientNode, error) + func (l *LocalClusterProvider) TearDown(ctx context.Context, _ Specs) error + type Node struct + Component Component + IP string + Namespace string + PodName string + Port int32 + func (node Node) String() string + type Provider interface + SetUp func(ctx context.Context, spec Specs) ([]Node, []ClientNode, error) + TearDown func(ctx context.Context, spec Specs) error + func NewDefaultClusterProvider() Provider + func NewK8sClusterProvider() Provider + func NewLocalClusterProvisioner(dbs, pds, kvs []string) Provider + type Specs struct + Cluster Cluster + Namespace string + NemesisGens []string
Go to main page