Index (Punch Shiva Distributed Scheduler 6.4.4 API)

A B C D E F G H I K L M N O P R S T U V W

A

AbstractWorkerApplication - Class in org.thales.punch.apps.shiva.worker.impl: Shiva applications can be of two types: processes or threads.
AbstractWorkerApplication(Path, Path, Application, String, String) - Constructor for class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
addApplication(Application) - Method in interface org.thales.punch.apps.shiva.ILeader: Add a new application to the set of applications known to the leader.
addApplication(Application) - Method in class org.thales.punch.apps.shiva.leader.impl.LeaderImpl
addConfiguration(long, Command) - Method in interface org.thales.punch.apps.shiva.IWorker: Refresh the configuration folder known to this worker.
addConfiguration(long, Command) - Method in class org.thales.punch.apps.shiva.worker.impl.WorkerImpl
addWorker(ISettingsMap) - Method in interface org.thales.punch.apps.shiva.ILeader: Add a new worker to be known to the leader.
addWorker(String, ISettingsMap) - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
addWorker(ISettingsMap) - Method in class org.thales.punch.apps.shiva.leader.impl.LeaderImpl
application - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: the application descriptor as read from Kafka
ApplicationDescriptor - Class in org.thales.punch.apps.shiva.leader.impl: Simple class to keep track of assigned apps.
ApplicationDescriptor(Application) - Constructor for class org.thales.punch.apps.shiva.leader.impl.ApplicationDescriptor
applicationFailedToStart(String, String) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
applicationFailedToStart() - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
applicationFolder - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: where are stored the application command and arguments files.
ApplicationPlatformReporter - Class in org.thales.punch.apps.shiva.worker.impl: This class is in charge of reporting importants events to the platform.
ApplicationPlatformReporter(Application, Logger) - Constructor for class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
applicationStarted() - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter: Report an application started event
ApplicationStdIoCallback - Class in org.thales.punch.apps.shiva.worker.impl: This callback receives child process stdout or stderr outputs.
ApplicationStdIoCallback(ApplicationStdIoCallback.IO, Application) - Constructor for class org.thales.punch.apps.shiva.worker.impl.ApplicationStdIoCallback: Create a callback to receive child process stdout and stderr logs
ApplicationStdIoCallback.IO - Enum in org.thales.punch.apps.shiva.worker.impl
applicationStopped() - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
applyAsInt(JobExecution) - Method in class org.thales.punch.apps.shiva.plan.PlanCallback: The callback function.
applyResolverOnFiles(File, Application) - Static method in class org.thales.punch.apps.shiva.worker.utils.WorkerUtil: From your channel_structure, apply_resolver_on a list of string where each element is a path relative to the working space directory
asSettingsMap() - Method in interface org.thales.punch.apps.shiva.IWorker
asSettingsMap() - Method in class org.thales.punch.apps.shiva.worker.impl.WorkerImpl
asyncStop() - Method in class org.thales.punch.apps.shiva.plan.PlanThreadImpl
asyncStop() - Method in interface org.thales.punch.apps.shiva.worker.impl.IThreadApplication: Stop the application.This method returns possibly before the thread is effectively gone.

B

burstFilterRate - Static variable in class org.thales.punch.apps.shiva.Main
burstFilterThreshold - Static variable in class org.thales.punch.apps.shiva.Main

C

call() - Method in class org.thales.punch.apps.shiva.plan.PlanThreadImpl
close() - Method in class org.thales.punch.apps.shiva.filesystem.FolderMonitor
clusterName - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: The Shiva cluster name of this task
confDirFolder - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: The top level directory associasted to this application.

D

decApplicationCount() - Method in class org.thales.punch.apps.shiva.leader.impl.WorkerDescriptor

E

ephemeral - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: True if the application must be executed only once.
eternalApplicationScheduled() - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
executionTime - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: the cron execution time.
exitReporter - Static variable in class org.thales.punch.apps.shiva.Main
exitValue() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
exitValue() - Method in class org.thales.punch.apps.shiva.worker.impl.ForkExecWorkerApplication
exitValue() - Method in class org.thales.punch.apps.shiva.worker.impl.PlanWorkerApplication: exit value here refers to a thread that dies or not; thus the plan thread itself and not the subprocess executed by plan thread

