streampack-core/io.github.thibaultbee.streampack.core.elements.metrics/WithEndpointMetrics

WithEndpointMetrics

interface WithEndpointMetrics<out T : Any> : WithMetrics<EndpointMetrics<T>> (source)

A specific WithMetrics for EndpointMetrics.

The members from BasicEndpointMetrics represent cumulative metrics.

Inheritors

DynamicEndpoint

CompositeEndpointWithMetrics

ISinkWithMetricsInternal

Properties

abstract val metrics: EndpointMetrics<T>

Metrics of the element.

Functions

createMetricsTracker

fun WithEndpointMetrics<*>.createMetricsTracker(): EndpointMetricsTracker

Creates an EndpointMetricsTracker for this WithEndpointMetrics.

fun WithEndpointMetrics<*>.metricsFlow(interval: Duration = 1000.milliseconds): Flow<TrackedMetrics>

Returns a Flow that emits the BasicEndpointMetrics difference since the last emission. Every collector gets its own isolated EndpointMetricsTracker to prevent state collisions.