gc

Documentation

Index

• type GC
  • func NewGC(ms metascheduler.MetaScheduler, scheduler scheduler.Scheduler) *GC
  • func (gc *GC) FindAndCancelUnhandledJobs(ctx context.Context) (err error)
  • func (gc *GC) Loop(ctx context.Context) error

Types

type GC

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

func NewGC

func NewGC(
	ms metascheduler.MetaScheduler,
	scheduler scheduler.Scheduler,
) *GC

func (*GC) FindAndCancelUnhandledJobs

func (gc *GC) FindAndCancelUnhandledJobs(
	ctx context.Context,
) (err error)

FindAndCancelUnhandledJobs matches jobs from the metascheduler to the scheduler.

Jobs that doesn't appear in squeue and is RUNNING on the metascheduler is considered as a zombie.

func (*GC) Loop

func (gc *GC) Loop(ctx context.Context) error