core

Sep 24, 2024

Changes in this version

type SystemMetrics

+ MemoryCachedBytes float64

Jul 23, 2024

Changes in this version

+ func EstimateTrueWorkingSetSize(series []float64, cfg WssEstimatorConfig) float64

+ func ProjectNextHighest(series []float64, projectLen float64) float64

type ActionMonitorDownscale

+ TargetRevision vmv1.RevisionWithTime

type ActionMonitorUpscale

+ TargetRevision vmv1.RevisionWithTime

type ActionNeonVMRequest

+ TargetRevision vmv1.RevisionWithTime

type ActionPluginRequest

+ TargetRevision vmv1.RevisionWithTime

type Config

+ ObservabilityCallbacks ObservabilityCallbacks

+ RevisionSource RevisionSource

type LFCMetrics

+ ApproximateworkingSetSizeBuckets []float64

+ type ObservabilityCallbacks struct

+ MonitorLatency revsource.ObserveCallback

+ NeonVMLatency revsource.ObserveCallback

+ PluginLatency revsource.ObserveCallback

+ type RevisionSource interface

+ Next func(ts time.Time, flags vmv1.Flag) vmv1.Revision

+ Observe func(moment time.Time, rev vmv1.Revision) error

+ type WssEstimatorConfig struct

+ InitialOffset int

+ MaxAllowedIncreaseFactor float64

+ WindowSize int

Jun 17, 2024

Changes in this version

+ func ParseMetrics(content io.Reader, metrics FromPrometheus) error

+ type FromPrometheus interface

+ type LFCMetrics struct

+ ApproximateWorkingSetSizeTotal float64

+ CacheHitsTotal float64

+ CacheMissesTotal float64

+ CacheWritesTotal float64

type State

+ func (s *State) UpdateLFCMetrics(metrics LFCMetrics)

+ func (s *State) UpdateSystemMetrics(metrics SystemMetrics)

+ type SystemMetrics struct

+ LoadAverage1Min float64

+ MemoryUsageBytes float64

+ func (m SystemMetrics) ToAPI() api.Metrics

Apr 15, 2024

Changes in this version

+ type Metrics struct

+ LoadAverage1Min float32

+ MemoryUsageBytes float32

+ func ReadMetrics(nodeExporterOutput []byte, loadPrefix string) (m Metrics, err error)

+ func (m Metrics) ToAPI() api.Metrics

Jan 10, 2024

Changes in this version

type Config

+ ComputeUnit api.Resources

Dec 15, 2023

Changes in this version

type StateDump

+ func (d StateDump) MarshalJSON() ([]byte, error)

Oct 23, 2023

Changes in this version

type Config

+ MonitorDownscaleFollowUpWait time.Duration

Oct 17, 2023

Changes in this version

type ActionMonitorDownscale

+ func (a ActionMonitorDownscale) MarshalLogObject(enc zapcore.ObjectEncoder) error

type ActionMonitorUpscale

+ func (a ActionMonitorUpscale) MarshalLogObject(enc zapcore.ObjectEncoder) error

type ActionNeonVMRequest

+ func (a ActionNeonVMRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

type ActionPluginRequest

+ func (a ActionPluginRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

type ActionSet

+ func (s ActionSet) MarshalLogObject(enc zapcore.ObjectEncoder) error

type ActionWait

+ func (a ActionWait) MarshalLogObject(enc zapcore.ObjectEncoder) error

type Config

+ NeonVMRetryWait time.Duration

+ PluginRetryWait time.Duration

Oct 9, 2023

Changes in this version

+ type ActionMonitorDownscale struct

+ Current api.Resources

+ Target api.Resources

+ type ActionMonitorUpscale struct

+ Current api.Resources

+ Target api.Resources

+ type ActionNeonVMRequest struct

+ Current api.Resources

+ Target api.Resources

+ type ActionPluginRequest struct

+ LastPermit *api.Resources

+ Metrics *api.Metrics

+ Target api.Resources

+ type ActionSet struct

+ MonitorDownscale *ActionMonitorDownscale

+ MonitorUpscale *ActionMonitorUpscale

+ NeonVMRequest *ActionNeonVMRequest

+ PluginRequest *ActionPluginRequest

+ Wait *ActionWait

+ type ActionWait struct

+ Duration time.Duration

+ type Config struct

+ DefaultScalingConfig api.ScalingConfig

+ Log LogConfig

+ MonitorDeniedDownscaleCooldown time.Duration

+ MonitorRequestedUpscaleValidPeriod time.Duration

+ MonitorRetryWait time.Duration

+ PluginDeniedRetryWait time.Duration

+ PluginRequestTick time.Duration

+ type LogConfig struct

+ Info func(string, ...zap.Field)

+ Warn func(string, ...zap.Field)

+ type MonitorHandle struct

+ func (h MonitorHandle) Active(active bool)

+ func (h MonitorHandle) DownscaleRequestAllowed(now time.Time)

+ func (h MonitorHandle) DownscaleRequestDenied(now time.Time)

+ func (h MonitorHandle) DownscaleRequestFailed(now time.Time)

+ func (h MonitorHandle) Reset()

+ func (h MonitorHandle) StartingDownscaleRequest(now time.Time, resources api.Resources)

+ func (h MonitorHandle) StartingUpscaleRequest(now time.Time, resources api.Resources)

+ func (h MonitorHandle) UpscaleRequestFailed(now time.Time)

+ func (h MonitorHandle) UpscaleRequestSuccessful(now time.Time)

+ func (h MonitorHandle) UpscaleRequested(now time.Time, resources api.MoreResources)

+ type NeonVMHandle struct

+ func (h NeonVMHandle) RequestFailed(now time.Time)

+ func (h NeonVMHandle) RequestSuccessful(now time.Time)

+ func (h NeonVMHandle) StartingRequest(now time.Time, resources api.Resources)

+ type OngoingMonitorRequestDump struct

+ Kind monitorRequestKind

+ Requested api.Resources

+ type PluginHandle struct

+ func (h PluginHandle) NewScheduler()

+ func (h PluginHandle) RequestFailed(now time.Time)

+ func (h PluginHandle) RequestSuccessful(now time.Time, resp api.PluginResponse) error

+ func (h PluginHandle) SchedulerGone()

+ func (h PluginHandle) StartingRequest(now time.Time, resources api.Resources)

+ type State struct

+ func NewState(vm api.VmInfo, config Config) *State

+ func (s *State) Debug(enabled bool)

+ func (s *State) DesiredResourcesFromMetricsOrRequestedUpscaling(now time.Time) (api.Resources, func(ActionSet) *time.Duration)

+ func (s *State) Dump() StateDump

+ func (s *State) Monitor() MonitorHandle

+ func (s *State) NeonVM() NeonVMHandle

+ func (s *State) NextActions(now time.Time) ActionSet

+ func (s *State) Plugin() PluginHandle

+ func (s *State) UpdateMetrics(metrics api.Metrics)

+ func (s *State) UpdatedVM(vm api.VmInfo)

+ type StateDump struct

+ Config Config

+ Metrics *api.Metrics

+ Monitor monitorStateDump

+ NeonVM neonvmStateDump

+ Plugin pluginStateDump

+ VM api.VmInfo