Versions in this module Expand all Collapse all v1 v1.1.9 Oct 1, 2018 Changes in this version + const CockroachBinaryInContainer + const DefaultTCP + var CockroachBinary = flag.String("b", func() string { ... }(), "the host-side binary to run") + var ErrIntOverflowTestconfig = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTestconfig = fmt.Errorf("proto: negative length found during unmarshaling") + var HTTPClient = http.Client + var InitMode_name = map[int32]string + var InitMode_value = map[string]int32 + 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) + ExecCLI func(ctx context.Context, i int, args []string) (string, 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 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 Event struct + NodeIndex int + Status 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 struct + Stores []StoreConfig + Version string + 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 + 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 + InitMode InitMode + Name string + Nodes []NodeConfig + 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 Incompatible versions in this module v19.2.12+incompatible Jan 12, 2021
Go to main page