public class DefaultCoreEnvironment extends Object implements CoreEnvironment
Modifier and Type | Class and Description |
---|---|
static class |
DefaultCoreEnvironment.Builder |
Modifier and Type | Field and Description |
---|---|
static int |
BOOTSTRAP_CARRIER_DIRECT_PORT |
static boolean |
BOOTSTRAP_CARRIER_ENABLED |
static int |
BOOTSTRAP_CARRIER_SSL_PORT |
static int |
BOOTSTRAP_HTTP_DIRECT_PORT |
static boolean |
BOOTSTRAP_HTTP_ENABLED |
static int |
BOOTSTRAP_HTTP_SSL_PORT |
static int |
COMPUTATION_POOL_SIZE |
static int |
IO_POOL_SIZE |
static int |
KEYVALUE_ENDPOINTS |
static String |
PACKAGE_NAME_AND_VERSION |
static boolean |
QUERY_ENABLED |
static int |
QUERY_ENDPOINTS |
static int |
QUERY_PORT |
static int |
REQUEST_BUFFER_SIZE |
static int |
RESPONSE_BUFFER_SIZE |
static boolean |
SSL_ENABLED |
static String |
SSL_KEYSTORE_FILE |
static String |
SSL_KEYSTORE_PASSWORD |
static String |
USER_AGENT |
static int |
VIEW_ENDPOINTS |
Modifier | Constructor and Description |
---|---|
protected |
DefaultCoreEnvironment(DefaultCoreEnvironment.Builder builder) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
booleanPropertyOr(String path,
boolean def) |
int |
bootstrapCarrierDirectPort()
The port to use when bootstrapping through carrier publication without SSL.
|
boolean |
bootstrapCarrierEnabled() |
int |
bootstrapCarrierSslPort()
The port to use when bootstrapping through carrier publication with SSL.
|
int |
bootstrapHttpDirectPort()
The port to use when bootstrapping through HTTP without SSL.
|
boolean |
bootstrapHttpEnabled() |
int |
bootstrapHttpSslPort()
The port to use when bootstrapping through HTTP with SSL.
|
static DefaultCoreEnvironment.Builder |
builder() |
int |
computationPoolSize() |
static DefaultCoreEnvironment |
create() |
protected int |
intPropertyOr(String path,
int def) |
EventLoopGroup |
ioPool()
Returns the IO pool for the underlying IO framework.
|
int |
ioPoolSize()
Returns the configured IO pool size.
|
int |
kvEndpoints()
The number of key/value service endpoints.
|
protected static long |
longPropertyOr(String path,
long def) |
String |
packageNameAndVersion()
Returns name and the version of the package.
|
boolean |
queryEnabled() |
int |
queryEndpoints()
The number of query service endpoints.
|
int |
queryPort() |
int |
requestBufferSize()
Returns the size of the request ringbuffer.
|
int |
responseBufferSize()
Returns the size of the response ringbuffer.
|
Scheduler |
scheduler()
Returns the scheduler which should be used for all core actions that need to happen asynchronously.
|
Observable<Boolean> |
shutdown()
Shutdown the
CoreEnvironment . |
boolean |
sslEnabled()
Identifies if SSL should be enabled.
|
String |
sslKeystoreFile() |
String |
sslKeystorePassword() |
protected String |
stringPropertyOr(String path,
String def) |
String |
toString() |
String |
userAgent()
Library identification string, which can be used as User-Agent header in HTTP requests.
|
int |
viewEndpoints()
The number of view service endpoints.
|
public static final boolean SSL_ENABLED
public static final String SSL_KEYSTORE_FILE
public static final String SSL_KEYSTORE_PASSWORD
public static final boolean QUERY_ENABLED
public static final int QUERY_PORT
public static final boolean BOOTSTRAP_HTTP_ENABLED
public static final boolean BOOTSTRAP_CARRIER_ENABLED
public static final int BOOTSTRAP_HTTP_DIRECT_PORT
public static final int BOOTSTRAP_HTTP_SSL_PORT
public static final int BOOTSTRAP_CARRIER_DIRECT_PORT
public static final int BOOTSTRAP_CARRIER_SSL_PORT
public static final int REQUEST_BUFFER_SIZE
public static final int RESPONSE_BUFFER_SIZE
public static final int IO_POOL_SIZE
public static final int COMPUTATION_POOL_SIZE
public static final int KEYVALUE_ENDPOINTS
public static final int VIEW_ENDPOINTS
public static final int QUERY_ENDPOINTS
public static String PACKAGE_NAME_AND_VERSION
public static String USER_AGENT
protected DefaultCoreEnvironment(DefaultCoreEnvironment.Builder builder)
public static DefaultCoreEnvironment create()
public static DefaultCoreEnvironment.Builder builder()
protected boolean booleanPropertyOr(String path, boolean def)
protected int intPropertyOr(String path, int def)
protected static long longPropertyOr(String path, long def)
public EventLoopGroup ioPool()
CoreEnvironment
Returns the IO pool for the underlying IO framework.
ioPool
in interface CoreEnvironment
public Observable<Boolean> shutdown()
CoreEnvironment
Shutdown the CoreEnvironment
.
shutdown
in interface CoreEnvironment
public Scheduler scheduler()
CoreEnvironment
Returns the scheduler which should be used for all core actions that need to happen asynchronously.
scheduler
in interface CoreEnvironment
public boolean sslEnabled()
CoreEnvironment
Identifies if SSL should be enabled.
sslEnabled
in interface CoreEnvironment
public String sslKeystoreFile()
sslKeystoreFile
in interface CoreEnvironment
public String sslKeystorePassword()
sslKeystorePassword
in interface CoreEnvironment
public boolean queryEnabled()
queryEnabled
in interface CoreEnvironment
public int queryPort()
queryPort
in interface CoreEnvironment
public boolean bootstrapHttpEnabled()
bootstrapHttpEnabled
in interface CoreEnvironment
public boolean bootstrapCarrierEnabled()
bootstrapCarrierEnabled
in interface CoreEnvironment
public int bootstrapHttpDirectPort()
CoreEnvironment
The port to use when bootstrapping through HTTP without SSL.
bootstrapHttpDirectPort
in interface CoreEnvironment
public int bootstrapHttpSslPort()
CoreEnvironment
The port to use when bootstrapping through HTTP with SSL.
bootstrapHttpSslPort
in interface CoreEnvironment
public int bootstrapCarrierDirectPort()
CoreEnvironment
The port to use when bootstrapping through carrier publication without SSL.
bootstrapCarrierDirectPort
in interface CoreEnvironment
public int bootstrapCarrierSslPort()
CoreEnvironment
The port to use when bootstrapping through carrier publication with SSL.
bootstrapCarrierSslPort
in interface CoreEnvironment
public int ioPoolSize()
CoreEnvironment
Returns the configured IO pool size.
ioPoolSize
in interface CoreEnvironment
public int computationPoolSize()
computationPoolSize
in interface CoreEnvironment
public int requestBufferSize()
CoreEnvironment
Returns the size of the request ringbuffer.
requestBufferSize
in interface CoreEnvironment
public int responseBufferSize()
CoreEnvironment
Returns the size of the response ringbuffer.
responseBufferSize
in interface CoreEnvironment
public int kvEndpoints()
CoreEnvironment
The number of key/value service endpoints.
kvEndpoints
in interface CoreEnvironment
public int viewEndpoints()
CoreEnvironment
The number of view service endpoints.
viewEndpoints
in interface CoreEnvironment
public int queryEndpoints()
CoreEnvironment
The number of query service endpoints.
queryEndpoints
in interface CoreEnvironment
public String userAgent()
CoreEnvironment
Library identification string, which can be used as User-Agent header in HTTP requests.
userAgent
in interface CoreEnvironment
public String packageNameAndVersion()
CoreEnvironment
Returns name and the version of the package. This method used to by @{link userAgent()}.
packageNameAndVersion
in interface CoreEnvironment
Copyright © 2014 Couchbase, Inc.