crd

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 10, 2019 License: Apache-2.0 Imports: 19 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 GetCrdClient 

func GetCrdClient(config *rest.Config) (*rest.RESTClient, error)

GetCrdClient gets a CRD client config

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 CanaryConfigInterface 

type CanaryConfigInterface interface {
	Create(*fv1.CanaryConfig) (*fv1.CanaryConfig, error)
	Get(name string) (*fv1.CanaryConfig, error)
	Update(*fv1.CanaryConfig) (*fv1.CanaryConfig, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.CanaryConfigList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeCanaryConfigInterface 

func MakeCanaryConfigInterface(crdClient *rest.RESTClient, namespace string) CanaryConfigInterface

type EnvironmentInterface 

type EnvironmentInterface interface {
	Create(*fv1.Environment) (*fv1.Environment, error)
	Get(name string) (*fv1.Environment, error)
	Update(*fv1.Environment) (*fv1.Environment, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.EnvironmentList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeEnvironmentInterface 

func MakeEnvironmentInterface(crdClient *rest.RESTClient, namespace string) EnvironmentInterface

type FissionClient 

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

func MakeFissionClient 

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

func (*FissionClient) CanaryConfigs 

func (fc *FissionClient) CanaryConfigs(ns string) CanaryConfigInterface

func (*FissionClient) Environments 

func (fc *FissionClient) Environments(ns string) EnvironmentInterface

func (*FissionClient) Functions 

func (fc *FissionClient) Functions(ns string) FunctionInterface

func (*FissionClient) GetCrdClient 

func (fc *FissionClient) GetCrdClient() *rest.RESTClient

func (*FissionClient) HTTPTriggers 

func (fc *FissionClient) HTTPTriggers(ns string) HTTPTriggerInterface

func (*FissionClient) KubernetesWatchTriggers 

func (fc *FissionClient) KubernetesWatchTriggers(ns string) KubernetesWatchTriggerInterface

func (*FissionClient) MessageQueueTriggers 

func (fc *FissionClient) MessageQueueTriggers(ns string) MessageQueueTriggerInterface

func (*FissionClient) Packages 

func (fc *FissionClient) Packages(ns string) PackageInterface

func (*FissionClient) Recorders 

func (fc *FissionClient) Recorders(ns string) RecorderInterface

func (*FissionClient) TimeTriggers 

func (fc *FissionClient) TimeTriggers(ns string) TimeTriggerInterface

func (*FissionClient) WaitForCRDs 

func (fc *FissionClient) WaitForCRDs() error

type FunctionInterface 

type FunctionInterface interface {
	Create(*fv1.Function) (*fv1.Function, error)
	Get(name string) (*fv1.Function, error)
	Update(*fv1.Function) (*fv1.Function, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.FunctionList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeFunctionInterface 

func MakeFunctionInterface(crdClient *rest.RESTClient, namespace string) FunctionInterface

type HTTPTriggerInterface 

type HTTPTriggerInterface interface {
	Create(*fv1.HTTPTrigger) (*fv1.HTTPTrigger, error)
	Get(name string) (*fv1.HTTPTrigger, error)
	Update(*fv1.HTTPTrigger) (*fv1.HTTPTrigger, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.HTTPTriggerList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeHTTPTriggerInterface 

func MakeHTTPTriggerInterface(crdClient *rest.RESTClient, namespace string) HTTPTriggerInterface

type KubernetesWatchTriggerInterface 

type KubernetesWatchTriggerInterface interface {
	Create(*fv1.KubernetesWatchTrigger) (*fv1.KubernetesWatchTrigger, error)
	Get(name string) (*fv1.KubernetesWatchTrigger, error)
	Update(*fv1.KubernetesWatchTrigger) (*fv1.KubernetesWatchTrigger, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.KubernetesWatchTriggerList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeKubernetesWatchTriggerInterface 

func MakeKubernetesWatchTriggerInterface(crdClient *rest.RESTClient, namespace string) KubernetesWatchTriggerInterface

type MessageQueueTriggerInterface 

type MessageQueueTriggerInterface interface {
	Create(*fv1.MessageQueueTrigger) (*fv1.MessageQueueTrigger, error)
	Get(name string) (*fv1.MessageQueueTrigger, error)
	Update(*fv1.MessageQueueTrigger) (*fv1.MessageQueueTrigger, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.MessageQueueTriggerList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeMessageQueueTriggerInterface 

func MakeMessageQueueTriggerInterface(crdClient *rest.RESTClient, namespace string) MessageQueueTriggerInterface

type PackageInterface 

type PackageInterface interface {
	Create(*fv1.Package) (*fv1.Package, error)
	Get(name string) (*fv1.Package, error)
	Update(*fv1.Package) (*fv1.Package, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.PackageList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakePackageInterface 

func MakePackageInterface(crdClient *rest.RESTClient, namespace string) PackageInterface

type RecorderInterface 

type RecorderInterface interface {
	Create(*fv1.Recorder) (*fv1.Recorder, error)
	Get(name string) (*fv1.Recorder, error)
	Update(*fv1.Recorder) (*fv1.Recorder, error)
	Delete(name string, opts *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.RecorderList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeRecorderInterface 

func MakeRecorderInterface(crdClient *rest.RESTClient, namespace string) RecorderInterface

type TimeTriggerInterface 

type TimeTriggerInterface interface {
	Create(*fv1.TimeTrigger) (*fv1.TimeTrigger, error)
	Get(name string) (*fv1.TimeTrigger, error)
	Update(*fv1.TimeTrigger) (*fv1.TimeTrigger, error)
	Delete(name string, options *metav1.DeleteOptions) error
	List(opts metav1.ListOptions) (*fv1.TimeTriggerList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
}

func MakeTimeTriggerInterface 

func MakeTimeTriggerInterface(crdClient *rest.RESTClient, namespace string) TimeTriggerInterface

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.