This project contains the framework for creating components, such as HCDs and Assemblies.
This project contains the framework for creating components, such as HCDs and Assemblies.
A component is implemented by extending the csw.framework.scaladsl.ComponentHandlers base class. These handlers are executed under an Supervisor Actor: csw.framework.internal.supervisor.SupervisorBehavior and TLA Actor (Top Level Actor): csw.framework.internal.component.ComponentBehavior defined in the framework which handles the lifecycle and supervision of this component.
Components are controlled by a csw.framework.internal.supervisor.SupervisorBehavior actor that intercepts common messages (ex. Shutdown, Restart) or lifecycle messages (ex. GoOffline or GoOnline) sent from external entities to determine the state of the component.
Components that are not in the csw.messages.framework.SupervisorLifecycleState.Running state, do not receive csw.messages.CommandMessage.
When Component is created using this framework, it guarantees that component (HCD/Assembly) is registered with
LocationService only when Component moves to csw.messages.framework.SupervisorLifecycleState.Running state.
That means, one component can resolve other component only when its in
state and ready to accept messages.CommandMessageRunning
- csw.framework.internal.supervisor.SupervisorBehavior : Each component created by this framework is supervised by this actor.
Default strategy of supervisor is to stop child actor but depending on nature of the failure, the supervisor has a choice of the following two options:
Supervisor changes its csw.messages.framework.SupervisorLifecycleState based on the messages it receives.
Decision to handle external messages or not is taken by the supervisor based on its current csw.messages.framework.SupervisorLifecycleState.
For complete list of supported messages per csw.messages.framework.SupervisorLifecycleState, see csw-messages
project.
- csw.framework.internal.component.ComponentBehavior : Like Supervisor, evey component is associate with this actor which is known as TLA (Top Level Actor) And it also maintains its own state csw.framework.internal.component.ComponentLifecycleState based on messages it receives.
Main purpose of this actor is to invoke component specific code written in their corresponding handlers. This is where framework code meets Component specific code.
- csw.framework.internal.pubsub.PubSubBehavior : This actor is created by framework which is wrapped into csw.framework.CurrentStatePublisher for easy interaction with this actor and then passed to component handlers so that component can publish their csw.messages.params.states.CurrentState.
If one component (ex. Assembly) is interested in csw.messages.params.states.CurrentState published by other component (ex. HCD) then Assembly can subscribe to HCD's current state.
PubSub actor maintains the list of subscribers and keeps publishing csw.messages.params.states.CurrentState to all subscribers.
- csw.framework.internal.container.ContainerBehavior : When multiple components needs to be started in container, then this actor is created. Job of this actor is just to logically group multiple components and support csw.messages.SupervisorContainerCommonMessages. It receives csw.messages.SupervisorContainerCommonMessages.Shutdown or csw.messages.SupervisorContainerCommonMessages.Restart message and forwards it to all the components residing in this container.
- csw.framework.deploy.containercmd.ContainerCmd : ContainerCmd is a helper utility provided by framework to start multiple components in container mode or single component in Standalone mode.
Here is an example of a config file for creating a container with the name IRIS_Container that
contains one assembly (named Filter) and depends on the services of two HCDs (Instrument_Filter and Disperser).
Factory class for assembly is csw.common.components.framework.SampleComponentBehaviorFactory
.
A Supervisor
actor will be created to manage the assembly, which includes registering it with the
location service, using the given name and prefix. The prefix can be used to distribute parts of the
configurations to different HCDs. HCDs register themselves with the Location Service and specify a unique
prefix that can be used for this purpose.
name = "IRIS_Container" components: [ { name = "Filter" componentType = assembly behaviorFactoryClassName = csw.common.components.framework.SampleComponentBehaviorFactory prefix = tcs.mobie.blue.filter locationServiceUsage = RegisterOnly connections = [ { name: Instrument_Filter componentType: hcd connectionType: akka }, { name: Disperser componentType: hcd connectionType: akka } ] }, { name = "Instrument_Filter" componentType = hcd behaviorFactoryClassName = csw.common.components.framework.SampleComponentBehaviorFactory prefix = tcs.mobie.blue.filter locationServiceUsage = RegisterOnly }, { name = "Disperser" componentType: hcd behaviorFactoryClassName: csw.common.components.framework.SampleComponentBehaviorFactory prefix: tcs.mobie.blue.disperser locationServiceUsage = RegisterOnly } ]
name = "IFS_Detector"
componentType = hcd
behaviorFactoryClassName = csw.common.components.framework.SampleComponentBehaviorFactory
prefix = iris.ifs
locationServiceUsage = RegisterOnly
connections = []
- csw.framework.deploy.hostconfig.HostConfig : This is just a helper to create host configuration application. This support starting multiple containers on a given host machine and each container will have single/multiple components.
# This is a host configuration file which contains list of containers to be spawned by host configuration app containers: [ { # mode can be one of Container or Standalone mode: "Container" # path of individual container configuration file configFilePath: "/resources/assemblyContainer.conf" # provide 'Remote' if file needs to fetched from config service else # provide 'Local' to fetch file from local machine configFileLocation: "Local" }, { mode: "Standalone" configFilePath: "/resources/hcdStandalone.conf" configFileLocation: "Local" } ]
This project is intended to hold reusable models and messages used throughout the csw source code.
This project is intended to hold reusable models and messages used throughout the csw source code.
This also provides out of the box support to cater to the diverse communication requirements. Consumer of this library will be able to create Commands, Events, States to store ParameterSets.
This packages contains classes, traits and models used to create *commands* and *events*. These are all based on type-safe keys and items (a set of values with optional units). Each key has a specific type and the key's values must be of that type.
Two types of csw.messages.commands.Command are supported:
Following are the concrete commands supported by csw:
Two types of csw.messages.events.Event are supported:
Another important feature provided by *commands* package is csw.messages.commands.matchers.Matcher One of the use case for using matcher is when Assembly sends csw.messages.CommandMessage.Oneway command to HCD and in response to this command HCD keeps publishing its current state. Then Assembly can use Matcher with the matching definition as provided by csw.messages.commands.matchers.StateMatcher to match against the current states published by HCD.
These packages contain reusable classes, traits and models. We are keeping all the models which are getting transferred over the wire and
requires serialization and deserialization in csw-messages
project. All the models are marked with csw.messages.TMTSerializable.
csw.messages.TMTSerializable is a marker trait which extends scala.Serializable. This is configured to use kryo
serialization.
Also these models are being shared between multiple projects. csw-location
, csw-framework
and csw-logging
depends on csw-messages
project
which uses these models.
Location Service uses csw.messages.location.Connection model to register component/container of type:
When you resolve/find a csw.messages.location.Connection, you get csw.messages.location.Location in return which can be one of below type:
Framework package contains following actor messages:
This package supports serialization and deserialization of commands, events and state variables in following formats:
All the param and event classes are immutable. The set
methods return a new instance of the object with a
new item added and the get
methods return an Option, in case the Key is not found. There are also value
methods
that return a value directly, throwing an exception if the key or value is not found.
A set of standard key types and matching items are defined. Each key accepts one or more values of the given type.
Following csw.messages.params.generics.KeyType are supported by csw:
+--------------+-------------------------+---------------------------+ | Primitive | Scala KeyType | Java KeyType | +--------------+-------------------------+---------------------------+ | Boolean | KeyType.BooleanKey | JKeyTypes.BooleanKey | | Character | KeyType.CharKey | JKeyTypes.JCharKey | | Byte | KeyType.ByteKey | JKeyTypes.ByteKey | | Short | KeyType.ShortKey | JKeyTypes.ShortKey | | Long | KeyType.LongKey | JKeyTypes.LongKey | | Int | KeyType.IntKey | JKeyTypes.IntKey | | Float | KeyType.FloatKey | JKeyTypes.FloatKey | | Double | KeyType.DoubleKey | JKeyTypes.DoubleKey | | String | KeyType.StringKey | JKeyTypes.StringKey | | Timestamp | KeyType.TimestampKey | JKeyTypes.TimestampKey | | ---------- | ---------- | ---------- | | ByteArray | KeyType.ByteArrayKey | JKeyTypes.ByteArrayKey | | ShortArray | KeyType.ShortArrayKey | JKeyTypes.ShortArrayKey | | LongArray | KeyType.LongArrayKey | JKeyTypes.LongArrayKey | | IntArray | KeyType.IntArrayKey | JKeyTypes.IntArrayKey | | FloatArray | KeyType.FloatArrayKey | JKeyTypes.FloatArrayKey | | DoubleArray | KeyType.DoubleArrayKey | JKeyTypes.DoubleArrayKey | | ---------- | ---------- | ---------- | | ByteMatrix | KeyType.ByteMatrixKey | JKeyTypes.ByteMatrixKey | | ShortMatrix | KeyType.ShortMatrixKey | JKeyTypes.ShortMatrixKey | | LongMatrix | KeyType.LongMatrixKey | JKeyTypes.LongMatrixKey | | IntMatrix | KeyType.IntMatrixKey | JKeyTypes.IntMatrixKey | | FloatMatrix | KeyType.FloatMatrixKey | JKeyTypes.FloatMatrixKey | | DoubleMatrix | KeyType.DoubleMatrixKey | JKeyTypes.DoubleMatrixKey | | ---------- | ---------- | ---------- | | Choice | KeyType.ChoiceKey | JKeyTypes.ChoiceKey | | RaDec | KeyType.RaDecKey | JKeyTypes.RaDecKey | | Struct | KeyType.StructKey | JKeyTypes.StructKey | +--------------+-------------------------+---------------------------+
Detailed information about creating Keys and Parameters can be found here: https://tmtsoftware.github.io/csw-prod/services/messages/keys-parameters.html
Detailed information about creating commands can be found here: https://tmtsoftware.github.io/csw-prod/services/messages/commands.html
Detailed information about creating events can be found here: https://tmtsoftware.github.io/csw-prod/services/messages/events.html