scheduler

Documentation

Index

• type BlockBuilderScheduler
  • func New(cfg Config, logger log.Logger, reg prometheus.Registerer) (*BlockBuilderScheduler, error)
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
  • func (cfg *Config) Validate() error

Types

type BlockBuilderScheduler

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

func New

func New(
	cfg Config,
	logger log.Logger,
	reg prometheus.Registerer,
) (*BlockBuilderScheduler, error)

type Config

type Config struct {
	ConsumerGroup      string        `yaml:"consumer_group"`
	SchedulingInterval time.Duration `yaml:"kafka_monitor_interval"`
	ConsumeInterval    time.Duration `yaml:"consume_interval"`
	StartupObserveTime time.Duration `yaml:"startup_observe_time"`
	JobLeaseExpiry     time.Duration `yaml:"job_lease_expiry"`

	// Config parameters defined outside the block-builder-scheduler config and are injected dynamically.
	Kafka ingest.KafkaConfig `yaml:"-"`
}

func (*Config) RegisterFlags

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

func (*Config) Validate

func (cfg *Config) Validate() error