org.thales.punch.apps.shiva

Class Main

java.lang.Object

org.thales.punch.apps.shiva.Main

public final class Main
extends Object

Shiva daemon main class.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
static int	burstFilterRate
static int	burstFilterThreshold
static org.thales.punch.platform.api.IApplicationExitReporter	exitReporter
static org.thales.punch.libraries.metrics.impl.MetricRegistryImpl	metricRegistry
static org.thales.punch.libraries.reporters.api.ReporterGroup	reporterGroup
static org.thales.punch.platform.api.IApplicationStartReporter	startReporter
static ThreadPoolExecutor	threadPool

Constructor Summary

Constructors

Constructor and Description
Main()

Method Summary

Modifier and Type	Method and Description
static org.thales.punch.platform.api.LogRecord	getLogRecord(org.thales.punch.libraries.shiva.api.Application application, String runnerId, String clusterName) return a ready to use log record (this version is faster because we do not need to parse the app name each log).
static org.thales.punch.platform.api.LogRecord	getLogRecord(String shivaWorker, String clusterName)
static org.thales.punch.platform.api.LogRecord	getLogRecord(String appName, String runnerId, String clusterName) return a ready to use log record Warning: prefer the signature using Application instead of task name, for performance.
static void	main(String... args) Main entry point.
static void	startFilesystemLeader(String root, ILeader leader, long tickInterval)
static void	startFilesystemWorker(String root, IWorker worker, long tickInterval)
static void	startLeader(String kafkaUrl, ILeader leader, long tickInterval)
static void	startWorker(String kafkaUrl, IWorker worker, long tickInterval)

Methods inherited from class java.lang.Object

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

Field Detail

reporterGroup

public static org.thales.punch.libraries.reporters.api.ReporterGroup reporterGroup

metricRegistry

public static org.thales.punch.libraries.metrics.impl.MetricRegistryImpl metricRegistry

threadPool

public static ThreadPoolExecutor threadPool

startReporter

public static org.thales.punch.platform.api.IApplicationStartReporter startReporter

exitReporter

public static org.thales.punch.platform.api.IApplicationExitReporter exitReporter

burstFilterRate

public static int burstFilterRate

burstFilterThreshold

public static int burstFilterThreshold

Constructor Detail

Main

public Main()

Method Detail

main

public static void main(String... args)
                 throws IOException,
                        org.apache.commons.cli.ParseException

Main entry point.

Parameters:

args - the command line args

Throws:

IOException

org.apache.commons.cli.ParseException

startLeader

public static void startLeader(String kafkaUrl,
                               ILeader leader,
                               long tickInterval)

startFilesystemLeader

public static void startFilesystemLeader(String root,
                                         ILeader leader,
                                         long tickInterval)
                                  throws IOException

Throws:

IOException

startWorker

public static void startWorker(String kafkaUrl,
                               IWorker worker,
                               long tickInterval)

startFilesystemWorker

public static void startFilesystemWorker(String root,
                                         IWorker worker,
                                         long tickInterval)
                                  throws IOException

Throws:

IOException

getLogRecord

public static org.thales.punch.platform.api.LogRecord getLogRecord(String appName,
                                                                   String runnerId,
                                                                   String clusterName)

return a ready to use log record Warning: prefer the signature using Application instead of task name, for performance.

Parameters:

appName - the shiva app name

runnerId - the runner type

clusterName - the shiva cluser name

Returns:

getLogRecord

public static org.thales.punch.platform.api.LogRecord getLogRecord(org.thales.punch.libraries.shiva.api.Application application,
                                                                   String runnerId,
                                                                   String clusterName)

return a ready to use log record (this version is faster because we do not need to parse the app name each log).

Parameters:

application - the shiva Application

runnerId - the runner type

clusterName - the shiva cluser name

Returns:

getLogRecord

public static org.thales.punch.platform.api.LogRecord getLogRecord(String shivaWorker,
                                                                   String clusterName)