probes

Nov 11, 2024

Changes in this version

+ const ProbeDelayVariance

+ var ProbeDelay = float64(time.Second.Milliseconds())

type ProbeResult

+ PreviousCheck metav1.Time

Nov 7, 2024

Changes in this version

+ const PROBE_TIMEOUT

+ var ExpectedResponses = []int

+ func TransportWithDNSResponse(overrides map[string]string, allowInsecureCertificates bool) http.RoundTripper

+ type Probe struct

+ Transport RoundTripperFunc

+ func NewProbe(probeConfig *v1alpha1.DNSHealthCheckProbe, headers v1alpha1.AdditionalHeaders) *Probe

+ func (w *Probe) ExecuteProbe(ctx context.Context, probe *v1alpha1.DNSHealthCheckProbe) <-chan struct{}

+ func (w *Probe) Start(clientctx context.Context, k8sClient client.Client) context.CancelFunc

+ type ProbeManager struct

+ func NewProbeManager() *ProbeManager

+ func (m *ProbeManager) EnsureProbeWorker(ctx context.Context, k8sClient client.Client, ...)

+ func (m *ProbeManager) StopProbeWorker(ctx context.Context, probeCR *v1alpha1.DNSHealthCheckProbe)

+ type ProbeResult struct

+ CheckedAt metav1.Time

+ Healthy bool

+ Reason string

+ Status int

+ type RoundTripperFunc func(*http.Request) (*http.Response, error)

+ func (fn RoundTripperFunc) RoundTrip(r *http.Request) (*http.Response, error)