google-adk-kotlin-core/com.google.adk.kt.runners/InMemoryRunner

InMemoryRunner

open class InMemoryRunner : AbstractRunner

An in-memory implementation of a Runner that manages the lifecycle of a BaseAgent execution.

It provides default in-memory implementations for session, artifact, and memory services. It can be constructed either directly from a root agent or from an App.

Inheritors

ReplRunner

Constructors

InMemoryRunner

constructor(agent: BaseAgent, appName: String = "InMemoryRunner", sessionService: SessionService = InMemorySessionService(), artifactService: ArtifactService? = InMemoryArtifactService(), memoryService: MemoryService? = InMemoryMemoryService())

Creates an InMemoryRunner from a root agent and default in-memory services.

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

Creates an InMemoryRunner from an App, deriving its App.appName, App.rootAgent, App.plugins, and App.resumabilityConfig.

Creates an InMemoryRunner with an explicit pluginManager.

Creates an InMemoryRunner with an explicit resumabilityConfig.

Creates an InMemoryRunner with both an explicit pluginManager and resumabilityConfig.

Properties

agent

override val agent: BaseAgent

app

val app: App?

appName

override val appName: String

artifactService

override val artifactService: ArtifactService?

memoryService

override val memoryService: MemoryService?

pluginManager

override val pluginManager: PluginManager

resumabilityConfig

override val resumabilityConfig: ResumabilityConfig

sessionService

override val sessionService: SessionService

Functions

applyStateDelta

fun applyStateDelta(event: Event, stateDelta: Map<String, Any>?)

Applies the provided stateDelta to the given event.

rewindAsync

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

Rewinds the session to before the specified invocation.

run

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

Sync interface for local testing and convenience purpose.

runAsync

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.