Merge pull request #12 from codefresh-io/cluster-api

cluster api support

Author: olegz-codefresh

pkg/codefresh/cluster.go

@@ -0,0 +1,56 @@
+package codefresh
+
+import "fmt"
+
+type (
+	IClusterAPI interface {
+		GetClusterCredentialsByAccountId(selector string) (*Cluster, error)
+		GetAccountClusters() ([]*ClusterMinified, error)
+	}
+
+	cluster struct {
+		codefresh Codefresh
+	}
+
+	Cluster struct {
+		Auth struct {
+			Bearer string
+		} `json:"auth"`
+		Ca  string `json:"ca"`
+		Url string `json:"url"`
+	}
+
+	ClusterMinified struct {
+		Cluster struct {
+			Name string `json:"name"`
+		} `json:"cluster"`
+
+		BehindFirewall bool   `json:"behindFirewall"`
+		Selector       string `json:"selector"`
+		Provider       string `json:"provider"`
+	}
+)
+
+func newClusterAPI(codefresh Codefresh) IClusterAPI {
+	return &cluster{codefresh}
+}
+
+func (p *cluster) GetClusterCredentialsByAccountId(selector string) (*Cluster, error) {
+	r := &Cluster{}
+	resp, err := p.codefresh.requestAPI(&requestOptions{
+		path:   fmt.Sprintf("/api/clusters/%s/credentials", selector),
+		method: "GET",
+	})
+	err = p.codefresh.decodeResponseInto(resp, &r)
+	return r, err
+}
+
+func (p *cluster) GetAccountClusters() ([]*ClusterMinified, error) {
+	r := make([]*ClusterMinified, 0)
+	resp, err := p.codefresh.requestAPI(&requestOptions{
+		path:   fmt.Sprintf("/api/clusters"),
+		method: "GET",
+	})
+	err = p.codefresh.decodeResponseInto(resp, &r)
+	return r, err
+}

pkg/codefresh/codefresh.go

@@ -20,6 +20,7 @@ type (
 		RuntimeEnvironments() IRuntimeEnvironmentAPI
 		Workflows() IWorkflowAPI
 		Progresses() IProgressAPI
+		Clusters() IClusterAPI
 	}
 )
 
@@ -56,6 +57,10 @@ func (c *codefresh) Progresses() IProgressAPI {
 	return newProgressAPI(c)
 }
 
+func (c *codefresh) Clusters() IClusterAPI {
+	return newClusterAPI(c)
+}
+
 func (c *codefresh) requestAPI(opt *requestOptions) (*http.Response, error) {
 	var body []byte
 	finalURL := fmt.Sprintf("%s%s", c.host, opt.path)