backends

Documentation

Index

• type KnativeBackend
• type KubeBackend
  • func MakeKubeBackend(kubeClientset *kubernetes.Clientset, cfg *types.Config) *KubeBackend
  • func (k *KubeBackend) CreateService(service types.Service) error
  • func (k *KubeBackend) DeleteService(name string) error
  • func (k *KubeBackend) GetInfo() *types.ServerlessBackendInfo
  • func (k *KubeBackend) ListServices() ([]*types.Service, error)
  • func (k *KubeBackend) ReadService(name string) (*types.Service, error)
  • func (k *KubeBackend) UpdateService(service types.Service) error
• type OpenfaasBackend
  • func MakeOpenfaasBackend(kubeClientset *kubernetes.Clientset, kubeConfig *rest.Config, ...) *OpenfaasBackend
  • func (of *OpenfaasBackend) CreateService(service types.Service) error
  • func (of *OpenfaasBackend) DeleteService(name string) error
  • func (of *OpenfaasBackend) GetInfo() *types.ServerlessBackendInfo
  • func (of *OpenfaasBackend) GetProxyDirector(serviceName string) func(req *http.Request)
  • func (of *OpenfaasBackend) ListServices() ([]*types.Service, error)
  • func (of *OpenfaasBackend) ReadService(name string) (*types.Service, error)
  • func (of *OpenfaasBackend) UpdateService(service types.Service) error

Types

type KnativeBackend

type KnativeBackend struct{}

KnativeBackend struct to represent a Knative client

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.Clientset, 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) 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.Clientset, 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) 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) UpdateService

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

UpdateService updates an existent service