watchserviceaccounts

Documentation

Index

• type Listener
• type Provider
  • func NewProvider(ctx context.Context, opts ProviderOptions) *Provider
  • func (p *Provider) AddListener(l Listener)
  • func (p *Provider) Close() error
  • func (p *Provider) Get(ctx context.Context, namespace, name string) (*corev1.ServiceAccount, error)
  • func (p *Provider) Start(ctx context.Context)
• type ProviderOptions

Types

type Listener

type Listener interface {
	UpdateServiceAccount(*corev1.ServiceAccount)
}

type Provider

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

func NewProvider

func NewProvider(ctx context.Context, opts ProviderOptions) *Provider

func (*Provider) AddListener

func (p *Provider) AddListener(l Listener)

func (*Provider) Close

func (p *Provider) Close() error

func (*Provider) Get

func (p *Provider) Get(ctx context.Context, namespace, name string) (*corev1.ServiceAccount, error)

func (*Provider) Start

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

type ProviderOptions

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