scheduler

package

v1.10.0 Latest Latest Go to latest Published: Aug 3, 2021 License: Apache-2.0, Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cortexproject/cortex

Links

Open Source Insights

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 ¶

View Source

const (
	New planStatus = iota
	InProgress
	Finished
	Error
	Invalid
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	ScanInterval        time.Duration
	PlanScanConcurrency int
	MaxProgressFileAge  time.Duration
	AllowedUsers        string
	IgnoredUserPattern  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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL