Uses of Interface
org.opencastproject.job.api.Job
Packages that use Job
Package
Description
Service implementation classes
Utility classes for dealing with media packages, collections, URLs, files, and streams.
-
Uses of Job in org.opencastproject.job.api
Classes in org.opencastproject.job.api that implement JobMethods in org.opencastproject.job.api that return JobModifier and TypeMethodDescriptionstatic JobJobParser.parseJob(InputStream in) Parses a stream representing aJobstatic JobParses an xml string representing aJobJaxbJob.toJob()Methods in org.opencastproject.job.api that return types with arguments of type JobModifier and TypeMethodDescriptionJaxbJob.fnFromJob()JobBarrier.Result.getStatus()Returns the status details.Methods in org.opencastproject.job.api with parameters of type JobModifier and TypeMethodDescriptionvoidAsks the job producer to handle the given job using the provided operation and list of arguments.voidAsks the job producer to handle the given job using the provided operation and list of arguments.voidAdds the job to the list of jobs to wait for.protected voidAbstractJobProducer.finallyUpdateJob(Job job) Private utility to update and optionally fail job, called from a finally block.booleanAbstractJobProducer.isReadyToAccept(Job job) Whether the job can be accepted.booleanJobProducer.isReadyToAccept(Job job) Whether the job can be accepted.protected abstract StringAsks the overriding class to process the arguments using the given operation.Method parameters in org.opencastproject.job.api with type arguments of type JobConstructors in org.opencastproject.job.api with parameters of type JobModifierConstructorDescriptionJobBarrier(Job waiter, ServiceRegistry registry) Creates a barrier without any jobs, usingregistryto poll for the outcome of the monitored jobs using the default polling intervalJobBarrier.DEFAULT_POLLING_INTERVAL.JobBarrier(Job waiter, ServiceRegistry registry, long pollingInterval) Creates a wrapper forjob, usingregistryto poll for the job outcome.JobBarrier(Job waiter, ServiceRegistry registry, long pollingInterval, Job... jobs) Creates a wrapper forjob, usingregistryto poll for the job outcome.JobBarrier(Job waiter, ServiceRegistry registry, Job... jobs) Creates a barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling intervalJobBarrier.DEFAULT_POLLING_INTERVAL.Constructor parameters in org.opencastproject.job.api with type arguments of type JobModifierConstructorDescriptionJaxbJobList(Collection<? extends Job> jobs) Result(Map<Job, Job.Status> status) Creates a new job barrier result. -
Uses of Job in org.opencastproject.serviceregistry.api
Fields in org.opencastproject.serviceregistry.api declared as JobModifier and TypeFieldDescriptionprotected JobServiceRegistryInMemoryImpl.currentJobHolds the current running jobFields in org.opencastproject.serviceregistry.api with type parameters of type JobModifier and TypeFieldDescriptionprotected Map<ServiceRegistrationInMemoryImpl, Set<Job>> ServiceRegistryInMemoryImpl.jobHostsA mapping of services to jobsMethods in org.opencastproject.serviceregistry.api that return JobModifier and TypeMethodDescriptionCreate and store a new job that will be dispatched as soon as possible.Create and store a new job that will be dispatched as soon as possible.Create and store a new job that will be dispatched as soon as possible.ServiceRegistry.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable) Create and store a new job.ServiceRegistry.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable, Float jobLoad) Create and store a new job.ServiceRegistry.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable, Job parentJob, Float jobLoad) Create and store a new job.Create and store a new job that will be dispatched as soon as possible.Create and store a new job that will be dispatched as soon as possible.ServiceRegistryInMemoryImpl.createJob(String type, String operation, List<String> arguments, Float jobLoad) Create and store a new job that will be dispatched as soon as possible.ServiceRegistryInMemoryImpl.createJob(String type, String operation, List<String> arguments, String payload) ServiceRegistryInMemoryImpl.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable) Create and store a new job.ServiceRegistryInMemoryImpl.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable, Float jobLoad) Create and store a new job.ServiceRegistryInMemoryImpl.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable, Job parentJob, Float jobLoad) Create and store a new job.ServiceRegistry.getCurrentJob()Gets the current running jobServiceRegistryInMemoryImpl.getCurrentJob()ServiceRegistry.getJob(long id) Gets a receipt by its ID, or null if not foundServiceRegistryInMemoryImpl.getJob(long id) Gets a receipt by its ID, or null if not foundNopService.nop()Update the job in the databaseUpdate the job in the databaseMethods in org.opencastproject.serviceregistry.api that return types with arguments of type JobModifier and TypeMethodDescriptionServiceRegistry.getActiveJobs()Get the list of active jobs.ServiceRegistryInMemoryImpl.getActiveJobs()Get the list of active jobs.ServiceRegistry.getChildJobs(long id) Get all child jobs from a jobServiceRegistryInMemoryImpl.getChildJobs(long id) Get all child jobs from a jobServiceRegistry.getJobs(String serviceType, Job.Status status) Gets the list of jobs that match the specified parameters.ServiceRegistryInMemoryImpl.getJobs(String serviceType, Job.Status status) Gets the list of jobs that match the specified parameters.Methods in org.opencastproject.serviceregistry.api with parameters of type JobModifier and TypeMethodDescriptionServiceRegistry.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable, Job parentJob, Float jobLoad) Create and store a new job.ServiceRegistryInMemoryImpl.createJob(String type, String operation, List<String> arguments, String payload, boolean queueable, Job parentJob, Float jobLoad) Create and store a new job.protected booleanServiceRegistryInMemoryImpl.dispatchJob(Job job) Dispatches the job to the least loaded service or throws aServiceUnavailableExceptionif there is no such service.voidIncidents.record(Job job, Incident.Severity severity, int code) Record an incident for a given job.voidIncidents.record(Job job, Incident.Severity severity, int code, Map<String, String> params, List<Tuple<String, String>> details) Record an incident for a given job.voidIncidents.recordFailure(Job job, int code, Throwable t, Map<String, String> params, List<Tuple<String, String>> details) Record a failure incident for a given job.voidIncidents.recordFailure(Job job, int code, Map<String, String> params) Record a failure incident for a given job.voidIncidents.recordJobCreationIncident(Job job, Throwable t) voidServiceRegistry.setCurrentJob(Job job) Sets the current running jobvoidServiceRegistryInMemoryImpl.setCurrentJob(Job job) IncidentService.storeIncident(Job job, Date timestamp, String code, Incident.Severity severity, Map<String, String> descriptionParameters, List<Tuple<String, String>> details) Stores a new job incident.voidIncidents.unhandledException(Job job, Incident.Severity severity, Throwable t) Record an incident for a given job caused by an uncatched exception.Update the job in the databaseUpdate the job in the database -
Uses of Job in org.opencastproject.util
Fields in org.opencastproject.util with type parameters of type JobMethods in org.opencastproject.util that return types with arguments of type JobModifier and TypeMethodDescriptionJobUtil.getNonFinished(List<Job> jobs) Get all jobs that are not in stateJob.Status.FINISHED.static Function<Job, MediaPackageElement> JobUtil.payloadAsMediaPackageElement(Job waiter, ServiceRegistry reg) Interpret the payload of a completedJobas aMediaPackageElement.static Function<Job, MediaPackageElement> JobUtil.payloadAsMediaPackageElement(ServiceRegistry reg) Interpret the payload of a completedJobas aMediaPackageElement.static com.entwinemedia.fn.data.Opt<Job> JobUtil.update(ServiceRegistry reg, Job job) Get the latest state of a job.JobUtil.waitForJobSuccess(Job waiter, ServiceRegistry reg, Option<Long> timeout) Wait for the job to complete and return the success value.Methods in org.opencastproject.util with parameters of type JobModifier and TypeMethodDescriptionstatic com.entwinemedia.fn.data.Opt<String> JobUtil.getPayload(ServiceRegistry reg, Job job) Update the job from the service registry and get its payload.static booleanJobUtil.isReadyToDispatch(Job job) Returnstrueif the job is ready to be dispatched.static javax.ws.rs.core.Responsestatic Function<Job, MediaPackageElement> JobUtil.payloadAsMediaPackageElement(Job waiter, ServiceRegistry reg) Interpret the payload of a completedJobas aMediaPackageElement.static com.entwinemedia.fn.data.Opt<Job> JobUtil.update(ServiceRegistry reg, Job job) Get the latest state of a job.static JobBarrier.ResultJobUtil.waitForJob(Job waiter, ServiceRegistry reg, Job job) Check ifjobis not done yet and wait in case.static JobBarrier.ResultJobUtil.waitForJob(Job waiter, ServiceRegistry reg, Option<Long> timeout, Job job) Check ifjobis not done yet and wait in case.static JobBarrier.ResultJobUtil.waitForJob(ServiceRegistry reg, Job job) Check ifjobis not done yet and wait in case.static JobBarrier.ResultJobUtil.waitForJob(ServiceRegistry reg, Option<Long> timeout, Job job) Check ifjobis not done yet and wait in case.static JobBarrier.ResultJobUtil.waitForJobs(Job waiter, ServiceRegistry reg, long pollingInterval, long timeout, Job... jobs) Waits for the result of a created barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling interval.static JobBarrier.ResultJobUtil.waitForJobs(Job waiter, ServiceRegistry reg, long timeout, Job... jobs) Waits for the result of a created barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling interval.static JobBarrier.ResultJobUtil.waitForJobs(Job waiter, ServiceRegistry reg, Collection<Job> jobs) Waits for the result of a created barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling interval.static JobBarrier.ResultJobUtil.waitForJobs(Job waiter, ServiceRegistry reg, Job... jobs) Waits for the result of a created barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling interval.static JobBarrier.ResultJobUtil.waitForJobs(ServiceRegistry reg, Job... jobs) Waits for the result of a created barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling interval.JobUtil.waitForJobSuccess(Job waiter, ServiceRegistry reg, Option<Long> timeout) Wait for the job to complete and return the success value.Method parameters in org.opencastproject.util with type arguments of type JobModifier and TypeMethodDescriptionJobUtil.getNonFinished(List<Job> jobs) Get all jobs that are not in stateJob.Status.FINISHED.static longJobUtil.sumQueueTime(List<Job> jobs) Sum up the queue time of a list of jobs.static JobBarrier.ResultJobUtil.waitForJobs(Job waiter, ServiceRegistry reg, Collection<Job> jobs) Waits for the result of a created barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling interval.static JobBarrier.ResultJobUtil.waitForJobs(ServiceRegistry reg, Collection<Job> jobs) Waits for the result of a created barrier forjobs, usingregistryto poll for the outcome of the monitored jobs using the default polling interval.Constructors in org.opencastproject.util with parameters of type Job