AbstractRunner

abstract class AbstractRunner(val appName: String, val agent: BaseAgent, val sessionService: SessionService, val artifactService: ArtifactService?, val memoryService: MemoryService?, val pluginManager: PluginManager, val resumabilityConfig: ResumabilityConfig = ResumabilityConfig()) : Runner

An abstract base class for Runner implementations that provides common orchestration logic.

Constructors

constructor(appName: String, agent: BaseAgent, sessionService: SessionService, artifactService: ArtifactService?, memoryService: MemoryService?, pluginManager: PluginManager, resumabilityConfig: ResumabilityConfig = ResumabilityConfig())

open override val agent: BaseAgent

open override val appName: String

Applies the provided stateDelta to the given event.

open override fun run(userId: String, sessionId: String, newMessage: Content, runConfig: RunConfig?): Iterator<Event>

Sync interface for local testing and convenience purpose.

open override fun runAsync(userId: String, sessionId: String, invocationId: String?, newMessage: Content?, stateDelta: Map<String, Any>?, runConfig: RunConfig?): Flow<Event>

Main entry method to run the agent in this runner.