I had some other ideas on how to do this... let's chat tomorrow, maybe what I'm thinking won't work.

Something you can consider is keeping the synchronous operation and just wrapping the call in a goroutine.

outc := make(chan interface{})
errc := make(chan error)
go func() {
   obj, err := storage.Create(object)
   if err != nil {
      errc <- obj
      return
   }
   objc <- obj
}()
select {
  case obj := <-objc:
        // ...
  case err := <-errc:
        // ...
  case <- time.After(1 * time.Second):
        // ...
}

Ok, I discussed this offline w/ @lavalamp and we came up with the following approach, I added a MakeAsync method that is used by the registries now, this means that individual storage's don't need deal in containers.

Take another look and let me know what you think.

I would have thought the MakeAsync logic would be around the ControllerRegistryStorage methods calls ot in their impl.

The problem with the go routine wrapping the whole thing is that you don't get immediate feedback for validation errors. In this approach, you get an immediate error if the request isn't accepted, and then you get a channel that you can optionally wait on for the result.

Comments addressed, ptal.

Thanks
--brendan

btw, @brendandburns @brendanburns-- I'm working on some changes to cloudcfg, so you don't need to update that.