org.thales.punch.apps.shiva.leader.impl

Class LeaderImpl

java.lang.Object

org.thales.punch.apps.shiva.leader.impl.LeaderImpl

All Implemented Interfaces:

ILeader

public class LeaderImpl
extends Object
implements ILeader

This class is told upon new arrival and departure of new tasks and workers. All it does is to keep track of who is there not there anymore. Upon a change, it recompute the assignments, and if something changed publish the change to the (ephemeral) assignment node. Each worker will be told upon it.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
LeaderImpl(String leaderId, String clusterName)

Method Summary

Modifier and Type	Method and Description
void	addApplication(org.thales.punch.libraries.shiva.api.Application application) Add a new application to the set of applications known to the leader.
void	addWorker(org.thales.punch.settings.api.ISettingsMap map) Add a new worker to be known to the leader.
org.thales.punch.settings.api.ISettingsMap	getAssignements(long offset)
String	getLeaderId()
long	initAssignements(org.thales.punch.settings.api.ISettingsMap map) Make the leader start from a latest saved assignment.
void	removeApplication(String applicationName) The user stopped one of the shiva application.
void	removeWorker(String workerId) Remove a worker from the set of known workers.

Methods inherited from class java.lang.Object

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

Constructor Detail

LeaderImpl

public LeaderImpl(String leaderId,
                  String clusterName)

Parameters:

leaderId - the logical name of this shiva daemon

clusterName - the shiva cluster name

Method Detail

addWorker

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

Description copied from interface: ILeader

Add a new worker to be known to the leader.

The settings map used here conforms to the one generated by KafkaShivaUtil.getWorkerDeclarationMap(String, java.util.List)

Specified by:

addWorker in interface ILeader

Parameters:

map - the worker information.

removeWorker

public void removeWorker(String workerId)

Description copied from interface: ILeader

Remove a worker from the set of known workers.

Specified by:

removeWorker in interface ILeader

Parameters:

workerId - the worker name

addApplication

public void addApplication(org.thales.punch.libraries.shiva.api.Application application)

Description copied from interface: ILeader

Add a new application to the set of applications known to the leader.

This in turn will make the liader schedule it and assign it to some worker.

Specified by:

addApplication in interface ILeader

Parameters:

application - the application to start

removeApplication

public void removeApplication(String applicationName)

The user stopped one of the shiva application.

Specified by:

removeApplication in interface ILeader

getLeaderId

public String getLeaderId()

Specified by:

getLeaderId in interface ILeader

Returns:

the unique identifier of this leader.

getAssignements

public org.thales.punch.settings.api.ISettingsMap getAssignements(long offset)

Specified by:

getAssignements in interface ILeader

Parameters:

offset - the offset of the latest record read

Returns:

the latest assignment view

initAssignements

public long initAssignements(org.thales.punch.settings.api.ISettingsMap map)

Description copied from interface: ILeader

Make the leader start from a latest saved assignment.

Specified by:

initAssignements in interface ILeader

Parameters:

map - the latest assignment map.

Returns:

the offset recorded in the map. It indicates the offset up to which the assignement has been computed.