handlers

package
v0.0.0-...-260b785 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandleAddEventingSecurityRule 

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

HandleAddEventingSecurityRule is an endpoint handler which adds a security rule in eventing

func HandleAddEventingTriggerRule 

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

HandleAddEventingTriggerRule is an endpoint handler which adds a trigger rule to eventing

func HandleAddIntegrationHook 

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

HandleAddIntegrationHook handles the add integration hook request

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) http.HandlerFunc

HandleAdminLogin creates the admin login endpoint

func HandleAdminQueueEvent 

func HandleAdminQueueEvent(adminMan *admin.Manager, modules *modules.Modules) http.HandlerFunc

HandleAdminQueueEvent creates a queue event endpoint

func HandleApplyProject 

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

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

func HandleBatchApplyConfig 

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

HandleBatchApplyConfig applies all the config at once

func HandleCluster 

func HandleCluster() http.HandlerFunc

HandleCluster returns handler cluster

func HandleCreateFile 

func HandleCreateFile(modules *modules.Modules) http.HandlerFunc

HandleCreateFile creates the create file or directory endpoint

func HandleCrudAggregate 

func HandleCrudAggregate(modules *modules.Modules) http.HandlerFunc

HandleCrudAggregate creates the aggregate operation endpoint

func HandleCrudBatch 

func HandleCrudBatch(modules *modules.Modules) http.HandlerFunc

HandleCrudBatch creates the batch operation endpoint

func HandleCrudCreate 

func HandleCrudCreate(modules *modules.Modules) http.HandlerFunc

HandleCrudCreate creates the create operation endpoint

func HandleCrudDelete 

func HandleCrudDelete(modules *modules.Modules) http.HandlerFunc

HandleCrudDelete creates the delete operation endpoint

func HandleCrudPreparedQuery 

func HandleCrudPreparedQuery(modules *modules.Modules) http.HandlerFunc

HandleCrudPreparedQuery creates the PreparedQuery operation endpoint

func HandleCrudRead 

func HandleCrudRead(modules *modules.Modules) http.HandlerFunc

HandleCrudRead creates the read operation endpoint

func HandleCrudUpdate 

func HandleCrudUpdate(modules *modules.Modules) http.HandlerFunc

HandleCrudUpdate creates the update operation endpoint

func HandleDelete 

func HandleDelete(modules *modules.Modules) http.HandlerFunc

HandleDelete creates read file and list directory endpoint

func HandleDeleteEventingSchema 

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

HandleDeleteEventingSchema is an endpoint handler which deletes a schema in eventing

func HandleDeleteEventingSecurityRule 

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

HandleDeleteEventingSecurityRule is an endpoint handler which deletes a security rule in eventing

func HandleDeleteEventingTriggerRule 

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

HandleDeleteEventingTriggerRule 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 HandleDeleteIntegration 

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

HandleDeleteIntegration handles the delete integration request

func HandleDeleteIntegrationHook 

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

HandleDeleteIntegrationHook handles the delete integration hook request

func HandleDeleteProjectConfig 

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

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

func HandleDeleteProjectRoute 

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

HandleDeleteProjectRoute deletes the specified route from project config

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 HandleDeleteTable 

func HandleDeleteTable(adminMan *admin.Manager, modules *modules.Modules, syncman *syncman.Manager) http.HandlerFunc

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

func HandleDeleteTableRules 

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

HandleDeleteTableRules is an endpoint handler which deletes database collection rules in config

func HandleDeleteUserManagement 

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

HandleDeleteUserManagement returns handler to delete auth

func HandleEmailEditProfile 

func HandleEmailEditProfile(modules *modules.Modules) http.HandlerFunc

HandleEmailEditProfile returns the handler for edit profile

func HandleEmailSignIn 

func HandleEmailSignIn(modules *modules.Modules) http.HandlerFunc

HandleEmailSignIn returns the handler for email sign in

func HandleEmailSignUp 

func HandleEmailSignUp(modules *modules.Modules) http.HandlerFunc

HandleEmailSignUp returns the handler for email sign up

func HandleFunctionCall 

func HandleFunctionCall(modules *modules.Modules) http.HandlerFunc

HandleFunctionCall creates a functions request endpoint

func HandleGenerateAdminToken 

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

HandleGenerateAdminToken generates an admin token with the claims provided

