Package com.linkedin.venice.fastclient

Class RequestContext

java.lang.Object
com.linkedin.venice.fastclient.RequestContext
Direct Known Subclasses:
GetRequestContext, MultiKeyRequestContext
public abstract class RequestContext extends Object
This class is used to include all the intermediate fields required for the communication between the different tiers.

  • Constructor Details

    • RequestContext

      public RequestContext()

  • Method Details

    • getRequestType

      public abstract RequestType getRequestType()

    • setServerClusterName

      public void setServerClusterName(String serverClusterName)

    • getServerClusterName

      public String getServerClusterName()

    • setInstanceHealthMonitor

      public void setInstanceHealthMonitor(InstanceHealthMonitor instanceHealthMonitor)

    • getInstanceHealthMonitor

      public InstanceHealthMonitor getInstanceHealthMonitor()

    • isRetryRequest

      public boolean isRetryRequest()

    • setRetryRequest

      public void setRetryRequest(boolean retryRequest)

    • getResultFuture

      public CompletableFuture getResultFuture()

    • setResultFuture

      public void setResultFuture(CompletableFuture resultFuture)

    • setRequestId

      public void setRequestId(long requestId)

    • getRequestId

      public long getRequestId()

    • getHelixGroupId

      public int getHelixGroupId()

    • setHelixGroupId

      public void setHelixGroupId(int helixGroupId)

    • addNonAvailableReplicaPartition

      public void addNonAvailableReplicaPartition(int partitionId)

    • getNonAvailableReplicaPartitions

      public Set<Integer> getNonAvailableReplicaPartitions()

    • getCurrentVersion

      public int getCurrentVersion()

    • setCurrentVersion

      public void setCurrentVersion(int currentVersion)

    • getRouteRequestMap

      public Map<String,CompletableFuture<Integer>> getRouteRequestMap()

    • hasNonAvailablePartition

      public boolean hasNonAvailablePartition()

    • setRequestSerializationTime

      public void setRequestSerializationTime(double latency)