crd

Documentation

Index

• func CacheKey(metadata *metav1.ObjectMeta) string
• func EnsureFissionCRDs(logger *zap.Logger, clientset *apiextensionsclient.Clientset) error
• func GetKubernetesClient() (*rest.Config, *kubernetes.Clientset, *apiextensionsclient.Clientset, error)
• type FissionClient
  • func MakeFissionClient() (*FissionClient, *kubernetes.Clientset, *apiextensionsclient.Clientset, error)
  • func (fc *FissionClient) WaitForCRDs() error

Functions

func CacheKey

func CacheKey(metadata *metav1.ObjectMeta) string

Given metadata, create a key that uniquely identifies the contents of the object. Since resourceVersion changes on every update and UIDs are unique, uid+resourceVersion identifies the content. (ResourceVersion may also update on status updates, so this will result in some unnecessary cache misses. That should be ok.)

func EnsureFissionCRDs

func EnsureFissionCRDs(logger *zap.Logger, clientset *apiextensionsclient.Clientset) error

Ensure CRDs

func GetKubernetesClient

func GetKubernetesClient() (*rest.Config, *kubernetes.Clientset, *apiextensionsclient.Clientset, error)

Get a kubernetes client using the kubeconfig file at the environment var $KUBECONFIG, or an in-cluster config if that's undefined.

Types

type FissionClient

type FissionClient struct {
	genClientset.Interface
}

func MakeFissionClient

func MakeFissionClient() (*FissionClient, *kubernetes.Clientset, *apiextensionsclient.Clientset, error)

func (*FissionClient) WaitForCRDs

func (fc *FissionClient) WaitForCRDs() error