Interface StoreMetadata

    • Method Detail

      • getClusterName

        java.lang.String getClusterName()
      • getStoreName

        java.lang.String getStoreName()
      • getCurrentStoreVersion

        int getCurrentStoreVersion()
      • getPartitionId

        int getPartitionId​(int version,
                           java.nio.ByteBuffer key)
      • getPartitionId

        int getPartitionId​(int version,
                           byte[] key)
      • getReplicas

        java.util.List<java.lang.String> getReplicas​(int version,
                                                     int partitionId)
      • getReplicas

        default java.util.List<java.lang.String> getReplicas​(long requestId,
                                                             int version,
                                                             int partitionId,
                                                             int requiredReplicaCount)
        This function is expected to return fully qualified URI, such as: "https://fake.host:8888".
        Parameters:
        version -
        partitionId -
        Returns:
      • getReplicas

        java.util.List<java.lang.String> getReplicas​(long requestId,
                                                     int version,
                                                     int partitionId,
                                                     int requiredReplicaCount,
                                                     java.util.Set<java.lang.String> excludedInstances)
      • trackHealthBasedOnRequestToInstance

        ChainedCompletableFuture<java.lang.Integer,​java.lang.Integer> trackHealthBasedOnRequestToInstance​(java.lang.String instance,
                                                                                                                int version,
                                                                                                                int partitionId,
                                                                                                                java.util.concurrent.CompletableFuture<TransportClientResponse> transportFuture)
      • getBatchGetLimit

        int getBatchGetLimit()
      • start

        void start()
      • isReady

        default boolean isReady()