io.goshawkdb.client

Class ConnectionFactory

java.lang.Object

io.goshawkdb.client.ConnectionFactory

public class ConnectionFactory
extends java.lang.Object

This class is used to construct connections to a GoshawkDB node or cluster.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_PORT
io.netty.channel.EventLoopGroup	group

Constructor Summary

Constructors

Constructor and Description
ConnectionFactory() Create a new ConnectionFactory using a new NioEventLoopGroup
ConnectionFactory(io.netty.channel.EventLoopGroup group) Create a new ConnectionFactory

Method Summary

Modifier and Type	Method and Description
Connection	connect(Certs certs, java.lang.String host) Create and start a connection to a GoshawkDB node using the default port (7894)
Connection	connect(Certs certs, java.lang.String host, int port) Create and start a connection to a GoshawkDB node using the specified port

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

group

public final io.netty.channel.EventLoopGroup group

Constructor Detail

ConnectionFactory

public ConnectionFactory()

Create a new ConnectionFactory using a new NioEventLoopGroup

ConnectionFactory

public ConnectionFactory(io.netty.channel.EventLoopGroup group)

Create a new ConnectionFactory

Parameters:

group - the netty EventLoopGroup to use

Method Detail

connect

public Connection connect(Certs certs,
                          java.lang.String host)
                   throws java.lang.InterruptedException

Create and start a connection to a GoshawkDB node using the default port (7894)

Parameters:

certs - The certificates to use for mutual authentication

host - The host to connect to (host name or IP address). This can be in host:port format

Returns:

a new connection

Throws:

java.lang.InterruptedException - if an interruption occurs during connection

connect

public Connection connect(Certs certs,
                          java.lang.String host,
                          int port)
                   throws java.lang.InterruptedException

Create and start a connection to a GoshawkDB node using the specified port

Parameters:

certs - The certificates to use for mutual authentication

host - The host to connect to (host name or IP address)

port - The port to connect to

Returns:

a new connection

Throws:

java.lang.InterruptedException - if an interruption occurs during connection