0.3.3

core/gay.zharel.fateweaver.log/FateLogReader

FateLogReader

class FateLogReader(stream: InputStream) : AutoCloseable, Iterator<FateLogEntry>

Reads log files created by FateLogWriter.

Constructors

constructor(stream: InputStream)

Types

data class ChannelInfo(val name: String, val schema: FateSchema<*>)

object Companion

Functions

open override fun close()

fun getChannel(index: Int): FateLogReader.ChannelInfo?

Returns the channel info for the given index.

fun getChannels(): List<FateLogReader.ChannelInfo>

Returns all channels that have been registered in the log.

open operator override fun hasNext(): Boolean

open operator override fun next(): FateLogEntry

fun readAll(): List<FateLogEntry>

Returns all entries in the log as a list.

readMessagesForChannel

fun readMessagesForChannel(channelName: String): List<FateLogEntry.Message<*>>

Returns all message entries for the given channel name.