fa0bbc42fe
* Update worker to let it inject checkpointer and kinesis Add two functions to inject checkpointer and kinesis for custom implementation or adding mock for unit test. This change also remove the worker_custom.go since it is no longer needed. Test: Update the integration tests to cover newly added functions. Signed-off-by: Tao Jiang <taoj@vmware.com> * Fix typo on the test function Signed-off-by: Tao Jiang <taoj@vmware.com> |
||
|---|---|---|
| .. | ||
| checkpoint | ||
| common | ||
| config | ||
| interfaces | ||
| metrics | ||
| partition | ||
| utils | ||
| worker | ||