kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-01 16:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

e2e/framework: add consul and vault client detection

Browse Source
This commit is contained in:
Nick Ethier
2018-06-28 22:58:57 -04:00
parent cb9e1e14a4
commit 7c224cf766
1 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
e2e/framework/provisioner.go
View File

@@ -43,20 +43,33 @@ func (p *singleClusterProvisioner) ProvisionCluster(opts ProvisionerOptions) (*C
ID: hex.EncodeToString(h.Sum(nil))[:8],
Name: opts.Name,
}
nomadAddr := os.Getenv("NOMAD_ADDR")
if len(nomadAddr) == 0 {
if len(os.Getenv("NOMAD_ADDR")) == 0 {
return nil, fmt.Errorf("environment variable NOMAD_ADDR not set")
}
nomadConfig := napi.DefaultConfig()
nomadConfig.Address = nomadAddr
nomadClient, err := napi.NewClient(nomadConfig)
nomadClient, err := napi.NewClient(napi.DefaultConfig())
if err != nil {
return nil, err
}
info.NomadClient = nomadClient
if len(os.Getenv(capi.HTTPAddrEnvName)) != 0 {
consulClient, err := capi.NewClient(capi.DefaultConfig())
if err != nil {
return nil, err
}
info.ConsulClient = consulClient
}
if len(os.Getenv(vapi.EnvVaultAddress)) != 0 {
vaultClient, err := vapi.NewClient(vapi.DefaultConfig())
if err != nil {
return nil, err
}
info.VaultClient = vaultClient
}
return info, err
}