org.opendaylight.infrautils.jobcoordinator

Interface JobCoordinator

All Known Implementing Classes:

JobCoordinatorImpl

public interface JobCoordinator

This interface defines methods for a JobCoordinator which enables executing jobs in a parallel/sequential fashion based on their keys.

Enqueued jobs are stored in unbounded queues until they are run, this should be kept in mind as it might lead to an OOM.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_RETRIES

Method Summary

Modifier and Type	Method and Description
void	enqueueJob(String key, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker) Enqueues a job with DEFAULT_MAX_RETRIES (3) retries.
void	enqueueJob(String key, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker, int maxRetries) Enqueues a job with max retries.
void	enqueueJob(String key, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker, RollbackCallable rollbackWorker) Enqueues a job with a rollback task and DEFAULT_MAX_RETRIES (3) retries..
void	enqueueJob(String key, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker, RollbackCallable rollbackWorker, int maxRetries) Enqueues a job with a rollback task and max retries.

Field Detail

DEFAULT_MAX_RETRIES

static final int DEFAULT_MAX_RETRIES

See Also:

Constant Field Values

Method Detail

enqueueJob

void enqueueJob(String key,
                Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker)

Enqueues a job with DEFAULT_MAX_RETRIES (3) retries.

Parameters:

key - The job's key. Jobs with the same key are run sequentially. Jobs with different keys are run in parallel.

mainWorker - The task that runs for the job.

enqueueJob

void enqueueJob(String key,
                Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker,
                RollbackCallable rollbackWorker)

Enqueues a job with a rollback task and DEFAULT_MAX_RETRIES (3) retries..

Parameters:

rollbackWorker - The rollback task which runs in case the job's main task fails.

See Also:

enqueueJob(String, Callable)

enqueueJob

void enqueueJob(String key,
                Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker,
                int maxRetries)

Enqueues a job with max retries. In case the job's main task fails, it will be retried until it succeeds or the specified maximum number of retries has been reached.

Parameters:

maxRetries - The maximum number of retries for the job's main task until it succeeds.

See Also:

enqueueJob(String, Callable)

enqueueJob

void enqueueJob(String key,
                Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> mainWorker,
                RollbackCallable rollbackWorker,
                int maxRetries)

Enqueues a job with a rollback task and max retries.

Parameters:

rollbackWorker - The rollback task which runs in case the job's main task fails.

maxRetries - The maximum number of retries for the job's main task until it succeeds.

See Also:

enqueueJob(String, Callable, RollbackCallable), enqueueJob(String, Callable, int)