| Interface | Description |
|---|---|
| JobDefinitionRepository |
A repository for persisting
JobDefinitions. |
| StreamDefinitionRepository |
A repository for persisting
StreamDefinitions. |
| StreamRepository |
A repository for persisting
Streams. |
| XDParser |
| Class | Description |
|---|---|
| AbstractDeployer<D extends BaseDefinition> |
Abstract implementation of the @link
ResourceDeployer interface. |
| AbstractInstancePersistingDeployer<D extends BaseDefinition,I extends BaseInstance<D>> |
Base support class for deployers that know how to deal with
instances of a
definition. |
| BaseInstance<D extends BaseDefinition> |
A runtime representation of a Definition.
|
| DefaultStreamParser | |
| DeploymentMessageSender | |
| JobDefinition | |
| JobDeployer | |
| Stream |
A runtime representation of a running stream.
|
| StreamDefinition |
Represents a model for a data flow in the system.
|
| StreamDeployer |
Default implementation of
StreamDeployer that emits deployment request messages on a bus and relies on
StreamDefinitionRepository and StreamRepository for persistence. |
| XDStreamParser |
| Exception | Description |
|---|---|
| AlreadyDeployedException |
Thrown when an attempt is made to deploy a definition that is already deployed.
|
| DefinitionAlreadyExistsException |
Exception which is raised when a resource definition with the same name already exists.
|
| MissingRequiredDefinitionException |
Exception which is raised when a definition is syntactically correct but a required elements definition is missing.
|
| NoSuchDefinitionException |
Exception which is raised when a named resource definition cannot be found.
|
| NotDeployedException |
Thrown when a definition was assumed to be deployed when it actually was not.
|