Skip to content

Commit

Permalink
fix review
Browse files Browse the repository at this point in the history
  • Loading branch information
juliens authored and traefiker committed Jul 11, 2018
1 parent 33dd539 commit 31250e7
Show file tree
Hide file tree
Showing 6 changed files with 10 additions and 0 deletions.
2 changes: 2 additions & 0 deletions provider/boltdb/boltdb.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,12 @@ func (p *Provider) Init(constraints types.Constraints) error {
if err != nil {
return err
}

store, err := p.CreateStore()
if err != nil {
return fmt.Errorf("failed to Connect to KV store: %v", err)
}

p.SetKVClient(store)
return nil
}
Expand Down
2 changes: 2 additions & 0 deletions provider/consul/consul.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,12 @@ func (p *Provider) Init(constraints types.Constraints) error {
if err != nil {
return err
}

store, err := p.CreateStore()
if err != nil {
return fmt.Errorf("failed to Connect to KV store: %v", err)
}

p.SetKVClient(store)
return nil
}
Expand Down
1 change: 1 addition & 0 deletions provider/consulcatalog/consul_catalog.go
Original file line number Diff line number Diff line change
Expand Up @@ -95,6 +95,7 @@ func (p *Provider) Init(constraints types.Constraints) error {
if err != nil {
return err
}

client, err := p.createClient()
if err != nil {
return err
Expand Down
1 change: 1 addition & 0 deletions provider/ecs/ecs.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ func (p *Provider) createClient() (*awsClient, error) {
if err != nil {
return nil, err
}

ec2meta := ec2metadata.New(sess)
if p.Region == "" {
log.Infoln("No EC2 region provided, querying instance metadata endpoint...")
Expand Down
2 changes: 2 additions & 0 deletions provider/etcd/etcd.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,10 +27,12 @@ func (p *Provider) Init(constraints types.Constraints) error {
if err != nil {
return err
}

store, err := p.CreateStore()
if err != nil {
return fmt.Errorf("failed to Connect to KV store: %v", err)
}

p.SetKVClient(store)
return nil
}
Expand Down
2 changes: 2 additions & 0 deletions provider/zk/zk.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,12 @@ func (p *Provider) Init(constraints types.Constraints) error {
if err != nil {
return err
}

store, err := p.CreateStore()
if err != nil {
return fmt.Errorf("failed to Connect to KV store: %v", err)
}

p.SetKVClient(store)
return nil
}
Expand Down

0 comments on commit 31250e7

Please sign in to comment.