io.github.retz.protocol.data

Class Job

java.lang.Object

io.github.retz.protocol.data.Job

public class Job
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Job.JobState State diagram: [CREATED] ---> [QUEUED] ---> [STARTED] ---> [FINISHED] | +--------> [KILLED] +----------------------------^

Constructor Summary

Constructors

Constructor and Description
Job(java.lang.String appName, java.lang.String cmd, java.util.Properties props, int cpu, int memMB, int disk)
Job(java.lang.String appName, java.lang.String cmd, java.util.Properties props, int cpu, int memMB, int disk, int gpu, int ports)
Job(java.lang.String appName, java.lang.String cmd, java.util.Properties props, int cpu, int memMB, int disk, int gpu, int ports, java.lang.String attributes)
Job(java.lang.String cmd, java.lang.String scheduled, java.lang.String started, java.lang.String finished, java.util.Properties props, int result, int id, java.lang.String url, java.lang.String reason, int retry, int priority, java.lang.String appid, java.lang.String name, java.util.Set<java.lang.String> tags, ResourceQuantity resources, java.util.Optional<java.lang.String> attributes, java.lang.String taskId, Job.JobState state)

Method Summary

Modifier and Type	Method and Description
void	addTags(java.util.Collection<java.lang.String> tags)
void	addTags(java.lang.String... tags)
java.lang.String	appid()
java.util.Optional<java.lang.String>	attributes()
java.lang.String	cmd()
void	doRetry()
java.lang.String	finished()
void	finished(java.lang.String now, java.util.Optional<java.lang.String> url, int result)
int	id()
void	killed(java.lang.String now, java.util.Optional<java.lang.String> maybeUrl, java.lang.String reason)
java.lang.String	name()
java.lang.String	pp()
int	priority()
java.util.Properties	props()
java.lang.String	reason()
ResourceQuantity	resources()
int	result()
int	retry()
void	schedule(int id, java.lang.String now)
java.lang.String	scheduled()
void	setName(java.lang.String name)
void	setPriority(int p)
java.lang.String	started()
void	started(java.lang.String taskId, java.util.Optional<java.lang.String> maybeUrl, java.lang.String now)
void	starting(java.lang.String taskId, java.util.Optional<java.lang.String> maybeUrl, java.lang.String now)
Job.JobState	state()
java.util.Set<java.lang.String>	tags()
java.lang.String	taskId()
java.lang.String	toString()
java.lang.String	url()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Job

public Job(java.lang.String appName,
           java.lang.String cmd,
           java.util.Properties props,
           int cpu,
           int memMB,
           int disk)

Job

public Job(java.lang.String appName,
           java.lang.String cmd,
           java.util.Properties props,
           int cpu,
           int memMB,
           int disk,
           int gpu,
           int ports)

Job

public Job(java.lang.String appName,
           java.lang.String cmd,
           java.util.Properties props,
           int cpu,
           int memMB,
           int disk,
           int gpu,
           int ports,
           java.lang.String attributes)

Job

public Job(java.lang.String cmd,
           java.lang.String scheduled,
           java.lang.String started,
           java.lang.String finished,
           java.util.Properties props,
           int result,
           int id,
           java.lang.String url,
           java.lang.String reason,
           int retry,
           int priority,
           java.lang.String appid,
           java.lang.String name,
           java.util.Set<java.lang.String> tags,
           ResourceQuantity resources,
           java.util.Optional<java.lang.String> attributes,
           java.lang.String taskId,
           Job.JobState state)

Method Detail

cmd

public java.lang.String cmd()

scheduled

public java.lang.String scheduled()

started

public java.lang.String started()

props

public java.util.Properties props()

finished

public java.lang.String finished()

result

public int result()

id

public int id()

url

public java.lang.String url()

reason

public java.lang.String reason()

retry

public int retry()

priority

public int priority()

appid

public java.lang.String appid()

name

public java.lang.String name()

tags

public java.util.Set<java.lang.String> tags()

resources

public ResourceQuantity resources()

attributes

public java.util.Optional<java.lang.String> attributes()

taskId

public java.lang.String taskId()

state

public Job.JobState state()

schedule

public void schedule(int id,
                     java.lang.String now)

doRetry

public void doRetry()

starting

public void starting(java.lang.String taskId,
                     java.util.Optional<java.lang.String> maybeUrl,
                     java.lang.String now)

started

public void started(java.lang.String taskId,
                    java.util.Optional<java.lang.String> maybeUrl,
                    java.lang.String now)

finished

public void finished(java.lang.String now,
                     java.util.Optional<java.lang.String> url,
                     int result)

killed

public void killed(java.lang.String now,
                   java.util.Optional<java.lang.String> maybeUrl,
                   java.lang.String reason)

setPriority

public void setPriority(int p)

setName

public void setName(java.lang.String name)

addTags

public void addTags(java.lang.String... tags)

addTags

public void addTags(java.util.Collection<java.lang.String> tags)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

pp

public java.lang.String pp()