scheduler

package
v1.17.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 15, 2026 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Option 

type Option func(*options)

func WithClientEndpoints added in v1.16.0 

func WithClientEndpoints(endpoints ...string) Option

func WithClientPassword added in v1.16.0 

func WithClientPassword(password string) Option

func WithClientUsername added in v1.16.0 

func WithClientUsername(username string) Option

func WithDataDir 

func WithDataDir(dataDir string) Option

func WithEmbed added in v1.16.0 

func WithEmbed(embed bool) Option

func WithEtcdClientPort added in v1.15.0 

func WithEtcdClientPort(port int) Option

func WithExecOptions 

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

func WithExit1 added in v1.16.0 

func WithExit1() 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 WithKubeconfig added in v1.15.0 

func WithKubeconfig(kubeconfig string) Option

func WithLogLevel 

func WithLogLevel(level string) Option

func WithLogLineStderr added in v1.17.0 

func WithLogLineStderr(ll *logline.LogLine) Option

func WithLogLineStdout added in v1.16.0 

func WithLogLineStdout(ll *logline.LogLine) Option

func WithMetricsPort 

func WithMetricsPort(port int) Option

func WithMode added in v1.15.0 

func WithMode(mode string) Option

func WithNamespace 

func WithNamespace(namespace string) Option

func WithOverrideBroadcastHostPort added in v1.15.0 

func WithOverrideBroadcastHostPort(address string) Option

func WithPort 

func WithPort(port int) Option

func WithSentry 

func WithSentry(sentry *sentry.Sentry) Option

func WithWorkers added in v1.17.0 

func WithWorkers(workers *uint32) 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) ClientMTLSNS added in v1.16.4 

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

func (*Scheduler) DataDir 

func (s *Scheduler) DataDir() string

func (*Scheduler) ETCDClient added in v1.15.0 

func (s *Scheduler) ETCDClient(t *testing.T, ctx context.Context) *clientv3.Client

func (*Scheduler) EtcdClientPort 

func (s *Scheduler) EtcdClientPort() int

func (*Scheduler) EtcdJobs added in v1.15.0 

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 added in v1.15.0 

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

func (*Scheduler) JobNowJob added in v1.15.0 

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

func (*Scheduler) Kill added in v1.16.0 

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

func (*Scheduler) ListAllKeys added in v1.15.0 

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

func (*Scheduler) ListJobActors added in v1.15.0 

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

func (*Scheduler) ListJobJobs added in v1.15.0 

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

func (*Scheduler) Metrics added in v1.15.0 

func (s *Scheduler) Metrics(t assert.TestingT, ctx context.Context) *metrics.Metrics

Metrics returns a subset of metrics scraped from the metrics endpoint

func (*Scheduler) MetricsAddress added in v1.15.0 

func (s *Scheduler) MetricsAddress() string

func (*Scheduler) MetricsPort 

func (s *Scheduler) MetricsPort() int

func (*Scheduler) MetricsWithLabels added in v1.16.0 

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

func (*Scheduler) Port 

func (s *Scheduler) Port() int

func (*Scheduler) Restart added in v1.17.7 

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

func (*Scheduler) RestartGraceful added in v1.17.7 

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

RestartGraceful is like Restart but interrupts the scheduler with SIGINT instead of SIGKILL. The graceful path lets diagrid-cron's leadership package revoke its etcd lease on the way out, so the replacement instance can claim leadership immediately rather than waiting for the 20s lease TTL to expire. Use this when the test only needs to exercise behaviour that is independent of crash semantics.

func (*Scheduler) Run 

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

func (*Scheduler) WaitUntilLeadership added in v1.15.0 

func (s *Scheduler) WaitUntilLeadership(t *testing.T, ctx context.Context, leaders int)

func (*Scheduler) WaitUntilRunning 

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

func (*Scheduler) WatchJobs added in v1.15.0 

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

func (*Scheduler) WatchJobsFailed added in v1.15.0 

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

func (*Scheduler) WatchJobsSuccess added in v1.15.0 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.