Version: v1.1.1 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Feb 23, 2023 License: Apache-2.0 Imports: 17 Imported by: 238




This section is empty.



func ConfigureApplyForObject added in v0.6.0

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


type ControllerMeta added in v0.3.0

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 added in v0.7.0

type Factory struct {
	// contains filtered or unexported fields

func NewFactoryFromConfigWithOptions added in v0.7.0

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

func (*Factory) ControllerFactory added in v0.7.0

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

func (*Factory) SetThreadiness added in v0.7.0

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

func (*Factory) Start added in v0.7.0

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

func (*Factory) Sync added in v0.7.0

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

type FactoryOptions added in v0.7.0

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

type GeneratingHandlerOptions added in v0.3.0

type GeneratingHandlerOptions struct {
	AllowCrossNamespace bool
	AllowClusterScoped  bool
	NoOwnerReference    bool
	DynamicLookup       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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL