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 {
	AddPodServiceAccount(*serviceaccounts.Reference)
	DeletePodServiceAccount(*serviceaccounts.Reference)
}

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
	FallbackSource  pods.Provider
	KubeClient      *kubernetes.Clientset
	MetricsRegistry *prometheus.Registry
	ResyncPeriod    time.Duration
}