org.apache.tinkerpop.gremlin.driver

Class Client

java.lang.Object

org.apache.tinkerpop.gremlin.driver.Client

Direct Known Subclasses:

Client.ClusteredClient, Client.ReboundClusteredClient, Client.SessionedClient

public abstract class Client
extends Object

A Client is constructed from a Cluster and represents a way to send messages to Gremlin Server. This class itself is a base class as there are different implementations that provide differing kinds of functionality. See the implementations for specifics on their individual usage.

The Client is designed to be re-used and shared across threads.

Author:

Stephen Mallette (http://stephen.genoprime.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Client.ClusteredClient A Client implementation that does not operate in a session.
static class	Client.ReboundClusteredClient Uses a Client.ClusteredClient that rebinds requests to a specified Graph or TraversalSource instances on the server-side.
static class	Client.SessionedClient A Client implementation that operates in the context of a session.

Field Summary

Fields

Modifier and Type	Field and Description
protected Cluster	cluster
protected boolean	initialized

Method Summary

Modifier and Type	Method and Description
RequestMessage	buildMessage(RequestMessage.Builder builder) Makes any final changes to the builder and returns the constructed RequestMessage.
protected abstract org.apache.tinkerpop.gremlin.driver.Connection	chooseConnection(RequestMessage msg) Chooses a Connection to write the message to.
void	close() Closes the client by making a synchronous call to closeAsync().
abstract CompletableFuture<Void>	closeAsync() Asynchronous close of the Client.
Client	init() Initializes the client which typically means that a connection is established to the server.
protected abstract void	initializeImplementation() Called in the init() method.
abstract Client	rebind(String graphOrTraversalSource) Create a new Client that rebinds the specified Graph or TraversalSource name on the server to a variable called "g" for the context of the requests made through that Client.
ResultSet	submit(String gremlin) Submits a Gremlin script to the server and returns a ResultSet once the write of the request is complete.
ResultSet	submit(String gremlin, Map<String,Object> parameters) Submits a Gremlin script and bound parameters to the server and returns a ResultSet once the write of the request is complete.
CompletableFuture<ResultSet>	submitAsync(RequestMessage msg) A low-level method that allows the submission of a manually constructed RequestMessage.
CompletableFuture<ResultSet>	submitAsync(String gremlin) The asynchronous version of submit(String) where the returned future will complete when the write of the request completes.
CompletableFuture<ResultSet>	submitAsync(String gremlin, Map<String,Object> parameters) The asynchronous version of submit(String, Map)} where the returned future will complete when the write of the request completes.

Methods inherited from class java.lang.Object

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

Field Detail

cluster

protected final Cluster cluster

initialized

protected volatile boolean initialized

Method Detail

buildMessage

public RequestMessage buildMessage(RequestMessage.Builder builder)

Makes any final changes to the builder and returns the constructed RequestMessage. Implementers may choose to override this message to append data to the request before sending. By default, this method will simply call the RequestMessage.Builder.create() and return the RequestMessage.

initializeImplementation

protected abstract void initializeImplementation()

Called in the init() method.

chooseConnection

protected abstract org.apache.tinkerpop.gremlin.driver.Connection chooseConnection(RequestMessage msg)
                                                                            throws TimeoutException,
                                                                                   ConnectionException

Chooses a Connection to write the message to.

Throws:

TimeoutException

ConnectionException

closeAsync

public abstract CompletableFuture<Void> closeAsync()

Asynchronous close of the Client.

rebind

public abstract Client rebind(String graphOrTraversalSource)

Create a new Client that rebinds the specified Graph or TraversalSource name on the server to a variable called "g" for the context of the requests made through that Client.

Parameters:

graphOrTraversalSource - rebinds the specified global Gremlin Server variable to "g"

init

public Client init()

Initializes the client which typically means that a connection is established to the server. Depending on the implementation and configuration this blocking call may take some time. This method will be called automatically if it is not called directly and multiple calls will not have effect.

submit

public ResultSet submit(String gremlin)

Submits a Gremlin script to the server and returns a ResultSet once the write of the request is complete.

Parameters:

gremlin - the gremlin script to execute

submit

public ResultSet submit(String gremlin,
                        Map<String,Object> parameters)

Submits a Gremlin script and bound parameters to the server and returns a ResultSet once the write of the request is complete. If a script is to be executed repeatedly with slightly different arguments, prefer this method to concatenating a Gremlin script from dynamically produced strings and sending it to submit(String). Parameterized scripts will perform better.

Parameters:

gremlin - the gremlin script to execute

parameters - a map of parameters that will be bound to the script on execution

submitAsync

public CompletableFuture<ResultSet> submitAsync(String gremlin)

The asynchronous version of submit(String) where the returned future will complete when the write of the request completes.

Parameters:

gremlin - the gremlin script to execute

submitAsync

public CompletableFuture<ResultSet> submitAsync(String gremlin,
                                                Map<String,Object> parameters)

The asynchronous version of submit(String, Map)} where the returned future will complete when the write of the request completes.

Parameters:

gremlin - the gremlin script to execute

parameters - a map of parameters that will be bound to the script on execution

submitAsync

public CompletableFuture<ResultSet> submitAsync(RequestMessage msg)

A low-level method that allows the submission of a manually constructed RequestMessage.

close

public void close()

Closes the client by making a synchronous call to closeAsync().