func HandleGenerateTokenForMissionControl 

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

HandleGenerateTokenForMissionControl handles the request of creating internal tokens

func HandleGetAllTableNames 

func HandleGetAllTableNames(adminMan *admin.Manager, modules *modules.Modules) http.HandlerFunc

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

func HandleGetCacheConfig 

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

HandleGetCacheConfig is an endpoint handler which gets cache config

func HandleGetCacheConnectionState 

func HandleGetCacheConnectionState(adminMan *admin.Manager, caching *caching.Cache) http.HandlerFunc

HandleGetCacheConnectionState is an endpoint handler which get cache connection state

func HandleGetClusterConfig 

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

HandleGetClusterConfig returns handler to get cluster-config

func HandleGetCredentials 

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

HandleGetCredentials is an endpoint handler which gets username pass

func HandleGetDatabaseConfig 

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

HandleGetDatabaseConfig returns handler to get Database Collection

func HandleGetDatabaseConnectionState 

func HandleGetDatabaseConnectionState(adminMan *admin.Manager, modules *modules.Modules) http.HandlerFunc

HandleGetDatabaseConnectionState gives the status of connection state of client

func HandleGetEncryptWhitelistedDomain 

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

HandleGetEncryptWhitelistedDomain returns handler to get Encrypt White listed Domain

func HandleGetEventingConfig 

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

HandleGetEventingConfig returns handler to get event config

func HandleGetEventingSchema 

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

HandleGetEventingSchema returns handler to get event schema

func HandleGetEventingSecurityRules 

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

HandleGetEventingSecurityRules returns handler to get event security rules

func HandleGetEventingTriggers 

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

HandleGetEventingTriggers returns handler to get event trigger

func HandleGetFileRule 

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

HandleGetFileRule returns handler to get file rule

func HandleGetFileState 

func HandleGetFileState(adminMan *admin.Manager, modules *modules.Modules) http.HandlerFunc

HandleGetFileState gets file state

func HandleGetFileStore 

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

HandleGetFileStore returns handler to get file store

func HandleGetGlobalRouteConfig 

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

HandleGetGlobalRouteConfig gets the project level ingress route config

func HandleGetIntegrationHooks 

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

HandleGetIntegrationHooks handles the get integration hook request

func HandleGetIntegrationTokens 

func HandleGetIntegrationTokens(syncMan *syncman.Manager) http.HandlerFunc

HandleGetIntegrationTokens handles the get integration tokens request

func HandleGetIntegrations 

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

HandleGetIntegrations handles the get integration hook request

func HandleGetPermissions 

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

HandleGetPermissions returns the permission the authenticated user has

func HandleGetPreparedQuery 

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

HandleGetPreparedQuery returns handler to get PreparedQuery

func HandleGetProjectConfig 

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

HandleGetProjectConfig returns handler to get config of the project

func HandleGetProjectRoute 

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

HandleGetProjectRoute returns handler to get project route

func HandleGetSchemas 

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

HandleGetSchemas returns handler to get schema

func HandleGetService 

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

HandleGetService returns handler to get services of the project

func HandleGetTableRules 

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

HandleGetTableRules returns handler to get collection rule

func HandleGetUserManagement 

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

HandleGetUserManagement returns handler to get auth

func HandleGraphQLRequest 

func HandleGraphQLRequest(modules *modules.Modules, syncMan *syncman.Manager) http.HandlerFunc

HandleGraphQLRequest executes graphql queries

func HandleGraphqlSocket 

func HandleGraphqlSocket(modules WebsocketModulesInterface) http.HandlerFunc

HandleGraphqlSocket handles graphql subscriptions

func HandleHealthCheck 

func HandleHealthCheck(syncMan *syncman.Manager) http.HandlerFunc

HandleHealthCheck check health of gateway

func HandleInspectCollectionSchema 

func HandleInspectCollectionSchema(adminMan *admin.Manager, modules *modules.Modules, syncman *syncman.Manager) http.HandlerFunc

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

func HandleInspectTrackedCollectionsSchema 

func HandleInspectTrackedCollectionsSchema(adminMan *admin.Manager, modules *modules.Modules) http.HandlerFunc

HandleInspectTrackedCollectionsSchema is an endpoint handler which return schema for all tracked collections of a particular database

