AbstractRunner

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())

Creates a runner from explicit fields, not using an App.

constructor(app: App, sessionService: SessionService, artifactService: ArtifactService?, memoryService: MemoryService?, skipClosingPlugins: Boolean = false)

override val agent: BaseAgent

val app: App?

override val appName: String

Applies the provided stateDelta to the given event.

open suspend override fun rewindAsync(userId: String, sessionId: String, rewindBeforeInvocationId: String)

Rewinds the session to before the specified invocation.

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.