Check-in the karbon stubs (#14)

Move over karbon stubs from nutanix/terraform-provider-nutanix.

Author: thunderboltsid

CHANGELOG.md

@@ -8,6 +8,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Added
 - Add the fc stubs from nutanix/terraform-provider-nutanix
 - Add the foundation stubs from nutanix/terraform-provider-nutanix
+- Add the karbon stubs from nutanix/terraform-provider-nutanix
 
 ### Changed
 - Updated the http client with the latest from github.com/nutanix/terraform-provider-nutanix

Makefile

@@ -7,5 +7,6 @@ build:
 test:
 		go test -v pkg/nutanix/fc/*.go
 		go test -v pkg/nutanix/foundation/*.go
+		go test -v pkg/nutanix/karbon/*.go
 		go test -v pkg/nutanix/v3/*.go
 		go test -v pkg/nutanix/*.go  

pkg/nutanix/karbon/karbon_api.go

@@ -0,0 +1,55 @@
+package karbon
+
+import (
+	"fmt"
+	"strings"
+
+	client "github.com/nutanix-cloud-native/prism-go-client/pkg/nutanix"
+)
+
+const (
+	absolutePath = "karbon"
+	userAgent    = "nutanix"
+	clientName   = "karbon"
+)
+
+// Client manages the V3 API
+type Client struct {
+	client          *client.Client
+	Cluster         ClusterService
+	PrivateRegistry PrivateRegistryService
+	Meta            MetaService
+}
+
+// NewKarbonAPIClient return a client to operate Karbon resources
+func NewKarbonAPIClient(credentials client.Credentials) (*Client, error) {
+	var baseClient *client.Client
+
+	// check if all required fields are present. Else create an empty client
+	if credentials.Username != "" && credentials.Password != "" && credentials.Endpoint != "" {
+		c, err := client.NewClient(&credentials, userAgent, absolutePath, false)
+		if err != nil {
+			return nil, err
+		}
+		baseClient = c
+	} else {
+		errorMsg := fmt.Sprintf("karbon Client is missing. "+
+			"Please provide required details - %s in provider configuration.", strings.Join(credentials.RequiredFields[clientName], ", "))
+		baseClient = &client.Client{UserAgent: userAgent, ErrorMsg: errorMsg}
+	}
+
+	f := &Client{
+		client: baseClient,
+		Cluster: ClusterOperations{
+			client: baseClient,
+		},
+		PrivateRegistry: PrivateRegistryOperations{
+			client: baseClient,
+		},
+		Meta: MetaOperations{
+			client: baseClient,
+		},
+	}
+
+	return f, nil
+}

pkg/nutanix/karbon/karbon_api_test.go

@@ -0,0 +1,43 @@
+package karbon
+
+import (
+	"testing"
+
+	client "github.com/nutanix-cloud-native/prism-go-client/pkg/nutanix"
+)
+
+func TestNewKarbonAPIClient(t *testing.T) {
+	// verifies positive client creation
+	cred := client.Credentials{
+		URL:                "foo.com",
+		Username:           "username",
+		Password:           "password",
+		Port:               "",
+		Endpoint:           "0.0.0.0",
+		Insecure:           true,
+		FoundationEndpoint: "10.0.0.0",
+		FoundationPort:     "8000",
+		RequiredFields:     nil,
+	}
+	_, err := NewKarbonAPIClient(cred)
+	if err != nil {
+		t.Errorf(err.Error())
+	}
+
+	// verify missing client scenario
+	cred2 := client.Credentials{
+		URL:      "foo.com",
+		Insecure: true,
+		RequiredFields: map[string][]string{
+			"karbon": {"username", "password", "endpoint"},
+		},
+	}
+	v3Client2, err2 := NewKarbonAPIClient(cred2)
+	if err2 != nil {
+		t.Errorf(err2.Error())
+	}
+
+	if v3Client2.client.ErrorMsg == "" {
+		t.Errorf("NewKarbonAPIClient(%v) expected the base client in karbon client to have some error message", cred2)
+	}
+}

pkg/nutanix/karbon/karbon_cluster_service.go

@@ -0,0 +1,203 @@
+package karbon
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+
+	client "github.com/nutanix-cloud-native/prism-go-client/pkg/nutanix"
+)
+
+// ClusterOperations ...
+type ClusterOperations struct {
+	client *client.Client
+}
+
+// Service ...
+type ClusterService interface {
+	// karbon v2.1
+	ListKarbonClusters() (*ClusterListIntentResponse, error)
+	CreateKarbonCluster(createRequest *ClusterIntentInput) (*ClusterActionResponse, error)
+	GetKarbonCluster(karbonClusterName string) (*ClusterIntentResponse, error)
+	GetKarbonClusterNodePool(karbonClusterName string, nodePoolName string) (*ClusterNodePool, error)
+	DeleteKarbonCluster(karbonClusterName string) (*ClusterActionResponse, error)
+	GetKubeConfigForKarbonCluster(karbonClusterName string) (*ClusterKubeconfigResponse, error)
+	GetSSHConfigForKarbonCluster(karbonClusterName string) (*ClusterSSHconfig, error)
+	ScaleUpKarbonCluster(karbonClusterName, karbonNodepoolName string, scaleUpRequest *ClusterScaleUpIntentInput) (*ClusterActionResponse, error)
+	ScaleDownKarbonCluster(karbonClusterName, karbonNodepoolName string, scaleDownRequest *ClusterScaleDownIntentInput) (*ClusterActionResponse, error)
+	// registries
+	ListPrivateRegistries(karbonClusterName string) (*PrivateRegistryListResponse, error)
+	AddPrivateRegistry(karbonClusterName string, createRequest PrivateRegistryOperationIntentInput) (*PrivateRegistryResponse, error)
+	DeletePrivateRegistry(karbonClusterName string, privateRegistryName string) (*PrivateRegistryOperationResponse, error)
+}
+
+// karbon 2.1
+func (op ClusterOperations) ListKarbonClusters() (*ClusterListIntentResponse, error) {
+	ctx := context.TODO()
+	path := "/v1-beta.1/k8s/clusters"
+	req, err := op.client.NewRequest(ctx, http.MethodGet, path, nil)
+	karbonClusterListIntentResponse := new(ClusterListIntentResponse)
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterListIntentResponse, op.client.Do(ctx, req, karbonClusterListIntentResponse)
+}
+
+func (op ClusterOperations) CreateKarbonCluster(createRequest *ClusterIntentInput) (*ClusterActionResponse, error) {
+	ctx := context.TODO()
+
+	path := "/v1/k8s/clusters"
+	req, err := op.client.NewRequest(ctx, http.MethodPost, path, createRequest)
+	karbonClusterActionResponse := new(ClusterActionResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterActionResponse, op.client.Do(ctx, req, karbonClusterActionResponse)
+}
+
+func (op ClusterOperations) GetKarbonCluster(name string) (*ClusterIntentResponse, error) {
+	ctx := context.TODO()
+
+	path := fmt.Sprintf("/v1/k8s/clusters/%s", name)
+	req, err := op.client.NewRequest(ctx, http.MethodGet, path, nil)
+	karbonClusterIntentResponse := new(ClusterIntentResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterIntentResponse, op.client.Do(ctx, req, karbonClusterIntentResponse)
+}
+
+func (op ClusterOperations) GetKarbonClusterNodePool(name string, nodePoolName string) (*ClusterNodePool, error) {
+	ctx := context.TODO()
+
+	path := fmt.Sprintf("/v1-beta.1/k8s/clusters/%s/node-pools/%s", name, nodePoolName)
+
+	req, err := op.client.NewRequest(ctx, http.MethodGet, path, nil)
+	karbonClusterNodePool := new(ClusterNodePool)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterNodePool, op.client.Do(ctx, req, karbonClusterNodePool)
+}
+
+func (op ClusterOperations) DeleteKarbonCluster(name string) (*ClusterActionResponse, error) {
+	ctx := context.TODO()
+
+	path := fmt.Sprintf("/v1/k8s/clusters/%s", name)
+
+	req, err := op.client.NewRequest(ctx, http.MethodDelete, path, nil)
+	karbonClusterActionResponse := new(ClusterActionResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterActionResponse, op.client.Do(ctx, req, karbonClusterActionResponse)
+}
+
+func (op ClusterOperations) GetKubeConfigForKarbonCluster(name string) (*ClusterKubeconfigResponse, error) {
+	ctx := context.TODO()
+
+	path := fmt.Sprintf("/v1/k8s/clusters/%s/kubeconfig", name)
+
+	req, err := op.client.NewRequest(ctx, http.MethodGet, path, nil)
+	karbonClusterKubeconfigResponse := new(ClusterKubeconfigResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterKubeconfigResponse, op.client.Do(ctx, req, karbonClusterKubeconfigResponse)
+}
+
+func (op ClusterOperations) GetSSHConfigForKarbonCluster(name string) (*ClusterSSHconfig, error) {
+	ctx := context.TODO()
+
+	path := fmt.Sprintf("/v1/k8s/clusters/%s/ssh", name)
+
+	req, err := op.client.NewRequest(ctx, http.MethodGet, path, nil)
+	karbonClusterSSHconfig := new(ClusterSSHconfig)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterSSHconfig, op.client.Do(ctx, req, karbonClusterSSHconfig)
+}
+
+func (op ClusterOperations) ListPrivateRegistries(karbonClusterName string) (*PrivateRegistryListResponse, error) {
+	ctx := context.TODO()
+	path := fmt.Sprintf("/v1-alpha.1/k8s/clusters/%s/registries", karbonClusterName)
+
+	req, err := op.client.NewRequest(ctx, http.MethodGet, path, nil)
+	karbonPrivateRegistryListResponse := new(PrivateRegistryListResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonPrivateRegistryListResponse, op.client.Do(ctx, req, karbonPrivateRegistryListResponse)
+}
+
+func (op ClusterOperations) AddPrivateRegistry(karbonClusterName string, createRequest PrivateRegistryOperationIntentInput) (*PrivateRegistryResponse, error) {
+	ctx := context.TODO()
+	path := fmt.Sprintf("/v1-alpha.1/k8s/clusters/%s/registries", karbonClusterName)
+
+	req, err := op.client.NewRequest(ctx, http.MethodPost, path, createRequest)
+	karbonPrivateRegistryResponse := new(PrivateRegistryResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonPrivateRegistryResponse, op.client.Do(ctx, req, karbonPrivateRegistryResponse)
+}
+
+func (op ClusterOperations) DeletePrivateRegistry(karbonClusterName string, privateRegistryName string) (*PrivateRegistryOperationResponse, error) {
+	ctx := context.TODO()
+	path := fmt.Sprintf("/v1-alpha.1/k8s/clusters/%s/registries/%s", karbonClusterName, privateRegistryName)
+
+	req, err := op.client.NewRequest(ctx, http.MethodDelete, path, nil)
+	karbonPrivateRegistryOperationResponse := new(PrivateRegistryOperationResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonPrivateRegistryOperationResponse, op.client.Do(ctx, req, karbonPrivateRegistryOperationResponse)
+}
+
+func (op ClusterOperations) ScaleUpKarbonCluster(karbonClusterName, karbonNodepoolName string, scaleUpRequest *ClusterScaleUpIntentInput) (*ClusterActionResponse, error) {
+	ctx := context.TODO()
+
+	path := fmt.Sprintf("/v1-alpha.1/k8s/clusters/%s/node-pools/%s/add-nodes", karbonClusterName, karbonNodepoolName)
+	req, err := op.client.NewRequest(ctx, http.MethodPost, path, scaleUpRequest)
+	karbonClusterActionResponse := new(ClusterActionResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterActionResponse, op.client.Do(ctx, req, karbonClusterActionResponse)
+}
+
+func (op ClusterOperations) ScaleDownKarbonCluster(karbonClusterName, karbonNodepoolName string, scaleDownRequest *ClusterScaleDownIntentInput) (*ClusterActionResponse, error) {
+	ctx := context.TODO()
+
+	path := fmt.Sprintf("/v1-alpha.1/k8s/clusters/%s/node-pools/%s/remove-nodes", karbonClusterName, karbonNodepoolName)
+	req, err := op.client.NewRequest(ctx, http.MethodPost, path, scaleDownRequest)
+	karbonClusterActionResponse := new(ClusterActionResponse)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return karbonClusterActionResponse, op.client.Do(ctx, req, karbonClusterActionResponse)
+}