func HandleInstantInvalidate 

func HandleInstantInvalidate(modules *modules.Modules) http.HandlerFunc

HandleInstantInvalidate is an endpoint handler for handling instant invalidation

func HandleLetsEncryptWhitelistedDomain 

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

HandleLetsEncryptWhitelistedDomain handles the lets encrypt config request

func HandleLoadEnv 

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

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

func HandleMissionControl 

func HandleMissionControl(staticPath string) http.HandlerFunc

HandleMissionControl hosts the static resources for mission control

func HandleModifyAllSchema 

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

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

func HandleModifySchema 

func HandleModifySchema(adminMan *admin.Manager, modules *modules.Modules, syncman *syncman.Manager) http.HandlerFunc

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

func HandlePostIntegration 

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

HandlePostIntegration handles the post integration request

func HandleProfile 

func HandleProfile(modules *modules.Modules) http.HandlerFunc

HandleProfile returns the handler for fetching single user profile

func HandleProfiles 

func HandleProfiles(modules *modules.Modules) http.HandlerFunc

HandleProfiles returns the handler for fetching all user profiles

func HandlePurgeCache 

func HandlePurgeCache(adminMan *admin.Manager, caching *caching.Cache) http.HandlerFunc

HandlePurgeCache is an endpoint handler which purge cache

func HandleQueueEvent 

func HandleQueueEvent(modules *modules.Modules) http.HandlerFunc

HandleQueueEvent creates a queue event endpoint

func HandleRead 

func HandleRead(modules *modules.Modules) http.HandlerFunc

HandleRead creates read file and list directory endpoint

func HandleRealtimeEvent 

func HandleRealtimeEvent(modules *modules.Modules) http.HandlerFunc

HandleRealtimeEvent handles the request coming from the eventing module

func HandleRefreshToken 

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

HandleRefreshToken creates the refresh-token endpoint

func HandleReloadSchema 

func HandleReloadSchema(adminMan *admin.Manager, modules *modules.Modules, syncman *syncman.Manager) http.HandlerFunc

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

func HandleRemoveDatabaseConfig 

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

HandleRemoveDatabaseConfig is an endpoint handler which removes database config

func HandleRemovePreparedQueries 

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

HandleRemovePreparedQueries is an endpoint handler which removes database PreparedQueries

func HandleSetCacheConfig 

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

HandleSetCacheConfig is an endpoint handler which sets cache config

func HandleSetClusterConfig 

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

HandleSetClusterConfig set cluster-config

func HandleSetDatabaseConfig 

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

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

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 HandleSetEventingSchema 

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

HandleSetEventingSchema is an endpoint handler which sets a schema in eventing

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 HandleSetGlobalRouteConfig 

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

HandleSetGlobalRouteConfig sets the project level ingress route config

func HandleSetPreparedQueries 

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

HandleSetPreparedQueries is an endpoint handler which updates database PreparedQueries

func HandleSetProjectRoute 

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

HandleSetProjectRoute adds a route in specified project config

func HandleSetTableRules 

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

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

func HandleSetUserManagement 

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

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

func HandleUntrackCollectionSchema 

func HandleUntrackCollectionSchema(adminMan *admin.Manager, modules *modules.Modules, syncman *syncman.Manager) http.HandlerFunc

HandleUntrackCollectionSchema removes the tables(un tracks the table) from the schema config

func HandleWebsocket 

func HandleWebsocket(modules WebsocketModulesInterface) http.HandlerFunc

HandleWebsocket handles all websocket communications

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

Close gracefully closes the connection

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

Header returns the header of the response writer

func (*ResponseWriterCounter) Hijack 

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

Hijack returns the hijack of the response writer

func (*ResponseWriterCounter) Started 

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

Started returns the started counter

func (*ResponseWriterCounter) Write 

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

func (*ResponseWriterCounter) WriteHeader 

func (counter *ResponseWriterCounter) WriteHeader(statusCode int)

WriteHeader returns the writeHeader of the response writer

type WebsocketModulesInterface 

type WebsocketModulesInterface interface {
	Realtime(projectID string) (modules.RealtimeInterface, error)
	GraphQL(projectID string) (modules.GraphQLInterface, error)
}

WebsocketModulesInterface is used to accept the modules object

Source Files

View all Source files

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.