public interface IController
Underlying shiva support kafka or filesystem based controllers. The term controller means here something in charge of handling the read/write of the protocol between works, leader and cli.
Modifier and Type | Method and Description |
---|---|
void |
startLeader(ILeader leader,
long tickInterval) |
void |
startWorker(IWorker worker,
long tickInterval)
Start the worker controler
|
void startLeader(ILeader leader, long tickInterval)
leader
- the leadertickInterval
- the refresh intervalvoid startWorker(IWorker worker, long tickInterval)
leader
- the leadertickInterval
- the refresh intervalCopyright © 2022. All rights reserved.