schedules

Documentation

Index

• Constants
• Variables
• type NotebookScheduler
  • func NewNotebookScheduler(q *qs.QueryServer, keeper *pods.Keeper, config *config.Config) *NotebookScheduler
  • func (nb *NotebookScheduler) ScheduleRequest(user *types.User, pod *types.POD) (*types.POD, error)

Constants

const NbSchedulerKey = "NBScheduler:Queues"

NbSchedulerKey : Notebook Scheduler Queue Database key

Variables

var SaveStateInterval = 60 // seconds

SaveStateInterval : Determines how often the state of botebook scheduler is backed up

var SweepInterval = 15 // minutes

SweepInterval : Time interval to sync state of wait and active list

Types

type NotebookScheduler

type NotebookScheduler struct {

	// Active list of runnning notebooks
	Active map[uint64]interface{}

	// WaitList queue of notebook runs
	WaitList map[int]uint64
	// contains filtered or unexported fields
}

NotebookScheduler : Responsible for monitoring scheduled notebooks

func NewNotebookScheduler

func NewNotebookScheduler(q *qs.QueryServer, keeper *pods.Keeper, config *config.Config) *NotebookScheduler

NewNotebookScheduler : Returns New Instance of NotebookScheduler

func (*NotebookScheduler) ScheduleRequest

func (nb *NotebookScheduler) ScheduleRequest(user *types.User, pod *types.POD) (*types.POD, error)

ScheduleRequest : Adds notebook request in the queue