Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

scheduler

package

Go to main page

Versions in this module

v0

v0.3.1

Oct 19, 2026

v0.3.0

Oct 19, 2026

Changes in this version

+ const MaxModuleBytes

+ const MaxStoredRunBytes

+ const QueueRowCharge

+ var ErrQueueLimit = errors.New("executor retained queue limit reached")

+ var ErrUploadLimit = uploadsize.ErrLimit

+ func StoredRunBytes(spec Spec) (int64, error)

type Disposition

+ Archived int64

type Policy

+ EgressGrant *pb.EgressGrant

+ type QueueLimits struct

+ Bytes int64

+ Runs int64

+ func DefaultQueueLimits() QueueLimits

+ func (l QueueLimits) Validate() error

type Spec

+ OutputVersion uint32

v0.3.0-rc.1

Oct 6, 2026

v0.2.0

Sep 27, 2026

Changes in this version

+ const CleanupTimeout

+ var ErrBindingMismatch = errors.New("debuglet belongs to another control session")

+ var ErrClosed = errors.New("scheduler is shut down")

+ var ErrDebugletAlreadyStarted = errors.New("debuglet has already started. won't restart")

+ var ErrTerminalNotRetained = errors.New("terminal event is not retained under this control binding")

+ type Admission struct

+ Insert AdmissionGuard

+ Start AdmissionGuard

+ type AdmissionGuard func(controlsession.Binding, func()) error

+ type Completion struct

+ CleanupErr error

+ type Disposition struct

+ Bindings int

+ Quarantined int64

+ Queued int64

+ RejectedTerminal int64

+ Retained int64

+ RetainedTerminal int64

+ Started int64

+ Truncated bool

+ UnsentTerminal int64

+ func (d Disposition) Empty() bool

+ func (d Disposition) Summary() string

+ type FailedFunc func(context.Context, Spec, error) Completion

+ type Policy struct

+ Addresses []string

+ CeilBW int64

+ FloorBW int64

+ ListenSCION bool

+ ListenTCP bool

+ ListenUDP bool

+ RequireICMP bool

+ Timeout time.Duration

+ type RestoreEligibility func(controlsession.Binding) bool

+ type RetainedRun struct

+ Binding controlsession.Binding

+ DebugletID uuid.UUID

+ StartTime time.Time

+ StartedAt time.Time

+ Status RetainedRunStatus

+ TransactionID string

+ func (r RetainedRun) Started() bool

+ type RetainedRunStatus uint8

+ const RetainedRunAbsent

+ const RetainedRunFiltered

+ const RetainedRunFound

+ const RetainedRunUnknown

+ func (s RetainedRunStatus) String() string

+ type RunInspection interface

+ InspectRetainedRun func(ctx context.Context, id uuid.UUID, current controlsession.Binding) (RetainedRun, error)

+ type Scheduler interface

+ CancelBound func(context.Context, uuid.UUID, controlsession.Binding, error) (bool, error)

+ Insert func(context.Context, Spec) error

+ RegisterFailed func(FailedFunc)

+ RegisterOnStart func(StartFunc)

+ Shutdown func(context.Context) error

+ StartLoop func(ctx context.Context) error

+ type Spec struct

+ Args []string

+ Binding controlsession.Binding

+ DebugletID uuid.UUID

+ Policy Policy

+ StartTime *time.Time

+ TransactionID string

+ Wasm []byte

+ type StartFunc func(context.Context, Spec) Completion

+ type TerminalAttempt struct

+ Attempts int64

+ Failure error

+ Rejected bool

+ type TerminalEvent struct

+ Attempts int64

+ Binding controlsession.Binding

+ DebugletID uuid.UUID

+ ErrorMessage *string

+ ExitCode int32

+ LastAttemptAt time.Time

+ LastError string

+ RecordedAt time.Time

+ Rejected bool

+ type TerminalRetention interface

+ ListRetainedTerminals func(ctx context.Context, binding controlsession.Binding, limit int64) ([]TerminalEvent, error)

+ NoteTerminalFailure func(ctx context.Context, id uuid.UUID, binding controlsession.Binding, ...) error

+ RecordTerminal func(context.Context, TerminalEvent) error

+ ReleaseTerminal func(ctx context.Context, id uuid.UUID, binding controlsession.Binding) error

v0.2.0-rc.3

Sep 26, 2026

v0.2.0-rc.2

Sep 26, 2026

v0.2.0-rc.1

Sep 25, 2026