stream_class

type StreamClassMetricsReporter interface {

	// AddStreamClass registers a new stream class with the given kind, metric name, and tags for metrics reporting.
	AddStreamClass(kind string, metricName string, tags map[string]string)

	// RemoveStreamClass unregisters the stream class of the specified kind from metrics reporting.
	RemoveStreamClass(kind string)
}

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

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

type UnmanagedControllerFactory interface {

	// CreateStreamController creates an unmanaged controller for the given GroupVersionKind (GVK).
	CreateStreamController(ctx context.Context, gvk schema.GroupVersionKind, streamClass *v1.StreamClass) (controller.Controller, error)
}