Modifier and Type | Interface and Description |
---|---|
interface |
ICommProvider<ConfigType extends CommConfig>
Interface for all communication providers giving access to an input stream
for reading incoming data and an output stream for sending outgoing data.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IDataProducerModule<ConfigType extends ModuleConfig>
Base interface for all modules producing streaming data
|
Modifier and Type | Interface and Description |
---|---|
interface |
IModuleManager<ModuleType extends IModule<?>>
Base interface for all module managers.
|
Modifier and Type | Method and Description |
---|---|
<ModuleType extends IModule<?>> |
IModuleManagerFactory.getManager(Class<ModuleType> moduleType)
Gets the manager instance handling the specified type of module.
|
<ModuleType extends IModule<?>> |
IModuleManagerFactory.getManager(Class<ModuleType> moduleType,
Map<String,Object> hints)
Gets the manager instance handling the specified type of module and that provides
as much functionality specified by the hints table as possible.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
IModuleProvider.getModuleClass() |
Constructor and Description |
---|
ModuleEvent(IModule<?> moduleInstance,
ModuleConfig newConfig) |
ModuleEvent(IModule<?> moduleInstance,
ModuleEvent.Type type) |
Modifier and Type | Interface and Description |
---|---|
interface |
IObsStorageModule<ConfigType extends ObsStorageConfig> |
interface |
IRecordStorageModule<ConfigType extends StorageConfig> |
interface |
IStorageModule<ConfigType extends StorageConfig> |
Modifier and Type | Interface and Description |
---|---|
interface |
IOnDemandProcessModule<ConfigType extends ProcessConfig>
Base interface for on-demand processing modules.
This type of module is configured to fetch data from fixed streaming or archive sources, but can be further parameterized for each execution. The caller is responsible for getting new process instances when appropriate: A single process instance can be reused several times sequentially, but separate instances are needed to launch in parallel. |
interface |
IProcessModule<ConfigType extends ProcessConfig>
Base interface for all SensorHub data processing modules
|
interface |
IStreamProcessModule<ConfigType extends StreamProcessConfig>
Interface for all event stream processors.
This type of process is started in a persistent manner and listens to incoming events. |
Modifier and Type | Interface and Description |
---|---|
interface |
ISensorModule<ConfigType extends SensorConfig>
Interface to be implemented by all sensor drivers connected to the system
|
Modifier and Type | Interface and Description |
---|---|
interface |
IServiceModule<ConfigType extends ServiceConfig>
TODO: Common base to all service interfaces
|
Modifier and Type | Class and Description |
---|---|
class |
TCPCommProvider
Communication provider for TCP/IP links
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
TCPCommModuleDescriptor.getModuleClass() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractModule<ConfigType extends ModuleConfig>
Class providing default implementation of common module API methods
|
Modifier and Type | Method and Description |
---|---|
IModule<?> |
ModuleRegistry.enableModule(String moduleID)
Enables/Start the module with the given id
|
IModule<?> |
ModuleRegistry.getModuleById(String moduleID) |
IModule<?> |
ModuleRegistry.loadModule(ModuleConfig config)
Instantiates one module using the given configuration
|
Modifier and Type | Method and Description |
---|---|
List<IModule<?>> |
ModuleRegistry.getLoadedModules() |
WeakReference<? extends IModule<?>> |
ModuleRegistry.getModuleRef(String moduleID) |
Modifier and Type | Class and Description |
---|---|
class |
GenericStreamStorage
Generic wrapper/adapter enabling any storage implementation to store data
coming from data events (e.g.
|
class |
InMemoryBasicStorage
In-memory basic storage implementation.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
StreamStorageModuleDescriptor.getModuleClass() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractStreamProcess<ConfigType extends StreamProcessConfig>
Class providing default implementation of common stream processing API methods.
|
class |
SMLStreamProcess
Implementation of process module fully configured using a SensorML process
chain description.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
SMLStreamProcessDescriptor.getModuleClass() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSensorModule<ConfigType extends SensorConfig>
Class providing default implementation of common sensor API methods.
|
Modifier and Type | Class and Description |
---|---|
class |
HttpServer
Wrapper module for the HTTP server engine (Jetty for now)
|
Modifier and Type | Method and Description |
---|---|
static String |
MsgUtils.moduleClass(IModule<?> module) |
static String |
MsgUtils.moduleClassAndId(IModule<?> module) |
static String |
MsgUtils.moduleString(IModule<?> module) |
Copyright © 2015 Sensia Software LLC. All rights reserved.