Package com.linkedin.venice.client.store.transport

Class D2TransportClient

java.lang.Object

com.linkedin.venice.client.store.transport.TransportClient

com.linkedin.venice.client.store.transport.D2TransportClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class D2TransportClient
extends TransportClient

D2Client based TransportClient implementation.

Field Summary

Fields inherited from class com.linkedin.venice.client.store.transport.TransportClient

HTTPS

Constructor Summary

Constructors

Constructor	Description
D2TransportClient(String d2ServiceName, com.linkedin.d2.balancer.D2Client d2Client)	Construct by an existing D2Client (such as from the pegasus-d2-client-default-cmpt).
D2TransportClient(String d2ServiceName, ClientConfig clientConfig)	Construct by customized zookeeper and other configs.

Method Summary

Modifier and Type	Method	Description
void	close()
CompletableFuture<TransportClientResponse>	get(String requestPath, Map<String,String> headers)
com.linkedin.d2.balancer.D2Client	getD2Client()
String	getServiceName()
CompletableFuture<TransportClientResponse>	post(String requestPath, Map<String,String> headers, byte[] requestBody)
void	setRedirectNotifier(Runnable notifier)	Wires the redirect notifier once.
void	setServiceName(String newServiceName)	Plain setter for the D2 service name.
void	streamPost(String requestPath, Map<String,String> headers, byte[] requestBody, TransportClientStreamingCallback callback, int keyCount)
String	toString()

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

get, getCopyIfNotUsableInCallback, post

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

D2TransportClient

public D2TransportClient(String d2ServiceName,
 com.linkedin.d2.balancer.D2Client d2Client)

Construct by an existing D2Client (such as from the pegasus-d2-client-default-cmpt).

Parameters:

d2ServiceName -

d2Client -

D2TransportClient

public D2TransportClient(String d2ServiceName,
 ClientConfig clientConfig)

Construct by customized zookeeper and other configs.

Parameters:

d2ServiceName -

clientConfig -

Method Details

getServiceName

public String getServiceName()

setServiceName

public void setServiceName(String newServiceName)

Plain setter for the D2 service name. Null/empty values are ignored. Does not fire the redirect notifier — see redirectNotifier for the migration-only firing contract.

setRedirectNotifier

public void setRedirectNotifier(Runnable notifier)

Wires the redirect notifier once. The notifier runs after a 301-redirect-driven service-name change. Calling again with a non-null notifier throws IllegalStateException — only one notifier is supported per transport.

get

public CompletableFuture<TransportClientResponse> get(String requestPath,
 Map<String,String> headers)

Specified by:

get in class TransportClient

post

public CompletableFuture<TransportClientResponse> post(String requestPath,
 Map<String,String> headers,
 byte[] requestBody)

Specified by:

post in class TransportClient

streamPost

public void streamPost(String requestPath,
 Map<String,String> headers,
 byte[] requestBody,
 TransportClientStreamingCallback callback,
 int keyCount)

Specified by:

streamPost in class TransportClient

close

public void close()

getD2Client

public com.linkedin.d2.balancer.D2Client getD2Client()

toString

public String toString()

Overrides:

toString in class Object