doc.go

/*
Package clusters provides information and interaction with the clusters through
the OpenStack Clustering service.

Example to Create a Cluster

	createOpts := clusters.CreateOpts{
		Name:            "test-cluster",
		DesiredCapacity: 1,
		ProfileID:       "b7b870ee-d3c5-4a93-b9d7-846c53b2c2da",
	}

	cluster, err := clusters.Create(context.TODO(), serviceClient, createOpts).Extract()
	if err != nil {
		panic(err)
	}

Example to Get a Cluster

	clusterName := "cluster123"
	cluster, err := clusters.Get(context.TODO(), serviceClient, clusterName).Extract()
	if err != nil {
		panic(err)
	}
	fmt.Printf("%+v\n", cluster)

Example to List Clusters

	listOpts := clusters.ListOpts{
		Name: "testcluster",
	}

	allPages, err := clusters.List(serviceClient, listOpts).AllPages(context.TODO())
	if err != nil {
		panic(err)
	}

	allClusters, err := clusters.ExtractClusters(allPages)
	if err != nil {
		panic(err)
	}

	for _, cluster := range allClusters {
		fmt.Printf("%+v\n", cluster)
	}

Example to Update a Cluster

	updateOpts := clusters.UpdateOpts{
		Name:       "testcluster",
		ProfileID:  "b7b870ee-d3c5-4a93-b9d7-846c53b2c2da",
	}

	clusterID := "7d85f602-a948-4a30-afd4-e84f47471c15"
	cluster, err := clusters.Update(context.TODO(), serviceClient, clusterName, opts).Extract()
	if err != nil {
		panic(err)
	}
	fmt.Printf("%+v\n", cluster)

Example to Delete a Cluster

	clusterID := "dc6d336e3fc4c0a951b5698cd1236ee"
	err := clusters.Delete(context.TODO(), serviceClient, clusterID).ExtractErr()
	if err != nil {
		panic(err)
	}

Example to Resize a Cluster

	number := 1
	maxSize := 5
	minSize := 1
	minStep := 1
	strict := true

	resizeOpts := clusters.ResizeOpts{
		AdjustmentType: clusters.ChangeInCapacityAdjustment,
		Number:         number,
		MaxSize:        &maxSize,
		MinSize:        &minSize,
		MinStep:        &minStep,
		Strict:         &strict,
	}

	actionID, err := clusters.Resize(context.TODO(), client, clusterName, resizeOpts).Extract()
	if err != nil {
		t.Fatalf("Unable to resize cluster: %v", err)
	}
	fmt.Println("Resize actionID", actionID)

Example to ScaleIn a Cluster

	count := 2
	scaleInOpts := clusters.ScaleInOpts{
		Count: &count,
	}
	clusterID:  "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"

	action, err := clusters.ScaleIn(context.TODO(), computeClient, clusterID, scaleInOpts).Extract()
	if err != nil {
		panic(err)
	}

Example to ScaleOut a cluster

	scaleOutOpts := clusters.ScaleOutOpts{
		Count: 2,
	}
	clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"

	actionID, err := clusters.ScaleOut(context.TODO(), computeClient, clusterID, scaleOutOpts).Extract()
	if err != nil {
		panic(err)
	}

Example to List Policies for a Cluster

	clusterID := "7d85f602-a948-4a30-afd4-e84f47471c15"
	allPages, err := clusters.ListPolicies(serviceClient, clusterID, nil).AllPages(context.TODO())
	if err != nil {
		panic(err)
	}

	allClusterPolicies, err := clusters.ExtractClusterPolicies(allPages)
	if err != nil {
		panic(err)
	}

	for _, clusterPolicy := range allClusterPolicies {
		fmt.Printf("%+v\n", clusterPolicy)
	}

Example to Get a Cluster Policy

	clusterID := "7d85f602-a948-4a30-afd4-e84f47471c15"
	profileID := "714fe676-a08f-4196-b7af-61d52eeded15"
	clusterPolicy, err := clusterpolicies.Get(serviceCLient, clusterID, profileID).Extract()
	if err != nil {
		panic(err)
	}

	fmt.Printf("%+v\n", clusterPolicy)

Example to Attach a Policy to a Cluster

	enabled := true
	attachPolicyOpts := clusters.AttachPolicyOpts{
		PolicyID: "policy-123",
		Enabled:  &enabled,
	}

	clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	actionID, err := clusters.AttachPolicy(context.TODO(), serviceClient, clusterID, attachPolicyOpts).Extract()
	if err != nil {
		panic(err)
	}

	fmt.Println("Attach Policy actionID", actionID)

Example to Detach a Policy to Cluster

	detachpolicyOpts := clusters.DetachPolicyOpts{
		PolicyID: "policy-123",
	}

	clusterID :=  "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	actionID, err := clusters.DetachPolicy(context.TODO(), serviceClient, clusterID, detachpolicyOpts).Extract()
	if err != nil {
		panic(err)
	}

	fmt.Println("Update Policy actionID", actionID)

Example to Update a Policy to a Cluster

	enabled := true
	updatePolicyOpts := clusters.UpdatePolicyOpts{
		PolicyID: "policy-123",
		Enabled:  &enabled,
	}

	clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	actionID, err := clusters.UpdatePolicy(context.TODO(), serviceClient, clusterID, updatePolicyOpts).Extract()
	if err != nil {
		panic(err)
	}

	fmt.Println("Attach Policy actionID", actionID)

Example to Recover a Cluster

	check := true
	checkCapacity := true
	recoverOpts := clusters.RecoverOpts{
		Operation:     clusters.RebuildRecovery,
		Check:         &check,
		CheckCapacity: &checkCapacity,
	}

	clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	actionID, err := clusters.Recover(context.TODO(), computeClient, clusterID, recoverOpts).Extract()
	if err != nil {
		panic(err)
	}
	fmt.Println("action=", actionID)

Example to Check a Cluster

	clusterID :=  "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	action, err := clusters.Check(context.TODO(), computeClient, clusterID).Extract()
	if err != nil {
		panic(err)
	}

Example to Complete Life Cycle

	clusterID :=  "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	lifecycleOpts := clusters.CompleteLifecycleOpts{LifecycleActionTokenID: "2b827124-69e1-496e-9484-33ca769fe4df"}

	action, err := clusters.CompleteLifecycle(context.TODO(), computeClient, clusterID, lifecycleOpts).Extract()
	if err != nil {
		panic(err)
	}

Example to add nodes to a cluster

		addNodesOpts := clusters.AddNodesOpts{
			Nodes: []string{"node-123"},
		}
		clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
		actionID, err := clusters.AddNodes(context.TODO(), serviceClient, clusterID, addNodesOpts).Extract()
		if err != nil {
			panic(err)
		}
	    fmt.Println("action=", actionID)

Example to remove nodes from a cluster

	removeNodesOpts := clusters.RemoveNodesOpts{
		Nodes: []string{"node-123"},
	}
	clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	err := clusters.RemoveNodes(context.TODO(), serviceClient, clusterID, removeNodesOpts).ExtractErr()
	if err != nil {
		panic(err)
	}

Example to replace nodes for a cluster

	replaceNodesOpts := clusters.ReplaceNodesOpts{
		Nodes: map[string]string{"node-1234": "node-5678"},
	}
	clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	actionID, err := clusters.ReplaceNodes(context.TODO(), serviceClient, clusterID, replaceNodesOpts).Extract()
	if err != nil {
		panic(err)
	}

Example to collect node attributes across a cluster

	serviceClient.Microversion = "1.2"
	clusterID := "b7b870e3-d3c5-4a93-b9d7-846c53b2c2da"
	opts := clusters.CollectOpts{
		Path: "status",
	}
	attrs, err := clusters.Collect(context.TODO(), serviceClient, clusterID, opts).Extract()
	if err != nil {
		panic(err)
	}

Example to perform an operation on a cluster

	serviceClient.Microversion = "1.4"
	clusterID := "cluster123"
	operationOpts := clusters.OperationOpts{
		Operation: clusters.RebootOperation,
		Filters:   clusters.OperationFilters{"role": "slave"},
		Params:    clusters.OperationParams{"type": "SOFT"},
	}
	actionID, err := clusters.Ops(context.TODO(), serviceClient, clusterID, operationOpts).Extract()
	if err != nil {
		panic(err)
	}
*/
package clusters