Documentation ¶
Index ¶
- Variables
- func CreatePublicHandler(sc *ServerContext) http.Handler
- func ListenAndServeHTTP(addr string, connLimit int, readTimeout int, writeTimeout int, ...) error
- func RatedListen(protocol string, addr string, limit int) (net.Listener, error)
- func StartServer(listenIP string, listenPort int, isSSL bool, configPath string)
- func ValidateMethod(request, expected string) error
- type ContainerImageInfo
- type Handler
- type HandlerMethod
- type HandlerPrivs
- type Master
- type NotebookInfo
- type PodInfo
- type ResourceGroupInfo
- type ResourceProfInfo
- type ResourceProfsInfo
- type ServerContext
- type SessionInfo
- type UserInfo
- type UserSignupInfo
Constants ¶
This section is empty.
Variables ¶
var DefaultMaxIncomingConnections = 0
DefaultMaxIncomingConnections : No limit by default
var ServerReadTimeout = 200
ServerReadTimeout : Timeout limit on read requests
var ServerWriteTimeout = 200
ServerWriteTimeout : Timeout limit on write requests
Functions ¶
func CreatePublicHandler ¶
func CreatePublicHandler(sc *ServerContext) http.Handler
CreatePublicHandler : Public Method handler
func ListenAndServeHTTP ¶
func ListenAndServeHTTP(addr string, connLimit int, readTimeout int, writeTimeout int, Handler http.Handler) error
ListenAndServeHTTP : Listen to HTTP requests
func RatedListen ¶
RatedListen : Listener method
func StartServer ¶
StartServer : Initiates Master server afte injecting config params
func ValidateMethod ¶
ValidateMethod : check if HTTP method is permitted
Types ¶
type ContainerImageInfo ¶
type ContainerImageInfo struct {
*types.ContainerImage
}
ContainerImageInfo : API Object for sending / receiving ContainerImage
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler : HTTP Request Handler
func (*Handler) SessionUser ¶
SessionUser : Returns loggeed in User
type Master ¶
Master : Master Server that handlers all REST calls
func NewMasterServer ¶
NewMasterServer : Handles creation of a new Master
func (*Master) ListenAddress ¶
ListenAddress : Returns the listening address for the server from config
type NotebookInfo ¶
type NotebookInfo struct {
PodInfo
}
NotebookInfo : API Object for POD with jupyter LAB
type PodInfo ¶
type PodInfo struct { // User POD ID ID uint64 // Resource Profile ID ResourceProfileID uint64 // Resources ResourceProfile *types.ResourceProfile // Container Image ID ContainerImageID uint64 // ContainerImage ContainerImage *types.ContainerImage // Pod Workspace Params Params *types.PODParams // UserPOD (optional) POD *types.POD // POD Status message Status string // Pod Phase message Phase string }
PodInfo : API Object for User POD
type ResourceGroupInfo ¶
type ResourceGroupInfo struct { ID uint64 Name string ResourceProfile []ResourceProfInfo }
ResourceGroupInfo :
type ResourceProfInfo ¶
type ResourceProfInfo struct {
*types.ResourceProfile
}
ResourceProfInfo : API Object for sending/receiving ResourceProfInfo
type ResourceProfsInfo ¶
type ResourceProfsInfo []types.ResourceProfile
ResourceProfsInfo : List of Resource Profile messages
type ServerContext ¶
type ServerContext struct { DBContext db.DatabaseContext HTTPClient *http.Client DisablePodRequest bool // contains filtered or unexported fields }
ServerContext : Retains Server Context Parameters
func NewServerContext ¶
func NewServerContext(config *constants.Config) (*ServerContext, error)
NewServerContext : Initiates a new server context
func (*ServerContext) ReadyForRequests ¶
func (sc *ServerContext) ReadyForRequests() bool
ReadyForRequests : Disable pod requests in Safe Mode
type SessionInfo ¶
SessionInfo :
type UserSignupInfo ¶
UserSignupInfo :
Source Files ¶
- api.go
- api_data_types.go
- auth_api.go
- bck_notebooks_api.go
- commit_api.go
- constants.go
- container_image_api.go
- dataset_api.go
- file_api.go
- flow_api.go
- handler.go
- http_listener.go
- log_api.go
- master_server.go
- notebook_api.go
- object_ops_api.go
- repo_api.go
- resource_group_api.go
- resource_prof_api.go
- rice-box.go
- routing.go
- server_context.go
- start_server.go
- utils.go
- virtual_fs_api.go
- worker_api.go