agents-core/ai.koog.agents.core.feature.pipeline

Package-level declarations

Types

class AIAgentFunctionalPipeline(agentConfig: AIAgentConfig, clock: Clock = Clock.System) : AIAgentPipeline

Represents a specific implementation of an AI agent pipeline that does not use graph-based processing. This class inherits from the base AIAgentPipeline class and may be used for handling workflows or data processing tasks that do not require graph-based data structures.

AIAgentGraphPipeline

expect open class AIAgentGraphPipeline(agentConfig: AIAgentConfig, clock: Clock = Clock.System, basePipelineDelegate: AIAgentPipelineImpl = AIAgentPipelineImpl(agentConfig, clock)) : AIAgentPipeline, AIAgentGraphPipelineAPI

Represents a pipeline for AI agent graph execution, extending the functionality of AIAgentPipeline. This class manages the execution of specific nodes in the pipeline using registered handlers.

actual open class AIAgentGraphPipeline(agentConfig: AIAgentConfig, clock: Clock, basePipelineDelegate: AIAgentPipelineImpl) : AIAgentPipeline, AIAgentGraphPipelineAPI

AIAgentGraphPipelineAPI

interface AIAgentGraphPipelineAPI : AIAgentPipelineAPI

Public API surface for graph-specific pipeline operations (nodes and subgraphs).

AIAgentPipeline

expect abstract class AIAgentPipeline(agentConfig: AIAgentConfig, clock: Clock) : AIAgentPipelineAPI

Pipeline for AI agent features that provides interception points for various agent lifecycle events.

actual abstract class AIAgentPipeline(agentConfig: AIAgentConfig, clock: Clock) : AIAgentPipelineAPI

AIAgentPipelineAPI

interface AIAgentPipelineAPI

Platform-agnostic API for agent pipelines. Implemented by both the expect/actual AIAgentPipeline and the shared AIAgentPipelineImpl.

AIAgentPipelineImpl

class AIAgentPipelineImpl(val config: AIAgentConfig, val clock: Clock) : AIAgentPipelineAPI

Default implementation of AIAgentPipelineAPI

AIAgentPlannerPipeline

expect open class AIAgentPlannerPipeline(agentConfig: AIAgentConfig, clock: Clock = Clock.System, basePipelineDelegate: AIAgentPipelineImpl = AIAgentPipelineImpl(agentConfig, clock)) : AIAgentPipeline, AIAgentPlannerPipelineAPI

Represents a specific implementation of an AI agent pipeline that uses a planner approach.

actual open class AIAgentPlannerPipeline(agentConfig: AIAgentConfig, clock: Clock, basePipelineDelegate: AIAgentPipelineImpl) : AIAgentPipeline, AIAgentPlannerPipelineAPI

AIAgentPlannerPipelineAPI

interface AIAgentPlannerPipelineAPI : AIAgentPipelineAPI

Platform-agnostic API for planner agent pipelines, extending the base pipeline API with planner-specific functionality.

AIAgentPlannerPipelineImpl

class AIAgentPlannerPipelineImpl(config: AIAgentConfig, clock: Clock = kotlin.time.Clock.System, basePipelineDelegate: AIAgentPipelineImpl) : AIAgentPlannerPipelineAPI, AIAgentPipelineAPI

Default implementation of AIAgentPlannerPipelineAPI that delegates base pipeline operations to AIAgentPipelineImpl and implements planner-specific functionality.

AsyncInterceptor

fun interface AsyncInterceptor<ContextT>

Represents an asynchronous interceptor interface that processes a given context type. This interface is designed to be implemented to provide custom interceptor logic that can operate asynchronously using a CompletableFuture.

Interceptor

fun interface Interceptor<ContextT>

Represents an interceptor that can intercept and process a given context of type ContextT. This is a functional interface, allowing functional-style usage.

RegisteredFeature

class RegisteredFeature(val featureImpl: Any, val featureConfig: FeatureConfig)

Represents configured and installed agent feature implementation along with its configuration.

TransformInterceptor

fun interface TransformInterceptor<ContextT, DataT>

A functional interface designed to intercept and transform data of type DataT during processing, using a provided context of type ContextT.