FeatureMessageLogWriter

An abstract base class for implementing a stream feature provider that logs incoming feature messages into a provided logger instance.

targetLogger

The KLogger instance used for feature messages to be streamed into.

Constructors

constructor(targetLogger: KLogger, logLevel: FeatureMessageLogWriter.LogLevel = LogLevel.INFO)

Defines the logging levels supported by the system.

A StateFlow representing the current open state of the processor.

A filter for messages to be sent to message processors.

open suspend override fun close()

open suspend fun initialize()

Initializes the feature output stream provider to ensure it is ready for use.

Receives and processes an incoming feature message.

Sets the message filter used to determine which feature messages should be processed.

Converts the incoming ai.koog.agents.core.feature.message.FeatureMessage into a target logger message.