watchpods

Documentation

Index

• type Listener
• type Provider
  • func NewProvider(opts ProviderOptions) *Provider
  • func (p *Provider) AddListener(l Listener)
  • func (p *Provider) Close() error
  • func (p *Provider) GetByIP(ctx context.Context, ipAddr string) (*corev1.Pod, error)
  • func (p *Provider) Start(ctx context.Context)
• type ProviderOptions

Types

type Listener

type Listener interface {
	AddPod(*corev1.Pod)
	DeletePod(*corev1.Pod)
}

type Provider

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

func NewProvider

func NewProvider(opts ProviderOptions) *Provider

func (*Provider) AddListener

func (p *Provider) AddListener(l Listener)

func (*Provider) Close

func (p *Provider) Close() error

func (*Provider) GetByIP

func (p *Provider) GetByIP(ctx context.Context, ipAddr string) (*corev1.Pod, error)

func (*Provider) Start

func (p *Provider) Start(ctx context.Context)

type ProviderOptions

type ProviderOptions struct {
	NodeName         string
	MetricsSubsystem string
	FallbackSource   pods.Provider
	KubeClient       *kubernetes.Clientset
	MetricsRegistry  *prometheus.Registry
	ResyncPeriod     time.Duration
}