scheduler

Documentation

Index

• type BlockBuilderScheduler
  • func New(cfg Config, logger log.Logger, reg prometheus.Registerer) (*BlockBuilderScheduler, error)
  • func (s *BlockBuilderScheduler) AssignJob(_ context.Context, req *schedulerpb.AssignJobRequest) (*schedulerpb.AssignJobResponse, error)
  • func (s *BlockBuilderScheduler) UpdateJob(_ context.Context, req *schedulerpb.UpdateJobRequest) (*schedulerpb.UpdateJobResponse, 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)

func (*BlockBuilderScheduler) AssignJob

func (s *BlockBuilderScheduler) AssignJob(_ context.Context, req *schedulerpb.AssignJobRequest) (*schedulerpb.AssignJobResponse, error)

AssignJob returns an assigned job for the given workerID.

func (*BlockBuilderScheduler) UpdateJob

func (s *BlockBuilderScheduler) UpdateJob(_ context.Context, req *schedulerpb.UpdateJobRequest) (*schedulerpb.UpdateJobResponse, error)

UpdateJob takes a job update from the client and records it, if necessary.

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