status

Mar 25, 2021

Changes in this version

type ProbeTarget

+ Port string

Apr 20, 2021

Changes in this version

+ type Manager interface

+ CancelPodProbing func(pod corev1.Pod)

+ CancelProbing func(sub eventingduckv1.SubscriberSpec)

+ IsReady func(ctx context.Context, ch messagingv1beta1.KafkaChannel, ...) (bool, error)

+ type ProbeTarget struct

+ PodIPs sets.String

+ PodPort string

+ URL *url.URL

+ type ProbeTargetLister interface

+ ListProbeTargets func(ctx context.Context, ch messagingv1beta1.KafkaChannel) (*ProbeTarget, error)

+ type Prober struct

+ func NewProber(logger *zap.SugaredLogger, targetLister ProbeTargetLister, ...) *Prober

+ func (m *Prober) CancelPodProbing(pod corev1.Pod)

+ func (m *Prober) CancelProbing(sub eventingduckv1.SubscriberSpec)

+ func (m *Prober) IsReady(ctx context.Context, ch messagingv1beta1.KafkaChannel, ...) (bool, error)

+ func (m *Prober) RefreshPodProbing(ctx context.Context)

+ func (m *Prober) Start(done <-chan struct{}) chan struct{}