watcher

Documentation

Index

• func MapJobDefinitionToScheduler(j metaschedulerabi.JobDefinition, t uint64, body string) scheduler.JobDefinition
• type Watcher
  • func New(metascheduler metascheduler.MetaScheduler, scheduler scheduler.Scheduler, ...) *Watcher
  • func (w *Watcher) Watch(parent context.Context) error

Functions

func MapJobDefinitionToScheduler

func MapJobDefinitionToScheduler(
	j metaschedulerabi.JobDefinition,
	t uint64,
	body string,
) scheduler.JobDefinition

Types

type Watcher

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

func New

func New(
	metascheduler metascheduler.MetaScheduler,
	scheduler scheduler.Scheduler,
	sbatch sbatch.Client,
	pollingTime time.Duration,
	resourceManager *lock.ResourceManager,
	gridLoggerDialer gridlogger.Dialer,
) *Watcher

func (*Watcher) Watch

func (w *Watcher) Watch(parent context.Context) error

Watch incoming jobs and handles it.