scheduler

Documentation

Index

• type BatchServiceJobScheduler
  • func NewBatchServiceJobScheduler(params BatchServiceJobSchedulerParams) *BatchServiceJobScheduler
  • func (b *BatchServiceJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error
• type BatchServiceJobSchedulerParams
• type DaemonJobScheduler
  • func NewDaemonJobScheduler(params DaemonJobSchedulerParams) *DaemonJobScheduler
  • func (b *DaemonJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error
• type DaemonJobSchedulerParams
• type OpsJobScheduler
  • func NewOpsJobScheduler(params OpsJobSchedulerParams) *OpsJobScheduler
  • func (b *OpsJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error
• type OpsJobSchedulerParams

Types

type BatchServiceJobScheduler

type BatchServiceJobScheduler struct {
	// contains filtered or unexported fields
}

BatchServiceJobScheduler is a scheduler for: - batch jobs that run until completion on N number of nodes - service jobs than run until stopped on N number of nodes

func NewBatchServiceJobScheduler

func NewBatchServiceJobScheduler(params BatchServiceJobSchedulerParams) *BatchServiceJobScheduler

func (*BatchServiceJobScheduler) Process

func (b *BatchServiceJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error

type BatchServiceJobSchedulerParams

type BatchServiceJobSchedulerParams struct {
	JobStore      jobstore.Store
	Planner       orchestrator.Planner
	NodeSelector  orchestrator.NodeSelector
	RetryStrategy orchestrator.RetryStrategy
	QueueBackoff  time.Duration
	// Clock is the clock used for time-based operations.
	// If not provided, the system clock is used.
	Clock clock.Clock
}

type DaemonJobScheduler

type DaemonJobScheduler struct {
	// contains filtered or unexported fields
}

DaemonJobScheduler is a scheduler for batch jobs that run until completion

func NewDaemonJobScheduler

func NewDaemonJobScheduler(params DaemonJobSchedulerParams) *DaemonJobScheduler

func (*DaemonJobScheduler) Process

func (b *DaemonJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error

type DaemonJobSchedulerParams

type DaemonJobSchedulerParams struct {
	JobStore     jobstore.Store
	Planner      orchestrator.Planner
	NodeSelector orchestrator.NodeSelector
}

type OpsJobScheduler

type OpsJobScheduler struct {
	// contains filtered or unexported fields
}

OpsJobScheduler is a scheduler for batch jobs that run until completion

func NewOpsJobScheduler

func NewOpsJobScheduler(params OpsJobSchedulerParams) *OpsJobScheduler

func (*OpsJobScheduler) Process

func (b *OpsJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error

type OpsJobSchedulerParams

type OpsJobSchedulerParams struct {
	JobStore     jobstore.Store
	Planner      orchestrator.Planner
	NodeSelector orchestrator.NodeSelector
	// Clock is the clock used for time-based operations.
	// If not provided, the system clock is used.
	Clock clock.Clock
}