google-adk-kotlin-core/com.google.adk.kt.sessions

Package-level declarations

Types

class BufferedSessionService @JvmOverloads constructor(delegate: SessionService, context: CoroutineContext, config: BufferedSessionServiceConfig = BufferedSessionServiceConfig()) : SessionService, AutoCloseable

A SessionService that persists writes in the background: appendEvent updates the live session and returns, and a writer per session writes the events to delegate in order, and in order across sessions for app: and user: state, retrying as BufferedSessionServiceConfig.retryPolicy decides.

BufferedSessionServiceConfig

data class BufferedSessionServiceConfig @JvmOverloads constructor(val retryPolicy: RetryPolicy = ExponentialBackoff(), val cacheConfig: SessionCacheConfig? = null)

Configuration for a BufferedSessionService.

GetSessionConfig

data class GetSessionConfig(val numRecentEvents: Int? = null, val afterTimestamp: Instant? = null)

Configuration for getting a session.

InMemorySessionService

class InMemorySessionService : SessionService

An in-memory implementation of SessionService assuming Session objects are mutable regarding their state map, events list, and last update time.

ListEventsResponse

data class ListEventsResponse(val events: List<Event> = emptyList(), val nextPageToken: String? = null)

Response for listing events.

ListSessionsResponse

data class ListSessionsResponse(val sessions: List<Session> = emptyList())

Response for listing sessions.

Lock

interface Lock

A read/write lock.

Session

data class Session(val key: SessionKey, val state: State = State(), val events: MutableList<Event> = concurrentMutableListOf(), var lastUpdateTime: Instant = Instant.fromEpochMilliseconds(0))

A Session object that encapsulates the State and Events of a session.

SessionCacheConfig

data class SessionCacheConfig(val ttl: Duration = DEFAULT_TTL, val maxSessions: Int = DEFAULT_MAX_SESSIONS)

Configuration for the read cache of a BufferedSessionService.

SessionException

class SessionException(message: String, cause: Throwable? = null) : RuntimeException

Thrown when a SessionService operation fails. A caller that needs to act on one particular failure matches message against the constants declared here, so this stays one type rather than a hierarchy.

SessionKey

data class SessionKey(val appName: String, val userId: String, val id: String?)

Composite identifier for a Session.

SessionService

interface SessionService

Defines the contract for managing Sessions and their associated Events. Provides methods for creating, retrieving, listing, and deleting sessions, as well as listing and appending events to a session. Implementations of this interface handle the underlying storage and retrieval logic.

State

class State(initialState: Map<String, Any> = emptyMap(), initialDelta: Map<String, Any> = emptyMap()) : Map<String, Any>

A thread-safe state map that maintains the current value and tracks modifications.

VertexAiSessionService

class VertexAiSessionService : SessionService

A SessionService backed by the managed Vertex AI Session Service.

Functions

Lock

actual fun Lock(): Lock

expect fun Lock(): Lock

Creates a new Lock.