backends

package
v2.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeServerlessBackend added in v2.5.0 

func MakeServerlessBackend(kubeClientset kubernetes.Interface, kubeConfig *rest.Config, cfg *types.Config) types.ServerlessBackend

MakeServerlessBackend returns a ServerlessBackend based on the configuration

Types

type FakeBackend added in v2.4.0 

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

FakeBackend fake struct to mock the beahaviour of the ServerlessBackend interface

func MakeFakeBackend added in v2.4.0 

func MakeFakeBackend() *FakeBackend

MakeFakeBackend returns the pointer of a new FakeBackend struct

func MakeFakeSyncBackend added in v2.5.1 

func MakeFakeSyncBackend() *FakeBackend

MakeFakeSyncBackend returns the pointer of a new FakeSyncBackend struct

func (*FakeBackend) AddError added in v2.4.0 

func (f *FakeBackend) AddError(functionName string, err error)

AddError append an error to the specified function

func (*FakeBackend) CreateService added in v2.4.0 

func (f *FakeBackend) CreateService(service types.Service) error

CreateService creates a new service as a k8s podTemplate (fake)

func (*FakeBackend) DeleteService added in v2.4.0 

func (f *FakeBackend) DeleteService(name string) error

DeleteService deletes a service (fake)

func (*FakeBackend) GetInfo added in v2.4.0 

func (f *FakeBackend) GetInfo() *types.ServerlessBackendInfo

GetInfo returns the ServerlessBackendInfo with the name and version (fake)

func (*FakeBackend) GetKubeClientset added in v2.4.0 

func (f *FakeBackend) GetKubeClientset() kubernetes.Interface

GetKubeClientset returns the Kubernetes Clientset (fake)

func (*FakeBackend) GetProxyDirector added in v2.5.1 

func (f *FakeBackend) GetProxyDirector(serviceName string) func(req *http.Request)

GetProxyDirector returns the ProxyDirector (fake)

func (*FakeBackend) ListServices added in v2.4.0 

func (f *FakeBackend) ListServices() ([]*types.Service, error)

ListServices returns a slice with all services registered in the provided namespace (fake)

func (*FakeBackend) ReadService added in v2.4.0 

func (f *FakeBackend) ReadService(name string) (*types.Service, error)

ReadService returns a Service (fake)

func (*FakeBackend) UpdateService added in v2.4.0 

func (f *FakeBackend) UpdateService(service types.Service) error

UpdateService updates an existent service (fake)

type KnativeBackend 

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

KnativeBackend struct to represent a Knative client

func MakeKnativeBackend added in v2.4.0 

func MakeKnativeBackend(kubeClientset kubernetes.Interface, kubeConfig *rest.Config, cfg *types.Config) *KnativeBackend

MakeKnativeBackend makes a KnativeBackend from the provided k8S clientset and config

func (*KnativeBackend) CreateService added in v2.4.0 

func (kn *KnativeBackend) CreateService(service types.Service) error

CreateService creates a new service as a Knative service

func (*KnativeBackend) DeleteService added in v2.4.0 

func (kn *KnativeBackend) DeleteService(name string) error

DeleteService deletes a service

func (*KnativeBackend) GetInfo added in v2.4.0 

func (kn *KnativeBackend) GetInfo() *types.ServerlessBackendInfo

GetInfo returns the ServerlessBackendInfo with the name and version

func (*KnativeBackend) GetKubeClientset added in v2.4.0 

func (kn *KnativeBackend) GetKubeClientset() kubernetes.Interface

GetKubeClientset returns the Kubernetes Clientset

func (*KnativeBackend) GetProxyDirector added in v2.4.0 

func (kn *KnativeBackend) GetProxyDirector(serviceName string) func(req *http.Request)

GetProxyDirector returns a director function to use in a httputil.ReverseProxy

func (*KnativeBackend) ListServices added in v2.4.0 

