9187: Refactor dispatcher support into common library and update to use Locking API.
authorPeter Amstutz <peter.amstutz@curoverse.com>
Thu, 19 May 2016 18:12:42 +0000 (14:12 -0400)
committerPeter Amstutz <peter.amstutz@curoverse.com>
Thu, 26 May 2016 20:11:51 +0000 (16:11 -0400)
commit4153cb6cfad920ed0b1a4b818d3bcc8de492d134
treead1ea792fd434121aaef264e04309a51d2f0bdb4
parent0c5e684422234d62870b3c06b9e1014988878099
9187: Refactor dispatcher support into common library and update to use Locking API.

New dispatcher package in Go SDK provides framework for monitoring list of
queued/locked/running containers.  Try to lock containers in the queue; locked
or running containers are passed to RunContainer goroutine supplied by the
specific dispatcher.  Refactor existing dispatchers (-local and -slurm) to use
this framework.  Dispatchers have crash recovery behavior, can put containers
which are unaccounted in cancelled state.
sdk/go/dispatch/dispatch.go [new file with mode: 0644]
services/crunch-dispatch-local/crunch-dispatch-local.go
services/crunch-dispatch-local/crunch-dispatch-local_test.go
services/crunch-dispatch-slurm/crunch-dispatch-slurm.go
services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go