org.thales.punch.platform.impl

Class ShivaClusterImpl

java.lang.Object

org.thales.punch.platform.impl.ShivaClusterImpl

All Implemented Interfaces:

IShivaCluster

public class ShivaClusterImpl
extends Object
implements IShivaCluster

IShivaCluster implementation.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
ShivaClusterImpl(String shivaClusterName, IPunchPlatformProperties properties) Ctor

Method Summary

Modifier and Type	Method and Description
String	getAssignementTopic()
String	getCommandTopic()
String	getFilesystemRoot() Simple shiva "cluster" can run on one node and rely on the local filesystem.
String	getKafkaBoostrapServers()
String	getKafkaClusterName()
String	getName() The logical name of the cluster.
Set<String>	getServerNames() Get the set of Shiva server hostnames
Set<String>	getWorkersServerNames() Get the set of Shiva workers server hostnames
boolean	isLocalFileSystemDaemon() Simple shiva "cluster" can run on one node and rely on the local filesystem.

Methods inherited from class java.lang.Object

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

Constructor Detail

ShivaClusterImpl

public ShivaClusterImpl(String shivaClusterName,
                        IPunchPlatformProperties properties)
                 throws ConfigurationException

Ctor

Parameters:

shivaClusterName - the logical shiva cluster name, i.e. 'common'

properties - the platform properties

Throws:

ConfigurationException

Method Detail

getFilesystemRoot

public String getFilesystemRoot()
                         throws ConfigurationException

Description copied from interface: IShivaCluster

Simple shiva "cluster" can run on one node and rely on the local filesystem.

Specified by:

getFilesystemRoot in interface IShivaCluster

Returns:

the root filesystem where the topics are emulated.

Throws:

PlatformPropertiesConfigurationException

ConfigurationException

isLocalFileSystemDaemon

public boolean isLocalFileSystemDaemon()
                                throws ConfigurationException

Description copied from interface: IShivaCluster

Simple shiva "cluster" can run on one node and rely on the local filesystem.

Specified by:

isLocalFileSystemDaemon in interface IShivaCluster

Returns:

true if it is a local one node daemon

Throws:

PlatformPropertiesConfigurationException

ConfigurationException

getCommandTopic

public String getCommandTopic()
                       throws ConfigurationException

Specified by:

getCommandTopic in interface IShivaCluster

Returns:

the topic used for commands

Throws:

PlatformPropertiesConfigurationException

ConfigurationException

getAssignementTopic

public String getAssignementTopic()
                           throws ConfigurationException

Specified by:

getAssignementTopic in interface IShivaCluster

Returns:

the topic used to publish the shiva cluster status

Throws:

PlatformPropertiesConfigurationException

ConfigurationException

getKafkaBoostrapServers

public String getKafkaBoostrapServers()
                               throws ConfigurationException

Specified by:

getKafkaBoostrapServers in interface IShivaCluster

Returns:

the kafka bootstrap serv ers associated to this shiva cluster

Throws:

PlatformPropertiesConfigurationException

ConfigurationException

getKafkaClusterName

public String getKafkaClusterName()
                           throws ConfigurationException

Specified by:

getKafkaClusterName in interface IShivaCluster

Returns:

the kafka cluster name

Throws:

PlatformPropertiesConfigurationException

ConfigurationException

getName

public String getName()

Description copied from interface: IShivaCluster

The logical name of the cluster. It is the name of the cluster section in the punchplatform.properties

Specified by:

getName in interface IShivaCluster

Returns:

the corresponding Shiva cluster name

getServerNames

public Set<String> getServerNames()
                           throws ConfigurationException

Description copied from interface: IShivaCluster

Get the set of Shiva server hostnames

Specified by:

getServerNames in interface IShivaCluster

Returns:

the set of server names

Throws:

PlatformPropertiesConfigurationException

ConfigurationException

getWorkersServerNames

public Set<String> getWorkersServerNames()
                                  throws ConfigurationException

Description copied from interface: IShivaCluster

Get the set of Shiva workers server hostnames

Specified by:

getWorkersServerNames in interface IShivaCluster

Returns:

the set of server names

Throws:

PlatformPropertiesConfigurationException

ConfigurationException