main.go

# Flocker go library examples

package main

import (
        "encoding/json"
        flockerApi "github.com/simonswine/flocker-go"
        "log"
)


func main() {
        log.Printf("test123")
        c, err := flockerApi.NewClient("control-service", 4523, "172.20.131.33", "/host/etc/flocker/cluster.crt", "/host/etc/flocker/kubelet.key", "/host/etc/flocker/kubelet.crt")
        if err != nil {
                log.Fatal(err)
        }
        log.Printf("client %v", c)

        createOptions := &flockerApi.CreateDatasetOptions{
                Metadata: map[string]string{
                        "type": "k8s-dynamic-prov",
                },
        }

        b, err := json.Marshal(createOptions)
        if err != nil {
                log.Fatal(err)
        }
        log.Printf("json %s", string(b))

        datasetState, err := c.CreateDS(createOptions)
        if err != nil {
                log.Fatal(err)
        }

        log.Printf("dataset %v", datasetState)


        err = c.DeleteDataset("b4bc013d-5d0b-450a-a2df-b62042562f04")
        if err != nil {
                log.Fatal(err)
        }

}
ip-