controller

Documentation

Index

• func ConfigCanaryFeature(context context.Context, logger *zap.Logger, fissionClient *crd.FissionClient, ...) error
• func ConfigureFeatures(context context.Context, logger *zap.Logger, unitTestMode bool, ...) (map[string]string, error)
• func RegisterCanaryConfigRoute(ws *restful.WebService)
• func RegisterEnvironmentRoute(ws *restful.WebService)
• func RegisterFunctionRoute(ws *restful.WebService)
• func RegisterHTTPTriggerRoute(ws *restful.WebService)
• func RegisterMessageQueueTriggerRoute(ws *restful.WebService)
• func RegisterPackageRoute(ws *restful.WebService)
• func RegisterStorageServiceProxyRoute(ws *restful.WebService)
• func RegisterTimeTriggerRoute(ws *restful.WebService)
• func RegisterWatchRoute(ws *restful.WebService)
• func Start(logger *zap.Logger, port int, unitTestFlag bool)
• type API
  • func MakeAPI(logger *zap.Logger, featureStatus map[string]string) (*API, error)
  • func (api *API) ApiVersionMismatchHandler(w http.ResponseWriter, r *http.Request)
  • func (a *API) CanaryConfigApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) CanaryConfigApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) CanaryConfigApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) CanaryConfigApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) CanaryConfigApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (a *API) CanaryConfigApiUpdateStatus(w http.ResponseWriter, r *http.Request)
  • func (a *API) ConfigMapExists(w http.ResponseWriter, r *http.Request)
  • func (a *API) EnvironmentApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) EnvironmentApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) EnvironmentApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) EnvironmentApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) EnvironmentApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (a *API) FunctionApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) FunctionApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) FunctionApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) FunctionApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) FunctionApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (a *API) FunctionLogsApiPost(w http.ResponseWriter, r *http.Request)
  • func (a *API) FunctionPodLogs(w http.ResponseWriter, r *http.Request)
  • func (api *API) GetHandler() http.Handler
  • func (api *API) GetSvcName(w http.ResponseWriter, r *http.Request)
  • func (a *API) HTTPTriggerApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) HTTPTriggerApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) HTTPTriggerApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) HTTPTriggerApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) HTTPTriggerApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (api *API) HealthHandler(w http.ResponseWriter, r *http.Request)
  • func (api *API) HomeHandler(w http.ResponseWriter, r *http.Request)
  • func (a *API) MessageQueueTriggerApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) MessageQueueTriggerApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) MessageQueueTriggerApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) MessageQueueTriggerApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) MessageQueueTriggerApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (a *API) PackageApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) PackageApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) PackageApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) PackageApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) PackageApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (a *API) PackageApiUpdateStatus(w http.ResponseWriter, r *http.Request)
  • func (a *API) SecretExists(w http.ResponseWriter, r *http.Request)
  • func (api *API) Serve(port int)
  • func (api *API) StorageServiceProxy(w http.ResponseWriter, r *http.Request)
  • func (a *API) TimeTriggerApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) TimeTriggerApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) TimeTriggerApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) TimeTriggerApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) TimeTriggerApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (a *API) WatchApiCreate(w http.ResponseWriter, r *http.Request)
  • func (a *API) WatchApiDelete(w http.ResponseWriter, r *http.Request)
  • func (a *API) WatchApiGet(w http.ResponseWriter, r *http.Request)
  • func (a *API) WatchApiList(w http.ResponseWriter, r *http.Request)
  • func (a *API) WatchApiUpdate(w http.ResponseWriter, r *http.Request)
  • func (api *API) WorkflowApiserverProxy(w http.ResponseWriter, r *http.Request)

Functions

func ConfigCanaryFeature

func ConfigCanaryFeature(context context.Context, logger *zap.Logger, fissionClient *crd.FissionClient, kubeClient *kubernetes.Clientset, featureConfig *config.FeatureConfig, featureStatus map[string]string) error

func ConfigureFeatures

func ConfigureFeatures(context context.Context, logger *zap.Logger, unitTestMode bool, fissionClient *crd.FissionClient, kubeClient *kubernetes.Clientset) (map[string]string, error)

ConfigureFeatures gets the feature config and configures the features that are enabled

func RegisterCanaryConfigRoute

func RegisterCanaryConfigRoute(ws *restful.WebService)

func RegisterEnvironmentRoute

func RegisterEnvironmentRoute(ws *restful.WebService)

func RegisterFunctionRoute

func RegisterFunctionRoute(ws *restful.WebService)

func RegisterHTTPTriggerRoute

func RegisterHTTPTriggerRoute(ws *restful.WebService)

func RegisterMessageQueueTriggerRoute

func RegisterMessageQueueTriggerRoute(ws *restful.WebService)

func RegisterPackageRoute

func RegisterPackageRoute(ws *restful.WebService)

func RegisterStorageServiceProxyRoute

func RegisterStorageServiceProxyRoute(ws *restful.WebService)

func RegisterTimeTriggerRoute

func RegisterTimeTriggerRoute(ws *restful.WebService)

func RegisterWatchRoute

func RegisterWatchRoute(ws *restful.WebService)

func Start

func Start(logger *zap.Logger, port int, unitTestFlag bool)

Types

type API

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

func MakeAPI

func MakeAPI(logger *zap.Logger, featureStatus map[string]string) (*API, error)

func (*API) ApiVersionMismatchHandler

func (api *API) ApiVersionMismatchHandler(w http.ResponseWriter, r *http.Request)

func (*API) CanaryConfigApiCreate

