multiinstance

Feb 19, 2026

Changes in this version

+ const SchedulingQueueSize

+ type DiagnosticsExposer interface

+ RegisterInstance func(manager.ID, http.Handler)

+ UnregisterInstance func(manager.ID)

+ type DiagnosticsServer struct

+ func NewDiagnosticsServer(listenerPort int, opts ...DiagnosticsServerOption) *DiagnosticsServer

+ func (s *DiagnosticsServer) RegisterInstance(instanceID manager.ID, instanceDiagnosticsHandler http.Handler)

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

+ func (s *DiagnosticsServer) Start(ctx context.Context) error

+ func (s *DiagnosticsServer) UnregisterInstance(instanceID manager.ID)

+ type DiagnosticsServerOption func(*DiagnosticsServer)

+ func WithPprofHandler() DiagnosticsServerOption

+ type InstanceNotFoundError struct

+ func NewInstanceNotFoundError(id manager.ID) InstanceNotFoundError

+ func (e InstanceNotFoundError) Error() string

+ type InstanceWithIDAlreadyScheduledError struct

+ func NewInstanceWithIDAlreadyScheduledError(id manager.ID) InstanceWithIDAlreadyScheduledError

+ func (e InstanceWithIDAlreadyScheduledError) Error() string

+ type Manager struct

+ func NewManager(logger logr.Logger, opts ...ManagerOption) *Manager

+ func (m *Manager) GetInstanceConfigHash(id manager.ID) (string, error)

+ func (m *Manager) IsInstanceReady(id manager.ID) error

+ func (m *Manager) ScheduleInstance(in ManagerInstance) error

+ func (m *Manager) Start(ctx context.Context) error

+ func (m *Manager) StopInstance(instanceID manager.ID) error

+ type ManagerInstance interface

+ Config func() managercfg.Config

+ DiagnosticsHandler func() http.Handler

+ ID func() manager.ID

+ IsReady func() error

+ KongValidator func() admission.KongHTTPValidator

+ Run func(context.Context) error

+ type ManagerOption func(*Manager)

+ func WithDiagnosticsExposer(exposer DiagnosticsExposer) ManagerOption

+ func WithValidator(admissionReqHandler *admission.RequestHandler) ManagerOption