crd

Documentation

Index

• Constants
• func CacheKeyUIDFromMeta(metadata *metav1.ObjectMeta) types.UID
• func EnsureFissionCRDs(ctx context.Context, logger *zap.Logger, ...) error
• func WaitForFunctionCRDs(ctx context.Context, logger *zap.Logger, fissionClient versioned.Interface) error
• type CacheKeyUR
  • func CacheKeyURFromMeta(metadata *metav1.ObjectMeta) CacheKeyUR
  • func CacheKeyURFromObject(obj metav1.Object) CacheKeyUR
  • func (ck CacheKeyUR) String() string
• type CacheKeyURG
  • func CacheKeyURGFromMeta(metadata *metav1.ObjectMeta) CacheKeyURG
  • func (ck CacheKeyURG) String() string
• 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)
  • func (cg *ClientGenerator) GetRestConfig() (*rest.Config, error)
• type ClientGeneratorInterface

Constants

const (
	EnvKubeClientQps   = "KUBE_CLIENT_QPS"
	EnvKubeClientBurst = "KUBE_CLIENT_BURST"
)

Functions

func CacheKeyUIDFromMeta

func CacheKeyUIDFromMeta(metadata *metav1.ObjectMeta) types.UID

CacheKeyUIDFromMeta 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 WaitForFunctionCRDs

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

WaitForFunctionCRDs does a timeout to check if CRDs have been installed

Types

type CacheKeyUR

type CacheKeyUR struct {
	UID             types.UID
	ResourceVersion string
}

func CacheKeyURFromMeta

func CacheKeyURFromMeta(metadata *metav1.ObjectMeta) CacheKeyUR

CacheKeyURFromMeta : 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 CacheKeyURFromObject

func CacheKeyURFromObject(obj metav1.Object) CacheKeyUR

func (CacheKeyUR) String

func (ck CacheKeyUR) String() string

type CacheKeyURG

type CacheKeyURG struct {
	UID             types.UID
	ResourceVersion string
	Generation      int64
}

func CacheKeyURGFromMeta

func CacheKeyURGFromMeta(metadata *metav1.ObjectMeta) CacheKeyURG

CacheKeyURGFromMeta : 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. Generation is also included to identify latest generation of the object.

func (CacheKeyURG) String

func (ck CacheKeyURG) String() string

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)

func (*ClientGenerator) GetRestConfig

func (cg *ClientGenerator) GetRestConfig() (*rest.Config, error)

type ClientGeneratorInterface

type ClientGeneratorInterface interface {
	GetRestConfig() (*rest.Config, error)
	GetFissionClient() (versioned.Interface, error)
	GetKubernetesClient() (kubernetes.Interface, error)
	GetApiExtensionsClient() (apiextensionsclient.Interface, error)
	GetMetricsClient() (metricsclient.Interface, error)
	GetDynamicClient() (dynamic.Interface, error)
}