Package com.google.genkit.ai.agent.internal

package com.google.genkit.ai.agent.internal
  • Class
    Description
    AbortAwareMutator
    Wraps a SnapshotMutator so that it returns null (no-op) when the current row is already SnapshotStatus.ABORTED, preventing a completed or failed write from clobbering a concurrent abort.
    AgentActions
    Factory for defining custom agents.
    DetachController
    Runs a detached agent turn: writes a PENDING snapshot, suppresses streaming, starts a heartbeat, runs the turn on a background daemon thread, and finalizes the pending snapshot to a terminal status when the turn completes.
    DetachController.DetachedTurn<S>
    The body of a detached turn.
    InProcessTransport<S>
    In-process AgentTransport that drives a locally-defined Agent via its bidi action.
    LeafSelection
    Utility for selecting the leaf snapshot from a collection of snapshots in a session's parent-chain.
    PendingAbortRegistry
    Registry mapping a still-PENDING detached turn's snapshot id to the live AtomicBoolean abort signal handed to that turn's AgentFnContext.
    PointerDoc
    Tiny POJO representing the contents of a per-session pointer file.
    SessionResolver
    Resolves a Session from an AgentInit at the start of an agent invocation.
    SessionResolver.Resolution<S>
    Result of session resolution: either a ready Session, or a graceful pre-turn failure.
    SnapshotSharding
    Pure, backend-agnostic sharding / checkpoint / RFC-6902 reconstruction helpers shared by the Firestore, DynamoDB, and Cosmos DB session stores.
    StreamEmitter<S>
    Bridges Session state-change events to AgentStreamChunk emission for one invocation.