| 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.