scheduler

package
v1.18.0 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2026 License: Apache-2.0 Imports: 35 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 WithEtcdSpaceQuota added in v1.18.0 

func WithEtcdSpaceQuota(quota string) Option

WithEtcdSpaceQuota sets the --etcd-space-quota flag. Accepts any value parsable by k8s resource.ParseQuantity (e.g. "16Mi", "1Gi"). Used by tests that need to exercise etcd quota-exceeded behaviour.

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) FillQuota added in v1.18.0 

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

FillQuota writes 1MiB values under the given etcd key prefix until etcd returns "database space exceeded". Requires the scheduler to have been started with a low --etcd-space-quota (see WithEtcdSpaceQuota); without one, we would otherwise just keep writing against etcd's default 2GiB quota and eventually fill the backing disk.

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) RecoverQuota added in v1.18.0 

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

RecoverQuota deletes keys under prefix, compacts revisions, defragments the backend, and disarms any etcd alarms so writes can resume. Each etcd operation is bounded by its own 5s timeout so a hung backend cannot stall the test until the suite-level deadline.

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)

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) WaitUntilSidecarsConnected added in v1.18.0 

func (s *Scheduler) WaitUntilSidecarsConnected(t *testing.T, ctx context.Context, want int)

WaitUntilSidecarsConnected blocks until the scheduler has exactly `want` sidecar stream connections and that count has remained stable across 20 consecutive polls (~1s). This catches the startup window where daprd's WatchHosts stream can trigger a short disconnect/reconnect cycle of all scheduler job streams, during which a newly-scheduled job can be delivered to streams that are about to disconnect as well as their replacements.

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.