informant

Aug 9, 2023

Changes in this version

+ const MaxMonitorProtocolVersion

+ const MinMonitorProtocolVersion

+ const MonitorHealthCheckDelay

+ const MonitorResponseTimeout

+ type Dispatcher struct

+ func NewDispatcher(logger *zap.Logger, addr string, notifier util.CondChannelSender) (disp Dispatcher, _ error)

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

+ func (disp *Dispatcher) DoHealthChecks(ctx context.Context)

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

+ type MonitorResult struct

+ Confirmation *api.UpscaleConfirmation

+ HealthCheck *api.HealthCheck

+ Result *api.DownscaleResult

Jun 16, 2023

Changes in this version

type AgentSet

+ func (s *AgentSet) Current() *Agent

+ func (s *AgentSet) CurrentIdStr() string

May 24, 2023

Changes in this version

type CgroupConfig

+ DoNotFreezeMoreOftenThanMillis uint

+ MemoryHighIncreaseByBytes uint64

+ MemoryHighIncreaseEveryMillis uint

type CgroupManager

+ func (c *CgroupManager) FetchMemoryHighBytes() (*uint64, error)

+ func (c *CgroupManager) SetMemHighBytes(bytes uint64) error

+ func (c *CgroupManager) SetMemLimits(limits memoryLimits) error

May 7, 2023

Changes in this version

+ const MaxProtocolVersion

+ const MinProtocolVersion

type State

+ func (s *State) HealthCheck(ctx context.Context, info *api.AgentIdentification) (*api.InformantHealthCheckResp, int, error)

Mar 10, 2023

Changes in this version

+ var DefaultFileCacheConfig FileCacheConfig = FileCacheConfig

+ var DefaultStateConfig StateConfig = StateConfig

+ type FileCacheConfig struct

+ InMemory bool

+ MinRemainingAfterCache uint64

+ ResourceMultiplier float64

+ SpreadFactor float64

+ func (c *FileCacheConfig) CalculateCacheSize(total uint64) uint64

+ func (c *FileCacheConfig) Validate() error

+ type FileCacheState struct

+ func (s *FileCacheState) GetFileCacheSize(ctx context.Context) (uint64, error)

+ func (s *FileCacheState) SetFileCacheSize(ctx context.Context, sizeInBytes uint64) (uint64, error)

type NewStateOpts

+ func WithPostgresFileCache(connStr string, config FileCacheConfig) NewStateOpts

+ type StateConfig struct

+ SysBufferBytes uint64

Feb 7, 2023

Changes in this version

+ const AgentUpscaleTimeout

type Agent

+ func (a *Agent) SpawnRequestUpscale(timeout time.Duration, handleError func(error))

+ func (a *Agent) Suspend(timeout time.Duration, handleError func(error))

type AgentSet

+ func (s *AgentSet) ReceivedUpscale()

+ func (s *AgentSet) RequestUpscale()

+ type CgroupConfig struct

+ MaxUpscaleWaitMillis uint

+ MemoryHighBufferBytes uint64

+ OOMBufferBytes uint64

+ SysBufferBytes uint64

+ var DefaultCgroupConfig CgroupConfig = CgroupConfig{ ... }

+ type CgroupManager struct

+ ErrCh <-chan error

+ MemoryHighEvent util.CondChannelReceiver

+ func NewCgroupManager(groupName string) (*CgroupManager, error)

+ func (c *CgroupManager) CurrentMemoryUsage() (uint64, error)

+ func (c *CgroupManager) FetchState() (cgroup2.State, error)

+ func (c *CgroupManager) Freeze() error

+ func (c *CgroupManager) SetHighMem(bytes uint64) error

+ func (c *CgroupManager) Thaw() error

+ type CgroupState struct

+ func (s *CgroupState) ReceivedUpscale()

+ type NewStateOpts struct

+ func WithCgroup(cgm *CgroupManager, config CgroupConfig) NewStateOpts

Feb 6, 2023

Changes in this version

+ const AgentBackgroundCheckDelay

+ const AgentBackgroundCheckTimeout

+ const AgentResumeTimeout

+ const AgentSuspendTimeout

+ const CheckDeadlockDelay

+ const CheckDeadlockTimeout

+ const PrometheusPort

+ const ProtocolVersion

+ type Agent struct

+ func (a *Agent) CheckID(timeout time.Duration) error

+ func (a *Agent) EnsureUnregistered() (wasCurrent bool)

+ func (a *Agent) Resume(timeout time.Duration) error

+ func (a *Agent) SpawnSuspend(timeout time.Duration, handleError func(error))

+ type AgentSet struct

+ func NewAgentSet() *AgentSet

+ func (s *AgentSet) Get(id uuid.UUID) (_ *Agent, ok bool)

+ func (s *AgentSet) RegisterNewAgent(info *api.AgentDesc) (uint32, int, error)

+ type State struct

+ func NewState(agents *AgentSet) *State

+ func (s *State) NotifyUpscale(newResources *api.RawResources) (*struct{}, int, error)

+ func (s *State) RegisterAgent(info *api.AgentDesc) (*api.InformantDesc, int, error)

+ func (s *State) TryDownscale(target *api.RawResources) (*api.DownscaleResult, int, error)

+ func (s *State) UnregisterAgent(info *api.AgentDesc) (*api.UnregisterAgent, int, error)