scheduler_service

Documentation

Overview

Package scheduler_service implements the code for query the scheduler service in other nodes.

Index

• func GetApiUrl(host string) string
• func GetLeastLoadedMachineOfNRandom(n uint, currentLoad uint, checkQueues bool) (string, float64, error)
• func GetMonitoringLoadUrl(host string) string
• func GetPeerFunctionUrl(host string, functionName string) string
• type APIResponse
  • func ExecuteFunction(host string, request *types.PeerJobRequest) (*APIResponse, error)
  • func GetLoad(host string) (int, *APIResponse, error)
• type NoLessLoadedMachine
  • func (n NoLessLoadedMachine) Error() string

Functions

func GetApiUrl

func GetApiUrl(host string) string

func GetLeastLoadedMachineOfNRandom

func GetLeastLoadedMachineOfNRandom(n uint, currentLoad uint, checkQueues bool) (string, float64, error)

getLeastLoadedMachine retrieves the least loaded machine from an array of ips, if all machines are full loaded, the least queue is returned, and if there is no less loaded queue than us, an error is returned. This function returns (ip, mean_probing_time, errors)

func GetMonitoringLoadUrl

func GetMonitoringLoadUrl(host string) string

func GetPeerFunctionUrl

func GetPeerFunctionUrl(host string, functionName string) string

Types

type APIResponse

type APIResponse struct {
	Headers    http.Header
	Body       []byte
	StatusCode int
}

func ExecuteFunction

func ExecuteFunction(host string, request *types.PeerJobRequest) (*APIResponse, error)

ExecuteFunction allows to request another machine to execute a function

func GetLoad

func GetLoad(host string) (int, *APIResponse, error)

GetLoad allows to get the load of another machine, from a machine

type NoLessLoadedMachine

type NoLessLoadedMachine struct {
	Reason string
}

func (NoLessLoadedMachine) Error

func (n NoLessLoadedMachine) Error() string