Expand description
Crate zerodds-corba-cos-notify. Safety classification: STANDARD.
OMG CosNotification 1.1 (formal/2004-10-11) — the structured-event notification service, successor to CosEvent.
In-memory model (analogous to [zerodds_corba_cos_event], but for
StructuredEvent with an any payload):
event§2.2 —StructuredEvent/EventType/Property.comm§3 — structured push/pull consumer/supplier traits + publish/subscribe.channel§4 —EventChannelFactory/EventChannel/ConsumerAdmin/SupplierAdmin/ structured-proxy hierarchy (push fanout + pull queue).filter§5 —Filter/ConstraintExp/FilterFactory(event-type match).qos§2.5 — QoS/admin property bag.
Pure Rust, forbid(unsafe_code). Live wiring over GIOP (analogous to the
CosEvent EventBus e2e) is the job of the interop layer.
Re-exports§
pub use channel::ConsumerAdmin;pub use channel::EventChannel;pub use channel::EventChannelFactory;pub use channel::StructuredProxyPullSupplier;pub use channel::StructuredProxyPushConsumer;pub use channel::StructuredProxyPushSupplier;pub use channel::SupplierAdmin;pub use comm::ConnectError;pub use comm::Disconnected;pub use comm::NotifyPublish;pub use comm::NotifySubscribe;pub use comm::StructuredPullConsumer;pub use comm::StructuredPullSupplier;pub use comm::StructuredPushConsumer;pub use comm::StructuredPushSupplier;pub use event::EventHeader;pub use event::EventType;pub use event::FixedEventHeader;pub use event::Property;pub use event::PropertySeq;pub use event::StructuredEvent;pub use filter::ConstraintExp;pub use filter::Filter;pub use filter::FilterFactory;pub use filter::InstalledConstraint;pub use qos::QoSProperties;
Modules§
- channel
- CosNotifyChannelAdmin §4 — EventChannelFactory + EventChannel + Consumer/SupplierAdmin + structured-proxy hierarchy.
- comm
- CosNotifyComm §3 — structured-event push/pull traits + publish/subscribe.
- event
- CosNotification §2.2 —
StructuredEvent+EventType+Property. - filter
- CosNotifyFilter §5 —
Filter+ConstraintExp+FilterFactory. - qos
- CosNotification §2.5 — QoS + admin properties as a
Propertybag.