F

FilesystemController - Class in org.thales.punch.apps.shiva.filesystem: This class has only one purpose : share the same producer between the worker and the leader.
FilesystemController(String, String, String, String) - Constructor for class org.thales.punch.apps.shiva.filesystem.FilesystemController
FilesystemLeaderController - Class in org.thales.punch.apps.shiva.filesystem: This class takes care of the kafka gossip exchange required by the leader.
FilesystemLeaderController(File, String, String, String, ILeader, long) - Constructor for class org.thales.punch.apps.shiva.filesystem.FilesystemLeaderController
FilesystemWorkerController - Class in org.thales.punch.apps.shiva.filesystem: File system based worker controller.
FilesystemWorkerController(File, String, String, IWorker, long) - Constructor for class org.thales.punch.apps.shiva.filesystem.FilesystemWorkerController
FolderMonitor - Class in org.thales.punch.apps.shiva.filesystem
FolderMonitor(Path, Consumer<File>) - Constructor for class org.thales.punch.apps.shiva.filesystem.FolderMonitor
ForkExecWorkerApplication - Class in org.thales.punch.apps.shiva.worker.impl: Each application managed by a worker is represented by an instance of this class.
ForkExecWorkerApplication(String, String, Path, Path, Application) - Constructor for class org.thales.punch.apps.shiva.worker.impl.ForkExecWorkerApplication

G

getApplication() - Method in class org.thales.punch.apps.shiva.leader.impl.ApplicationDescriptor
getApplication() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
getApplicationCount() - Method in class org.thales.punch.apps.shiva.leader.impl.WorkerDescriptor
getAsSettingsMap() - Method in class org.thales.punch.apps.shiva.leader.impl.WorkerDescriptor
getAssignements(long) - Method in interface org.thales.punch.apps.shiva.ILeader
getAssignements(long) - Method in class org.thales.punch.apps.shiva.leader.impl.LeaderImpl
getClusterName() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
getCurrentKnownWorkers() - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
getFolder() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
getLeaderId() - Method in interface org.thales.punch.apps.shiva.ILeader
getLeaderId() - Method in class org.thales.punch.apps.shiva.leader.impl.LeaderImpl
getLogRecord(String, String, String) - Static method in class org.thales.punch.apps.shiva.Main: return a ready to use log record Warning: prefer the signature using Application instead of task name, for performance.
getLogRecord(Application, String, String) - Static method in class org.thales.punch.apps.shiva.Main: return a ready to use log record (this version is faster because we do not need to parse the app name each log).
getLogRecord(String, String) - Static method in class org.thales.punch.apps.shiva.Main
getName() - Method in class org.thales.punch.apps.shiva.leader.impl.ApplicationDescriptor
getName() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
getTags() - Method in class org.thales.punch.apps.shiva.leader.impl.ApplicationDescriptor
getWorker() - Method in class org.thales.punch.apps.shiva.leader.impl.ApplicationDescriptor
getWorkerId() - Method in interface org.thales.punch.apps.shiva.IWorker
getWorkerId() - Method in class org.thales.punch.apps.shiva.leader.impl.WorkerDescriptor
getWorkerId() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
getWorkerId() - Method in class org.thales.punch.apps.shiva.worker.impl.WorkerImpl

H

hasStarted - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: true if the a start has been issued.

I

IController - Interface in org.thales.punch.apps.shiva: Top level interface to start new controlles.
ILeader - Interface in org.thales.punch.apps.shiva: This interface completely defines the leader input callback : add or remove a new worker, add or remove an application.
incApplicationCount() - Method in class org.thales.punch.apps.shiva.leader.impl.WorkerDescriptor
initAssignements(ISettingsMap) - Method in interface org.thales.punch.apps.shiva.ILeader: Make the leader start from a latest saved assignment.
initAssignements(ISettingsMap) - Method in class org.thales.punch.apps.shiva.leader.impl.LeaderImpl
isAlive() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
isAlive() - Method in class org.thales.punch.apps.shiva.worker.impl.ForkExecWorkerApplication
isAlive() - Method in class org.thales.punch.apps.shiva.worker.impl.PlanWorkerApplication
isEphemeral() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
isEverRunningTask() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
isStarted() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
IThreadApplication - Interface in org.thales.punch.apps.shiva.worker.impl: Use this interface for application embedded as shiva threads.
IWorker - Interface in org.thales.punch.apps.shiva: Each worker has a fairly simple design.

