Documentation
¶
Overview ¶
Package scheduler provides task scheduling services
Index ¶
Constants ¶
View Source
const ( // TaskPrefix is the prefix for all scheduled tasks TaskPrefix = "cbt:" // QueueName is the queue name for scheduler tasks QueueName = "scheduler" )
Variables ¶
View Source
var ( // ErrInvalidConcurrency is returned when concurrency is not positive ErrInvalidConcurrency = errors.New("concurrency must be positive") )
View Source
var ( // ErrScheduleRegistrationFailed is returned when one or more scheduled tasks fail to register ErrScheduleRegistrationFailed = errors.New("failed to register scheduled tasks") )
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Interval time.Duration `yaml:"interval" default:"1m"`
Concurrency int `yaml:"concurrency" default:"10"`
}
Config defines scheduler configuration
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service manages scheduled tasks for transformations
func NewService ¶
func NewService(log *logrus.Logger, cfg *Config, redisOpt *redis.Options, dag *models.DependencyGraph, coord *coordinator.Service) (*Service, error)
NewService creates a new scheduler service
func (*Service) HandleScheduledBackfill ¶
HandleScheduledBackfill processes scheduled backfill scans
func (*Service) HandleScheduledForward ¶
HandleScheduledForward processes scheduled forward fill checks
Source Files
Click to show internal directories.
Click to hide internal directories.