Modifier and Type | Interface and Description |
---|---|
interface |
IClientModule<ConfigType extends ClientConfig>
Common base for client modules connecting to remote services
|
Modifier and Type | Interface and Description |
---|---|
interface |
ICommNetwork<ConfigType extends ModuleConfig>
Interface used to represent communication networks of different types, such
as Ethernet, WiFi, Bluetooth, Bluetooth LE, ZigBee, etc...
|
interface |
ICommProvider<ConfigType extends CommProviderConfig<?>>
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 |
---|---|
IModule<?> |
ModuleEvent.getModule() |
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
IModuleProvider.getModuleClass() |
Constructor and Description |
---|
ModuleEvent(IModule<?> module,
ModuleEvent.ModuleState newState) |
ModuleEvent(IModule<?> module,
ModuleEvent.Type type) |
ModuleEvent(IModule<?> module,
String msg) |
ModuleEvent(IModule<?> module,
Throwable error) |
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.
Inputs/Output should always be created in the init() method even if they are further modified during or after startup. |
Modifier and Type | Interface and Description |
---|---|
interface |
IServiceModule<ConfigType extends ServiceConfig>
Common base to all service interfaces
|
Modifier and Type | Class and Description |
---|---|
class |
SOSTClient
Implementation of an SOS-T client that listens to sensor events and
forwards them to an SOS via InsertSensor/UpdateSensor, InsertResultTemplate
and InsertResult requests.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
SOSTClientModuleDescriptor.getModuleClass() |
Modifier and Type | Class and Description |
---|---|
class |
TCPCommProvider
Communication provider for TCP/IP links
|
class |
UDPCommProvider
Communication provider for UDP links
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
TCPCommModuleDescriptor.getModuleClass() |
Class<? extends IModule<?>> |
UDPCommModuleDescriptor.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.getModuleById(String moduleID) |
IModule<?> |
ModuleRegistry.initModule(String moduleID)
Initializes the module with the given local ID
This method is synchronous so it will block forever until the module is actually initialized or an exception is thrown |
IModule<?> |
ModuleRegistry.initModule(String moduleID,
boolean force,
long timeOut)
Initializes the module with the given local ID
This method is synchronous so it will block until the module is actually initialized, the timeout occurs or an exception is thrown |
IModule<?> |
ModuleRegistry.initModuleAsync(String moduleID,
boolean force,
IEventListener listener)
Initializes the module with the given local ID
This method is asynchronous so it returns immediately and the listener will be notified when the module is actually initialized |
IModule<?> |
ModuleRegistry.loadModule(ModuleConfig config)
Instantiates and loads a module using the given configuration
This method is synchronous so it will block forever until the module is actually loaded, and it will also wait for it to be started if 'autostart' was requested. |
IModule<?> |
ModuleRegistry.loadModule(ModuleConfig config,
long timeOut)
Instantiates and loads a module using the given configuration
This method is synchronous so it will block until the module is actually loaded, (and started if 'autostart' was true), the timeout occurs or an exception is thrown |
IModule<?> |
ModuleRegistry.loadModuleAsync(ModuleConfig config,
IEventListener listener)
Instantiates and loads a module using the given configuration
This method is asynchronous so, when it returns without error, the module is guaranteed to be loaded but not necessarilly initialized or started. |
IModule<?> |
ModuleRegistry.startModule(String moduleID)
Starts the module with the given local ID
This method is synchronous so it will block forever until the module is actually started or an exception is thrown |
IModule<?> |
ModuleRegistry.startModule(String moduleID,
long timeOut)
Starts the module with the given local ID
This method is synchronous so it will block until the module is actually started, the timeout occurs or an exception is thrown |
IModule<?> |
ModuleRegistry.startModuleAsync(String moduleID,
IEventListener listener)
Starts the module with the given local ID
This method is asynchronous so it returns immediately and the listener will be notified when the module is actually started |
IModule<?> |
ModuleRegistry.stopModule(String moduleID)
Stops the module with the given local ID
This method is synchronous so it will block forever until the module is actually stopped or an exception is thrown |
IModule<?> |
ModuleRegistry.stopModule(String moduleID,
long timeOut)
Stops the module with the given local ID
This method is synchronous so it will block until the module is actually stopped, the timeout occurs or an exception is thrown |
IModule<?> |
ModuleRegistry.stopModuleAsync(String moduleID,
IEventListener listener)
Stops the module with the given local ID
This method is asynchronous so it returns immediately and the listener will be notified when the module is actually stopped |
Modifier and Type | Method and Description |
---|---|
Collection<IModule<?>> |
ModuleRegistry.getLoadedModules() |
WeakReference<? extends IModule<?>> |
ModuleRegistry.getModuleRef(String moduleID) |
Modifier and Type | Method and Description |
---|---|
void |
ModuleRegistry.initModuleAsync(IModule<?> module,
boolean force)
Inits the module asynchronously in a separate thread
|
protected void |
ModuleRegistry.postInit(IModule<?> module) |
void |
ModuleRegistry.restartModuleAsync(IModule<?> module)
Restarts the module asynchronously in a separate thread
This will actually called requestStop() and then requestStart() |
void |
ModuleRegistry.startModuleAsync(IModule<?> module)
Starts the module asynchronously in a separate thread
|
void |
ModuleRegistry.stopModuleAsync(IModule<?> module)
Stops the module asynchronously in a separate thread
|
void |
ModuleRegistry.updateModuleConfigAsync(IModule module,
ModuleConfig config)
Updates the module configuration asynchronously in a separate thread
|
Constructor and Description |
---|
ModuleSecurity(IModule<?> module,
String moduleTypeAlias,
boolean enable) |
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 |
BasicStorageImpl
PERST implementation of
IBasicStorage for storing simple data records. |
class |
MultiEntityStorageImpl
PERST implementation of
IMultiSourceStorage module. |
class |
ObsStorageImpl
PERST implementation of
IObsStorage for storing observations. |
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
MultiEntityStorageModuleDescriptor.getModuleClass() |
Class<? extends IModule<?>> |
ObsStorageModuleDescriptor.getModuleClass() |
Class<? extends IModule<?>> |
BasicStorageModuleDescriptor.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 |
BasicSecurityRealm |
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
BasicSecurityRealmDescriptor.getModuleClass() |
Constructor and Description |
---|
ModulePermissions(IModule<?> module,
String moduleTypeAlias) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSensorModule<ConfigType extends SensorConfig>
Class providing default implementation of common sensor API methods.
This can be used as the base for most sensor driver implementations as it generates defaults for the following: A random Unique ID using a UUID (the same is used between restarts) A short XML ID A default SensorML description including IDs, temporal validity, I/Os and position (location + orientation) if the sensor configuration provides static location and/or orientation A feature of interest if the sensor configuration provides static location |
class |
SensorSystem
Class allowing to group several sensors drivers and processes into a single
system.
The system's outputs consist of the ones from the individual sensors and processes included in the group. Relative location and orientation of components can also be set |
Modifier and Type | Class and Description |
---|---|
class |
SOSVirtualSensor
Virtual sensor interface created by SOS InsertSensor
|
Modifier and Type | Class and Description |
---|---|
class |
SWEVirtualSensor
Driver for SWE enabled sensors communicating via SOS & SPS standard services.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
SWEVirtualSensorDescriptor.getModuleClass() |
Modifier and Type | Class and Description |
---|---|
class |
HttpServer
Wrapper module for the HTTP server engine (Jetty for now)
|
Modifier and Type | Class and Description |
---|---|
class |
SOSService
Implementation of SensorHub generic SOS service.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
SOSModuleDescriptor.getModuleClass() |
Modifier and Type | Class and Description |
---|---|
class |
SPSService
Implementation of SensorHub generic SPS service.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule<?>> |
SPSModuleDescriptor.getModuleClass() |
Modifier and Type | Class and Description |
---|---|
class |
DefaultModulePanel<ModuleType extends IModule<? extends ModuleConfig>>
Default implementation of module panel letting the user edit the module
configuration through a generic auto-generated form.
|
Modifier and Type | Class and Description |
---|---|
class |
AdminUIModule |
Modifier and Type | Method and Description |
---|---|
protected IModuleAdminPanel<IModule<?>> |
AdminUIModule.generatePanel(Class<?> clazz) |
Modifier and Type | Method and Description |
---|---|
protected void |
AdminUI.addModuleToTable(IModule<?> module,
com.vaadin.ui.TreeTable table) |
void |
ModuleInstanceSelectionPopup.ModuleInstanceSelectionCallback.onSelected(IModule module) |
protected void |
AdminUI.openModuleInfo(MyBeanItem<ModuleConfig> beanItem,
IModule<?> module) |
Modifier and Type | Method and Description |
---|---|
protected void |
AdminUI.buildModuleList(com.vaadin.ui.VerticalLayout layout,
List<IModule<?>> moduleList,
Class<?> configType) |
protected com.vaadin.ui.Field<Object> |
GenericConfigForm.makeModuleSelectField(com.vaadin.ui.Field<Object> field,
Class<? extends IModule> moduleType) |
Constructor and Description |
---|
ModuleInstanceSelectionPopup(Class<? extends IModule> moduleType,
ModuleInstanceSelectionPopup.ModuleInstanceSelectionCallback callback) |
Modifier and Type | Interface and Description |
---|---|
interface |
IModuleAdminPanel<ModuleType extends IModule<? extends ModuleConfig>>
Interface for all UI panels used to interact with modules
|
Modifier and Type | Method and Description |
---|---|
Class<? extends IModule> |
BaseProperty.getModuleType() |
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 © 2016 Sensia Software LLC. All rights reserved.