processors

Documentation

Index

• type RemoveRunProcessor
  • func NewRemoveRunProcessor(clusterContext executorContext.ClusterContext, ...) *RemoveRunProcessor
  • func (j *RemoveRunProcessor) Run()
• type RunPreemptedProcessor
  • func NewRunPreemptedProcessor(clusterContext executorContext.ClusterContext, ...) *RunPreemptedProcessor
  • func (j *RunPreemptedProcessor) Run()

Types

type RemoveRunProcessor

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

func NewRemoveRunProcessor

func NewRemoveRunProcessor(clusterContext executorContext.ClusterContext, jobRunStateStore job.RunStateStore) *RemoveRunProcessor

func (*RemoveRunProcessor) Run

func (j *RemoveRunProcessor) Run()

type RunPreemptedProcessor

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

func NewRunPreemptedProcessor

func NewRunPreemptedProcessor(
	clusterContext executorContext.ClusterContext,
	jobRunStateStore job.RunStateStore,
	eventReporter reporter.EventReporter,
) *RunPreemptedProcessor

func (*RunPreemptedProcessor) Run

func (j *RunPreemptedProcessor) Run()