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 (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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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)
Types ¶
type API ¶
type API struct {
// contains filtered or unexported fields
}
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) 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) 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)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.