Class WeatherProbeRunner

java.lang.Object

ecmwf.ecpds.master.weather.WeatherProbeRunner

All Implemented Interfaces:

AutoCloseable

public final class WeatherProbeRunner
extends Object
implements AutoCloseable

One optional worker, no waiting jobs; remote job polling cannot relaunch a known job.

Constructor Summary

Constructors

Constructor	Description
WeatherProbeRunner(String source, UUID epoch)

Method Summary

Modifier and Type	Method	Description
void	acknowledge(List<UUID> ids)
void	cancel()
void	close()
void	offer(WeatherProbe.Job job, WeatherNegotiation.Lease lease)
void	reconcile(WeatherNegotiation.Lease lease)
List<WeatherProbe.Result>	results()
String	status()

Methods inherited from class Object

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

Constructor Details

WeatherProbeRunner

public WeatherProbeRunner(String source,
 UUID epoch)

Method Details

offer

public void offer(WeatherProbe.Job job,
 WeatherNegotiation.Lease lease)

results

public List<WeatherProbe.Result> results()

status

public String status()

acknowledge

public void acknowledge(List<UUID> ids)

cancel

public void cancel()

reconcile

public void reconcile(WeatherNegotiation.Lease lease)

close

public void close()

Specified by:

close in interface AutoCloseable