controller

Documentation

Overview

Package controller provides helper methods for external controllers for Custom Task types.

Index

• func FilterRunRef(apiVersion, kind string) func(interface{}) bool

Functions

func FilterRunRef

func FilterRunRef(apiVersion, kind string) func(interface{}) bool

FilterRunRef returns a filter that can be passed to a Run Informer, which filters out Runs for apiVersion and kinds that a controller doesn't care about.

For example, a controller impl that wants to be notified of updates to Runs which reference a Task with apiVersion "example.dev/v0" and kind "Example":

runinformer.Get(ctx).Informer().AddEventHandler(cache.FilteringResourceEventHandler{
  FilterFunc: FilterRunRef("example.dev/v0", "Example"),
  Handler:    controller.HandleAll(impl.Enqueue),
})