Uses of Interface
org.thales.punch.apps.shiva.IWorker

Packages that use IWorker

Package	Description
org.thales.punch.apps.shiva	Shiva Punch Scheduler
org.thales.punch.apps.shiva.filesystem	Punch Filesystem Protocol Design
org.thales.punch.apps.shiva.kafka	Shiva Worker logic
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.

Uses of IWorker in org.thales.punch.apps.shiva

Methods in org.thales.punch.apps.shiva with parameters of type IWorker

Modifier and Type	Method and Description
static void	Main.startFilesystemWorker(String root, IWorker worker, long tickInterval)
void	IController.startWorker(IWorker worker, long tickInterval) Start the worker controler
static void	Main.startWorker(String kafkaUrl, IWorker worker, long tickInterval)

Uses of IWorker in org.thales.punch.apps.shiva.filesystem

Methods in org.thales.punch.apps.shiva.filesystem with parameters of type IWorker

Modifier and Type	Method and Description
void	FilesystemController.startWorker(IWorker worker, long tickInterval) A worker is started only once and is not supposed to vanish ever.

Constructors in org.thales.punch.apps.shiva.filesystem with parameters of type IWorker

Constructor and Description
FilesystemWorkerController(File rootFolder, String controlTopic, String assignementTopic, IWorker worker, long tickInterval)

Uses of IWorker in org.thales.punch.apps.shiva.kafka

Methods in org.thales.punch.apps.shiva.kafka with parameters of type IWorker

Modifier and Type	Method and Description
void	KafkaTopicController.startWorker(IWorker worker, long tickInterval) A worker is started only once and is not supposed to vanish ever.

Constructors in org.thales.punch.apps.shiva.kafka with parameters of type IWorker

Constructor and Description
KafkaWorkerController(String bootstrapServers, org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer, String clusterName, String commandTopic, String assignementTopic, String controlTopic, IWorker worker, long tickInterval, org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)
KafkaWorkerControlPlaneController(org.thales.punch.kafka.api.KafkaContinuousConsumerBuilder<String,byte[]> consumerBuilder, org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer, String controlTopic, IWorker worker)

Uses of IWorker in org.thales.punch.apps.shiva.worker.impl

Classes in org.thales.punch.apps.shiva.worker.impl that implement IWorker

Modifier and Type	Class and Description
class	WorkerImpl IWorker implementation.