AlertMessage |
A message that should be sent to a configured alert provider.
|
AlertProviderConfiguration |
Configuration for an alert provider.
|
AppEndpoint |
The MessageDispatcher sends messages to a DigitalTwin
|
AppEndpointException |
Thrown if an error occurs while sending a message to a DigitalTwin
|
AwsIotAction |
Enum AwsIotAction defines the supported actions when registering a device through the AwsIotHub with
ScaleOut StreamServer.
|
AwsIotEndpoint |
The AwsIotEndpoint is used to establish a running grid that connects into AwsIoT Core.
|
AwsIotEndpointBuilder |
The AwsIotEndpointBuilder is used to create an endpoint between AWS IoT Core and the digital twin's ExecutionEnvironment (Deployed Model).
|
AwsIotEndpointException |
Thrown if an error occurs while establishing the AwsIotEndpoint grid.
|
AwsIotMultiplexer |
The AwsIotMultiplexer handles incoming messages from AWS IoT core
|
AwsIotObservingSubscriber |
The AwsIotObservingSubscriber handles establishing new connections with AWS IoT core and reposting messages
from AWS IoT core to established DigitalTwins.
|
AwsIotSubscriptionManager |
Manages subscriptions to AWS IoT hub.
|
AwsIotSubscriptionMetadata |
The AwsIotSubscription metadata stored information about a connected data source.
|
AzureDigitalTwinPersistentStorage<V extends DigitalTwinBase> |
Persistent storage for AzureDigitalTwins - transparently store and load digital twins to and from Azure Digital Twins.
|
AzureDigitalTwinsPersistenceProvider |
AzureDigitalTwinsPersistenceProvider is a persistence provider implementation that is backed by Azure Digital Twins.
|
CacheOperationStatus |
Status of a cache operation.
|
CacheResult |
Represents a response from a SharedData operation.
|
DefaultPersistentStorage<V extends DigitalTwinBase> |
Default persistent storage - transparently store and load digital twins to and from the configured default persistent storage.
|
DigitalTwinBase |
A real-time digital twin of a data source.
|
DigitalTwinTimerMessage |
A message sent to a digital twin instance's message processor.
|
DynamoDbPersistenceProvider<V extends DigitalTwinBase> |
DynamoDB persistent storage - transparently store and load digital twins to and from a DynamoDB deployment.
|
ExecutionEnvironment |
Creates an ExecutionEnvironment for hosting DigitalTwins
|
ExecutionEnvironmentBuilder |
The ExecutionEnvironmentBuilder is used to create and deploy the ExecutionEnvironment for hosting digital twins
|
ExecutionEnvironmentException |
Thrown if an error occurs while establishing the ExecutionEnvironment
|
InitContext |
|
KafkaDeploymentException |
Thrown if an error occurs connecting to Kafka, establishing the connector grid, or other exception occurs
|
KafkaEndpoint |
Creates a KafkaEndpoint which can be used to consume and produce messages from and to Kafka.
|
KafkaEndpointBuilder |
The KafkaEndpointBuilder is used to create an endpoint between a Kafka server and the DigitalTwin execution environment.
|
KafkaRecordPosterAsJsonArray |
The KafkaRecordPosterAsJsonArray concatenates consumed messages for a given DigitalTwin and posts the list of messages
to the DigitalTwin.
|
LogMessage |
A messaged that was logged by a digital twin.
|
MembershipState |
|
MessageFactory |
Message list factory retrieves message lists for a MessageProcessor
|
MessageProcessor<T extends DigitalTwinBase,V> |
Processes messages for a real-time digital twin.
|
MessageProcessorBase<T extends DigitalTwinBase> |
Base class for the MessageProcessor to help with typing.
|
ModelSchema |
The ModelSchema class is used as a Java object representation of the model.json schema file used for deploying a
digital twin model to the real-time digital twin cloud service.
|
PersistenceProvider |
An interface that can be used for persisting/retrieving the state of real-time digital twins.
|
PersistenceProviderType |
|
PersistentStorage<V extends DigitalTwinBase> |
Persistent storage base class
|
ProcessingContext |
Context object that allows the user to send a message to a DataSource.
|
ProcessingResult |
The result from a message processor which indicates to update the state object or to ignore
|
RegistrationMessage |
The RegisterMessage is used to register and deregister devices with the AWS IoT core connector.
|
SendingResult |
Marks a message as Delivered or not Delivered
|
SharedData |
SharedData is used to access a model's, or globally, shared cache.
|
SimulationController |
The SimulationController interface is used to interact with the running DigitalTwin simulation.
|
SimulationEventResult |
A simulation event result.
|
SimulationProcessor<T extends DigitalTwinBase> |
Processes simulation events for a digital twin.
|
SimulationStatus |
The status of a simulation.
|
SimulationStep |
The simulation step class encases the metadata for a completed interval of a simulation.
|
SqlitePersistentStorage<V extends DigitalTwinBase> |
SQLite persistent storage - transparently store and load digital twins to and from the a SQLite database (single-server only).
|
SqlServerPersistentStorage<V extends DigitalTwinBase> |
SQLServer persistent storage - transparently store and load digital twins to and from a SQL Server database.
|
TimerActionResult |
The result of a timer action.
|
TimerHandler<T extends DigitalTwinBase> |
|
TimerMetadata<T extends DigitalTwinBase> |
Metadata class for a timer.
|
TimerType |
Enum representation of the available timer types
|
Workbench |
The Workbench is used to represent an environment where developers can test real-time and simulated digital twins.
|
WorkbenchException |
A Workbench exception indicates that a real-time or simulated twin caused an exception.
|
WorkbenchSharedData |
|