Fixed kubeconfig reading
This commit is contained in:
@@ -124,6 +124,9 @@ func resourceK8sCreate(d *schema.ResourceData, m interface{}) error {
|
|||||||
urlValues = &url.Values{}
|
urlValues = &url.Values{}
|
||||||
urlValues.Add("k8sId", d.Id())
|
urlValues.Add("k8sId", d.Id())
|
||||||
kubeconfig, err := controller.decortAPICall("POST", K8sGetConfigAPI, urlValues)
|
kubeconfig, err := controller.decortAPICall("POST", K8sGetConfigAPI, urlValues)
|
||||||
|
if err != nil {
|
||||||
|
log.Warnf("could not get kubeconfig: %v", err)
|
||||||
|
}
|
||||||
d.Set("kubeconfig", kubeconfig)
|
d.Set("kubeconfig", kubeconfig)
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
@@ -146,6 +149,15 @@ func resourceK8sRead(d *schema.ResourceData, m interface{}) error {
|
|||||||
d.Set("workers", nodeToResource(k8s.Groups.Workers[0]))
|
d.Set("workers", nodeToResource(k8s.Groups.Workers[0]))
|
||||||
d.Set("default_wg_id", k8s.Groups.Workers[0].ID)
|
d.Set("default_wg_id", k8s.Groups.Workers[0].ID)
|
||||||
|
|
||||||
|
controller := m.(*ControllerCfg)
|
||||||
|
urlValues := &url.Values{}
|
||||||
|
urlValues.Add("k8sId", d.Id())
|
||||||
|
kubeconfig, err := controller.decortAPICall("POST", K8sGetConfigAPI, urlValues)
|
||||||
|
if err != nil {
|
||||||
|
log.Warnf("could not get kubeconfig: %v", err)
|
||||||
|
}
|
||||||
|
d.Set("kubeconfig", kubeconfig)
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user