Versions in this module Expand all Collapse all v1 v1.1.4 Jan 1, 2018 Changes in this version + func IsUnavailableError(err error) bool + func MakePerNodeFixedPortsCfg(numNodes int) map[int]NodeConfig + type Cluster struct + Nodes []*Node + func New(cfg ClusterConfig) *Cluster + func (c *Cluster) Client(idx int) *client.DB + func (c *Cluster) Close() + func (c *Cluster) HTTPPort(nodeIdx int) string + func (c *Cluster) IPAddr(nodeIdx int) string + func (c *Cluster) RPCPort(nodeIdx int) string + func (c *Cluster) RandNode(f func(int) int) int + func (c *Cluster) Split(nodeIdx int, splitKey roachpb.Key) error + func (c *Cluster) Start(ctx context.Context) + func (c *Cluster) TransferLease(nodeIdx int, r *rand.Rand, key roachpb.Key) (bool, error) + func (c *Cluster) UpdateZoneConfig(rangeMinBytes, rangeMaxBytes int64) + type ClusterConfig struct + AllNodeArgs []string + Binary string + DB string + DataDir string + Ephemeral bool + LogDir string + NumNodes int + NumWorkers int + PerNodeCfg map[int]NodeConfig + type LocalCluster struct + func (b *LocalCluster) Addr(ctx context.Context, i int, port string) string + func (b *LocalCluster) Assert(ctx context.Context, t testing.TB) + func (b *LocalCluster) AssertAndStop(ctx context.Context, t testing.TB) + func (b *LocalCluster) ExecCLI(ctx context.Context, i int, cmd []string) (string, string, error) + func (b *LocalCluster) Hostname(i int) string + func (b *LocalCluster) InternalIP(ctx context.Context, i int) net.IP + func (b *LocalCluster) Kill(ctx context.Context, i int) error + func (b *LocalCluster) NewClient(ctx context.Context, i int) (*client.DB, error) + func (b *LocalCluster) NumNodes() int + func (b *LocalCluster) PGUrl(ctx context.Context, i int) string + func (b *LocalCluster) Port(ctx context.Context, i int) string + func (b *LocalCluster) Restart(ctx context.Context, i int) error + func (b *LocalCluster) RestartAsync(ctx context.Context, i int) <-chan error + func (b *LocalCluster) URL(ctx context.Context, i int) string + type Node struct + Cfg NodeConfig + func (n *Node) Alive() bool + func (n *Node) Client() *client.DB + func (n *Node) DB() *gosql.DB + func (n *Node) HTTPPort() string + func (n *Node) IPAddr() string + func (n *Node) Kill() + func (n *Node) PGUrl() string + func (n *Node) RPCAddr() string + func (n *Node) RPCPort() string + func (n *Node) Start(ctx context.Context, joins ...string) + func (n *Node) StartAsync(ctx context.Context, joins ...string) <-chan error + func (n *Node) StatusClient() serverpb.StatusClient + type NodeConfig struct + Addr string + Binary string + DB string + DataDir string + ExtraArgs []string + ExtraEnv []string + HTTPPort int + LogDir string + NumWorkers int + RPCPort int
Go to main page