crd

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2018 License: Apache-2.0 Imports: 19 Imported by: 0

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(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 Environment 

type Environment struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ObjectMeta       `json:"metadata"`
	Spec            fission.EnvironmentSpec `json:"spec"`
}

Environments.

func (*Environment) GetObjectKind 

func (e *Environment) GetObjectKind() schema.ObjectKind

func (*Environment) GetObjectMeta 

func (e *Environment) GetObjectMeta() metav1.Object

type EnvironmentInterface 

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

func MakeEnvironmentInterface 

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

type EnvironmentList 

type EnvironmentList struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ListMeta `json:"metadata"`

	Items []Environment `json:"items"`
}

func (*EnvironmentList) GetListMeta 

func (el *EnvironmentList) GetListMeta() metav1.List

func (*EnvironmentList) GetObjectKind 

func (el *EnvironmentList) GetObjectKind() schema.ObjectKind

type FissionClient 

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

func MakeFissionClient 

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

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) TimeTriggers 

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

func (*FissionClient) WaitForCRDs 

func (fc *FissionClient) WaitForCRDs()

type Function 

type Function struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ObjectMeta    `json:"metadata"`
	Spec            fission.FunctionSpec `json:"spec"`
}

Functions.

func (*Function) GetObjectKind 

func (f *Function) GetObjectKind() schema.ObjectKind

func (*Function) GetObjectMeta 

func (f *Function) GetObjectMeta() metav1.Object

type FunctionInterface 

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

func MakeFunctionInterface 

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

type FunctionList 

type FunctionList struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ListMeta `json:"metadata"`

	Items []Function `json:"items"`
}

func (*FunctionList) GetListMeta 

func (fl *FunctionList) GetListMeta() metav1.List

func (*FunctionList) GetObjectKind 

func (fl *FunctionList) GetObjectKind() schema.ObjectKind

type HTTPTrigger 

type HTTPTrigger struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ObjectMeta       `json:"metadata"`
	Spec            fission.HTTPTriggerSpec `json:"spec"`
}

func (*HTTPTrigger) GetObjectKind 

func (ht *HTTPTrigger) GetObjectKind() schema.ObjectKind

func (*HTTPTrigger) GetObjectMeta 

func (ht *HTTPTrigger) GetObjectMeta() metav1.Object

type HTTPTriggerInterface 

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

func MakeHTTPTriggerInterface 

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

type HTTPTriggerList 

type HTTPTriggerList struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ListMeta `json:"metadata"`

	Items []HTTPTrigger `json:"items"`
}

func (*HTTPTriggerList) GetListMeta 

func (hl *HTTPTriggerList) GetListMeta() metav1.List

func (*HTTPTriggerList) GetObjectKind 

func (hl *HTTPTriggerList) GetObjectKind() schema.ObjectKind

type KubernetesWatchTrigger 

type KubernetesWatchTrigger struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ObjectMeta                  `json:"metadata"`
	Spec            fission.KubernetesWatchTriggerSpec `json:"spec"`
}

Kubernetes Watches as triggers

func (*KubernetesWatchTrigger) GetObjectKind 

func (w *KubernetesWatchTrigger) GetObjectKind() schema.ObjectKind

func (*KubernetesWatchTrigger) GetObjectMeta 

func (w *KubernetesWatchTrigger) GetObjectMeta() metav1.Object

type KubernetesWatchTriggerInterface 

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

func MakeKubernetesWatchTriggerInterface 

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

type KubernetesWatchTriggerList 

type KubernetesWatchTriggerList struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ListMeta `json:"metadata"`

	Items []KubernetesWatchTrigger `json:"items"`
}

func (*KubernetesWatchTriggerList) GetListMeta 

func (wl *KubernetesWatchTriggerList) GetListMeta() metav1.List

func (*KubernetesWatchTriggerList) GetObjectKind 

func (wl *KubernetesWatchTriggerList) GetObjectKind() schema.ObjectKind

type MessageQueueTrigger 

type MessageQueueTrigger struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ObjectMeta               `json:"metadata"`
	Spec            fission.MessageQueueTriggerSpec `json:"spec"`
}

Message Queue triggers

func (*MessageQueueTrigger) GetObjectKind 

func (w *MessageQueueTrigger) GetObjectKind() schema.ObjectKind

func (*MessageQueueTrigger) GetObjectMeta 

func (w *MessageQueueTrigger) GetObjectMeta() metav1.Object

type MessageQueueTriggerInterface 

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

func MakeMessageQueueTriggerInterface 

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

type MessageQueueTriggerList 

type MessageQueueTriggerList struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ListMeta `json:"metadata"`

	Items []MessageQueueTrigger `json:"items"`
}

func (*MessageQueueTriggerList) GetListMeta 

func (wl *MessageQueueTriggerList) GetListMeta() metav1.List

func (*MessageQueueTriggerList) GetObjectKind 

func (wl *MessageQueueTriggerList) GetObjectKind() schema.ObjectKind

type Package 

type Package struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ObjectMeta   `json:"metadata"`
	Spec            fission.PackageSpec `json:"spec"`

	Status fission.PackageStatus `json:"status"`
}

Packages. Think of these as function-level images.

func (*Package) GetObjectKind 

func (w *Package) GetObjectKind() schema.ObjectKind

func (*Package) GetObjectMeta 

func (w *Package) GetObjectMeta() metav1.Object

type PackageInterface 

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

func MakePackageInterface 

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

type PackageList 

type PackageList struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ListMeta `json:"metadata"`

	Items []Package `json:"items"`
}

func (*PackageList) GetListMeta 

func (wl *PackageList) GetListMeta() metav1.List

func (*PackageList) GetObjectKind 

func (wl *PackageList) GetObjectKind() schema.ObjectKind

type TimeTrigger 

type TimeTrigger struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ObjectMeta       `json:"metadata"`
	Spec            fission.TimeTriggerSpec `json:"spec"`
}

Time triggers

func (*TimeTrigger) GetObjectKind 

func (w *TimeTrigger) GetObjectKind() schema.ObjectKind

func (*TimeTrigger) GetObjectMeta 

func (w *TimeTrigger) GetObjectMeta() metav1.Object

type TimeTriggerInterface 

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

func MakeTimeTriggerInterface 

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

type TimeTriggerList 

type TimeTriggerList struct {
	metav1.TypeMeta `json:",inline"`
	Metadata        metav1.ListMeta `json:"metadata"`

	Items []TimeTrigger `json:"items"`
}

func (*TimeTriggerList) GetListMeta 

func (wl *TimeTriggerList) GetListMeta() metav1.List

func (*TimeTriggerList) GetObjectKind 

func (wl *TimeTriggerList) GetObjectKind() schema.ObjectKind

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.