public static class DefaultCoreEnvironment.Builder extends java.lang.Object implements CoreEnvironment
Modifier | Constructor and Description |
---|---|
protected |
DefaultCoreEnvironment.Builder() |
Modifier and Type | Method and Description |
---|---|
int |
bootstrapCarrierDirectPort()
The port to use when bootstrapping through carrier publication without SSL.
|
DefaultCoreEnvironment.Builder |
bootstrapCarrierDirectPort(int bootstrapCarrierDirectPort) |
boolean |
bootstrapCarrierEnabled() |
DefaultCoreEnvironment.Builder |
bootstrapCarrierEnabled(boolean bootstrapCarrierEnabled) |
int |
bootstrapCarrierSslPort()
The port to use when bootstrapping through carrier publication with SSL.
|
DefaultCoreEnvironment.Builder |
bootstrapCarrierSslPort(int bootstrapCarrierSslPort) |
int |
bootstrapHttpDirectPort()
The port to use when bootstrapping through HTTP without SSL.
|
DefaultCoreEnvironment.Builder |
bootstrapHttpDirectPort(int bootstrapHttpDirectPort) |
boolean |
bootstrapHttpEnabled() |
DefaultCoreEnvironment.Builder |
bootstrapHttpEnabled(boolean bootstrapHttpEnabled) |
int |
bootstrapHttpSslPort()
The port to use when bootstrapping through HTTP with SSL.
|
DefaultCoreEnvironment.Builder |
bootstrapHttpSslPort(int bootstrapHttpSslPort) |
DefaultCoreEnvironment |
build() |
int |
computationPoolSize() |
DefaultCoreEnvironment.Builder |
computationPoolSize(int computationPoolSize) |
io.netty.channel.EventLoopGroup |
ioPool()
Returns the IO pool for the underlying IO framework.
|
DefaultCoreEnvironment.Builder |
ioPool(io.netty.channel.EventLoopGroup group) |
int |
ioPoolSize()
Returns the configured IO pool size.
|
DefaultCoreEnvironment.Builder |
ioPoolSize(int ioPoolSize) |
int |
kvEndpoints()
The number of key/value service endpoints.
|
DefaultCoreEnvironment.Builder |
kvEndpoints(int kvServiceEndpoints) |
java.lang.String |
packageNameAndVersion()
Returns name and the version of the package.
|
DefaultCoreEnvironment.Builder |
packageNameAndVersion(java.lang.String packageNameAndVersion) |
boolean |
queryEnabled() |
DefaultCoreEnvironment.Builder |
queryEnabled(boolean queryEnabled) |
int |
queryEndpoints()
The number of query service endpoints.
|
DefaultCoreEnvironment.Builder |
queryEndpoints(int queryServiceEndpoints) |
int |
queryPort() |
DefaultCoreEnvironment.Builder |
queryPort(int queryPort) |
int |
requestBufferSize()
Returns the size of the request ringbuffer.
|
DefaultCoreEnvironment.Builder |
requestBufferSize(int requestBufferSize) |
int |
responseBufferSize()
Returns the size of the response ringbuffer.
|
DefaultCoreEnvironment.Builder |
responseBufferSize(int responseBufferSize) |
rx.Scheduler |
scheduler()
Returns the scheduler which should be used for all core actions that need to happen asynchronously.
|
DefaultCoreEnvironment.Builder |
scheduler(rx.Scheduler scheduler) |
rx.Observable<java.lang.Boolean> |
shutdown()
Shutdown the
CoreEnvironment . |
boolean |
sslEnabled()
Identifies if SSL should be enabled.
|
DefaultCoreEnvironment.Builder |
sslEnabled(boolean sslEnabled) |
java.lang.String |
sslKeystoreFile() |
DefaultCoreEnvironment.Builder |
sslKeystoreFile(java.lang.String sslKeystoreFile) |
java.lang.String |
sslKeystorePassword() |
DefaultCoreEnvironment.Builder |
sslKeystorePassword(java.lang.String sslKeystorePassword) |
java.lang.String |
userAgent()
Library identification string, which can be used as User-Agent header in HTTP requests
|
DefaultCoreEnvironment.Builder |
userAgent(java.lang.String userAgent) |
int |
viewEndpoints()
The number of view service endpoints.
|
DefaultCoreEnvironment.Builder |
viewEndpoints(int viewServiceEndpoints) |
public boolean sslEnabled()
CoreEnvironment
Identifies if SSL should be enabled.
sslEnabled
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder sslEnabled(boolean sslEnabled)
public java.lang.String sslKeystoreFile()
sslKeystoreFile
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder sslKeystoreFile(java.lang.String sslKeystoreFile)
public java.lang.String sslKeystorePassword()
sslKeystorePassword
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder sslKeystorePassword(java.lang.String sslKeystorePassword)
public boolean queryEnabled()
queryEnabled
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder queryEnabled(boolean queryEnabled)
public int queryPort()
queryPort
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder queryPort(int queryPort)
public boolean bootstrapHttpEnabled()
bootstrapHttpEnabled
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder bootstrapHttpEnabled(boolean bootstrapHttpEnabled)
public boolean bootstrapCarrierEnabled()
bootstrapCarrierEnabled
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder bootstrapCarrierEnabled(boolean bootstrapCarrierEnabled)
public int bootstrapHttpDirectPort()
CoreEnvironment
The port to use when bootstrapping through HTTP without SSL.
bootstrapHttpDirectPort
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder bootstrapHttpDirectPort(int bootstrapHttpDirectPort)
public int bootstrapHttpSslPort()
CoreEnvironment
The port to use when bootstrapping through HTTP with SSL.
bootstrapHttpSslPort
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder bootstrapHttpSslPort(int bootstrapHttpSslPort)
public int bootstrapCarrierDirectPort()
CoreEnvironment
The port to use when bootstrapping through carrier publication without SSL.
bootstrapCarrierDirectPort
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder bootstrapCarrierDirectPort(int bootstrapCarrierDirectPort)
public int bootstrapCarrierSslPort()
CoreEnvironment
The port to use when bootstrapping through carrier publication with SSL.
bootstrapCarrierSslPort
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder bootstrapCarrierSslPort(int bootstrapCarrierSslPort)
public int ioPoolSize()
CoreEnvironment
Returns the configured IO pool size.
ioPoolSize
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder ioPoolSize(int ioPoolSize)
public int computationPoolSize()
computationPoolSize
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder computationPoolSize(int computationPoolSize)
public int requestBufferSize()
CoreEnvironment
Returns the size of the request ringbuffer.
requestBufferSize
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder requestBufferSize(int requestBufferSize)
public int responseBufferSize()
CoreEnvironment
Returns the size of the response ringbuffer.
responseBufferSize
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder responseBufferSize(int responseBufferSize)
public int kvEndpoints()
CoreEnvironment
The number of key/value service endpoints.
kvEndpoints
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder kvEndpoints(int kvServiceEndpoints)
public int viewEndpoints()
CoreEnvironment
The number of view service endpoints.
viewEndpoints
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder viewEndpoints(int viewServiceEndpoints)
public int queryEndpoints()
CoreEnvironment
The number of query service endpoints.
queryEndpoints
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder queryEndpoints(int queryServiceEndpoints)
public java.lang.String userAgent()
CoreEnvironment
Library identification string, which can be used as User-Agent header in HTTP requests
userAgent
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder userAgent(java.lang.String userAgent)
public java.lang.String packageNameAndVersion()
CoreEnvironment
Returns name and the version of the package. This method used to by @{link userAgent()}
packageNameAndVersion
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder packageNameAndVersion(java.lang.String packageNameAndVersion)
public rx.Observable<java.lang.Boolean> shutdown()
CoreEnvironment
Shutdown the CoreEnvironment
.
shutdown
in interface CoreEnvironment
public io.netty.channel.EventLoopGroup ioPool()
CoreEnvironment
Returns the IO pool for the underlying IO framework.
ioPool
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder ioPool(io.netty.channel.EventLoopGroup group)
public rx.Scheduler scheduler()
CoreEnvironment
Returns the scheduler which should be used for all core actions that need to happen asynchronously.
scheduler
in interface CoreEnvironment
public DefaultCoreEnvironment.Builder scheduler(rx.Scheduler scheduler)
public DefaultCoreEnvironment build()