cron

Documentation

Index

• type Interface
  • func New(opts Options) Interface
• type Options

Types

type Interface

type Interface interface {
	// Run starts the cron server, blocking until the context is canceled.
	Run(ctx context.Context) error

	// Client returns a client to schedule jobs with the underlying cron
	// framework and database. Blocks until Etcd and the Cron library are ready.
	Client(ctx context.Context) (api.Interface, error)

	// AddWatch adds a watch for jobs to the connection pool.
	AddWatch(*schedulerv1pb.WatchJobsRequestInitial, schedulerv1pb.Scheduler_WatchJobsServer) error
}

Interface manages the cron framework, exposing a client to schedule jobs.

func New

func New(opts Options) Interface

type Options

type Options struct {
	ReplicaCount uint32
	ReplicaID    uint32
	Config       *embed.Config
	Healthz      healthz.Healthz
}