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.