scheduler

Documentation

Index

• Constants
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
• type Scheduler
  • func NewScheduler(cfg Config, scfg blocksconvert.SharedConfig, l log.Logger, ...) (*Scheduler, error)
  • func (s *Scheduler) NextPlan(ctx context.Context, req *blocksconvert.NextPlanRequest) (*blocksconvert.NextPlanResponse, error)

Constants

const (
	New planStatus = iota
	InProgress
	Finished
	Error
	Invalid
)

Types

type Config

type Config struct {
	ScanInterval        time.Duration
	PlanScanConcurrency int
	MaxProgressFileAge  time.Duration
	AllowedUsers        string
}

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

type Scheduler

type Scheduler struct {
	services.Service
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(cfg Config, scfg blocksconvert.SharedConfig, l log.Logger, reg prometheus.Registerer, http *mux.Router, grpcServ *grpc.Server) (*Scheduler, error)

func (*Scheduler) NextPlan

func (s *Scheduler) NextPlan(ctx context.Context, req *blocksconvert.NextPlanRequest) (*blocksconvert.NextPlanResponse, error)

Returns next plan that builder should work on.