scheduler

Documentation

Index

• type Option
  • func WithDataDir(dataDir string) Option
  • func WithEtcdClientPorts(ports []string) Option
  • func WithExecOptions(execOptions ...exec.Option) Option
  • func WithHealthzPort(port int) Option
  • func WithID(id string) Option
  • func WithInitialCluster(initialCluster string) Option
  • func WithInitialClusterPorts(ports ...int) Option
  • func WithListenAddress(address string) Option
  • func WithLogLevel(level string) Option
  • func WithMetricsPort(port int) Option
  • func WithNamespace(namespace string) Option
  • func WithPort(port int) Option
  • func WithReplicaCount(count uint32) Option
  • func WithSentry(sentry *sentry.Sentry) Option
• type Scheduler
  • func New(t *testing.T, fopts ...Option) *Scheduler
  • func (s *Scheduler) Address() string
  • func (s *Scheduler) Cleanup(t *testing.T)
  • func (s *Scheduler) Client(t *testing.T, ctx context.Context) schedulerv1pb.SchedulerClient
  • func (s *Scheduler) ClientMTLS(t *testing.T, ctx context.Context, appID string) schedulerv1pb.SchedulerClient
  • func (s *Scheduler) DataDir() string
  • func (s *Scheduler) EtcdClientPort() string
  • func (s *Scheduler) HealthzPort() int
  • func (s *Scheduler) ID() string
  • func (s *Scheduler) InitialCluster() string
  • func (s *Scheduler) MetricsPort() int
  • func (s *Scheduler) Port() int
  • func (s *Scheduler) Run(t *testing.T, ctx context.Context)
  • func (s *Scheduler) WaitUntilRunning(t *testing.T, ctx context.Context)

Types

type Option

type Option func(*options)

func WithDataDir

func WithDataDir(dataDir string) Option

func WithEtcdClientPorts

func WithEtcdClientPorts(ports []string) Option

func WithExecOptions

func WithExecOptions(execOptions ...exec.Option) Option

func WithHealthzPort

func WithHealthzPort(port int) Option

func WithID

func WithID(id string) Option

func WithInitialCluster

func WithInitialCluster(initialCluster string) Option

WithInitialCluster adds the initial etcd cluster peers. This should include http:// in the url.

func WithInitialClusterPorts

func WithInitialClusterPorts(ports ...int) Option

func WithListenAddress

func WithListenAddress(address string) Option

func WithLogLevel

func WithLogLevel(level string) Option

func WithMetricsPort

func WithMetricsPort(port int) Option

func WithNamespace

func WithNamespace(namespace string) Option

func WithPort

func WithPort(port int) Option

func WithReplicaCount

func WithReplicaCount(count uint32) Option

func WithSentry

func WithSentry(sentry *sentry.Sentry) Option

type Scheduler

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

func New

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

func (*Scheduler) Address

func (s *Scheduler) Address() string

func (*Scheduler) Cleanup

func (s *Scheduler) Cleanup(t *testing.T)

func (*Scheduler) Client

func (s *Scheduler) Client(t *testing.T, ctx context.Context) schedulerv1pb.SchedulerClient

func (*Scheduler) ClientMTLS

func (s *Scheduler) ClientMTLS(t *testing.T, ctx context.Context, appID string) schedulerv1pb.SchedulerClient

func (*Scheduler) DataDir

func (s *Scheduler) DataDir() string

func (*Scheduler) EtcdClientPort

func (s *Scheduler) EtcdClientPort() string

func (*Scheduler) HealthzPort

func (s *Scheduler) HealthzPort() int

func (*Scheduler) ID

func (s *Scheduler) ID() string

func (*Scheduler) InitialCluster

func (s *Scheduler) InitialCluster() string

func (*Scheduler) MetricsPort

func (s *Scheduler) MetricsPort() int

func (*Scheduler) Port

func (s *Scheduler) Port() int

func (*Scheduler) Run

func (s *Scheduler) Run(t *testing.T, ctx context.Context)

func (*Scheduler) WaitUntilRunning

func (s *Scheduler) WaitUntilRunning(t *testing.T, ctx context.Context)