Package com.twicedb.client.proxy

Class ClientProxy

java.lang.Object

com.twicedb.client.proxy.ClientProxy

public class ClientProxy
extends Object

A class for proxying network requests from the client to a TwiceDB server(s). Users should not instantiate this class directly; it should be instantiated automatically by the client.

Constructor Summary

Constructors

Constructor	Description
ClientProxy(String serverAddress, ClientConfig clientConfig)
ClientProxy(String zkAddress, String writerAddress, String readerAddress, ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
HealthCheckResponse	checkReader(HealthCheckRequest req)
HealthCheckResponse	checkWriter(HealthCheckRequest req)
protected static ByteBuffer	compressBlobWithCompressor(Compressor cmprsr, ByteString bytes)
protected Map<String,?>	getRetryingServiceConfig()
ReadResponseWithTiming	read(ReadRequest req)
ReadResponseWithTiming	readEvent(ReadRequest req)
Lsqt	readLsqt()
ReadResponseWithTiming	readObjects(ReadRequest req)
ServerStatus	status(ServerType serverType)
void	stop()
<any>	subscribe(SubscribeRequest sr, Function<SubscribeResponse,Boolean> cback)
protected ByteBuffer	uncompressBlob(ByteString bytes, int expectedUncompressedSize)
protected static ByteBuffer	uncompressBlobWithDecompressor(Decompressor dcmprsr, ByteString bytes, int expectedUncompressedSize)
WriteResponseWithTiming	write(WriteRequest req)

Methods inherited from class java.lang.Object

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

Constructor Details

ClientProxy

public ClientProxy(String serverAddress,
 ClientConfig clientConfig)

ClientProxy

public ClientProxy(String zkAddress,
 String writerAddress,
 String readerAddress,
 ClientConfig clientConfig)

Method Details

getRetryingServiceConfig

protected Map<String,?> getRetryingServiceConfig()

read

public ReadResponseWithTiming read(ReadRequest req)

readLsqt

public Lsqt readLsqt()

readEvent

public ReadResponseWithTiming readEvent(ReadRequest req)

uncompressBlobWithDecompressor

protected static ByteBuffer uncompressBlobWithDecompressor(Decompressor dcmprsr,
 ByteString bytes,
 int expectedUncompressedSize)

uncompressBlob

protected ByteBuffer uncompressBlob(ByteString bytes,
 int expectedUncompressedSize)

readObjects

public ReadResponseWithTiming readObjects(ReadRequest req)

compressBlobWithCompressor

protected static ByteBuffer compressBlobWithCompressor(Compressor cmprsr,
 ByteString bytes)

write

public WriteResponseWithTiming write(WriteRequest req)

checkReader

public HealthCheckResponse checkReader(HealthCheckRequest req)

checkWriter

public HealthCheckResponse checkWriter(HealthCheckRequest req)

stop

public void stop()

subscribe

public <any> subscribe(SubscribeRequest sr,
 Function<SubscribeResponse,Boolean> cback)

status

public ServerStatus status(ServerType serverType)