K

KafkaLeaderController - Class in org.thales.punch.apps.shiva.kafka: This class takes care of the kafka gossip exchange required by the leader.
KafkaLeaderController(String, KafkaProducer<String, byte[]>, String, String, String, String, ILeader, long, JavaStoreSecurity) - Constructor for class org.thales.punch.apps.shiva.kafka.KafkaLeaderController
KafkaLeaderControlPlaneController - Class in org.thales.punch.apps.shiva.kafka: This class runs the dedicated thread in charge of regularly checkking all alive workers.
KafkaLeaderControlPlaneController(KafkaContinuousConsumerBuilder<String, byte[]>) - Constructor for class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
KafkaTopicController - Class in org.thales.punch.apps.shiva.kafka: This class has only one purpose : share the same kafka producer between the worker and the leader.
KafkaTopicController(String, String, String, String, String, String, JavaStoreSecurity) - Constructor for class org.thales.punch.apps.shiva.kafka.KafkaTopicController: Ctor.
KafkaWorkerController - Class in org.thales.punch.apps.shiva.kafka
KafkaWorkerController(String, KafkaProducer<String, byte[]>, String, String, String, String, IWorker, long, JavaStoreSecurity) - Constructor for class org.thales.punch.apps.shiva.kafka.KafkaWorkerController
KafkaWorkerControlPlaneController - Class in org.thales.punch.apps.shiva.kafka
KafkaWorkerControlPlaneController(KafkaContinuousConsumerBuilder<String, byte[]>, KafkaProducer<String, byte[]>, String, IWorker) - Constructor for class org.thales.punch.apps.shiva.kafka.KafkaWorkerControlPlaneController

L

lastExecutionStart - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: the last execution start time.
launchChildApplication(String, Application, File, String, String[]) - Static method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: Create an environment for the new worker application and launch its subprocess
LeaderImpl - Class in org.thales.punch.apps.shiva.leader.impl: This class is told upon new arrival and departure of new tasks and workers.
LeaderImpl(String, String) - Constructor for class org.thales.punch.apps.shiva.leader.impl.LeaderImpl

M

Main - Class in org.thales.punch.apps.shiva: Shiva daemon main class.
Main() - Constructor for class org.thales.punch.apps.shiva.Main
main(String...) - Static method in class org.thales.punch.apps.shiva.Main: Main entry point.
matchesRequirements(List<String>) - Method in class org.thales.punch.apps.shiva.leader.impl.WorkerDescriptor
metricRegistry - Static variable in class org.thales.punch.apps.shiva.Main

N

numExecution - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: Keep track of the number of time this app has been executed.

O

onPartitionAssigned(IPartition, OffsetAndMetadata) - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderController
onPartitionAssigned(IPartition, OffsetAndMetadata) - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerController
onPartitionRevoked(IPartition) - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderController
onPartitionRevoked(IPartition) - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerController
onReceive(IPartition, ConsumerRecord<String, byte[]>) - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderController
onReceive(IPartition, ConsumerRecord<String, byte[]>) - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
onReceive(IPartition, ConsumerRecord<String, byte[]>) - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerController
onReceive(IPartition, ConsumerRecord<String, byte[]>) - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerControlPlaneController
onReceive(String) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationStdIoCallback
onTick(IPartition, long) - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderController
onTick(IPartition, long) - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerController
org.thales.punch.apps.shiva - package org.thales.punch.apps.shiva: Shiva Punch Scheduler
org.thales.punch.apps.shiva.filesystem - package org.thales.punch.apps.shiva.filesystem: Punch Filesystem Protocol Design
org.thales.punch.apps.shiva.kafka - package org.thales.punch.apps.shiva.kafka: Shiva Worker logic
org.thales.punch.apps.shiva.leader.impl - package org.thales.punch.apps.shiva.leader.impl
org.thales.punch.apps.shiva.plan - package org.thales.punch.apps.shiva.plan
org.thales.punch.apps.shiva.worker.impl - package org.thales.punch.apps.shiva.worker.impl: Copyright © 2016-2021 Thales Services Numériques Licensed under the Thales Inner Source Software License: Version 1.2, InnerOpen - Distribution Controlled You may not use this file except in compliance with the License.
org.thales.punch.apps.shiva.worker.utils - package org.thales.punch.apps.shiva.worker.utils

