controller

Documentation

Index

• type Filter
• type FilterFuncs
  • func (f FilterFuncs) Add(obj v1.Object) bool
  • func (f FilterFuncs) Delete(obj v1.Object) bool
  • func (f FilterFuncs) Parent(obj v1.Object) (namespace, name string)
  • func (f FilterFuncs) Update(oldObj, newObj v1.Object) bool
• type InformerGetter
• type InformerOption
  • func WithNoSync() InformerOption
• type KeySyncer
• type Option
  • func WithInformer(getter InformerGetter, filter ParentFilter, opts ...InformerOption) Option
  • func WithInformerSynced(getter InformerGetter) Option
  • func WithInitialEvent(namespace, name string) Option
  • func WithMaxRetries(maxRetries int) Option
  • func WithRateLimiter(limiter workqueue.RateLimiter) Option
• type ParentFilter
  • func FilterByNames(parentFunc ParentFunc, names ...string) ParentFilter
• type ParentFunc
• type Runner
  • func New(name string, sync KeySyncer, opts ...Option) Runner
• type SyncFunc
• type Syncer

Types

type Filter

type Filter interface {
	Add(obj v1.Object) bool
	Update(oldObj, newObj v1.Object) bool
	Delete(obj v1.Object) bool
}

type FilterFuncs

type FilterFuncs struct {
	ParentFunc ParentFunc
	AddFunc    func(obj v1.Object) bool
	UpdateFunc func(oldObj, newObj v1.Object) bool
	DeleteFunc func(obj v1.Object) bool
}

func (FilterFuncs) Add

func (f FilterFuncs) Add(obj v1.Object) bool

func (FilterFuncs) Delete

func (f FilterFuncs) Delete(obj v1.Object) bool

func (FilterFuncs) Parent

func (f FilterFuncs) Parent(obj v1.Object) (namespace, name string)

func (FilterFuncs) Update

func (f FilterFuncs) Update(oldObj, newObj v1.Object) bool

type InformerGetter

type InformerGetter interface {
	Informer() cache.SharedIndexInformer
}

type InformerOption

type InformerOption func() informerOptionCase // public so it can be referenced out of this package

func WithNoSync

func WithNoSync() InformerOption

public opt-out of sync

type KeySyncer

type KeySyncer interface {
	Key(namespace, name string) (v1.Object, error)
	Syncer
}

type Option

type Option func(*controller)

func WithInformer

func WithInformer(getter InformerGetter, filter ParentFilter, opts ...InformerOption) Option

func WithInformerSynced

func WithInformerSynced(getter InformerGetter) Option

func WithInitialEvent

func WithInitialEvent(namespace, name string) Option

func WithMaxRetries

func WithMaxRetries(maxRetries int) Option

func WithRateLimiter

func WithRateLimiter(limiter workqueue.RateLimiter) Option

type ParentFilter

type ParentFilter interface {
	Parent(obj v1.Object) (namespace, name string)
	Filter
}

func FilterByNames

func FilterByNames(parentFunc ParentFunc, names ...string) ParentFilter

type ParentFunc

type ParentFunc func(obj v1.Object) (namespace, name string)

type Runner

type Runner interface {
	Run(workers int, stopCh <-chan struct{})
}

func New

func New(name string, sync KeySyncer, opts ...Option) Runner

type SyncFunc

type SyncFunc func(v1.Object) error

type Syncer

type Syncer interface {
	Sync(v1.Object) error
}