func (kn *KnativeBackend) ListServices() ([]*types.Service, error)

ListServices returns a slice with all services registered in the provided namespace

func (*KnativeBackend) ReadService added in v2.4.0 

func (kn *KnativeBackend) ReadService(name string) (*types.Service, error)

ReadService returns a Service

func (*KnativeBackend) UpdateService added in v2.4.0 

func (kn *KnativeBackend) UpdateService(service types.Service) error

UpdateService updates an existent service

type KubeBackend 

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

KubeBackend struct to represent a Kubernetes client to store services as podTemplates

func MakeKubeBackend 

func MakeKubeBackend(kubeClientset kubernetes.Interface, cfg *types.Config) *KubeBackend

MakeKubeBackend makes a KubeBackend with the provided k8s clientset

func (*KubeBackend) CreateService 

func (k *KubeBackend) CreateService(service types.Service) error

CreateService creates a new service as a k8s podTemplate

func (*KubeBackend) DeleteService 

func (k *KubeBackend) DeleteService(name string) error

DeleteService deletes a service

func (*KubeBackend) GetInfo 

func (k *KubeBackend) GetInfo() *types.ServerlessBackendInfo

GetInfo returns the ServerlessBackendInfo with the name and version

func (*KubeBackend) GetKubeClientset added in v2.3.0 

func (k *KubeBackend) GetKubeClientset() kubernetes.Interface

GetKubeClientset returns the Kubernetes Clientset

func (*KubeBackend) ListServices 

func (k *KubeBackend) ListServices() ([]*types.Service, error)

ListServices returns a slice with all services registered in the provided namespace

func (*KubeBackend) ReadService 

func (k *KubeBackend) ReadService(name string) (*types.Service, error)

ReadService returns a Service

func (*KubeBackend) UpdateService 

func (k *KubeBackend) UpdateService(service types.Service) error

UpdateService updates an existent service

type OpenfaasBackend 

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

OpenfaasBackend struct to represent an Openfaas client

func MakeOpenfaasBackend 

func MakeOpenfaasBackend(kubeClientset kubernetes.Interface, kubeConfig *rest.Config, cfg *types.Config) *OpenfaasBackend

MakeOpenfaasBackend makes a OpenfaasBackend from the provided k8S clientset and config

func (*OpenfaasBackend) CreateService 

func (of *OpenfaasBackend) CreateService(service types.Service) error

CreateService creates a new service as a OpenFaaS function

func (*OpenfaasBackend) DeleteService 

func (of *OpenfaasBackend) DeleteService(name string) error

DeleteService deletes a service

func (*OpenfaasBackend) GetInfo 

func (of *OpenfaasBackend) GetInfo() *types.ServerlessBackendInfo

GetInfo returns the ServerlessBackendInfo with the name and version

func (*OpenfaasBackend) GetKubeClientset added in v2.3.0 

func (of *OpenfaasBackend) GetKubeClientset() kubernetes.Interface

GetKubeClientset returns the Kubernetes Clientset

func (*OpenfaasBackend) GetProxyDirector 

func (of *OpenfaasBackend) GetProxyDirector(serviceName string) func(req *http.Request)

GetProxyDirector returns a director function to use in a httputil.ReverseProxy

func (*OpenfaasBackend) ListServices 

func (of *OpenfaasBackend) ListServices() ([]*types.Service, error)

ListServices returns a slice with all services registered in the provided namespace

func (*OpenfaasBackend) ReadService 

func (of *OpenfaasBackend) ReadService(name string) (*types.Service, error)

ReadService returns a Service

func (*OpenfaasBackend) StartScaler added in v2.1.0 

func (of *OpenfaasBackend) StartScaler()

StartScaler starts the OpenFaaS Scaler

func (*OpenfaasBackend) UpdateService 

func (of *OpenfaasBackend) UpdateService(service types.Service) error

UpdateService updates an existent service

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.