crd

README

CRD

Once an operator is installed and CRDs are applied, these commands help to verify CRDs are in place.

package main

import (
    "flag"
	"fmt"
	"log"
	"os"
	"path/filepath"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"

	"github.com/banzaicloud/operator-tools/pkg/crd"
)

func main() {
	var kubeconfig *string
	if home := homeDir(); home != "" {
		kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
	} else {
		kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
	}
	flag.Parse()

	config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
	if err != nil {
		log.Fatal(err)
	}
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		log.Fatal(err)
	}

	c := crd.NewCRD(clientset)
	resources, err := c.ListAPIResources(metav1.GroupVersion{
		Group:   "monitoring.coreos.com",
		Version: "v1",
	})
	if err != nil {
		log.Fatal(err)
	}
	for _, resource := range resources {
		fmt.Println(resource.Name)
	}
	// Output:
	// alertmanagers
	// servicemonitors
	// prometheuses
	// prometheusrules
	// podmonitors

	has, err := c.HasAPIResource(metav1.GroupVersion{
		Group:   "monitoring.coreos.com",
		Version: "v1",
	}, "servicemonitors")
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("%t\n", has)
	// Output: true
}


func homeDir() string {
	if h := os.Getenv("HOME"); h != "" {
		return h
	}
	return os.Getenv("USERPROFILE") // windows
}

Documentation

Index

• type CRD
  • func NewCRD(sri ServerResourcesInterface) *CRD
  • func (c *CRD) HasAPIResource(groupVersion metav1.GroupVersion, name string) (bool, error)
  • func (c *CRD) ListAPIResources(groupVersion metav1.GroupVersion) ([]metav1.APIResource, error)
• type ServerResourcesInterface

Types

type CRD

type CRD struct {
	// contains filtered or unexported fields
}

func NewCRD

func NewCRD(sri ServerResourcesInterface) *CRD

func (*CRD) HasAPIResource

func (c *CRD) HasAPIResource(groupVersion metav1.GroupVersion, name string) (bool, error)

HasAPIResource checks whether a given resource is registered under a given API group and resource or not.

func (*CRD) ListAPIResources

func (c *CRD) ListAPIResources(groupVersion metav1.GroupVersion) ([]metav1.APIResource, error)

ListAPIResources returns all API resources registered for a given API group and version.

type ServerResourcesInterface

type ServerResourcesInterface interface {
	// ServerResourcesForGroupVersion returns the supported resources for a group and version.
	ServerResourcesForGroupVersion(groupVersion string) (*metav1.APIResourceList, error)
}

ServerResourcesInterface has methods for obtaining supported resources on the API server