dynamicwatcher

package

v0.2.1-0...-90e585d Latest Latest Go to latest Published: Jun 29, 2022 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/thetechnick/package-operator

Documentation ¶

Index ¶

type DynamicWatcher
- func New(log logr.Logger, scheme *runtime.Scheme, restMapper meta.RESTMapper, ...) *DynamicWatcher
type EnqueueWatchingObjects
type OwnerRef

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DynamicWatcher ¶

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

DynamicWatcher is able to dynamically allocate new watches for arbitrary objects. Multiple watches to the same resource, will be de-duplicated.

func New ¶

func New(
	log logr.Logger,
	scheme *runtime.Scheme,
	restMapper meta.RESTMapper,
	client dynamic.Interface,
) *DynamicWatcher

func (*DynamicWatcher) Free ¶

func (dw *DynamicWatcher) Free(owner client.Object) error

Free all watches associated with the given owner.

func (*DynamicWatcher) OwnersForNamespacedGKV ¶

func (dw *DynamicWatcher) OwnersForNamespacedGKV(ngvk namespacedGKV) []OwnerRef

func (*DynamicWatcher) Start ¶

func (dw *DynamicWatcher) Start(
	ctx context.Context,
	handler handler.EventHandler,
	queue workqueue.RateLimitingInterface,
	predicates ...predicate.Predicate,
) error

Starts this event source.

func (*DynamicWatcher) String ¶

func (dw *DynamicWatcher) String() string

func (*DynamicWatcher) Watch ¶

func (dw *DynamicWatcher) Watch(owner client.Object, obj runtime.Object) error

Watch the given object type and associate the watch with the given owner.

type EnqueueWatchingObjects ¶

type EnqueueWatchingObjects struct {
	WatcherRefGetter ownerRefGetter
	// WatcherType is the type of the Owner object to look for in OwnerReferences.  Only Group and Kind are compared.
	WatcherType runtime.Object
	// Whether the registered Watchers are namespace scoped or cluster scoped.
	ClusterScoped bool
	// contains filtered or unexported fields
}

Enqueues all objects watching the object mentioned in the event, filtered by WatcherType.

func (*EnqueueWatchingObjects) Create ¶

func (e *EnqueueWatchingObjects) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*EnqueueWatchingObjects) Delete ¶

func (e *EnqueueWatchingObjects) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*EnqueueWatchingObjects) Generic ¶

func (e *EnqueueWatchingObjects) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*EnqueueWatchingObjects) InjectScheme ¶

func (e *EnqueueWatchingObjects) InjectScheme(s *runtime.Scheme) error

InjectScheme is called by the Controller to provide a singleton scheme to the EnqueueRequestForOwner.

func (*EnqueueWatchingObjects) Update ¶

func (e *EnqueueWatchingObjects) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type OwnerRef ¶

type OwnerRef struct {
	UID       types.UID
	Group     string
	Kind      string
	Name      string
	Namespace string
}

Source Files ¶

View all Source files

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