discovery

Documentation

Index

• func NewResourceLister(pl v1listers.PodLister, sl v1listers.ServiceLister, nl v1listers.NodeLister) discovery.ResourceLister
• func NotifyOfChanges(get func() discovery.Config, notify func(), interval time.Duration, ...)
• type AuthChecker
  • func NewAuthChecker(accessGetter authv1.SelfSubjectAccessReviewInterface, namespace string, ...) *AuthChecker
  • func TestAuthChecker(accessGetter authv1.SelfSubjectAccessReviewInterface, namespace string, ...) *AuthChecker
  • func (checker *AuthChecker) CanListSecrets() bool
• type Manager
  • func NewDiscoveryManager(cfg RunConfig) *Manager
  • func (dm *Manager) Pause()
  • func (dm *Manager) Resume()
  • func (dm *Manager) Start()
  • func (dm *Manager) Stop()
• type RunConfig

Functions

func NewResourceLister

func NewResourceLister(pl v1listers.PodLister, sl v1listers.ServiceLister, nl v1listers.NodeLister) discovery.ResourceLister

func NotifyOfChanges

func NotifyOfChanges(get func() discovery.Config, notify func(), interval time.Duration, stopCh chan struct{})

Types

type AuthChecker

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

func NewAuthChecker

func NewAuthChecker(accessGetter authv1.SelfSubjectAccessReviewInterface, namespace string, refreshInterval time.Duration, reportInterval time.Duration) *AuthChecker

func TestAuthChecker

func TestAuthChecker(accessGetter authv1.SelfSubjectAccessReviewInterface, namespace string, refreshInterval time.Duration, reportInterval time.Duration, logger func(format string, args ...interface{})) *AuthChecker

func (*AuthChecker) CanListSecrets

func (checker *AuthChecker) CanListSecrets() bool

type Manager

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

Manager manages the discovery of kubernetes targets based on annotations or configuration rules.

func NewDiscoveryManager

func NewDiscoveryManager(cfg RunConfig) *Manager

NewDiscoveryManager creates a new instance of a discovery manager based on the given configuration.

func (*Manager) Pause

func (dm *Manager) Pause()

func (*Manager) Resume

func (dm *Manager) Resume()

func (*Manager) Start

func (dm *Manager) Start()

func (*Manager) Stop

func (dm *Manager) Stop()

type RunConfig

type RunConfig struct {
	KubeClient      kubernetes.Interface
	DiscoveryConfig discovery.Config
	Handler         metrics.ProviderHandler
	Lister          discovery.ResourceLister
	ScrapeCluster   bool
}

RunConfig encapsulates the runtime configuration required for a discovery manager