org.thales.punch.apps.shiva.worker.impl

Class WorkerImpl

java.lang.Object

org.thales.punch.apps.shiva.worker.impl.WorkerImpl

All Implemented Interfaces:

IWorker

public class WorkerImpl
extends Object
implements IWorker

IWorker implementation.

A worker is the class in charge of keeping track of the arrival and departure of task assignments. Upon a change, it recompute the assignments, and submit task for execution accordingly.

This class is very simple. In zookeeper a task is defined by a node:

"/zk_root/shiva/tasks/punchplatform/mytenant/services/myservice/mytask"

When assigned to a worker, the worker loads all the zookeeper data once, and put it under

"/data_dir/punchplatform/mytenant/services/myservice/mytask"

The task name used to uniquely identify a task is simply:

"/punchplatform/mytenant/services/myservice/mytask"

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
WorkerImpl(String clusterName, Path dataFolder, String myId, List<String> tags, boolean useKafkaStore) Create a new worker.

Method Summary

Modifier and Type	Method and Description
void	addConfiguration(long offset, org.thales.punch.libraries.shiva.api.Command cmd) 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() Let the worker check for all tasks.
void	updateAssignement(org.thales.punch.settings.api.ISettingsMap map) WATCHOUT this code is subtle.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerImpl

public WorkerImpl(String clusterName,
                  Path dataFolder,
                  String myId,
                  List<String> tags,
                  boolean useKafkaStore)

Create a new worker.

Parameters:

clusterName - shiva cluster name to join

dataFolder - folder to use for runtime

myId - worker id

tags - worker tags

useKafkaStore - if true, use a dedicated working directory from data folder, else use conf dir

Method Detail

updateAssignement

public void updateAssignement(org.thales.punch.settings.api.ISettingsMap map)

WATCHOUT this code is subtle. DO NOT CHANGE IT.

Specified by:

updateAssignement in interface IWorker

Parameters:

map - the refreshed assignments

tick

public void tick()

Let the worker check for all tasks. Start the one that must be started or restarted.

Specified by:

tick in interface IWorker

getWorkerId

public String getWorkerId()

Specified by:

getWorkerId in interface IWorker

Returns:

this worker unique identifier

asSettingsMap

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

Specified by:

asSettingsMap in interface IWorker

Returns:

the gossip representation of this worker

addConfiguration

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

Description copied from interface: IWorker

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.

Specified by:

addConfiguration in interface IWorker

Parameters:

offset - the corresponding kafka offset

cmd - the start command

removeApplication

public void removeApplication(String appName)

Description copied from interface: IWorker

Remove the folder of a stopped application

Specified by:

removeApplication in interface IWorker