程序包 io.agentscope.core.pipeline

接口 Pipeline<T>

类型参数:
T - Type of the pipeline result
所有已知实现类:
FanoutPipeline, SequentialPipeline
public interface Pipeline<T>
Base interface for pipeline execution in AgentScope. Pipelines provide orchestration of agents and operations in various patterns such as sequential, parallel (fanout), or custom flows.

  • 方法概要

    修饰符和类型
    方法
    说明
    default reactor.core.publisher.Mono<T>
    execute()
    Execute the pipeline with no input (for pipelines that don't need input).
    reactor.core.publisher.Mono<T>
    execute(Msg input)
    Execute the pipeline with the given input message.
    reactor.core.publisher.Mono<T>
    execute(Msg input, Class<?> structuredOutputClass)
    Execute the pipeline with the given input message and structured output.
    default reactor.core.publisher.Mono<T>
    execute(Class<?> structuredOutputClass)
    Execute the pipeline with no input but with structured output.
    default String
    getDescription()
    Get a description of this pipeline.

  • 方法详细资料

    • execute

      reactor.core.publisher.Mono<T> execute(Msg input)
      Execute the pipeline with the given input message.
      参数:
      input - Input message to process through the pipeline
      返回:
      Mono containing the pipeline result

    • execute

      reactor.core.publisher.Mono<T> execute(Msg input, Class<?> structuredOutputClass)
      Execute the pipeline with the given input message and structured output.
      参数:
      input - Input message to process through the pipeline
      structuredOutputClass - The class type for structured output
      返回:
      Mono containing the pipeline result with structured output

    • execute

      default reactor.core.publisher.Mono<T> execute()
      Execute the pipeline with no input (for pipelines that don't need input).
      返回:
      Mono containing the pipeline result

    • execute

      default reactor.core.publisher.Mono<T> execute(Class<?> structuredOutputClass)
      Execute the pipeline with no input but with structured output.
      参数:
      structuredOutputClass - The class type for structured output
      返回:
      Mono containing the pipeline result with structured output

    • getDescription

      default String getDescription()
      Get a description of this pipeline.
      返回:
      Human-readable description of the pipeline