agent

Jul 23, 2024

Changes in this version

+ func WrapHistogramVec(hist *prometheus.HistogramVec) revsource.ObserveCallback

type GlobalMetrics

+ func (m *GlobalMetrics) MonitorLatency() *prometheus.HistogramVec

+ func (m *GlobalMetrics) NeonVMLatency() *prometheus.HistogramVec

+ func (m *GlobalMetrics) PluginLatency() *prometheus.HistogramVec

Jun 17, 2024

Changes in this version

type MetricsConfig

+ LFC MetricsSourceConfig

+ System MetricsSourceConfig

+ type MetricsSourceConfig struct

+ Port uint16

+ RequestTimeoutSeconds uint

+ SecondsBetweenRequests uint

Apr 15, 2024

Changes in this version

type Config

+ NeonVM NeonVMConfig

+ RefreshStateIntervalSeconds uint

type MonitorConfig

+ MaxFailedRequestRate RateThresholdConfig

+ type NeonVMConfig struct

+ MaxFailedRequestRate RateThresholdConfig

+ RequestTimeoutSeconds uint

+ RetryFailedRequestSeconds uint

+ type RateThresholdConfig struct

+ IntervalSeconds uint

+ Threshold uint

type SchedulerConfig

+ MaxFailedRequestRate RateThresholdConfig

Jan 10, 2024

Changes in this version

type ScalingConfig

+ ComputeUnit api.Resources

Dec 8, 2023

Changes in this version

type Runner

+ func (r *Runner) DoSchedulerRequest(ctx context.Context, logger *zap.Logger, resources api.Resources, ...) (_ *api.PluginResponse, err error)

Nov 16, 2023

Changes in this version

+ type GlobalMetrics struct

+ type PerVMMetrics struct

Oct 23, 2023

Changes in this version

type MonitorConfig

+ DeniedDownscaleFollowUpWaitSeconds uint

Oct 17, 2023

Changes in this version

type ScalingConfig

+ RetryFailedRequestSeconds uint

type SchedulerConfig

+ RetryFailedRequestSeconds uint

Oct 9, 2023

Changes in this version

type Dispatcher

+ func (disp *Dispatcher) ExitError() error

+ func (disp *Dispatcher) ExitSignal() <-chan struct{}

+ func (disp *Dispatcher) Exited() bool

type MetricsConfig

+ Port uint16

type MonitorConfig

+ ConnectionRetryMinWaitSeconds uint

+ MaxHealthCheckSequentialFailuresSeconds uint

+ RequestedUpscaleValidSeconds uint

+ RetryDeniedDownscaleSeconds uint

+ RetryFailedRequestSeconds uint

+ ServerPort uint16

+ UnhealthyAfterSilenceDurationSeconds uint

+ UnhealthyStartupGracePeriodSeconds uint

+ type MonitorState struct

+ WaitersSize int

type RunnerState

+ ExecutorState executor.StateDump

+ Monitor *MonitorState

type SchedulerConfig

+ RequestAtLeastEverySeconds uint

+ RetryDeniedUpscaleSeconds uint

Sep 18, 2023

Changes in this version

type RunnerState

+ RequestedUpscale api.MoreResources

Sep 2, 2023

Changes in this version

+ type AtomicUpdateState struct

+ ComputeUnit api.Resources

+ Config api.ScalingConfig

+ LastApproved api.Resources

+ Metrics api.Metrics

+ RequestedUpscale api.MoreResources

+ VM api.VmInfo

+ func (s *AtomicUpdateState) DesiredVMState(allowDecrease bool) api.Resources

Aug 24, 2023

Changes in this version

type MonitorConfig

+ ConnectionTimeoutSeconds uint

Aug 17, 2023

Changes in this version

+ const MaxMonitorProtocolVersion

+ const MinMonitorProtocolVersion

type Config

+ Monitor MonitorConfig

+ type Dispatcher struct

+ func NewDispatcher(logger *zap.Logger, addr string, parent *InformantServer) (disp Dispatcher, _ error)

