org.thales.punch.apps.shiva

Interface ILeader

All Known Implementing Classes:

LeaderImpl

public interface ILeader

This interface completely defines the leader input callback : add or remove a new worker, add or remove an application.

Author:

dimi

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) Remove an app.
void	removeWorker(String name) Remove a worker from the set of known workers.

Method Detail

getAssignements

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

Parameters:

offset - the offset of the latest record read

Returns:

the latest assignment view

initAssignements

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

Make the leader start from a latest saved assignment.

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.

addApplication

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

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.

Parameters:

application - the application to start

offset - the corresponding offset. It is used to make sure we kown which version of the application we speak about.

removeApplication

void removeApplication(String applicationName)

Remove an app. This unschedules it.

Parameters:

name - the task name

addWorker

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

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)

Parameters:

map - the worker information.

removeWorker

void removeWorker(String name)

Remove a worker from the set of known workers.

Parameters:

name - the worker name

getLeaderId

String getLeaderId()

Returns:

the unique identifier of this leader.