P

periodicApplicationScheduled() - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
PlanCallback - Class in org.thales.punch.apps.shiva.plan: This callback is regularly invoked from the plan library, each time the plan punchline must be executed.
PlanCallback(Application, Path, String, Path, Path, String) - Constructor for class org.thales.punch.apps.shiva.plan.PlanCallback
PlanThreadImpl - Class in org.thales.punch.apps.shiva.plan: An instance of this class is used by ThreadWorkerApplication
PlanThreadImpl(String, Application, Path, Path) - Constructor for class org.thales.punch.apps.shiva.plan.PlanThreadImpl
PlanWorkerApplication - Class in org.thales.punch.apps.shiva.worker.impl: Plans are executed differently than other shiva apps.
PlanWorkerApplication(String, String, Path, Path, Application) - Constructor for class org.thales.punch.apps.shiva.worker.impl.PlanWorkerApplication
platformReporter - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: Contains helpers for logging information

R

removeApplication(String) - Method in interface org.thales.punch.apps.shiva.ILeader: Remove an app.
removeApplication(String) - Method in interface org.thales.punch.apps.shiva.IWorker: Remove the folder of a stopped application
removeApplication(String) - Method in class org.thales.punch.apps.shiva.leader.impl.LeaderImpl: The user stopped one of the shiva application.
removeApplication(String) - Method in class org.thales.punch.apps.shiva.worker.impl.WorkerImpl
removeWorker(String) - Method in interface org.thales.punch.apps.shiva.ILeader: Remove a worker from the set of known workers.
removeWorker(String) - Method in class org.thales.punch.apps.shiva.leader.impl.LeaderImpl
reporterGroup - Static variable in class org.thales.punch.apps.shiva.Main
reportRunningApplicationFailure(String) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
reportRunningApplicationFailure(String, String) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
reportRunningApplicationFailure(String, String, Exception) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
reportRunningApplicationInternalTaskFailure(String, Exception) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
reportRunningApplicationMessage(String) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
reportRunningApplicationSuccess(String) - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
reset() - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
run() - Method in class org.thales.punch.apps.shiva.filesystem.FilesystemLeaderController
run() - Method in class org.thales.punch.apps.shiva.filesystem.FilesystemWorkerController
run() - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderController
run() - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
run() - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerController
run() - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerControlPlaneController

S