+ func (disp *Dispatcher) Call(ctx context.Context, sender util.SignalSender[*MonitorResult], message any) error

+ func (disp *Dispatcher) HandleMessage(ctx context.Context, logger *zap.Logger, handlers messageHandlerFuncs) error

type InformantServer

+ func (s *InformantServer) MonitorDownscale(ctx context.Context, logger *zap.Logger, to api.Resources) (*api.DownscaleResult, error)

+ func (s *InformantServer) MonitorHealthCheck(ctx context.Context, logger *zap.Logger) error

+ func (s *InformantServer) MonitorUpscale(ctx context.Context, logger *zap.Logger, to api.Resources) error

+ type MonitorConfig struct

+ ResponseTimeoutSeconds uint

+ type MonitorResult struct

+ Confirmation *api.UpscaleConfirmation

+ HealthCheck *api.HealthCheck

+ Result *api.DownscaleResult

Aug 9, 2023

Changes in this version

+ type HttpMuxServer struct

+ func StartHttpMuxServer(logger *zap.Logger, port int) (*HttpMuxServer, error)

+ func (s *HttpMuxServer) RegisterMux(muxID string, subServer *http.ServeMux) error

+ func (s *HttpMuxServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *HttpMuxServer) UnregisterMux(muxID string)

type InformantConfig

+ CallbackPort int

May 24, 2023

Changes in this version

+ const RunnerRestartMaxWaitSeconds

+ const RunnerRestartMinWaitSeconds

May 7, 2023

Changes in this version

type InformantServer

+ func (s *InformantServer) HealthCheck(ctx context.Context) (*api.InformantHealthCheckResp, error)

type ScalingConfig

+ DefaultConfig api.ScalingConfig

Apr 15, 2023

Changes in this version

type InformantConfig

+ UnhealthyAfterSilenceDurationSeconds uint

+ UnhealthyStartupGracePeriodSeconds uint

+ type PromMetrics struct

+ type VMNodeIndex struct

+ func NewVMNodeIndex(node string) *VMNodeIndex

+ func (i *VMNodeIndex) Add(vm *vmapi.VirtualMachine)

+ func (i *VMNodeIndex) Delete(vm *vmapi.VirtualMachine)

+ func (i *VMNodeIndex) List() []*vmapi.VirtualMachine

+ func (i *VMNodeIndex) Update(oldVM, newVM *vmapi.VirtualMachine)

+ type VMStoreForNode = util.IndexedWatchStore[vmapi.VirtualMachine, *VMNodeIndex]

type VMUpdateReason

+ const UpdatedVMInfo

Apr 9, 2023

Changes in this version

type RunnerState

+ SchedulerRespondedWithMigration bool

Mar 29, 2023

Changes in this version

type Config

+ DumpState *DumpStateConfig

+ type DumpStateConfig struct

+ Port uint16

+ TimeoutSeconds uint

+ type StateDump struct

+ BuildInfo util.BuildInfo

+ Pods []podStateDump

+ Stopped bool

Mar 14, 2023

Changes in this version

type BillingConfig

+ ActiveTimeMetricName string

Feb 28, 2023

Changes in this version

+ const EndpointLabel

+ func RunBillingMetricsCollector(backgroundCtx context.Context, conf *BillingConfig, targetNode string, ...)

+ type BillingConfig struct

+ CPUMetricName string

+ CollectEverySeconds uint

+ PushEverySeconds uint

+ PushTimeoutSeconds uint

+ URL string

type Config

+ Billing *BillingConfig

Feb 26, 2023

Changes in this version

+ const PluginProtocolVersion

Feb 7, 2023

Changes in this version

type InformantServerState

+ ProtoVersion *api.InformantProtoVersion

type VMUpdateReason

+ const UpscaleRequested

Feb 6, 2023

Changes in this version

+ const MaxInformantProtocolVersion

+ const MinInformantProtocolVersion

+ var InformantServerAlreadyExitedError error = errors.New("Informant server has already exited")

+ var InformantServerNotCurrentError error = errors.New("Informant server has been replaced")

