engine

May 21, 2025

Changes in this version

type ControllerEngineOption

+ func WithMetrics(m Metrics) ControllerEngineOption

+ type Metrics interface

+ ControllerStarted func(name string)

+ ControllerStopped func(name string)

+ WatchStarted func(name string, t WatchType)

+ WatchStopped func(name string, t WatchType)

+ type NopMetrics struct

+ func (m *NopMetrics) ControllerStarted(_ string)

+ func (m *NopMetrics) ControllerStopped(_ string)

+ func (m *NopMetrics) WatchStarted(_ string, _ WatchType)

+ func (m *NopMetrics) WatchStopped(_ string, _ WatchType)

+ type PrometheusMetrics struct

+ func NewPrometheusMetrics() *PrometheusMetrics

+ func (m *PrometheusMetrics) Collect(ch chan<- prometheus.Metric)

+ func (m *PrometheusMetrics) ControllerStarted(name string)

+ func (m *PrometheusMetrics) ControllerStopped(name string)

+ func (m *PrometheusMetrics) Describe(ch chan<- *prometheus.Desc)

+ func (m *PrometheusMetrics) WatchStarted(name string, t WatchType)

+ func (m *PrometheusMetrics) WatchStopped(name string, t WatchType)

Feb 6, 2025

Changes in this version

type ControllerEngine

+ func (e *ControllerEngine) GetCached() client.Client

+ func (e *ControllerEngine) GetUncached() client.Client

Sep 12, 2024 GO-2024-3219

  GO-2024-3219: github.com/crossplane/crossplane: Unexpected behavior from Is methods for IPv4-mapped IPv6 addresses

Aug 28, 2024

Changes in this version

+ type ControllerEngine struct

+ func New(mgr manager.Manager, infs TrackingInformers, c client.Client, ...) *ControllerEngine

+ func (e *ControllerEngine) GarbageCollectCustomResourceInformers(ctx context.Context) error

+ func (e *ControllerEngine) GetClient() client.Client

+ func (e *ControllerEngine) GetFieldIndexer() client.FieldIndexer

+ func (e *ControllerEngine) GetWatches(name string) ([]WatchID, error)

+ func (e *ControllerEngine) IsRunning(name string) bool

+ func (e *ControllerEngine) Start(name string, o ...ControllerOption) error

+ func (e *ControllerEngine) StartWatches(name string, ws ...Watch) error

+ func (e *ControllerEngine) Stop(ctx context.Context, name string) error

+ func (e *ControllerEngine) StopWatches(ctx context.Context, name string, ws ...WatchID) (int, error)

+ type ControllerEngineOption func(*ControllerEngine)

+ func WithLogger(l logging.Logger) ControllerEngineOption

+ type ControllerOption func(o *ControllerOptions)

+ func WithNewControllerFn(fn NewControllerFn) ControllerOption

+ func WithRuntimeOptions(ko kcontroller.Options) ControllerOption

+ func WithWatchGarbageCollector(gc WatchGarbageCollector) ControllerOption

+ type ControllerOptions struct

+ type EventHandler struct

+ func NewEventHandler(ctx context.Context, q workqueue.RateLimitingInterface, h handler.EventHandler, ...) *EventHandler

+ func (e *EventHandler) HandlerFuncs() kcache.ResourceEventHandlerFuncs

+ func (e *EventHandler) OnAdd(obj interface{})

+ func (e *EventHandler) OnDelete(obj interface{})

+ func (e *EventHandler) OnUpdate(oldObj, newObj interface{})

+ type InformerTrackingCache struct

+ func TrackInformers(c cache.Cache, s *runtime.Scheme) *InformerTrackingCache

+ func (c *InformerTrackingCache) ActiveInformers() []schema.GroupVersionKind

+ func (c *InformerTrackingCache) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error

+ func (c *InformerTrackingCache) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error)

+ func (c *InformerTrackingCache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, ...) (cache.Informer, error)

+ func (c *InformerTrackingCache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

+ func (c *InformerTrackingCache) RemoveInformer(ctx context.Context, obj client.Object) error

+ type NewControllerFn func(name string, mgr manager.Manager, options kcontroller.Options) (kcontroller.Controller, error)

+ type StoppableSource struct

+ Type client.Object

+ func NewStoppableSource(infs cache.Informers, t client.Object, h handler.EventHandler, ...) *StoppableSource

+ func (s *StoppableSource) Start(ctx context.Context, q workqueue.RateLimitingInterface) error

+ func (s *StoppableSource) Stop(ctx context.Context) error

+ type TrackingInformers interface

+ ActiveInformers func() []schema.GroupVersionKind

+ type Watch struct

+ func WatchFor(kind client.Object, wt WatchType, h handler.EventHandler, ...) Watch

+ type WatchGarbageCollector interface

+ GarbageCollectWatches func(ctx context.Context, interval time.Duration)

+ type WatchID struct

+ GVK schema.GroupVersionKind

+ Type WatchType

+ type WatchType string

+ const WatchTypeClaim

+ const WatchTypeComposedResource

+ const WatchTypeCompositeResource

+ const WatchTypeCompositionRevision