manager

Documentation

Index

• Constants
• func AddExecutor(id string, workerCount int)
• func RecordHeartbeat(id string)
• func Schedule(ctx context.Context, calc LoadCalculator, source types.RequestSource)
• type Executor
  • func EligibleExecutors() []*Executor
  • func GetExecutor(id string) *Executor
• type ExponentialFunctionLoadCalculator
  • func (e *ExponentialFunctionLoadCalculator) Next() int
• type LoadCalculator
  • func NewExponentialLoadCalculator(minRps int, maxRps int) LoadCalculator
  • func NewLogarithmicLoadCalculator(minRps int, maxRps int) LoadCalculator
  • func NewStepFunctionLoadCalculator(minRps int, maxRps int, stepSize int) LoadCalculator
• type StepFunctionLoadCalculator
  • func (s *StepFunctionLoadCalculator) Next() int

Constants

const HeartbeatFrequencySeconds = 5

HeartbeatFrequencySeconds dictates the frequency of expected heartbeats from executors

const MaxMissedHeartbeats = 3

MaxMissedHeartbeats dictates the maximum number of heartbeats missed before we declare the executor dead

Functions

func AddExecutor

func AddExecutor(id string, workerCount int)

AddExecutor adds an Executor to the list of Executors to track.

func RecordHeartbeat

func RecordHeartbeat(id string)

RecordHeartbeat records a heartbeat for an executor by its id.

func Schedule

func Schedule(ctx context.Context,
	calc LoadCalculator,
	source types.RequestSource)

Types

type Executor

type Executor struct {
	Id            string
	HeartbeatTime time.Time
	Workers       int
	WorkChan      chan []types.Job
}

Executor represents a running client process that hosts worker threads. Each Executor can support up to #Workers simultaneously running Jobs.

func EligibleExecutors

func EligibleExecutors() []*Executor

EligibleExecutors returns an array of Executors that are currently alive and ready to receive work

func GetExecutor

func GetExecutor(id string) *Executor

GetExecutor returns an Executor by its id, if it exists. nil is returned otherwise.

type ExponentialFunctionLoadCalculator

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

func (*ExponentialFunctionLoadCalculator) Next

func (e *ExponentialFunctionLoadCalculator) Next() int

type LoadCalculator

type LoadCalculator interface {
	Next() int
}

func NewExponentialLoadCalculator

func NewExponentialLoadCalculator(minRps int, maxRps int) LoadCalculator

func NewLogarithmicLoadCalculator

func NewLogarithmicLoadCalculator(minRps int, maxRps int) LoadCalculator

func NewStepFunctionLoadCalculator

func NewStepFunctionLoadCalculator(minRps int, maxRps int, stepSize int) LoadCalculator

type StepFunctionLoadCalculator

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

func (*StepFunctionLoadCalculator) Next

func (s *StepFunctionLoadCalculator) Next() int