update provisioner to support consul based storage
Change-Id: Iaa649396d23bbf28a4d99a188c9846aea1310cd0
diff --git a/provisioner/dispatcher.go b/provisioner/dispatcher.go
index bf6ebbf..fed57a4 100644
--- a/provisioner/dispatcher.go
+++ b/provisioner/dispatcher.go
@@ -126,7 +126,13 @@
worker <- work
}()
case update := <-d.StatusChan:
- d.Storage.Put(update.Request.Info.Id, update)
+ err := d.Storage.Put(update.Request.Info.Id, update)
+ if err != nil {
+ log.Printf("[error] Unable to update storage with status for '%s' : %s",
+ update.Request.Info.Id, err)
+ } else {
+ log.Printf("[debug] Storage updated for '%s'", update.Request.Info.Id)
+ }
case <-d.QuitChan:
log.Println("[info] Stopping dispatcher")
return