| Class | Description |
|---|---|
| FilesystemController |
This class has only one purpose : share the same producer between the worker and the leader.
|
| FilesystemLeaderController |
This class takes care of the kafka gossip exchange required by the leader.
|
| FilesystemWorkerController |
File system based worker controller.
|
| FolderMonitor |
On single node, a plain filesystem is good enough to completly emulate the protocol required bewteen clients and shiva daemons. Each "topic" corresponds to a file. Each is overwritten each time a command is submitted or whenver the leader (thread) must signal something to the worker (thread).
Our design has not consisted in implementing a different leader worker logic. These stays exactly the same. Instead we have emulated the Kafka topics using plain files.
Copyright © 2022. All rights reserved.