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 WithKubeconfig(kubeconfig string) Option
  • func WithListenAddress(address string) Option
  • func WithLogLevel(level string) Option
  • func WithMetricsPort(port int) Option
  • func WithMode(mode string) Option
  • func WithNamespace(namespace string) Option
  • func WithOverrideBroadcastHostPort(address string) Option
  • func WithPort(port int) 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) ETCDClient(t *testing.T) *clientv3.Client
  • func (s *Scheduler) EtcdClientPort() string
  • func (s *Scheduler) EtcdJobs(t *testing.T, ctx context.Context) []*mvccpb.KeyValue
  • func (s *Scheduler) HealthzPort() int
  • func (s *Scheduler) ID() string
  • func (s *Scheduler) InitialCluster() string
  • func (s *Scheduler) JobNowActor(name, namespace, appID, actorType, actorID string) *schedulerv1pb.ScheduleJobRequest
  • func (s *Scheduler) JobNowJob(name, namespace, appID string) *schedulerv1pb.ScheduleJobRequest
  • func (s *Scheduler) ListAllKeys(t *testing.T, ctx context.Context, prefix string) []string
  • func (s *Scheduler) ListJobActors(t *testing.T, ctx context.Context, namespace, appID, actorType, actorID string) *schedulerv1pb.ListJobsResponse
  • func (s *Scheduler) ListJobJobs(t *testing.T, ctx context.Context, namespace, appID string) *schedulerv1pb.ListJobsResponse
  • func (s *Scheduler) Metrics(t *testing.T, ctx context.Context) *metrics.Metrics
  • func (s *Scheduler) MetricsAddress() 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)
  • func (s *Scheduler) WatchJobs(t *testing.T, ctx context.Context, ...) <-chan string
  • func (s *Scheduler) WatchJobsFailed(t *testing.T, ctx context.Context, ...) <-chan string
  • func (s *Scheduler) WatchJobsSuccess(t *testing.T, ctx context.Context, ...) <-chan string

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 WithKubeconfig

func WithKubeconfig(kubeconfig string) Option

func WithListenAddress

func WithListenAddress(address string) Option

func WithLogLevel

func WithLogLevel(level string) Option

func WithMetricsPort

func WithMetricsPort(port int) Option

func WithMode

func WithMode(mode string) Option

func WithNamespace

func WithNamespace(namespace string) Option

func WithOverrideBroadcastHostPort

func WithOverrideBroadcastHostPort(address string) Option

func WithPort

func WithPort(port int) 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) ETCDClient

func (s *Scheduler) ETCDClient(t *testing.T) *clientv3.Client

func (*Scheduler) EtcdClientPort

func (s *Scheduler) EtcdClientPort() string

func (*Scheduler) EtcdJobs

func (s *Scheduler) EtcdJobs(t *testing.T, ctx context.Context) []*mvccpb.KeyValue

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) JobNowActor

func (s *Scheduler) JobNowActor(name, namespace, appID, actorType, actorID string) *schedulerv1pb.ScheduleJobRequest

func (*Scheduler) JobNowJob

func (s *Scheduler) JobNowJob(name, namespace, appID string) *schedulerv1pb.ScheduleJobRequest

func (*Scheduler) ListAllKeys

func (s *Scheduler) ListAllKeys(t *testing.T, ctx context.Context, prefix string) []string

func (*Scheduler) ListJobActors

func (s *Scheduler) ListJobActors(t *testing.T, ctx context.Context, namespace, appID, actorType, actorID string) *schedulerv1pb.ListJobsResponse

func (*Scheduler) ListJobJobs

func (s *Scheduler) ListJobJobs(t *testing.T, ctx context.Context, namespace, appID string) *schedulerv1pb.ListJobsResponse

func (*Scheduler) Metrics

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

Metrics returns a subset of metrics scraped from the metrics endpoint

func (*Scheduler) MetricsAddress

func (s *Scheduler) MetricsAddress() 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)

func (*Scheduler) WatchJobs

func (s *Scheduler) WatchJobs(t *testing.T, ctx context.Context, initial *schedulerv1pb.WatchJobsRequestInitial, respStatus *atomic.Value) <-chan string

func (*Scheduler) WatchJobsFailed

func (s *Scheduler) WatchJobsFailed(t *testing.T, ctx context.Context, initial *schedulerv1pb.WatchJobsRequestInitial) <-chan string

func (*Scheduler) WatchJobsSuccess

func (s *Scheduler) WatchJobsSuccess(t *testing.T, ctx context.Context, initial *schedulerv1pb.WatchJobsRequestInitial) <-chan string