tpr

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2017 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CacheKey 

func CacheKey(metadata *api.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 EnsureFissionTPRs 

func EnsureFissionTPRs(clientset *kubernetes.Clientset) error

func GetKubernetesClient 

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

Get a kubernetes client using the kubeconfig file at the environment var $KUBECONFIG, or an in-cluster config if that's undefined.

func GetTprClient 

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

GetTprClient gets a TPR client config

Types

type Environment 

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

Environments.

func (*Environment) GetObjectKind 

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

func (*Environment) GetObjectMeta 

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

type EnvironmentInterface 

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

func MakeEnvironmentInterface 

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

type EnvironmentList 

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

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

func (*EnvironmentList) GetListMeta 

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

func (*EnvironmentList) GetObjectKind 

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

type FissionClient 

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

func MakeFissionClient 

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

func (*FissionClient) Environments 

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

func (*FissionClient) Functions 

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

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

func (fc *FissionClient) WaitForTPRs()

type Function 

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

Functions.

func (*Function) GetObjectKind 

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

func (*Function) GetObjectMeta 

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

type FunctionInterface 

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

func MakeFunctionInterface 

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

type FunctionList 

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

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

func (*FunctionList) GetListMeta 

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

func (*FunctionList) GetObjectKind 

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

type Httptrigger 

type Httptrigger struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             api.ObjectMeta          `json:"metadata"`
	Spec                 fission.HTTPTriggerSpec `json:"spec"`
}

HTTP Triggers. (Something in the TPR reflection stuff wants it to be spelled "Httptrigger" not "HTTPTrigger" or even "HttpTrigger". Bleh.)

func (*Httptrigger) GetObjectKind 

func (ht *Httptrigger) GetObjectKind() unversioned.ObjectKind

func (*Httptrigger) GetObjectMeta 

func (ht *Httptrigger) GetObjectMeta() meta.Object

type HttptriggerInterface 

type HttptriggerInterface interface {
	Create(*Httptrigger) (*Httptrigger, error)
	Get(name string) (*Httptrigger, error)
	Update(*Httptrigger) (*Httptrigger, error)
	Delete(name string, options *api.DeleteOptions) error
	List(opts api.ListOptions) (*HttptriggerList, error)
	Watch(opts api.ListOptions) (watch.Interface, error)
}

func MakeHttptriggerInterface 

func MakeHttptriggerInterface(tprClient *rest.RESTClient, namespace string) HttptriggerInterface

type HttptriggerList 

type HttptriggerList struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             unversioned.ListMeta `json:"metadata"`

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

func (*HttptriggerList) GetListMeta 

func (hl *HttptriggerList) GetListMeta() unversioned.List

func (*HttptriggerList) GetObjectKind 

func (hl *HttptriggerList) GetObjectKind() unversioned.ObjectKind

type Kuberneteswatchtrigger 

type Kuberneteswatchtrigger struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             api.ObjectMeta                     `json:"metadata"`
	Spec                 fission.KubernetesWatchTriggerSpec `json:"spec"`
}

Kubernetes Watches as triggers

func (*Kuberneteswatchtrigger) GetObjectKind 

func (w *Kuberneteswatchtrigger) GetObjectKind() unversioned.ObjectKind

func (*Kuberneteswatchtrigger) GetObjectMeta 

func (w *Kuberneteswatchtrigger) GetObjectMeta() meta.Object

type KuberneteswatchtriggerInterface 

type KuberneteswatchtriggerInterface interface {
	Create(*Kuberneteswatchtrigger) (*Kuberneteswatchtrigger, error)
	Get(name string) (*Kuberneteswatchtrigger, error)
	Update(*Kuberneteswatchtrigger) (*Kuberneteswatchtrigger, error)
	Delete(name string, options *api.DeleteOptions) error
	List(opts api.ListOptions) (*KuberneteswatchtriggerList, error)
	Watch(opts api.ListOptions) (watch.Interface, error)
}

func MakeKuberneteswatchtriggerInterface 

