watchnode

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) Get(ctx context.Context) (*corev1.Node, error)
  • func (p *Provider) Start(ctx context.Context)
• type ProviderOptions

Types

type Listener

type Listener interface {
	UpdateNodeServiceAccount(*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) Get

func (p *Provider) Get(ctx context.Context) (*corev1.Node, error)

func (*Provider) Start

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

type ProviderOptions

type ProviderOptions struct {
	NodeName              string
	FallbackSource        node.Provider
	KubeClient            *kubernetes.Clientset
	ResyncPeriod          time.Duration
	DefaultServiceAccount *serviceaccounts.Reference
}