job_context

Documentation

Index

• type ClusterJobContext
  • func NewClusterJobContext(clusterContext context.ClusterContext) *ClusterJobContext
  • func (c *ClusterJobContext) DeleteJobs(jobs []*RunningJob)
  • func (c *ClusterJobContext) GetRunningJobs() ([]*RunningJob, error)
  • func (c *ClusterJobContext) IsActiveJob(id string) bool
  • func (c *ClusterJobContext) RegisterActiveJobs(ids []string)
  • func (c *ClusterJobContext) RegisterDoneJobs(ids []string)
• 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)

func (*ClusterJobContext) IsActiveJob

func (c *ClusterJobContext) IsActiveJob(id string) bool

func (*ClusterJobContext) RegisterActiveJobs

func (c *ClusterJobContext) RegisterActiveJobs(ids []string)

func (*ClusterJobContext) RegisterDoneJobs

func (c *ClusterJobContext) RegisterDoneJobs(ids []string)

type JobContext

type JobContext interface {
	GetRunningJobs() ([]*RunningJob, error)
	DeleteJobs(jobs []*RunningJob)
	RegisterActiveJobs(ids []string)
	RegisterDoneJobs(ids []string)
	IsActiveJob(id string) bool
}

type RunningJob

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