AgentDataPlaneServiceStub
public static final class AgentDataPlaneServiceStub extends io.grpc.stub.AbstractAsyncStub<AgentDataPlaneServiceStub>源码Source
io/agentscope/controlplane/proto/AgentDataPlaneServiceGrpc.java:147–167智能体数据面服务存根，承载智能体的部署、调度与服务化运行。位于 io.agentscope.controlplane.proto 包，继承自 io.grpc.stub.AbstractAsyncStub<AgentDataPlaneServiceStub>。核心成员包括 build、connect。
A stub to allow clients to do asynchronous rpc calls to service AgentDataPlaneService.
AgentDataPlaneService is the ASDP gRPC service.
Single bidirectional stream multiplexing all message types (analogous to xDS ADS).
方法摘要Method Summary
方法详情Method Detail
build
protected AgentDataPlaneServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)构建并返回最终实例。
Creates and returns an instance.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
channel | io.grpc.Channel | 渠道（类型 `io.grpc.Channel`）。The channel. |
callOptions | io.grpc.CallOptions | 调用选项（类型 `io.grpc.CallOptions`）。The call options. |
AgentDataPlaneServiceStub返回AgentDataPlaneServiceStub。Returns agent data plane service stub.
源码Source
io/agentscope/controlplane/proto/AgentDataPlaneServiceGrpc.java:154–158connect
public io.grpc.stub.StreamObserver<io.agentscope.controlplane.proto.Upstream> connect(io.grpc.stub.StreamObserver<io.agentscope.controlplane.proto.Downstream> responseObserver)建立连接并完成初始化。
Performs the connect operation.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
responseObserver | io.grpc.stub.StreamObserver<io.agentscope.controlplane.proto.Downstream> | 响应观察者（类型 `io.grpc.stub.StreamObserver`）。The response observer. |
io.grpc.stub.StreamObserver<io.agentscope.controlplane.proto.Upstream>返回io.gRPC.存根.StreamObserver。Returns io grpc stub stream observer.
源码Source
io/agentscope/controlplane/proto/AgentDataPlaneServiceGrpc.java:162–166