setApplicationEnvironment(String, PunchProcessBuilder, Application, String) - Static method in class org.thales.punch.apps.shiva.worker.utils.WorkerApplicationEnvironmentUtil: Set the complete environment of a shiva worker application subprocess
setApplicationMetadataEnvironment(PunchProcessBuilder, Application) - Static method in class org.thales.punch.apps.shiva.worker.utils.WorkerApplicationEnvironmentUtil: Set the environment for the metadata of a worker application subprocess
setApplicationSecretEnvironment(PunchProcessBuilder) - Static method in class org.thales.punch.apps.shiva.worker.utils.WorkerApplicationEnvironmentUtil: Locate the secrets dir from the Shiva worker's environment and set it inside the application's subprocess environment.
setEnvVariable(PunchProcessBuilder, String, String) - Static method in class org.thales.punch.apps.shiva.worker.utils.WorkerApplicationEnvironmentUtil: Set the environment variable for a punch shiva worker application application subprocess
setWorker(WorkerDescriptor) - Method in class org.thales.punch.apps.shiva.leader.impl.ApplicationDescriptor
start() - Method in class org.thales.punch.apps.shiva.filesystem.FolderMonitor
start() - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
start() - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerControlPlaneController
start() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: Start a worker task, i.e.
start() - Method in class org.thales.punch.apps.shiva.worker.impl.ForkExecWorkerApplication
start() - Method in class org.thales.punch.apps.shiva.worker.impl.PlanWorkerApplication
started() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: Mark this application as running.
startFilesystemLeader(String, ILeader, long) - Static method in class org.thales.punch.apps.shiva.Main
startFilesystemWorker(String, IWorker, long) - Static method in class org.thales.punch.apps.shiva.Main
startLeader(ILeader, long) - Method in class org.thales.punch.apps.shiva.filesystem.FilesystemController: The leader is started in a dedicated thread but every time it vanishes, it is restarted from a fresh new state.
startLeader(ILeader, long) - Method in interface org.thales.punch.apps.shiva.IController
startLeader(ILeader, long) - Method in class org.thales.punch.apps.shiva.kafka.KafkaTopicController: The leader is started in a dedicated thread but every time it vanishes, it is restarted from a fresh new state.
startLeader(String, ILeader, long) - Static method in class org.thales.punch.apps.shiva.Main
startReporter - Static variable in class org.thales.punch.apps.shiva.Main
startWorker(IWorker, long) - Method in class org.thales.punch.apps.shiva.filesystem.FilesystemController: A worker is started only once and is not supposed to vanish ever.
startWorker(IWorker, long) - Method in interface org.thales.punch.apps.shiva.IController: Start the worker controler
startWorker(IWorker, long) - Method in class org.thales.punch.apps.shiva.kafka.KafkaTopicController: A worker is started only once and is not supposed to vanish ever.
startWorker(String, IWorker, long) - Static method in class org.thales.punch.apps.shiva.Main
stop() - Method in class org.thales.punch.apps.shiva.kafka.KafkaLeaderControlPlaneController
stop() - Method in class org.thales.punch.apps.shiva.kafka.KafkaWorkerControlPlaneController
stop() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: Stop a worker task, i.e.
stop() - Method in class org.thales.punch.apps.shiva.worker.impl.ForkExecWorkerApplication
stop() - Method in class org.thales.punch.apps.shiva.worker.impl.PlanWorkerApplication

T

taskShouldRunNow() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: An application must start only if : it must run all the time, it must run once and has never be executed yet, or if it is periodic and it's time to fire it.
threadApplicationStarted() - Method in class org.thales.punch.apps.shiva.worker.impl.ApplicationPlatformReporter
threadPool - Static variable in class org.thales.punch.apps.shiva.Main
tick() - Method in interface org.thales.punch.apps.shiva.IWorker: Make the worker check its application.
tick() - Method in class org.thales.punch.apps.shiva.worker.impl.WorkerImpl: Let the worker check for all tasks.
toString() - Method in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication
truncate(String, int) - Static method in class org.thales.punch.apps.shiva.worker.impl.ApplicationStdIoCallback

U

updateAssignement(ISettingsMap) - Method in interface org.thales.punch.apps.shiva.IWorker: Update the assignments associated to a worker.
updateAssignement(ISettingsMap) - Method in class org.thales.punch.apps.shiva.worker.impl.WorkerImpl: WATCHOUT this code is subtle.

V

valueOf(String) - Static method in enum org.thales.punch.apps.shiva.worker.impl.ApplicationStdIoCallback.IO: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.thales.punch.apps.shiva.worker.impl.ApplicationStdIoCallback.IO: Returns an array containing the constants of this enum type, in the order they are declared.

W

WorkerApplicationEnvironmentUtil - Class in org.thales.punch.apps.shiva.worker.utils
WorkerApplicationEnvironmentUtil() - Constructor for class org.thales.punch.apps.shiva.worker.utils.WorkerApplicationEnvironmentUtil
WorkerDescriptor - Class in org.thales.punch.apps.shiva.leader.impl: A simple class to represent a worker from the leader point of view.
WorkerDescriptor(String, List<String>) - Constructor for class org.thales.punch.apps.shiva.leader.impl.WorkerDescriptor: Ctor.
workerId - Variable in class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication: our worker identifier, used to properly log task traces to elasticsearch
WorkerImpl - Class in org.thales.punch.apps.shiva.worker.impl: IWorker implementation.
WorkerImpl(String, Path, String, List<String>, boolean) - Constructor for class org.thales.punch.apps.shiva.worker.impl.WorkerImpl: Create a new worker.
WorkerUtil - Class in org.thales.punch.apps.shiva.worker.utils

A B C D E F G H I K L M N O P R S T U V W