Table of Contents - aggregate_streams-1.0.0.0 Documentation
Classes and Modules
- AggregateStreams
- AggregateStreams::Aggregation
- AggregateStreams::Aggregation::Transform
- AggregateStreams::Consumer
- AggregateStreams::Controls
- AggregateStreams::Controls::Aggregation
- AggregateStreams::Controls::Aggregation::New
- AggregateStreams::Controls::Handler
- AggregateStreams::Controls::MessageData
- AggregateStreams::Controls::MessageData::Input
- AggregateStreams::Controls::MessageData::Metadata
- AggregateStreams::Controls::MessageData::Metadata::Input
- AggregateStreams::Controls::MessageData::Metadata::Output
- AggregateStreams::Controls::MessageData::Output
- AggregateStreams::Controls::Position
- AggregateStreams::Controls::Position::Global
- AggregateStreams::Controls::Position::Global::Causation
- AggregateStreams::Controls::Position::Global::Previous
- AggregateStreams::Controls::Position::Initial
- AggregateStreams::Controls::Position::Previous
- AggregateStreams::Controls::Store
- AggregateStreams::Controls::StreamName
- AggregateStreams::Controls::StreamName::Input
- AggregateStreams::Controls::StreamName::Input::Alternate
- AggregateStreams::Controls::StreamName::Input::Alternate::Category
- AggregateStreams::Controls::StreamName::Input::Category
- AggregateStreams::Controls::StreamName::Output
- AggregateStreams::Controls::StreamName::Output::Category
- AggregateStreams::Handle
- AggregateStreams::PositionStore
- AggregateStreams::Projection
- AggregateStreams::Store
Methods
- ::alternate — AggregateStreams::Controls::MessageData::Input
- ::alternate — AggregateStreams::Controls::MessageData::Output
- ::alternate — AggregateStreams::Controls::MessageData::Metadata::Input
- ::alternate — AggregateStreams::Controls::MessageData::Metadata::Output
- ::alternate — AggregateStreams::Controls::Position
- ::alternate — AggregateStreams::Controls::Position::Previous
- ::alternate — AggregateStreams::Controls::Position::Global
- ::alternate — AggregateStreams::Controls::Position::Global::Previous
- ::alternate — AggregateStreams::Controls::Position::Global::Previous
- ::build — AggregateStreams::PositionStore
- ::category — AggregateStreams::Controls::Store
- ::category — AggregateStreams::Controls::StreamName::Input
- ::category — AggregateStreams::Controls::StreamName::Input::Alternate
- ::category — AggregateStreams::Controls::StreamName::Output
- ::causation_message_global_position — AggregateStreams::Controls::MessageData::Metadata
- ::causation_message_position — AggregateStreams::Controls::MessageData::Metadata
- ::causation_message_stream_name — AggregateStreams::Controls::MessageData::Metadata
- ::correlation_stream_name — AggregateStreams::Controls::MessageData::Metadata
- ::example — AggregateStreams::Controls::Aggregation
- ::example — AggregateStreams::Controls::Aggregation::New
- ::example — AggregateStreams::Controls::Handler
- ::example — AggregateStreams::Controls::MessageData::Input
- ::example — AggregateStreams::Controls::MessageData::Output
- ::example — AggregateStreams::Controls::MessageData::Metadata
- ::example — AggregateStreams::Controls::MessageData::Metadata::Input
- ::example — AggregateStreams::Controls::MessageData::Metadata::Output
- ::example — AggregateStreams::Controls::Position
- ::example — AggregateStreams::Controls::Position::Previous
- ::example — AggregateStreams::Controls::Position::Initial
- ::example — AggregateStreams::Controls::Position::Global
- ::example — AggregateStreams::Controls::Position::Global::Previous
- ::example — AggregateStreams::Controls::Position::Global::Previous
- ::example — AggregateStreams::Controls::Store
- ::example — AggregateStreams::Controls::StreamName
- ::example — AggregateStreams::Controls::StreamName::Input
- ::example — AggregateStreams::Controls::StreamName::Input::Category
- ::example — AggregateStreams::Controls::StreamName::Input::Alternate
- ::example — AggregateStreams::Controls::StreamName::Input::Alternate::Category
- ::example — AggregateStreams::Controls::StreamName::Output
- ::example — AggregateStreams::Controls::StreamName::Output::Category
- ::get_sql_command — AggregateStreams::PositionStore
- ::global_position — AggregateStreams::Controls::MessageData::Metadata
- ::instance — AggregateStreams::Aggregation::Transform
- ::internal — AggregateStreams::Controls::StreamName::Output::Category
- ::local_properties — AggregateStreams::Controls::MessageData::Metadata
- ::position — AggregateStreams::Controls::MessageData::Metadata
- ::properties — AggregateStreams::Controls::MessageData::Metadata
- ::raw_data — AggregateStreams::Aggregation::Transform
- ::reply_stream_name — AggregateStreams::Controls::MessageData::Metadata
- ::schema_version — AggregateStreams::Controls::MessageData::Metadata
- ::sequence — AggregateStreams::Controls::Aggregation
- ::snapshot_interval — AggregateStreams::Controls::Store
- ::start — AggregateStreams
- ::stream_name — AggregateStreams::Controls::MessageData::Metadata
- ::stream_name — AggregateStreams::Controls::StreamName
- #apply — AggregateStreams::Projection
- #assure_message_data — AggregateStreams::Handle
- #configure — AggregateStreams::Consumer
- #configure — AggregateStreams::Handle
- #get — AggregateStreams::PositionStore
- #handle — AggregateStreams::Handle
- #processed? — AggregateStreams::Aggregation
- #raw_metadata — AggregateStreams::Handle
- #record_processed — AggregateStreams::Aggregation
- #sequence — AggregateStreams::Aggregation
- #set_sequence — AggregateStreams::Aggregation
- #transform — AggregateStreams::Handle