status

Documentation

Index

• type Manager
• type ProbeTarget
• type ProbeTargetLister
• type Prober
  • 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 messagingv1alpha1.KafkaTopicChannel, ...) (bool, error)
  • func (m *Prober) RefreshPodProbing(ctx context.Context)
  • func (m *Prober) Start(done <-chan struct{}) chan struct{}

Types

type Manager

type Manager interface {
	IsReady(ctx context.Context, ch messagingv1alpha1.KafkaTopicChannel, sub eventingduckv1.SubscriberSpec) (bool, error)
	CancelProbing(sub eventingduckv1.SubscriberSpec)
	CancelPodProbing(pod corev1.Pod)
}

Manager provides a way to check if a Subscription is ready

type ProbeTarget

type ProbeTarget struct {
	PodIPs  sets.String
	PodPort string
	URL     *url.URL
}

ProbeTarget contains the URLs to probes for a set of Pod IPs serving out of the same port.

type ProbeTargetLister

type ProbeTargetLister interface {
	// ListProbeTargets returns a list of targets to be probed
	ListProbeTargets(ctx context.Context, ch messagingv1alpha1.KafkaTopicChannel) (*ProbeTarget, error)
}

ProbeTargetLister lists all the targets that requires probing.

type Prober

type Prober struct {
	// contains filtered or unexported fields
}

Prober provides a way to check if a VirtualService is ready by probing the Envoy pods handling that VirtualService.

func NewProber

func NewProber(
	logger *zap.SugaredLogger,
	targetLister ProbeTargetLister,
	readyCallback func(messagingv1alpha1.KafkaTopicChannel, eventingduckv1.SubscriberSpec), opts ...interface{}) *Prober

NewProber creates a new instance of Prober

func (*Prober) CancelPodProbing

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

CancelPodProbing cancels probing of the provided Pod IP.

func (*Prober) CancelProbing

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

CancelProbing cancels probing of the provided Subscription

func (*Prober) IsReady

func (m *Prober) IsReady(ctx context.Context, ch messagingv1alpha1.KafkaTopicChannel, sub eventingduckv1.SubscriberSpec) (bool, error)

func (*Prober) RefreshPodProbing

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

RefreshPodProbing lists probe targets and invalidates any in-flight (non-ready) states whose initial probed targets changed from the current ones.

func (*Prober) Start

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

Start starts the Manager background operations