| 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.leader.impl | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
Main.startFilesystemLeader(String root,
                     ILeader leader,
                     long tickInterval)  | 
void | 
IController.startLeader(ILeader leader,
           long tickInterval)  | 
static void | 
Main.startLeader(String kafkaUrl,
           ILeader leader,
           long tickInterval)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
FilesystemController.startLeader(ILeader leader,
           long tickInterval)
The leader is started in a dedicated thread but every time it vanishes,
 it is restarted from a fresh new state. 
 | 
| Constructor and Description | 
|---|
FilesystemLeaderController(File rootFolder,
                          String commandTopic,
                          String controlTopic,
                          String assignementTopic,
                          ILeader leader,
                          long tickInterval)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaTopicController.startLeader(ILeader leader,
           long tickInterval)
The leader is started in a dedicated thread but every time it vanishes,
 it is restarted from a fresh new state. 
 | 
| Constructor and Description | 
|---|
KafkaLeaderController(String bootstrapServers,
                     org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer,
                     String clusterName,
                     String commandTopic,
                     String assignementTopic,
                     String controlTopic,
                     ILeader leader,
                     long tickInterval,
                     org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStore)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LeaderImpl
This class is told upon new arrival and departure of new tasks and workers. 
 | 
Copyright © 2022. All rights reserved.