etcd: github.com/etcd-io/etcd/pkg/schedule Index | Files

package schedule

import "github.com/etcd-io/etcd/pkg/schedule"

Package schedule provides mechanisms and policies for scheduling units of work.

Index

Package Files

doc.go schedule.go

type Job Uses

type Job func(context.Context)

type Scheduler Uses

type Scheduler interface {
    // Schedule asks the scheduler to schedule a job defined by the given func.
    // Schedule to a stopped scheduler might panic.
    Schedule(j Job)

    // Pending returns number of pending jobs
    Pending() int

    // Scheduled returns the number of scheduled jobs (excluding pending jobs)
    Scheduled() int

    // Finished returns the number of finished jobs
    Finished() int

    // WaitFinish waits until at least n job are finished and all pending jobs are finished.
    WaitFinish(n int)

    // Stop stops the scheduler.
    Stop()
}

Scheduler can schedule jobs.

func NewFIFOScheduler Uses

func NewFIFOScheduler() Scheduler

NewFIFOScheduler returns a Scheduler that schedules jobs in FIFO order sequentially

Package schedule imports 2 packages (graph). Updated 2018-08-28. Refresh now. Tools for package owners.