func (a *API) CanaryConfigApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) CanaryConfigApiDelete

func (a *API) CanaryConfigApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) CanaryConfigApiGet

func (a *API) CanaryConfigApiGet(w http.ResponseWriter, r *http.Request)

func (*API) CanaryConfigApiList

func (a *API) CanaryConfigApiList(w http.ResponseWriter, r *http.Request)

func (*API) CanaryConfigApiUpdate

func (a *API) CanaryConfigApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) CanaryConfigApiUpdateStatus

func (a *API) CanaryConfigApiUpdateStatus(w http.ResponseWriter, r *http.Request)

func (*API) ConfigMapExists

func (a *API) ConfigMapExists(w http.ResponseWriter, r *http.Request)

func (*API) EnvironmentApiCreate

func (a *API) EnvironmentApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) EnvironmentApiDelete

func (a *API) EnvironmentApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) EnvironmentApiGet

func (a *API) EnvironmentApiGet(w http.ResponseWriter, r *http.Request)

func (*API) EnvironmentApiList

func (a *API) EnvironmentApiList(w http.ResponseWriter, r *http.Request)

func (*API) EnvironmentApiUpdate

func (a *API) EnvironmentApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) FunctionApiCreate

func (a *API) FunctionApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) FunctionApiDelete

func (a *API) FunctionApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) FunctionApiGet

func (a *API) FunctionApiGet(w http.ResponseWriter, r *http.Request)

func (*API) FunctionApiList

func (a *API) FunctionApiList(w http.ResponseWriter, r *http.Request)

func (*API) FunctionApiUpdate

func (a *API) FunctionApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) FunctionLogsApiPost

func (a *API) FunctionLogsApiPost(w http.ResponseWriter, r *http.Request)

FunctionLogsApiPost establishes a proxy server to log database, and redirect query command send from client to database then proxy back the db response.

func (*API) FunctionPodLogs

func (a *API) FunctionPodLogs(w http.ResponseWriter, r *http.Request)

FunctionPodLogs : Get logs for a function directly from pod

func (*API) GetHandler

func (api *API) GetHandler() http.Handler

func (*API) GetSvcName

func (api *API) GetSvcName(w http.ResponseWriter, r *http.Request)

func (*API) HTTPTriggerApiCreate

func (a *API) HTTPTriggerApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) HTTPTriggerApiDelete

func (a *API) HTTPTriggerApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) HTTPTriggerApiGet

func (a *API) HTTPTriggerApiGet(w http.ResponseWriter, r *http.Request)

func (*API) HTTPTriggerApiList

func (a *API) HTTPTriggerApiList(w http.ResponseWriter, r *http.Request)

func (*API) HTTPTriggerApiUpdate

func (a *API) HTTPTriggerApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) HealthHandler

func (api *API) HealthHandler(w http.ResponseWriter, r *http.Request)

func (*API) HomeHandler

func (api *API) HomeHandler(w http.ResponseWriter, r *http.Request)

func (*API) MessageQueueTriggerApiCreate

func (a *API) MessageQueueTriggerApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) MessageQueueTriggerApiDelete

func (a *API) MessageQueueTriggerApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) MessageQueueTriggerApiGet

func (a *API) MessageQueueTriggerApiGet(w http.ResponseWriter, r *http.Request)

func (*API) MessageQueueTriggerApiList

func (a *API) MessageQueueTriggerApiList(w http.ResponseWriter, r *http.Request)

func (*API) MessageQueueTriggerApiUpdate

func (a *API) MessageQueueTriggerApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) PackageApiCreate

func (a *API) PackageApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) PackageApiDelete

func (a *API) PackageApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) PackageApiGet

func (a *API) PackageApiGet(w http.ResponseWriter, r *http.Request)

func (*API) PackageApiList

func (a *API) PackageApiList(w http.ResponseWriter, r *http.Request)

func (*API) PackageApiUpdate

func (a *API) PackageApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) PackageApiUpdateStatus

func (a *API) PackageApiUpdateStatus(w http.ResponseWriter, r *http.Request)

func (*API) SecretExists

func (a *API) SecretExists(w http.ResponseWriter, r *http.Request)

func (*API) Serve

func (api *API) Serve(port int)

func (*API) StorageServiceProxy

func (api *API) StorageServiceProxy(w http.ResponseWriter, r *http.Request)

func (*API) TimeTriggerApiCreate

func (a *API) TimeTriggerApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) TimeTriggerApiDelete

func (a *API) TimeTriggerApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) TimeTriggerApiGet

func (a *API) TimeTriggerApiGet(w http.ResponseWriter, r *http.Request)

func (*API) TimeTriggerApiList

func (a *API) TimeTriggerApiList(w http.ResponseWriter, r *http.Request)

func (*API) TimeTriggerApiUpdate

func (a *API) TimeTriggerApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) WatchApiCreate

func (a *API) WatchApiCreate(w http.ResponseWriter, r *http.Request)

func (*API) WatchApiDelete

func (a *API) WatchApiDelete(w http.ResponseWriter, r *http.Request)

func (*API) WatchApiGet

func (a *API) WatchApiGet(w http.ResponseWriter, r *http.Request)

func (*API) WatchApiList

func (a *API) WatchApiList(w http.ResponseWriter, r *http.Request)

func (*API) WatchApiUpdate

func (a *API) WatchApiUpdate(w http.ResponseWriter, r *http.Request)

func (*API) WorkflowApiserverProxy

func (api *API) WorkflowApiserverProxy(w http.ResponseWriter, r *http.Request)