+ var InformantServerSuspendedError error = errors.New("Informant server is currently suspended")

+ var InformantServerUnconfirmedError error = errors.New("Informant server has not yet been confirmed")

+ func IsNormalInformantError(err error) bool

+ type Config struct

+ Informant InformantConfig

+ Metrics MetricsConfig

+ Scaling ScalingConfig

+ Scheduler SchedulerConfig

+ func ReadConfig(path string) (*Config, error)

+ type EnvArgs struct

+ ConfigPath string

+ K8sNodeName string

+ K8sPodIP string

+ func ArgsFromEnv() (EnvArgs, error)

+ type InformantConfig struct

+ DownscaleTimeoutSeconds uint

+ RegisterRetrySeconds uint

+ RegisterTimeoutSeconds uint

+ RequestTimeoutSeconds uint

+ RetryServerMinWaitSeconds uint

+ RetryServerNormalWaitSeconds uint

+ ServerPort uint16

+ type InformantServer struct

+ func NewInformantServer(ctx context.Context, runner *Runner, updatedInformant util.CondChannelSender) (*InformantServer, util.SignalReceiver, error)

+ func (s *InformantServer) Downscale(ctx context.Context, to api.Resources) (*api.DownscaleResult, error)

+ func (s *InformantServer) ExitStatus() *InformantServerExitStatus

+ func (s *InformantServer) RegisterWithInformant(ctx context.Context) error

+ func (s *InformantServer) Upscale(ctx context.Context, to api.Resources) error

+ func (s *InformantServer) Valid() error

+ type InformantServerExitStatus struct

+ Err error

+ RetryShouldFix bool

+ type InformantServerMode string

+ const InformantServerRunning

+ const InformantServerSuspended

+ const InformantServerUnconfirmed

+ type InformantServerState struct

+ Desc api.AgentDesc

+ ExitStatus *InformantServerExitStatus

+ MadeContact bool

+ Mode InformantServerMode

+ ReceivedIDCheck bool

+ SeqNum uint64

+ type MainRunner struct

+ Config *Config

+ EnvArgs EnvArgs

+ KubeClient *kubernetes.Clientset

+ VMClient *vmclient.Clientset

+ func (r MainRunner) Run() error

+ type MetricsConfig struct

+ LoadMetricPrefix string

+ RequestTimeoutSeconds uint

+ SecondsBetweenRequests uint

+ type Runner struct

+ func (r *Runner) Run(ctx context.Context, vmName string) error

+ func (r *Runner) Spawn(ctx context.Context, vmName string)

+ func (r *Runner) State() RunnerState

+ type RunnerLogger struct

+ func (l RunnerLogger) Errorf(format string, args ...interface{})

+ func (l RunnerLogger) Fatalf(format string, args ...interface{})

+ func (l RunnerLogger) Infof(format string, args ...interface{})

+ func (l RunnerLogger) Warningf(format string, args ...interface{})

+ type RunnerState struct

+ BackgroundWorkerCount int64

+ ComputeUnit *api.Resources

+ Informant *api.InformantDesc

+ LastApproved *api.Resources

+ LastInformantError error

+ LastMetrics *api.Metrics

+ LastSchedulerError error

+ LogPrefix string

+ PodIP string

+ Scheduler *SchedulerState

+ Server *InformantServerState

+ VM api.VmInfo

+ type ScalingConfig struct

+ RequestTimeoutSeconds uint

+ type Scheduler struct

+ func (s *Scheduler) DoRequest(ctx context.Context, reqData *api.AgentRequest) (*api.PluginResponse, error)

+ func (s *Scheduler) Register(ctx context.Context, signalOk func()) error

+ type SchedulerConfig struct

+ RequestPort uint16

+ RequestTimeoutSeconds uint

+ SchedulerName string

+ type SchedulerState struct

+ FatalError error

+ Info schedulerInfo

+ LogPrefix string

+ Registered bool

+ type VMUpdateReason string

+ const RegisteredScheduler

+ const UpdatedMetrics