Add reaper client to GC containers

- Use reaper client to delete multiple container handles Signed-off-by: Shash Reddy <sreddy@pivotal.io>
SHyx0rmZ · Apr 18, 2018 · bd7423f · bd7423f
1 parent 954d289
commit bd7423f
Show file tree

Hide file tree

Showing 18 changed files with 449 additions and 147 deletions.
diff --git a/db/dbfakes/fake_worker.go b/db/dbfakes/fake_worker.go
diff --git a/db/migration/bindata.go b/db/migration/bindata.go
diff --git a/db/migration/migrations/1523974520_add_worker_reaper_addr.down.sql b/db/migration/migrations/1523974520_add_worker_reaper_addr.down.sql
@@ -0,0 +1,5 @@
+BEGIN;
+
+  ALTER TABLE workers DROP COLUMN reaper_addr;
+
+COMMIT;
diff --git a/db/migration/migrations/1523974520_add_worker_reaper_addr.up.sql b/db/migration/migrations/1523974520_add_worker_reaper_addr.up.sql
@@ -0,0 +1,5 @@
+BEGIN;
+
+  ALTER TABLE workers ADD COLUMN reaper_addr text;
+
+COMMIT;
diff --git a/db/worker.go b/db/worker.go
@@ -32,6 +32,7 @@ type Worker interface {
 	State() WorkerState
 	GardenAddr() *string
 	BaggageclaimURL() *string
+	ReaperAddr() *string
 	CertsPath() *string
 	ResourceCerts() (*UsedWorkerResourceCerts, bool, error)
 	HTTPProxyURL() string
@@ -62,6 +63,7 @@ type worker struct {
 	state            WorkerState
 	gardenAddr       *string
 	baggageclaimURL  *string
+	reaperAddr       *string
 	httpProxyURL     string
 	httpsProxyURL    string
 	noProxy          string
@@ -82,6 +84,7 @@ func (worker *worker) State() WorkerState                      { return worker.s
 func (worker *worker) GardenAddr() *string                     { return worker.gardenAddr }
 func (worker *worker) CertsPath() *string                      { return worker.certsPath }
 func (worker *worker) BaggageclaimURL() *string                { return worker.baggageclaimURL }
+func (worker *worker) ReaperAddr() *string                     { return worker.reaperAddr }
 func (worker *worker) HTTPProxyURL() string                    { return worker.httpProxyURL }
 func (worker *worker) HTTPSProxyURL() string                   { return worker.httpsProxyURL }
 func (worker *worker) NoProxy() string                         { return worker.noProxy }