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(), plugins: List<Plugin> = emptyList())

Creates an InMemoryRunner from a root agent, its plugins, 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.

Types

Builder

class Builder

Fluent builder for InMemoryRunner, provided primarily for Java callers. Any property left unset falls back to the same default as the constructor.

Companion

object Companion

Properties

agent

override val agent: BaseAgent

The agent this runner runs. For a node-rooted runner this is a NodeViewAgent over the running node.

appName

override val appName: String

artifactService

override val artifactService: ArtifactService?

memoryService

override val memoryService: MemoryService?

node

override val node: Node?

The node this runner runs, set when rooted on a node graph. The go-forward field; once agent is removed it holds the running unit for every runner.

pluginManager

override val pluginManager: PluginManager

resumabilityConfig

override val resumabilityConfig: ResumabilityConfig

sessionService

override val sessionService: SessionService

Functions

open override fun close()

Closes this runner, releasing the resources it owns.

rewindAsync

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

Rewinds the session as Runner.rewindAsync describes, then flushes sessionService so the rewind is persisted.

run

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

Sync interface for local testing and convenience purpose.

runAsync

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

Main entry method to run the agent in this runner.

runLive

@ExperimentalLiveApi

open override fun runLive(userId: String, sessionId: String, liveRequestQueue: LiveRequestQueue, runConfig: RunConfig? = null): Flow<Event>

Runs the agent live as Runner.runLive describes. Flushes sessionService once per turn, when the turn completes or hands over to another agent or step, and when the run completes or fails; each flush is bounded, so a stuck session service fails the run instead of hanging it.