Cluster shrink

package main

import (
    "github.com/oceanbase/obshell-sdk-go/services"
)

func main() {
    // Create a client instance. The node address is '10.10.10.1', and the port is 2886.
    // The root@sys password of the cluster is '****'.
    client, err := services.NewClientWithPassword("10.10.10.1", 2886, "****")
    if err != nil {
        panic(err)
    }

    // Remove the node '10.10.10.3:2886' from the cluster.
    req := client.V1().NewScaleInRequest("10.10.10.3", 2886)
    dag, err := client.V1().ScaleInWithRequest(req)
    if err != nil {
        panic(err)
    }

    // Wait for the task to succeed.
    if dag != nil && dag.GenericDTO != nil {
        if _, err = client.V1().WaitDagSucceed(dag.GenericID); err != nil {
            panic(err)
        }
    }
}