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