scheduler

Documentation

Index

• type BatchJobScheduler
  • func NewBatchJobScheduler(params BatchJobSchedulerParams) *BatchJobScheduler
  • func (b *BatchJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error
• type BatchJobSchedulerParams
• type OpsJobScheduler
  • func NewOpsJobScheduler(params OpsJobSchedulerParams) *OpsJobScheduler
  • func (b *OpsJobScheduler) Process(ctx context.Context, evaluation *models.Evaluation) error
• type OpsJobSchedulerParams

Types

type BatchJobScheduler

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

BatchJobScheduler is a scheduler for batch jobs that run until completion

func NewBatchJobScheduler

func NewBatchJobScheduler(params BatchJobSchedulerParams) *BatchJobScheduler

func (*BatchJobScheduler) Process

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

type BatchJobSchedulerParams

type BatchJobSchedulerParams struct {
	JobStore       jobstore.Store
	Planner        orchestrator.Planner
	NodeDiscoverer orchestrator.NodeDiscoverer
	NodeRanker     orchestrator.NodeRanker
	RetryStrategy  orchestrator.RetryStrategy
}

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
	NodeDiscoverer orchestrator.NodeDiscoverer
	NodeRanker     orchestrator.NodeRanker
}