Force connection close with token discovery

Signed-off-by: Pierre Wacrenier <pierre.wacrenier@gmail.com>
This commit is contained in:
Pierre Wacrenier 2015-02-01 05:48:30 +01:00
parent 85fa8d4291
commit e3bf42d5be
1 changed files with 6 additions and 1 deletions

View File

@ -87,8 +87,11 @@ func (s *TokenDiscoveryService) Watch(callback discovery.WatchCallback) {
func (s *TokenDiscoveryService) Register(addr string) error { func (s *TokenDiscoveryService) Register(addr string) error {
buf := strings.NewReader(addr) buf := strings.NewReader(addr)
_, err := http.Post(fmt.Sprintf("%s/%s/%s", s.url, resp, err := http.Post(fmt.Sprintf("%s/%s/%s", s.url,
"clusters", s.token), "application/json", buf) "clusters", s.token), "application/json", buf)
// Force connection close
resp.Body.Close()
return err return err
} }
@ -98,6 +101,8 @@ func (s *TokenDiscoveryService) CreateCluster() (string, error) {
if err != nil { if err != nil {
return "", err return "", err
} }
defer resp.Body.Close()
token, err := ioutil.ReadAll(resp.Body) token, err := ioutil.ReadAll(resp.Body)
return string(token), err return string(token), err
} }