scheduler

Documentation

Index

• Constants
• Variables
• type LambdoService
  • func (service *LambdoService) DeleteVM(VMID string) (err error)
  • func (service *LambdoService) SpawnVM(function database.Function) (data LambdoSpawnResponse, err error)
• type LambdoSpawnRequest
• type LambdoSpawnResponse
• type RootFSInfo
• type Scheduler
  • func (s *Scheduler) FindAndDestroyUnsused(hoursTimeout float64)
  • func (s *Scheduler) GetStateByID(id string) (fnState database.FunctionState, err error)
  • func (s *Scheduler) LookForReadyInstance(functionId uuid.UUID, cursor uint64) (fnState database.FunctionState, returnedCursor uint64, err error)
  • func (s *Scheduler) SetStatus(id string, status database.FnStatusCode) error
  • func (s *Scheduler) SpawnVM(function database.Function) (fnState database.FunctionState, err error)

Constants

const (
	IDTimestampSeparator = "_"
)

Variables

var ErrRecordNotFound = errors.New("could not find an available function")

Types

type LambdoService

type LambdoService struct {
	Host      string
	Port      int
	BucketURL string
}

func (*LambdoService) DeleteVM

func (service *LambdoService) DeleteVM(VMID string) (err error)

func (*LambdoService) SpawnVM

func (service *LambdoService) SpawnVM(function database.Function) (data LambdoSpawnResponse, err error)

type LambdoSpawnRequest

type LambdoSpawnRequest struct {
	// URL to the rootfs of the function
	Rootfs RootFSInfo `json:"rootfs"`
	// Ports that the virtual machine needs to be exposed
	// right now we only support one port
	RequestedPorts []uint16 `json:"requestedPorts"`
}

type LambdoSpawnResponse

type LambdoSpawnResponse struct {
	ID string `json:"id"`
	// Ports mapped by lambdo, leading to the requested ports
	// this a tuple under the form [host_port, vm_port]
	// for now we only support one port
	Ports [][2]uint16 `json:"port_mapping"`
}

type RootFSInfo

type RootFSInfo struct {
	ID       string `json:"id"`
	Location string `json:"location"`
}

type Scheduler

type Scheduler struct {
	Redis   *redis.Client
	Context *context.Context
	Lambdo  *LambdoService
}

func (*Scheduler) FindAndDestroyUnsused

func (s *Scheduler) FindAndDestroyUnsused(hoursTimeout float64)

goes through the whole redis instance and remove that have not been used within the last {hoursTimeout} Hours

func (*Scheduler) GetStateByID

func (s *Scheduler) GetStateByID(id string) (fnState database.FunctionState, err error)

Get all keys of a state by its ID

func (*Scheduler) LookForReadyInstance

func (s *Scheduler) LookForReadyInstance(functionId uuid.UUID, cursor uint64) (fnState database.FunctionState, returnedCursor uint64, err error)

Uses SCAN to look for the first instance marked as ready (https://redis.io/docs/latest/commands/scan/)

func (*Scheduler) SetStatus

func (s *Scheduler) SetStatus(id string, status database.FnStatusCode) error

func (*Scheduler) SpawnVM

func (s *Scheduler) SpawnVM(function database.Function) (fnState database.FunctionState, err error)