metrics/pro.respawn.flowmvi.metrics

Package-level declarations

Types

AppendableStringSink

class AppendableStringSink(appendable: Appendable) : Sink<String>

Sink that appends strings to an Appendable, one line per emit.

class ConsoleSink<T> : Sink<T>

Sink that writes snapshots using toString to stdout.

typealias MetricsSink = Sink<MetricsSnapshot>

Type alias for sinks that consume MetricsSnapshot.

Functions

fun <T> CompositeSink(vararg delegates: Sink<T>, parallel: Boolean = true): Sink<T>

Fan-out sink that forwards emissions to all delegates in parallel.

fun <T> JsonSink(delegate: Sink<String>, json: Json, serializer: SerializationStrategy<T>): Sink<T>

Serializes values with the provided serializer and forwards JSON strings to delegate.

LoggingJsonMetricsSink

fun LoggingJsonMetricsSink(json: Json, logger: StoreLogger = PlatformStoreLogger, level: StoreLogLevel = StoreLogLevel.Trace, tag: String = "Metrics"): MetricsSink

Ready-to-use JSON sink that logs via StoreLogger (PlatformStoreLogger by default).

inline fun <T, R> MappingSink(delegate: Sink<R>, crossinline map: (T) -> R): Sink<T>

Decorator that maps values before passing them to delegate.

fun <T> NoopSink(): Sink<T>

No-op sink used by default to disable metrics emission.

StoreLoggerSink

fun StoreLoggerSink(logger: StoreLogger = PlatformStoreLogger, level: StoreLogLevel = StoreLogLevel.Trace, tag: String = "Metrics"): Sink<String>

Sink that logs strings through a StoreLogger (defaults to PlatformStoreLogger).