public interface CoreEnvironment
A CoreEnvironment
provides all the core building blocks like environment settings and thread pools so that the application can work with it properly.
This interface defines the contract. How properties are loaded is chosen by the implementation. See the DefaultCoreEnvironment
class for the default implementation.
Note that the CoreEnvironment
is stateful, so be sure to call shutdown()
properly.
Modifier and Type | Method and Description |
---|---|
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.
|
int |
computationPoolSize() |
io.netty.channel.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.
|
java.lang.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.
|
rx.Scheduler |
scheduler()
Returns the scheduler which should be used for all core actions that need to happen asynchronously.
|
rx.Observable<java.lang.Boolean> |
shutdown()
Shutdown the
CoreEnvironment . |
boolean |
sslEnabled()
Identifies if SSL should be enabled.
|
java.lang.String |
sslKeystoreFile() |
java.lang.String |
sslKeystorePassword() |
java.lang.String |
userAgent()
Library identification string, which can be used as User-Agent header in HTTP requests
|
int |
viewEndpoints()
The number of view service endpoints.
|
rx.Observable<java.lang.Boolean> shutdown()
Shutdown the CoreEnvironment
.
io.netty.channel.EventLoopGroup ioPool()
Returns the IO pool for the underlying IO framework.
rx.Scheduler scheduler()
Returns the scheduler which should be used for all core actions that need to happen asynchronously.
boolean sslEnabled()
Identifies if SSL should be enabled.
java.lang.String sslKeystoreFile()
java.lang.String sslKeystorePassword()
boolean queryEnabled()
int queryPort()
boolean bootstrapHttpEnabled()
boolean bootstrapCarrierEnabled()
int bootstrapHttpDirectPort()
The port to use when bootstrapping through HTTP without SSL.
int bootstrapHttpSslPort()
The port to use when bootstrapping through HTTP with SSL.
int bootstrapCarrierDirectPort()
The port to use when bootstrapping through carrier publication without SSL.
int bootstrapCarrierSslPort()
The port to use when bootstrapping through carrier publication with SSL.
int ioPoolSize()
Returns the configured IO pool size.
int computationPoolSize()
int requestBufferSize()
Returns the size of the request ringbuffer.
int responseBufferSize()
Returns the size of the response ringbuffer.
int kvEndpoints()
The number of key/value service endpoints.
int viewEndpoints()
The number of view service endpoints.
int queryEndpoints()
The number of query service endpoints.
java.lang.String userAgent()
Library identification string, which can be used as User-Agent header in HTTP requests
java.lang.String packageNameAndVersion()
Returns name and the version of the package. This method used to by @{link userAgent()}