cluster

package

v1.16.21 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(t *testing.T, fopts ...Option) *Cluster

func (c *Cluster) Addresses() []string

func (c *Cluster) Cleanup(t *testing.T)

func (c *Cluster) Client(t *testing.T, ctx context.Context) schedulerv1pb.SchedulerClient

func (c *Cluster) ClientN(t *testing.T, ctx context.Context, n int) schedulerv1pb.SchedulerClient

func (c *Cluster) EtcdClientPortN(t *testing.T, n int) int

func (c *Cluster) Run(t *testing.T, ctx context.Context)

func (c *Cluster) WaitUntilRunning(t *testing.T, ctx context.Context)

type Option func(*options)

func WithCount(count uint32) Option

func WithOverrideBroadcastHostPorts(addresses ...string) Option