handlers

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Dec 26, 2019 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandleAddEventingRule

func HandleAddEventingRule(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleAddEventingRule is an endpoint handler which adds a rule to eventing

func HandleAddService

func HandleAddService(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleAddService is an endpoint handler which deletes a table in specified database

func HandleAdminLogin

func HandleAdminLogin(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleAdminLogin creates the admin login endpoint

func HandleCollectionRules

func HandleCollectionRules(adminMan *admin.Manager, syncman *syncman.Manager) http.HandlerFunc

HandleCollectionRules is an endpoint handler which update database collection rules in config & creates collection if it doesn't exist

func HandleCreateFile

func HandleCreateFile(auth *auth.Module, fileStore *filestore.Module) http.HandlerFunc

HandleCreateFile creates the create file or directory endpoint

func HandleCreateProject

func HandleCreateProject(adminMan *admin.Manager, syncman *syncman.Manager) http.HandlerFunc

HandleCreateProject is an endpoint handler which adds a project configuration in config

func HandleCrudAggregate

func HandleCrudAggregate(auth *auth.Module, crud *crud.Module) http.HandlerFunc

HandleCrudAggregate creates the aggregate operation endpoint

func HandleCrudBatch

func HandleCrudBatch(auth *auth.Module, crud *crud.Module, realtime *realtime.Module) http.HandlerFunc

HandleCrudBatch creates the batch operation endpoint

func HandleCrudCreate

func HandleCrudCreate(auth *auth.Module, crud *crud.Module, realtime *realtime.Module) http.HandlerFunc

HandleCrudCreate creates the create operation endpoint

func HandleCrudDelete

func HandleCrudDelete(auth *auth.Module, crud *crud.Module, realtime *realtime.Module) http.HandlerFunc

HandleCrudDelete creates the delete operation endpoint

func HandleCrudRead

func HandleCrudRead(auth *auth.Module, crud *crud.Module) http.HandlerFunc

HandleCrudRead creates the read operation endpoint

func HandleCrudUpdate

func HandleCrudUpdate(auth *auth.Module, crud *crud.Module, realtime *realtime.Module) http.HandlerFunc

HandleCrudUpdate creates the update operation endpoint

func HandleDatabaseConnection

func HandleDatabaseConnection(adminMan *admin.Manager, crud *crud.Module, syncman *syncman.Manager) http.HandlerFunc

HandleDatabaseConnection is an endpoint handler which updates database config & connects to database

func HandleDelete

func HandleDelete(auth *auth.Module, fileStore *filestore.Module) http.HandlerFunc

HandleDelete creates read file and list directory endpoint

func HandleDeleteCollection

func HandleDeleteCollection(adminMan *admin.Manager, crud *crud.Module, syncman *syncman.Manager) http.HandlerFunc

HandleDeleteCollection is an endpoint handler which deletes a table in specified database & removes it from config

func HandleDeleteEventingRule

func HandleDeleteEventingRule(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleDeleteEventingRule is an endpoint handler which deletes a rule in eventing

func HandleDeleteFileRule

func HandleDeleteFileRule(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleDeleteFileRule deletes file rule

func HandleDeleteProjectConfig

func HandleDeleteProjectConfig(adminMan *admin.Manager, syncMan *syncman.Manager, configPath string) http.HandlerFunc

HandleDeleteProjectConfig returns the handler to delete the config of a project via a REST endpoint

func HandleDeleteService

func HandleDeleteService(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleDeleteService is an endpoint handler which deletes a table in specified database

func HandleEmailEditProfile

func HandleEmailEditProfile(userManagement *userman.Module) http.HandlerFunc

HandleEmailEditProfile returns the handler for edit profile

func HandleEmailSignIn

func HandleEmailSignIn(userManagement *userman.Module) http.HandlerFunc

HandleEmailSignIn returns the handler for email sign in

func HandleEmailSignUp

func HandleEmailSignUp(userManagement *userman.Module) http.HandlerFunc

HandleEmailSignUp returns the handler for email sign up

func HandleFunctionCall

func HandleFunctionCall(functions *functions.Module, auth *auth.Module) http.HandlerFunc

HandleRealtimeEvent creates a functions request endpoint

func HandleGetCollectionSchemas

func HandleGetCollectionSchemas(adminMan *admin.Manager, schema *schema.Schema) http.HandlerFunc

HandleGetCollectionSchemas is an endpoint handler which return schema for all the collection in the config.crud

func HandleGetCollections

func HandleGetCollections(adminMan *admin.Manager, crud *crud.Module, syncMan *syncman.Manager) http.HandlerFunc

HandleGetCollections is an endpoint handler which return all the collection(table) names for specified data base

func HandleGetConnectionState

func HandleGetConnectionState(adminMan *admin.Manager, crud *crud.Module) http.HandlerFunc

HandleGetConnectionState gives the status of connection state of client

func HandleGetFileState

func HandleGetFileState(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleGetFileState gets file state

func HandleGlobalConfig

func HandleGlobalConfig(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleGlobalConfig returns the handler to store the global config of a project via a REST endpoint

func HandleGraphQLRequest

func HandleGraphQLRequest(graphql *graphql.Module) http.HandlerFunc

HandleGraphQLRequest creates the graphql operation endpoint

func HandleLoadEnv

func HandleLoadEnv(adminMan *admin.Manager) http.HandlerFunc

HandleLoadEnv returns the handler to load the projects via a REST endpoint

func HandleLoadProjects

func HandleLoadProjects(adminMan *admin.Manager, syncMan *syncman.Manager, configPath string) http.HandlerFunc

HandleLoadProjects returns the handler to load the projects via a REST endpoint

func HandleMetricMiddleWare

func HandleMetricMiddleWare(next http.Handler, metrics *metrics.Module) http.Handler

func HandleMissionControl

func HandleMissionControl(staticPath string) http.HandlerFunc

HandleMissionControl hosts the static resources for mission control

func HandleModifyAllSchema

func HandleModifyAllSchema(adminMan *admin.Manager, schemaArg *schema.Schema, syncman *syncman.Manager) http.HandlerFunc

HandleModifySchema is an endpoint handler which updates the existing schema & updates the config

func HandleModifySchema

func HandleModifySchema(adminMan *admin.Manager, schemaArg *schema.Schema, syncman *syncman.Manager) http.HandlerFunc

HandleModifySchema is an endpoint handler which updates the existing schema & updates the config

func HandleProcessEvent

func HandleProcessEvent(adminMan *admin.Manager, eventing *eventing.Module) http.HandlerFunc

HandleProcessEvent processes a transmitted event

func HandleProfile

func HandleProfile(userManagement *userman.Module) http.HandlerFunc

HandleProfile returns the handler for fetching single user profile

func HandleProfiles

func HandleProfiles(userManagement *userman.Module) http.HandlerFunc

HandleProfiles returns the handler for fetching all user profiles

func HandleQueueEvent

func HandleQueueEvent(adminMan *admin.Manager, eventing *eventing.Module) http.HandlerFunc

HandleQueueEvent creates a queue event endpoint

func HandleRead

func HandleRead(auth *auth.Module, fileStore *filestore.Module) http.HandlerFunc

HandleRead creates read file and list directory endpoint

func HandleRealtimeEvent

func HandleRealtimeEvent(auth *auth.Module, realtime *realtime.Module) http.HandlerFunc

HandleRealtimeEvent handles the request coming from the eventing module

func HandleRealtimeProcessRequest

func HandleRealtimeProcessRequest(auth *auth.Module, realtime *realtime.Module) http.HandlerFunc

func HandleReloadSchema

func HandleReloadSchema(adminMan *admin.Manager, schemaArg *schema.Schema, syncman *syncman.Manager) http.HandlerFunc

HandleReloadSchema is an endpoint handler which return & sets the schemas of all collection in config

func HandleSchemaInspection

func HandleSchemaInspection(adminMan *admin.Manager, schemaArg *schema.Schema, syncman *syncman.Manager) http.HandlerFunc

HandleSchemaInspection gets the schema for particular collection & update the database collection schema in config

func HandleSetEventingConfig

func HandleSetEventingConfig(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleSetEventingConfig is an endpoint handler which sets col and dytype in eventing according to body

func HandleSetFileRule

func HandleSetFileRule(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleSetFileRule sets file rule

func HandleSetFileStore

func HandleSetFileStore(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleSetFileStore set the file storage config

func HandleStoreProjectConfig

func HandleStoreProjectConfig(adminMan *admin.Manager, syncMan *syncman.Manager, configPath string) http.HandlerFunc

HandleStoreProjectConfig returns the handler to store the config of a project via a REST endpoint

func HandleUserManagement

func HandleUserManagement(adminMan *admin.Manager, syncMan *syncman.Manager) http.HandlerFunc

HandleUserManagement returns the handler to get the project config and validate the user via a REST endpoint

Types

type ReaderCounter

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

ReaderCounter is counter for io.Reader

func NewReaderCounter

func NewReaderCounter(r io.ReadCloser) *ReaderCounter

NewReaderCounter function for create new ReaderCounter

func (*ReaderCounter) Close

func (counter *ReaderCounter) Close() error

func (*ReaderCounter) Count

func (counter *ReaderCounter) Count() uint64

Count function return counted bytes

func (*ReaderCounter) Read

func (counter *ReaderCounter) Read(buf []byte) (int, error)

type ResponseWriterCounter

type ResponseWriterCounter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

ResponseWriterCounter is counter for http.ResponseWriter

func NewResponseWriterCounter

func NewResponseWriterCounter(rw http.ResponseWriter) *ResponseWriterCounter

NewResponseWriterCounter function create new ResponseWriterCounter

func (*ResponseWriterCounter) Count

func (counter *ResponseWriterCounter) Count() uint64

Count function return counted bytes

func (*ResponseWriterCounter) Header

func (counter *ResponseWriterCounter) Header() http.Header

func (*ResponseWriterCounter) Hijack

func (counter *ResponseWriterCounter) Hijack() (net.Conn, *bufio.ReadWriter, error)

func (*ResponseWriterCounter) Started

func (counter *ResponseWriterCounter) Started() time.Time

func (*ResponseWriterCounter) Write

func (counter *ResponseWriterCounter) Write(buf []byte) (int, error)

func (*ResponseWriterCounter) WriteHeader

func (counter *ResponseWriterCounter) WriteHeader(statusCode int)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL