7a8cacc9ec
The current implementation for the task coordinator unblocks tasks by performing destructive operations over its internal state (like closing channels and deleting maps from keys). This presents a problem in situations where we would like to revert the state of a task, such as when restarting an allocation with tasks that have already exited. With this new implementation the task coordinator behaves more like a finite state machine where task may be blocked/unblocked multiple times by performing a state transition. This initial part of the work only refactors the task coordinator and is functionally equivalent to the previous implementation. Future work will build upon this to provide bug fixes and enhancements. |
||
|---|---|---|
| .. | ||
| acl_testing.go | ||
| catalog_testing.go | ||
| check_watcher.go | ||
| check_watcher_test.go | ||
| config_entries_testing.go | ||
| connect.go | ||
| connect_proxies.go | ||
| connect_proxies_test.go | ||
| connect_proxies_testing.go | ||
| connect_test.go | ||
| group_test.go | ||
| int_test.go | ||
| namespaces_client.go | ||
| namespaces_client_test.go | ||
| self.go | ||
| self_test.go | ||
| service_client.go | ||
| service_client_test.go | ||
| structs.go | ||
| testing.go | ||
| unit_test.go | ||
| version_checker.go | ||
| version_checker_test.go | ||