Class ControlPlaneClient

java.lang.Object
io.grpc.xds.client.ControlPlaneClient

final class ControlPlaneClient extends Object
Common base type for XdsClient implementations, which encapsulates the layer abstraction of the xDS RPC stream.
  • Field Details

  • Constructor Details

  • Method Details

    • shutdown

      void shutdown()
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • adjustResourceSubscription

      void adjustResourceSubscription(XdsResourceType<?> resourceType)
      Updates the resource subscription for the given resource type.
    • ackResponse

      void ackResponse(XdsResourceType<?> type, String versionInfo, String nonce)
      Accepts the update for the given resource type by updating the latest resource version and sends an ACK request to the management server.
    • nackResponse

      void nackResponse(XdsResourceType<?> type, String nonce, String errorDetail)
      Rejects the update for the given resource type and sends an NACK request (request with last accepted version) to the management server.
    • isInBackoff

      boolean isInBackoff()
      Returns true if the resource discovery is currently in backoff.
    • isReady

      boolean isReady()
    • readyHandler

      void readyHandler()
      Starts a timer for each requested resource that hasn't been responded to and has been waiting for the channel to get ready.
    • startRpcStream

      private void startRpcStream()
      Establishes the RPC connection by creating a new RPC stream on the given channel for xDS protocol communication.
    • fromTypeUrl

      @Nullable XdsResourceType<?> fromTypeUrl(String typeUrl)