org.thales.punch.platform.api

Interface IShivaCluster

All Known Implementing Classes:

ShivaClusterImpl

public interface IShivaCluster

Shiva administration interface.

Author:

dimi

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.

Method Detail

isLocalFileSystemDaemon

boolean isLocalFileSystemDaemon()
                         throws ConfigurationException

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

Returns:

true if it is a local one node daemon

Throws:

MissingPlatformPropertiesConfigurationException

PlatformPropertiesConfigurationException

ConfigurationException

getFilesystemRoot

String getFilesystemRoot()
                  throws ConfigurationException

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

Returns:

the root filesystem where the topics are emulated.

Throws:

MissingPlatformPropertiesConfigurationException

PlatformPropertiesConfigurationException

ConfigurationException

getKafkaBoostrapServers

String getKafkaBoostrapServers()
                        throws ConfigurationException

Returns:

the kafka bootstrap serv ers associated to this shiva cluster

Throws:

PlatformPropertiesConfigurationException

MissingPlatformPropertiesConfigurationException

ConfigurationException

getKafkaClusterName

String getKafkaClusterName()
                    throws ConfigurationException

Returns:

the kafka cluster name

Throws:

MissingPlatformPropertiesConfigurationException

PlatformPropertiesConfigurationException

ConfigurationException

getName

String getName()

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

Returns:

the corresponding Shiva cluster name

getServerNames

Set<String> getServerNames()
                    throws ConfigurationException

Get the set of Shiva server hostnames

Returns:

the set of server names

Throws:

MissingPlatformPropertiesConfigurationException

PlatformPropertiesConfigurationException

ConfigurationException

getWorkersServerNames

Set<String> getWorkersServerNames()
                           throws ConfigurationException

Get the set of Shiva workers server hostnames

Returns:

the set of server names

Throws:

MissingPlatformPropertiesConfigurationException

PlatformPropertiesConfigurationException

ConfigurationException

getCommandTopic

String getCommandTopic()
                throws ConfigurationException

Returns:

the topic used for commands

Throws:

MissingPlatformPropertiesConfigurationException

PlatformPropertiesConfigurationException

ConfigurationException

getAssignementTopic

String getAssignementTopic()
                    throws ConfigurationException

Returns:

the topic used to publish the shiva cluster status

Throws:

PlatformPropertiesConfigurationException

MissingPlatformPropertiesConfigurationException

ConfigurationException