controller

package
v0.0.0-...-2f6cd6d Latest Latest
Warning

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

 Go to latest Published: May 30, 2017 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	READ requestType = iota
	WRITE
	DELETE
)

Variables

This section is empty.

Functions

This section is empty.

Types

type API 

type API struct {
	FunctionStore
	HTTPTriggerStore
	TimeTriggerStore
	EnvironmentStore
	WatchStore
}

func MakeAPI 

func MakeAPI(rs *ResourceStore) *API

func (*API) EnvironmentApiCreate 

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

func (*API) EnvironmentApiDelete 

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

func (*API) EnvironmentApiGet 

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

func (*API) EnvironmentApiList 

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

func (*API) EnvironmentApiUpdate 

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

func (*API) FunctionApiCreate 

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

func (*API) FunctionApiDelete 

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

func (*API) FunctionApiGet 

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

func (*API) FunctionApiList 

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

func (*API) FunctionApiUpdate 

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

func (*API) FunctionLogsApiPost 

func (api *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) HTTPTriggerApiCreate 

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

func (*API) HTTPTriggerApiDelete 

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

func (*API) HTTPTriggerApiGet 

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

func (*API) HTTPTriggerApiList 

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

func (*API) HTTPTriggerApiUpdate 

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

func (*API) HomeHandler 

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

func (*API) Serve 

func (api *API) Serve(port int)

func (*API) TimeTriggerApiCreate 

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

func (*API) TimeTriggerApiDelete 

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

func (*API) TimeTriggerApiGet 

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

func (*API) TimeTriggerApiList 

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

func (*API) TimeTriggerApiUpdate 

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

func (*API) WatchApiCreate 

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

func (*API) WatchApiDelete 

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

func (*API) WatchApiGet 

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

func (*API) WatchApiList 

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

func (*API) WatchApiUpdate 

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

type EnvironmentStore 

type EnvironmentStore struct {
	ResourceStore
}

func (*EnvironmentStore) Create 

func (es *EnvironmentStore) Create(e *fission.Environment) (string, error)

func (*EnvironmentStore) Delete 

func (es *EnvironmentStore) Delete(m fission.Metadata) error

func (*EnvironmentStore) Get 

func (es *EnvironmentStore) Get(m *fission.Metadata) (*fission.Environment, error)

func (*EnvironmentStore) List 

func (es *EnvironmentStore) List() ([]fission.Environment, error)

func (*EnvironmentStore) Update 

func (es *EnvironmentStore) Update(e *fission.Environment) (string, error)

type FileStore 

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

func MakeFileStore 

func MakeFileStore(path string) *FileStore

type FunctionStore 

type FunctionStore struct {
	ResourceStore
}

func (*FunctionStore) Create 

func (fs *FunctionStore) Create(f *fission.Function) (string, error)

func (*FunctionStore) Delete 

func (fs *FunctionStore) Delete(m fission.Metadata) error

func (*FunctionStore) Get 

func (fs *FunctionStore) Get(m *fission.Metadata) (*fission.Function, error)

func (*FunctionStore) List 

func (fs *FunctionStore) List() ([]fission.Function, error)

func (*FunctionStore) Update 

func (fs *FunctionStore) Update(f *fission.Function) (string, error)

type HTTPTriggerStore 

type HTTPTriggerStore struct {
	ResourceStore
}

func (*HTTPTriggerStore) Create 

func (hts *HTTPTriggerStore) Create(ht *fission.HTTPTrigger) (string, error)

func (*HTTPTriggerStore) Delete 

func (hts *HTTPTriggerStore) Delete(m fission.Metadata) error

func (*HTTPTriggerStore) Get 

func (hts *HTTPTriggerStore) Get(m *fission.Metadata) (*fission.HTTPTrigger, error)

func (*HTTPTriggerStore) List 

func (hts *HTTPTriggerStore) List() ([]fission.HTTPTrigger, error)

func (*HTTPTriggerStore) Update 

func (hts *HTTPTriggerStore) Update(ht *fission.HTTPTrigger) (string, error)

type JsonSerializer 

type JsonSerializer struct {
}

type ResourceStore 

type ResourceStore struct {
	*FileStore
	client.KeysAPI
	// contains filtered or unexported fields
}

func MakeResourceStore 

func MakeResourceStore(fs *FileStore, etcdUrls []string) (*ResourceStore, error)

type TimeTriggerStore 

type TimeTriggerStore struct {
	ResourceStore
}

func (*TimeTriggerStore) Create 

func (tts *TimeTriggerStore) Create(tt *fission.TimeTrigger) (string, error)

func (*TimeTriggerStore) Delete 

func (tts *TimeTriggerStore) Delete(m fission.Metadata) error

func (*TimeTriggerStore) Get 

func (tts *TimeTriggerStore) Get(m *fission.Metadata) (*fission.TimeTrigger, error)

func (*TimeTriggerStore) List 

func (tts *TimeTriggerStore) List() ([]fission.TimeTrigger, error)

func (*TimeTriggerStore) Update 

func (tts *TimeTriggerStore) Update(tt *fission.TimeTrigger) (string, error)

type WatchStore 

type WatchStore struct {
	ResourceStore
}

func (*WatchStore) Create 

func (ws *WatchStore) Create(w *fission.Watch) (string, error)

func (*WatchStore) Delete 

func (ws *WatchStore) Delete(m fission.Metadata) error

func (*WatchStore) Get 

func (ws *WatchStore) Get(m *fission.Metadata) (*fission.Watch, error)

func (*WatchStore) List 

func (ws *WatchStore) List() ([]fission.Watch, error)

func (*WatchStore) Update 

func (ws *WatchStore) Update(w *fission.Watch) (string, error)

Source Files

View all Source files

Directories

Path Synopsis

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.