org.thales.punch.apps.shiva

Interface IWorker

All Known Implementing Classes:

WorkerImpl

public interface IWorker

Each worker has a fairly simple design. A single executor thread is in charge of updating the assignments, and regularly checking the status of child process.

We use a single thread pattern hence no issue of concurrency.

Author:

dimi

Method Summary

Modifier and Type	Method and Description
void	addConfiguration(long offset, org.thales.punch.libraries.shiva.api.Command command) Refresh the configuration folder known to this worker.
org.thales.punch.settings.api.ISettingsMap	asSettingsMap()
String	getWorkerId()
void	removeApplication(String appName) Remove the folder of a stopped application
void	tick() Make the worker check its application.
void	updateAssignement(org.thales.punch.settings.api.ISettingsMap assignments) Update the assignments associated to a worker.

Method Detail

updateAssignement

void updateAssignement(org.thales.punch.settings.api.ISettingsMap assignments)

Update the assignments associated to a worker.

Parameters:

assignments - the refreshed assignments

getWorkerId

String getWorkerId()

Returns:

this worker unique identifier

addConfiguration

void addConfiguration(long offset,
                      org.thales.punch.libraries.shiva.api.Command command)

Refresh the configuration folder known to this worker. Note that this does not start any application.

This allow each worker to store locally all the required application files and be ready to eventually execute it should the leader decide so.

Parameters:

offset - the corresponding kafka offset

command - the start command

tick

void tick()

Make the worker check its application.

asSettingsMap

org.thales.punch.settings.api.ISettingsMap asSettingsMap()

Returns:

the gossip representation of this worker

removeApplication

void removeApplication(String appName)

Remove the folder of a stopped application

Parameters:

appName -