Partial progress on ClusterState

[AhmedSoliman]

Partial progress on ClusterState

ClusterState is a new data structure maintained by ClusterController. ClusterState is established by a scatter-gather request (GetProcessorsState) to all workers. For every worker, partition processor manager is the entity responsible for responding to GetProcessorsState requests, it keeps taps on running partition processors via a set of tokio watches.

This PR is a snapshot in time of progress done on this component, this is far from complete but it's best to merge the current progress until we circle back to it in a week or two.

---

Stack created with Sapling. Best reviewed with ReviewStack.

• -> #1514
• #1500
• #1511

[github-actions[bot]]

Test Results

 99 files  ±0   99 suites  ±0   8m 27s :stopwatch: -13s  84 tests ±0   82 :white_check_mark: ±0  2 :zzz: ±0  0 :x: ±0  215 runs   - 1  209 :white_check_mark:  - 1  6 :zzz: ±0  0 :x: ±0 

Results for commit 55d7f038. ± Comparison against base commit ab3c57e5.

This pull request removes 1 and adds 1 tests. Note that renamed tests count towards both.

dev.restate.e2e.JavaWorkflowAPITest ‑ Workflow cannot be submitted more than once

dev.restate.e2e.runtime.IngressTest ‑ Idempotent send then attach/getOutput

:recycle: This comment has been updated with latest results.