crd

Documentation

Index

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

Functions

func CacheKey

func CacheKey(metadata *metav1.ObjectMeta) string

CacheKey : 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 CacheKeyUID

func CacheKeyUID(metadata *metav1.ObjectMeta) string

CacheKeyForUID create a key that uniquely identifies the of the object. Since resourceVersion changes on every update and UIDs are unique, we don't use resource version here

func EnsureFissionCRDs

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

EnsureFissionCRDs checks if all Fission CRDs are present

func GetDynamicClient

func GetDynamicClient() (dynamic.Interface, error)

GetDynamicClient creates and returns new dynamic client or returns an error

func GetKubernetesClient

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

GetKubernetesClient gets 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
}

FissionClient exports the client interface to be used

func MakeFissionClient

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

func (*FissionClient) WaitForCRDs

func (fc *FissionClient) WaitForCRDs() error

WaitForCRDs does a timeout to check if CRDs have been installed