job_context

Documentation

Index

• type ClusterJobContext
  • func NewClusterJobContext(clusterContext context.ClusterContext) *ClusterJobContext
  • func (c ClusterJobContext) DeleteJobs(jobs []*RunningJob)
  • func (c ClusterJobContext) GetRunningJobs() ([]*RunningJob, error)
• type JobContext
• type RunningJob

Types

type ClusterJobContext

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

func NewClusterJobContext

func NewClusterJobContext(clusterContext context.ClusterContext) *ClusterJobContext

func (ClusterJobContext) DeleteJobs

func (c ClusterJobContext) DeleteJobs(jobs []*RunningJob)

func (ClusterJobContext) GetRunningJobs

func (c ClusterJobContext) GetRunningJobs() ([]*RunningJob, error)

type JobContext

type JobContext interface {
	GetRunningJobs() ([]*RunningJob, error)
	DeleteJobs(jobs []*RunningJob)
}

type RunningJob

type RunningJob struct {
	JobId string
	Pods  []*v1.Pod
}