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

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.

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 to before the specified invocation.

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): ERROR CLASS: Symbol not found for Flow<com/google/adk/kt/events/Event>

Main entry method to run the agent in this runner.