Versions in this module Expand all Collapse all v1 v1.6.0 Jul 29, 2026 v1.5.2 Mar 19, 2026 Changes in this version + func NewAPIServerIdentityToHostNameDecoder(kubeClient kubernetes.Interface) (*apiServerIdentityDecoder, error) + type BackendSampler struct + SampleRunner sampler.Runner + func (bs *BackendSampler) GetConnectionType() monitorapi.BackendConnectionType + func (bs *BackendSampler) GetDisruptionBackendName() string + func (bs *BackendSampler) GetLoadBalancerType() string + func (bs *BackendSampler) GetLocator() monitorapi.Locator + func (bs *BackendSampler) GetProtocol() string + func (bs *BackendSampler) GetTargetServerName() string + func (bs *BackendSampler) GetURL() (string, error) + func (bs *BackendSampler) RunEndpointMonitoring(ctx context.Context, m monitorapi.RecorderWriter, ...) error + func (bs *BackendSampler) StartEndpointMonitoring(ctx context.Context, m monitorapi.RecorderWriter, ...) error + func (bs *BackendSampler) Stop() + type Factory interface + New func(TestConfiguration) (Sampler, error) + func NewDisruptionTestFactory(config *rest.Config, kubeClient kubernetes.Interface) Factory + type Sampler interface + GetConnectionType func() monitorapi.BackendConnectionType + GetDisruptionBackendName func() string + GetLoadBalancerType func() string + GetLocator func() monitorapi.Locator + GetProtocol func() string + GetTargetServerName func() string + GetURL func() (string, error) + RunEndpointMonitoring func(ctx context.Context, m monitorapi.RecorderWriter, ...) error + StartEndpointMonitoring func(ctx context.Context, m monitorapi.RecorderWriter, ...) error + Stop func() + type ServerNameType string + const KubeAPIServer + const OpenShiftAPIServer + type TestConfiguration struct + EnableShutdownResponseHeader bool + Path string + SampleInterval time.Duration + Source string + Timeout time.Duration + type TestDescriptor struct + ConnectionType monitorapi.BackendConnectionType + LoadBalancerType backend.LoadBalancerType + Protocol backend.ProtocolType + TargetServer ServerNameType + func (t TestDescriptor) DisruptionLocator() monitorapi.Locator + func (t TestDescriptor) GetConnectionType() monitorapi.BackendConnectionType + func (t TestDescriptor) GetLoadBalancerType() backend.LoadBalancerType + func (t TestDescriptor) GetProtocol() backend.ProtocolType + func (t TestDescriptor) GetTargetServerName() string + func (t TestDescriptor) Name() string + func (t TestDescriptor) ShutdownLocator() monitorapi.Locator + func (t TestDescriptor) Validate() error
Go to main page