程序包 com.alibaba.nacos.common.remote.client.grpc

类 GrpcConnection

java.lang.Object
com.alibaba.nacos.common.remote.client.Connection
com.alibaba.nacos.common.remote.client.grpc.GrpcConnection
所有已实现的接口:
com.alibaba.nacos.api.remote.Requester
public class GrpcConnection extends Connection
gRPC connection.
版本:
$Id: GrpcConnection.java, v 0.1 2020年08月09日 1:36 PM liuzunfei Exp $
作者:
liuzunfei

  • 字段详细资料

    • channel

      protected io.grpc.ManagedChannel channel
      grpc channel.

    • grpcFutureServiceStub

      protected com.alibaba.nacos.api.grpc.auto.RequestGrpc.RequestFutureStub grpcFutureServiceStub
      stub to send request.

    • payloadStreamObserver

      protected io.grpc.stub.StreamObserver<com.alibaba.nacos.api.grpc.auto.Payload> payloadStreamObserver

  • 构造器详细资料

  • 方法详细资料

    • request

      public com.alibaba.nacos.api.remote.response.Response request(com.alibaba.nacos.api.remote.request.Request request, long timeouts) throws com.alibaba.nacos.api.exception.NacosException
      抛出:
      com.alibaba.nacos.api.exception.NacosException

    • requestFuture

      public com.alibaba.nacos.api.remote.RequestFuture requestFuture(com.alibaba.nacos.api.remote.request.Request request) throws com.alibaba.nacos.api.exception.NacosException
      抛出:
      com.alibaba.nacos.api.exception.NacosException

    • sendResponse

      public void sendResponse(com.alibaba.nacos.api.remote.response.Response response)

    • sendRequest

      public void sendRequest(com.alibaba.nacos.api.remote.request.Request request)

    • asyncRequest

      public void asyncRequest(com.alibaba.nacos.api.remote.request.Request request, com.alibaba.nacos.api.remote.RequestCallBack requestCallBack) throws com.alibaba.nacos.api.exception.NacosException
      抛出:
      com.alibaba.nacos.api.exception.NacosException

    • close

      public void close()

    • getChannel

      public io.grpc.ManagedChannel getChannel()
      Getter method for property channel.
      返回:
      property value of channel

    • setChannel

      public void setChannel(io.grpc.ManagedChannel channel)
      Setter method for property channel.
      参数:
      channel - value to be assigned to property channel

    • getGrpcFutureServiceStub

      public com.alibaba.nacos.api.grpc.auto.RequestGrpc.RequestFutureStub getGrpcFutureServiceStub()
      Getter method for property grpcFutureServiceStub.
      返回:
      property value of grpcFutureServiceStub

    • setGrpcFutureServiceStub

      public void setGrpcFutureServiceStub(com.alibaba.nacos.api.grpc.auto.RequestGrpc.RequestFutureStub grpcFutureServiceStub)
      Setter method for property grpcFutureServiceStub.
      参数:
      grpcFutureServiceStub - value to be assigned to property grpcFutureServiceStub

    • getPayloadStreamObserver

      public io.grpc.stub.StreamObserver<com.alibaba.nacos.api.grpc.auto.Payload> getPayloadStreamObserver()
      Getter method for property payloadStreamObserver.
      返回:
      property value of payloadStreamObserver

    • setPayloadStreamObserver

      public void setPayloadStreamObserver(io.grpc.stub.StreamObserver<com.alibaba.nacos.api.grpc.auto.Payload> payloadStreamObserver)
      Setter method for property payloadStreamObserver.
      参数:
      payloadStreamObserver - value to be assigned to property payloadStreamObserver