cluster

Oct 16, 2017

Changes in this version

+ var CockroachBinary = flag.String("b", func() string { ... }(), "the host-side binary to run")

+ var InitMode_name = map[int32]string

+ var InitMode_value = map[string]int32

type Cluster

+ ExecCLI func(ctx context.Context, i int, args []string) (string, string, error)

+ type DockerCluster struct

+ CertsDir string

+ Nodes []*testNode

+ func CreateDocker(ctx context.Context, cfg TestConfig, logDir string, stopper *stop.Stopper) *DockerCluster

+ func (l *DockerCluster) Addr(ctx context.Context, i int, port string) string

+ func (l *DockerCluster) Assert(ctx context.Context, t testing.TB)

+ func (l *DockerCluster) AssertAndStop(ctx context.Context, t testing.TB)

+ func (l *DockerCluster) Cleanup(ctx context.Context)

+ func (l *DockerCluster) ExecCLI(ctx context.Context, i int, cmd []string) (string, string, error)

+ func (l *DockerCluster) Hostname(i int) string

+ func (l *DockerCluster) InternalIP(ctx context.Context, i int) net.IP

+ func (l *DockerCluster) Kill(ctx context.Context, i int) error

+ func (l *DockerCluster) NewClient(ctx context.Context, i int) (*roachClient.DB, error)

+ func (l *DockerCluster) NumNodes() int

+ func (l *DockerCluster) OneShot(ctx context.Context, ref string, ipo types.ImagePullOptions, ...) error

+ func (l *DockerCluster) PGUrl(ctx context.Context, i int) string

+ func (l *DockerCluster) Restart(ctx context.Context, i int) error

+ func (l *DockerCluster) RunInitCommand(ctx context.Context, nodeIdx int)

+ func (l *DockerCluster) Start(ctx context.Context)

+ func (l *DockerCluster) URL(ctx context.Context, i int) string

+ type InitMode int32

+ const INIT_BOOTSTRAP_NODE_ZERO

+ const INIT_COMMAND

+ const INIT_NONE

+ func (InitMode) EnumDescriptor() ([]byte, []int)

+ func (x *InitMode) UnmarshalJSON(data []byte) error

+ func (x InitMode) Enum() *InitMode

+ func (x InitMode) String() string

type NodeConfig

+ Version string

type TestConfig

+ InitMode InitMode

Jun 7, 2017

Changes in this version

+ const CockroachBinaryInContainer

+ const DefaultDuration

+ const DefaultTCP

+ var ErrIntOverflowTestconfig = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTestconfig = fmt.Errorf("proto: negative length found during unmarshaling")

+ var HTTPClient = http.Client

+ func Consistent(ctx context.Context, c Cluster, i int) error

+ type Cluster interface

+ Addr func(ctx context.Context, i int, port string) string

+ Assert func(context.Context, testing.TB)

+ AssertAndStop func(context.Context, testing.TB)

+ ExecRoot func(ctx context.Context, i int, cmd []string) error

+ Hostname func(i int) string

+ InternalIP func(ctx context.Context, i int) net.IP

+ Kill func(context.Context, int) error

+ NewClient func(context.Context, int) (*client.DB, error)

+ NumNodes func() int

+ PGUrl func(context.Context, int) string

+ Restart func(context.Context, int) error

+ URL func(context.Context, int) string

+ type Container struct

+ func (c *Container) Addr(ctx context.Context, port nat.Port) *net.TCPAddr

+ func (c *Container) Inspect(ctx context.Context) (types.ContainerJSON, error)

+ func (c *Container) Kill(ctx context.Context) error

+ func (c *Container) Logs(ctx context.Context, w io.Writer) error

+ func (c *Container) Pause(ctx context.Context) error

+ func (c *Container) Remove(ctx context.Context) error

+ func (c *Container) Restart(ctx context.Context, timeout *time.Duration) error

+ func (c *Container) Start(ctx context.Context) error

+ func (c *Container) Stop(ctx context.Context, timeout *time.Duration) error

+ func (c *Container) Unpause(ctx context.Context) error

+ func (c *Container) Wait(ctx context.Context) error

+ func (c Container) Name() string

+ type Event struct

+ NodeIndex int

+ Status string

+ type LocalCluster struct

+ CertsDir string

+ Nodes []*testNode

+ func CreateLocal(ctx context.Context, cfg TestConfig, logDir string, privileged bool, ...) *LocalCluster

+ func (l *LocalCluster) Addr(ctx context.Context, i int, port string) string

+ func (l *LocalCluster) Assert(ctx context.Context, t testing.TB)

+ func (l *LocalCluster) AssertAndStop(ctx context.Context, t testing.TB)

+ func (l *LocalCluster) Cleanup(ctx context.Context)

+ func (l *LocalCluster) ExecRoot(ctx context.Context, i int, cmd []string) error

+ func (l *LocalCluster) Hostname(i int) string

+ func (l *LocalCluster) InternalIP(ctx context.Context, i int) net.IP

+ func (l *LocalCluster) Kill(ctx context.Context, i int) error

+ func (l *LocalCluster) NewClient(ctx context.Context, i int) (*roachClient.DB, error)

+ func (l *LocalCluster) NumNodes() int

+ func (l *LocalCluster) OneShot(ctx context.Context, ref string, ipo types.ImagePullOptions, ...) error

+ func (l *LocalCluster) PGUrl(ctx context.Context, i int) string

+ func (l *LocalCluster) Restart(ctx context.Context, i int) error

+ func (l *LocalCluster) Start(ctx context.Context)

+ func (l *LocalCluster) URL(ctx context.Context, i int) string

+ type NodeConfig struct

+ Count int32

+ Stores []StoreConfig

+ func (*NodeConfig) Descriptor() ([]byte, []int)

+ func (*NodeConfig) ProtoMessage()

+ func (m *NodeConfig) Marshal() (dAtA []byte, err error)

+ func (m *NodeConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *NodeConfig) Reset()

+ func (m *NodeConfig) Size() (n int)

+ func (m *NodeConfig) String() string

+ func (m *NodeConfig) Unmarshal(dAtA []byte) error

+ type StoreConfig struct

+ Count int32

+ MaxRanges int32

+ func (*StoreConfig) Descriptor() ([]byte, []int)

+ func (*StoreConfig) ProtoMessage()

+ func (m *StoreConfig) Marshal() (dAtA []byte, err error)

+ func (m *StoreConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *StoreConfig) Reset()

+ func (m *StoreConfig) Size() (n int)

+ func (m *StoreConfig) String() string

+ func (m *StoreConfig) Unmarshal(dAtA []byte) error

+ type TestConfig struct

+ Duration time.Duration

+ Name string

+ Nodes []NodeConfig

+ func DefaultConfigs() []TestConfig

+ func (*TestConfig) Descriptor() ([]byte, []int)

+ func (*TestConfig) ProtoMessage()

+ func (m *TestConfig) Marshal() (dAtA []byte, err error)

+ func (m *TestConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *TestConfig) Reset()

+ func (m *TestConfig) Size() (n int)

+ func (m *TestConfig) String() string

+ func (m *TestConfig) Unmarshal(dAtA []byte) error