scheduler

Documentation

Index

• type Scheduler
  • func NewScheduler(c config.Config) *Scheduler
  • func (s *Scheduler) AddWorkers(urls []url.URL)
  • func (s *Scheduler) GetLambdaInfoFromRequest(r *http.Request) (*lambda.Lambda, *httputil.HttpError)
  • func (s *Scheduler) RemoveWorkers(urls []url.URL)
  • func (s *Scheduler) RunLambda(w http.ResponseWriter, r *http.Request)
  • func (s *Scheduler) StatusCheckAllWorkers(w http.ResponseWriter, r *http.Request)

Types

type Scheduler

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

Scheduler is an object that can schedule lambda function workloads to a pool of workers.

func NewScheduler

func NewScheduler(c config.Config) *Scheduler

func (*Scheduler) AddWorkers

func (s *Scheduler) AddWorkers(urls []url.URL)

func (*Scheduler) GetLambdaInfoFromRequest

func (s *Scheduler) GetLambdaInfoFromRequest(r *http.Request) (*lambda.Lambda,
	*httputil.HttpError)

func (*Scheduler) RemoveWorkers

func (s *Scheduler) RemoveWorkers(urls []url.URL)

func (*Scheduler) RunLambda

func (s *Scheduler) RunLambda(w http.ResponseWriter, r *http.Request)

RunLambda is an HTTP request handler that expects requests of form /runLambda/<lambdaName>. It extracts the lambda name from the request path and then chooses a worker to run the lambda workload using the configured load balancer. The lambda response is forwarded to the client "as-is" without any modifications.

func (*Scheduler) StatusCheckAllWorkers

func (s *Scheduler) StatusCheckAllWorkers(w http.ResponseWriter, r *http.Request)