func MakeKuberneteswatchtriggerInterface(tprClient *rest.RESTClient, namespace string) KuberneteswatchtriggerInterface

type KuberneteswatchtriggerList 

type KuberneteswatchtriggerList struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             unversioned.ListMeta `json:"metadata"`

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

func (*KuberneteswatchtriggerList) GetListMeta 

func (wl *KuberneteswatchtriggerList) GetListMeta() unversioned.List

func (*KuberneteswatchtriggerList) GetObjectKind 

func (wl *KuberneteswatchtriggerList) GetObjectKind() unversioned.ObjectKind

type Messagequeuetrigger 

type Messagequeuetrigger struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             api.ObjectMeta                  `json:"metadata"`
	Spec                 fission.MessageQueueTriggerSpec `json:"spec"`
}

Message Queue triggers

func (*Messagequeuetrigger) GetObjectKind 

func (w *Messagequeuetrigger) GetObjectKind() unversioned.ObjectKind

func (*Messagequeuetrigger) GetObjectMeta 

func (w *Messagequeuetrigger) GetObjectMeta() meta.Object

type MessagequeuetriggerInterface 

type MessagequeuetriggerInterface interface {
	Create(*Messagequeuetrigger) (*Messagequeuetrigger, error)
	Get(name string) (*Messagequeuetrigger, error)
	Update(*Messagequeuetrigger) (*Messagequeuetrigger, error)
	Delete(name string, options *api.DeleteOptions) error
	List(opts api.ListOptions) (*MessagequeuetriggerList, error)
	Watch(opts api.ListOptions) (watch.Interface, error)
}

func MakeMessagequeuetriggerInterface 

func MakeMessagequeuetriggerInterface(tprClient *rest.RESTClient, namespace string) MessagequeuetriggerInterface

type MessagequeuetriggerList 

type MessagequeuetriggerList struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             unversioned.ListMeta `json:"metadata"`

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

func (*MessagequeuetriggerList) GetListMeta 

func (wl *MessagequeuetriggerList) GetListMeta() unversioned.List

func (*MessagequeuetriggerList) GetObjectKind 

func (wl *MessagequeuetriggerList) GetObjectKind() unversioned.ObjectKind

type Package 

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

Packages. Think of these as function-level images.

func (*Package) GetObjectKind 

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

func (*Package) GetObjectMeta 

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

type PackageInterface 

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

func MakePackageInterface 

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

type PackageList 

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

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

func (*PackageList) GetListMeta 

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

func (*PackageList) GetObjectKind 

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

type Timetrigger 

type Timetrigger struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             api.ObjectMeta          `json:"metadata"`
	Spec                 fission.TimeTriggerSpec `json:"spec"`
}

Time triggers

func (*Timetrigger) GetObjectKind 

func (w *Timetrigger) GetObjectKind() unversioned.ObjectKind

func (*Timetrigger) GetObjectMeta 

func (w *Timetrigger) GetObjectMeta() meta.Object

type TimetriggerInterface 

type TimetriggerInterface interface {
	Create(*Timetrigger) (*Timetrigger, error)
	Get(name string) (*Timetrigger, error)
	Update(*Timetrigger) (*Timetrigger, error)
	Delete(name string, options *api.DeleteOptions) error
	List(opts api.ListOptions) (*TimetriggerList, error)
	Watch(opts api.ListOptions) (watch.Interface, error)
}

func MakeTimetriggerInterface 

func MakeTimetriggerInterface(tprClient *rest.RESTClient, namespace string) TimetriggerInterface

type TimetriggerList 

type TimetriggerList struct {
	unversioned.TypeMeta `json:",inline"`
	Metadata             unversioned.ListMeta `json:"metadata"`

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

func (*TimetriggerList) GetListMeta 

func (wl *TimetriggerList) GetListMeta() unversioned.List

func (*TimetriggerList) GetObjectKind 

func (wl *TimetriggerList) GetObjectKind() unversioned.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.