stream_class

Feb 12, 2026

Changes in this version

+ type StreamClassMetricsReporter interface

+ AddStreamClass func(kind string, metricName string, tags map[string]string)

+ RemoveStreamClass func(kind string)

+ type StreamClassReconciler struct

+ func NewStreamClassReconciler(client client.Client, streamControllerFactory UnmanagedControllerFactory, ...) *StreamClassReconciler

+ func (s *StreamClassReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

+ func (s *StreamClassReconciler) SetupWithManager(mgr runtime.Manager) error

+ type StreamControllerHandle struct

+ type UnmanagedControllerFactory interface

+ CreateStreamController func(ctx context.Context, gvk schema.GroupVersionKind, streamClass *v1.StreamClass) (controller.Controller, error)