generic

Documentation

Index

• Variables
• func ConfigureApplyForObject(apply apply.Apply, obj metav1.Object, opts *GeneratingHandlerOptions) apply.Apply
• type ControllerMeta
• type Factory
  • func NewFactoryFromConfigWithOptions(config *rest.Config, opts *FactoryOptions) (*Factory, error)
  • func (c *Factory) ControllerFactory() controller.SharedControllerFactory
  • func (c *Factory) SetThreadiness(gvk schema.GroupVersionKind, threadiness int)
  • func (c *Factory) Start(ctx context.Context, defaultThreadiness int) error
  • func (c *Factory) Sync(ctx context.Context) error
• type FactoryOptions
• type GeneratingHandlerOptions
• type Handler
  • func NewRemoveHandler(name string, updater Updater, handler Handler) Handler
• type Updater

Variables

var ErrSkip = controller.ErrIgnore

Functions

func ConfigureApplyForObject

func ConfigureApplyForObject(apply apply.Apply, obj metav1.Object, opts *GeneratingHandlerOptions) apply.Apply

Types

type ControllerMeta

type ControllerMeta interface {
	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler Handler)
	Updater() Updater
}

type Factory

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

func NewFactoryFromConfigWithOptions

func NewFactoryFromConfigWithOptions(config *rest.Config, opts *FactoryOptions) (*Factory, error)

func (*Factory) ControllerFactory

func (c *Factory) ControllerFactory() controller.SharedControllerFactory

func (*Factory) SetThreadiness

func (c *Factory) SetThreadiness(gvk schema.GroupVersionKind, threadiness int)

func (*Factory) Start

func (c *Factory) Start(ctx context.Context, defaultThreadiness int) error

func (*Factory) Sync

func (c *Factory) Sync(ctx context.Context) error

type FactoryOptions

type FactoryOptions struct {
	Namespace               string
	Resync                  time.Duration
	SharedCacheFactory      cache.SharedCacheFactory
	SharedControllerFactory controller.SharedControllerFactory
	HealthCallback          func(bool)
}

type GeneratingHandlerOptions

type GeneratingHandlerOptions struct {
	AllowCrossNamespace bool
	AllowClusterScoped  bool
	NoOwnerReference    bool
	DynamicLookup       bool
	// UniqueApplyForResourceVersion will skip calling apply if the resource version didn't change from the previous execution
	UniqueApplyForResourceVersion bool
}

type Handler

type Handler func(key string, obj runtime.Object) (runtime.Object, error)

func NewRemoveHandler

func NewRemoveHandler(name string, updater Updater, handler Handler) Handler

type Updater

type Updater func(runtime.Object) (runtime.Object, error)