Package com.linkedin.venice.fastclient.transport

Class TransportClientResponseForRoute

java.lang.Object

com.linkedin.venice.client.store.transport.TransportClientResponse

com.linkedin.venice.fastclient.transport.TransportClientResponseForRoute

public class TransportClientResponseForRoute
extends TransportClientResponse

Constructor Summary

Constructors

Constructor	Description
TransportClientResponseForRoute(java.lang.String routeId, int schemaId, CompressionStrategy compressionStrategy, byte[] body, java.util.concurrent.CompletableFuture<java.lang.Integer> routeRequestFuture)

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
static TransportClientResponseForRoute	fromTransportClientWithRoute(TransportClientResponse transportClientResponse, java.lang.String replicaId, java.util.concurrent.CompletableFuture<java.lang.Integer> routeRequestFuture)
java.lang.String	getRouteId()
java.util.concurrent.CompletableFuture<java.lang.Integer>	getRouteRequestFuture()
int	hashCode()

Methods inherited from class com.linkedin.venice.client.store.transport.TransportClientResponse

getBody, getCompressionStrategy, getSchemaId, isSchemaIdValid

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportClientResponseForRoute

public TransportClientResponseForRoute(java.lang.String routeId,
                                       int schemaId,
                                       CompressionStrategy compressionStrategy,
                                       byte[] body,
                                       java.util.concurrent.CompletableFuture<java.lang.Integer> routeRequestFuture)

Method Detail

getRouteRequestFuture

public java.util.concurrent.CompletableFuture<java.lang.Integer> getRouteRequestFuture()

fromTransportClientWithRoute

public static TransportClientResponseForRoute fromTransportClientWithRoute(TransportClientResponse transportClientResponse,
                                                                           java.lang.String replicaId,
                                                                           java.util.concurrent.CompletableFuture<java.lang.Integer> routeRequestFuture)

getRouteId

public java.lang.String getRouteId()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class TransportClientResponse

hashCode

public int hashCode()

Overrides:

hashCode in class TransportClientResponse