core/io.devconsole.core/EventPipeline

EventPipeline

class EventPipeline(sessionId: UUID, capacity: Int, redactionEngine: RedactionEngine = RedactionEngine(RedactionPolicy.default()))

Constructors

Link copied to clipboard
constructor(sessionId: UUID, capacity: Int, redactionEngine: RedactionEngine = RedactionEngine(RedactionPolicy.default()))

Properties

Link copied to clipboard
val health: StateFlow<SdkHealth>

Functions

Link copied to clipboard
@Synchronized
fun publish(draft: EventDraft): EventEnvelope
Link copied to clipboard
@Synchronized
fun snapshot(): List<EventEnvelope>
Link copied to clipboard
Link copied to clipboard
Generated by Dokka
© 2026 Copyright