Package com.eventstore.dbclient

Class EventStoreDBClusterClient

java.lang.Object

com.eventstore.dbclient.EventStoreDBClusterClient

public class EventStoreDBClusterClient
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected io.grpc.ManagedChannel	channel
protected java.util.UUID	currentChannelId
protected Endpoint	endpoint
protected java.lang.Exception	lastException
protected java.util.Optional<com.eventstore.dbclient.ServerInfo>	serverInfo
protected EventStoreDBClientSettings	settings
protected boolean	shutdown
protected io.grpc.netty.shaded.io.netty.handler.ssl.SslContext	sslContext

Constructor Summary

Constructors

Constructor	Description
EventStoreDBClusterClient(java.util.List<java.net.InetSocketAddress> seedNodes, Endpoint domainEndpoint, NodePreference nodePreference, io.grpc.netty.shaded.io.netty.handler.ssl.SslContext sslContext, EventStoreDBClientSettings settings)

Method Summary

Modifier and Type	Method	Description
protected io.grpc.ManagedChannel	createChannel(Endpoint endpoint)
protected java.util.concurrent.Executor	createConnectionLoopExecutor()
protected boolean	doConnect()
java.util.concurrent.CompletableFuture<Endpoint>	getCurrentEndpoint()
EventStoreDBClientSettings	getSettings()
protected void	pushMsg(com.eventstore.dbclient.GrpcClient.Msg msg)
<A> java.util.concurrent.CompletableFuture<A>	run(java.util.function.Function<io.grpc.ManagedChannel,java.util.concurrent.CompletableFuture<A>> action)
<A> java.util.concurrent.CompletableFuture<A>	runWithArgs(java.util.function.Function<com.eventstore.dbclient.GrpcClient.WorkItemArgs,java.util.concurrent.CompletableFuture<A>> action)
void	shutdown()
protected void	sleep(long millis)
protected void	startConnectionLoop()

Methods inherited from class java.lang.Object

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

Field Detail

settings

protected final EventStoreDBClientSettings settings

sslContext

protected final io.grpc.netty.shaded.io.netty.handler.ssl.SslContext sslContext

channel

protected io.grpc.ManagedChannel channel

endpoint

protected Endpoint endpoint

lastException

protected java.lang.Exception lastException

currentChannelId

protected java.util.UUID currentChannelId

serverInfo

protected java.util.Optional<com.eventstore.dbclient.ServerInfo> serverInfo

shutdown

protected volatile boolean shutdown

Constructor Detail

EventStoreDBClusterClient

public EventStoreDBClusterClient(java.util.List<java.net.InetSocketAddress> seedNodes,
                                 Endpoint domainEndpoint,
                                 NodePreference nodePreference,
                                 io.grpc.netty.shaded.io.netty.handler.ssl.SslContext sslContext,
                                 EventStoreDBClientSettings settings)

Method Detail

doConnect

protected boolean doConnect()

startConnectionLoop

protected void startConnectionLoop()

createConnectionLoopExecutor

protected java.util.concurrent.Executor createConnectionLoopExecutor()

pushMsg

protected void pushMsg(com.eventstore.dbclient.GrpcClient.Msg msg)

getSettings

public EventStoreDBClientSettings getSettings()

runWithArgs

public <A> java.util.concurrent.CompletableFuture<A> runWithArgs(java.util.function.Function<com.eventstore.dbclient.GrpcClient.WorkItemArgs,java.util.concurrent.CompletableFuture<A>> action)

run

public <A> java.util.concurrent.CompletableFuture<A> run(java.util.function.Function<io.grpc.ManagedChannel,java.util.concurrent.CompletableFuture<A>> action)

getCurrentEndpoint

public java.util.concurrent.CompletableFuture<Endpoint> getCurrentEndpoint()

sleep

protected void sleep(long millis)

createChannel

protected io.grpc.ManagedChannel createChannel(Endpoint endpoint)

shutdown

public void shutdown()
              throws java.util.concurrent.ExecutionException,
                     java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException