scriptadmit

type Admission struct {
	Fixed             int
	Min               int
	Max               int
	MaxMemoryPercent  float64
	MaxCPUPercent     float64
	ShedMemoryPercent float64
}

type Admitter struct {
	Admission
	// contains filtered or unexported fields
}

type Config struct {
	// Concurrency is "adaptive" (the default, as are empty, zero and a
	// negative number) or a whole number of runs executed at once; 1 is the
	// one-at-a-time worker of earlier releases.
	Concurrency string `yaml:"concurrency"`
	// MaxConcurrency and MinConcurrency bound adaptive admission.
	MaxConcurrency int `yaml:"max_concurrency"`
	MinConcurrency int `yaml:"min_concurrency"`
	// MaxMemoryPercent and MaxCPUPercent are the shares of the container's
	// memory limit and CPU quota above which no further run is claimed;
	// ShedMemoryPercent is the memory above which the newest run is stopped.
	MaxMemoryPercent  float64 `yaml:"max_memory_percent"`
	MaxCPUPercent     float64 `yaml:"max_cpu_percent"`
	ShedMemoryPercent float64 `yaml:"shed_memory_percent"`
	// RunTimeout, MaxSteps and MaxQueryRows are a platform run's ceilings:
	// wall clock, interpreter steps, and the rows one platform.query may
	// return. The worker derives the claim lease from RunTimeout.
	RunTimeout   time.Duration `yaml:"run_timeout"`
	MaxSteps     int64         `yaml:"max_steps"`
	MaxQueryRows int           `yaml:"max_query_rows"`
	// ResultMaxBytes caps the value a run hands back with platform.result
	// (#1845, default 1 MiB).
	ResultMaxBytes int `yaml:"result_max_bytes"`
	// MaxReclaims is how many times a run is taken over from a worker whose
	// lease expired before it is failed instead (#1860, default 2).
	MaxReclaims int `yaml:"max_reclaims"`
	// MaxRunMemory is how much memory one run may hold (#1861): an absolute
	// size ("300MiB", "1GiB"), a share of the container's memory limit
	// ("50%"), or "unlimited". Empty is DefaultRunMemoryPercent of the limit
	// where the platform can read one, and no budget where it cannot.
	MaxRunMemory string `yaml:"max_run_memory"`
}

type LoadSource interface {
	Sample() procload.Sample
}