程序包 com.alibaba.nacos.istio.common

类 AbstractConnection<MessageT>

java.lang.Object
com.alibaba.nacos.istio.common.AbstractConnection<MessageT>
直接已知子类:
McpConnection, XdsConnection
public abstract class AbstractConnection<MessageT> extends Object
AbstractConnection maintains the life cycle of the connection.
作者:
special.fy

  • 字段详细资料

    • streamObserver

      protected io.grpc.stub.StreamObserver<MessageT> streamObserver

  • 构造器详细资料

    • AbstractConnection

      public AbstractConnection(io.grpc.stub.StreamObserver<MessageT> streamObserver)

  • 方法详细资料

    • setConnectionId

      public void setConnectionId(String clientId)

    • getConnectionId

      public String getConnectionId()

    • addWatchedResource

      public void addWatchedResource(String resourceType, WatchedStatus watchedStatus)

    • getWatchedStatusByType

      public WatchedStatus getWatchedStatusByType(String resourceType)

    • push

      public abstract void push(MessageT message, WatchedStatus watchedStatus)
      Push data to grpc connection.
      参数:
      message - response
      watchedStatus - watched status