informer

Documentation

Index

• type Factory
  • func NewFactory(client kubernetes.Interface, opts ...FactoryOption) (*Factory, error)
  • func (f *Factory) ForResource(r schema.Resource) (Informer, error)
  • func (f *Factory) Start(ctx context.Context)
  • func (f *Factory) Stop()
• type FactoryOption
  • func WithErrorHandler(fn watchers.ErrorHandler) FactoryOption
  • func WithResyncPeriod(p time.Duration) FactoryOption
• type Informer

Types

type Factory

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

func NewFactory

func NewFactory(client kubernetes.Interface, opts ...FactoryOption) (*Factory, error)

func (*Factory) ForResource

func (f *Factory) ForResource(r schema.Resource) (Informer, error)

func (*Factory) Start

func (f *Factory) Start(ctx context.Context)

func (*Factory) Stop

func (f *Factory) Stop()

type FactoryOption

type FactoryOption func(*Factory) error

func WithErrorHandler

func WithErrorHandler(fn watchers.ErrorHandler) FactoryOption

func WithResyncPeriod

func WithResyncPeriod(p time.Duration) FactoryOption

type Informer

type Informer interface {
	AddWatcher(watcher watchers.Watcher) error
}