requests

Documentation

Index

• type RequestHandler
  • func NewRequestHandler(cqs *qs.QueryServer, conf *config.Config, pk *pods.Keeper, ...) *RequestHandler
  • func (r *RequestHandler) GetBckNotebook(user *types.User, podID uint64) (*types.POD, error)
  • func (r *RequestHandler) GetBckNotebookStatus(user *types.User, podID uint64) (*types.POD, error)
  • func (r *RequestHandler) GetNotebook(user *types.User, id string) (pod types.POD, fnerr error)
  • func (r *RequestHandler) GetOrCreateUserDisk(user *types.User, diskname, diskHostpath string, size uint64) (*types.UserPersistentDisk, error)
  • func (r *RequestHandler) ListNotebooks(user *types.User) ([]*types.POD, error)
  • func (r *RequestHandler) ListPODs(kind string, user *types.User) (pods []*types.POD, fnerr error)
  • func (r *RequestHandler) ProcBackgroundRequest(user *types.User, resourceProfileID, containerImageID uint64, ...) (*types.POD, error)
  • func (r *RequestHandler) ProcessNotebookRequest(user *types.User, resourceProfileID, containerImageID uint64) (*types.POD, error)
  • func (r *RequestHandler) StopBckNotebook(user *types.User, podID uint64) (*types.POD, error)
  • func (r *RequestHandler) StopNotebook(user *types.User, podID uint64) (*types.POD, error)

Types

type RequestHandler

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

RequestHandler : Handle user requests

func NewRequestHandler

func NewRequestHandler(cqs *qs.QueryServer, conf *config.Config, pk *pods.Keeper, scheduler *schedules.NotebookScheduler) *RequestHandler

NewRequestHandler :

func (*RequestHandler) GetBckNotebook

func (r *RequestHandler) GetBckNotebook(user *types.User, podID uint64) (*types.POD, error)

GetBckNotebook : Get notebook

func (*RequestHandler) GetBckNotebookStatus

func (r *RequestHandler) GetBckNotebookStatus(user *types.User, podID uint64) (*types.POD, error)

GetBckNotebookStatus : Syncs status with K8s before returning POD Info

func (*RequestHandler) GetNotebook

func (r *RequestHandler) GetNotebook(user *types.User, id string) (pod types.POD, fnerr error)

GetNotebook : Get POD Status and Object

func (*RequestHandler) GetOrCreateUserDisk

func (r *RequestHandler) GetOrCreateUserDisk(user *types.User, diskname, diskHostpath string, size uint64) (*types.UserPersistentDisk, error)

GetOrCreateUserDisk :

func (*RequestHandler) ListNotebooks

func (r *RequestHandler) ListNotebooks(user *types.User) ([]*types.POD, error)

ListNotebooks : Get list of user pods with status info

func (*RequestHandler) ListPODs

func (r *RequestHandler) ListPODs(kind string, user *types.User) (pods []*types.POD, fnerr error)

ListPODs : Get all user pods

func (*RequestHandler) ProcBackgroundRequest

func (r *RequestHandler) ProcBackgroundRequest(user *types.User, resourceProfileID, containerImageID uint64, params *types.PODParams) (*types.POD, error)

ProcBackgroundRequest : Submit notebook to scheduler

func (*RequestHandler) ProcessNotebookRequest

func (r *RequestHandler) ProcessNotebookRequest(user *types.User, resourceProfileID, containerImageID uint64) (*types.POD, error)

ProcessNotebookRequest : creates a new POD for jupyter LAB

func (*RequestHandler) StopBckNotebook

func (r *RequestHandler) StopBckNotebook(user *types.User, podID uint64) (*types.POD, error)

StopBckNotebook : Stops background notebooks

func (*RequestHandler) StopNotebook

func (r *RequestHandler) StopNotebook(user *types.User, podID uint64) (*types.POD, error)

StopNotebook : Stop a notebook POD owned by user