Documentation
¶
Index ¶
- type Scheduler
- func (s *Scheduler) RunOptimisticScheduling(ctx context.Context, tenantId uuid.UUID, opts []*v1.WorkflowNameTriggerOpts, ...) (map[uuid.UUID][]*schedulingv1.AssignedItemWithTask, error)
- func (s *Scheduler) RunOptimisticSchedulingFromEvents(ctx context.Context, tenantId uuid.UUID, opts []v1.EventTriggerOpts, ...) (map[uuid.UUID][]*schedulingv1.AssignedItemWithTask, error)
- func (s *Scheduler) Start() (func() error, error)
- type SchedulerOpt
- func WithAlerter(a hatcheterrors.Alerter) SchedulerOpt
- func WithDataDecoderValidator(dv datautils.DataDecoderValidator) SchedulerOpt
- func WithLogger(l *zerolog.Logger) SchedulerOpt
- func WithMessageQueue(mq msgqueue.MessageQueue) SchedulerOpt
- func WithPartition(p *partition.Partition) SchedulerOpt
- func WithQueueLoggerConfig(lc *shared.LoggerConfigFile) SchedulerOpt
- func WithRepository(r repov1.Repository) SchedulerOpt
- func WithSchedulerPool(s *v1.SchedulingPool) SchedulerOpt
- type SchedulerOpts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func New ¶
func New( fs ...SchedulerOpt, ) (*Scheduler, error)
func (*Scheduler) RunOptimisticScheduling ¶ added in v0.78.0
func (s *Scheduler) RunOptimisticScheduling(ctx context.Context, tenantId uuid.UUID, opts []*v1.WorkflowNameTriggerOpts, localWorkerIds map[uuid.UUID]struct{}) (map[uuid.UUID][]*schedulingv1.AssignedItemWithTask, error)
func (*Scheduler) RunOptimisticSchedulingFromEvents ¶ added in v0.78.0
func (s *Scheduler) RunOptimisticSchedulingFromEvents(ctx context.Context, tenantId uuid.UUID, opts []v1.EventTriggerOpts, localWorkerIds map[uuid.UUID]struct{}) (map[uuid.UUID][]*schedulingv1.AssignedItemWithTask, error)
type SchedulerOpt ¶
type SchedulerOpt func(*SchedulerOpts)
func WithAlerter ¶
func WithAlerter(a hatcheterrors.Alerter) SchedulerOpt
func WithDataDecoderValidator ¶
func WithDataDecoderValidator(dv datautils.DataDecoderValidator) SchedulerOpt
func WithLogger ¶
func WithLogger(l *zerolog.Logger) SchedulerOpt
func WithMessageQueue ¶
func WithMessageQueue(mq msgqueue.MessageQueue) SchedulerOpt
func WithPartition ¶
func WithPartition(p *partition.Partition) SchedulerOpt
func WithQueueLoggerConfig ¶
func WithQueueLoggerConfig(lc *shared.LoggerConfigFile) SchedulerOpt
func WithRepository ¶
func WithRepository(r repov1.Repository) SchedulerOpt
func WithSchedulerPool ¶
func WithSchedulerPool(s *v1.SchedulingPool) SchedulerOpt
type SchedulerOpts ¶
type SchedulerOpts struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.