crd

Documentation

Index

• func CacheKey(metadata *metav1.ObjectMeta) string
• func CacheKeyUID(metadata *metav1.ObjectMeta) string
• func EnsureFissionCRDs(ctx context.Context, logger *zap.Logger, ...) error
• func WaitForCRDs(ctx context.Context, logger *zap.Logger, fissionClient versioned.Interface) error
• type ClientGenerator
  • func NewClientGenerator() *ClientGenerator
  • func NewClientGeneratorWithRestConfig(restConfig *rest.Config) *ClientGenerator
  • func (cg *ClientGenerator) GetApiExtensionsClient() (apiextensionsclient.Interface, error)
  • func (cg *ClientGenerator) GetDynamicClient() (dynamic.Interface, error)
  • func (cg *ClientGenerator) GetFissionClient() (versioned.Interface, error)
  • func (cg *ClientGenerator) GetKubernetesClient() (kubernetes.Interface, error)
  • func (cg *ClientGenerator) GetMetricsClient() (metricsclient.Interface, 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(ctx context.Context, logger *zap.Logger, clientset apiextensionsclient.Interface) error

EnsureFissionCRDs checks if all Fission CRDs are present

func WaitForCRDs

func WaitForCRDs(ctx context.Context, logger *zap.Logger, fissionClient versioned.Interface) error

WaitForCRDs does a timeout to check if CRDs have been installed

Types

type ClientGenerator

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

func NewClientGenerator

func NewClientGenerator() *ClientGenerator

func NewClientGeneratorWithRestConfig

func NewClientGeneratorWithRestConfig(restConfig *rest.Config) *ClientGenerator

func (*ClientGenerator) GetApiExtensionsClient

func (cg *ClientGenerator) GetApiExtensionsClient() (apiextensionsclient.Interface, error)

func (*ClientGenerator) GetDynamicClient

func (cg *ClientGenerator) GetDynamicClient() (dynamic.Interface, error)

func (*ClientGenerator) GetFissionClient

func (cg *ClientGenerator) GetFissionClient() (versioned.Interface, error)

func (*ClientGenerator) GetKubernetesClient

func (cg *ClientGenerator) GetKubernetesClient() (kubernetes.Interface, error)

func (*ClientGenerator) GetMetricsClient

func (cg *ClientGenerator) GetMetricsClient() (metricsclient.Interface, error)