Table of Contents - aggro-0.0.4 Documentation
Classes and Modules
- Aggro
- Aggro::Aggregate
- Aggro::AggregateRef
- Aggro::AttributeDSL
- Aggro::BindingDSL
- Aggro::BlockHelper
- Aggro::Channel
- Aggro::Client
- Aggro::ClusterConfig
- Aggro::Command
- Aggro::ConcurrentActor
- Aggro::EventBus
- Aggro::EventDSL
- Aggro::EventProxy
- Aggro::EventSerializer
- Aggro::FileStore
- Aggro::FileStore::Reader
- Aggro::FileStore::Writer
- Aggro::Handler
- Aggro::Handler::Command
- Aggro::Handler::CreateAggregate
- Aggro::Handler::GetEvents
- Aggro::Handler::Query
- Aggro::Handler::StartSaga
- Aggro::LocalNode
- Aggro::Locator
- Aggro::Logging
- Aggro::Message
- Aggro::Message::Ask
- Aggro::Message::Command
- Aggro::Message::CreateAggregate
- Aggro::Message::Endpoint
- Aggro::Message::Events
- Aggro::Message::GetEvents
- Aggro::Message::Heartbeat
- Aggro::Message::InvalidTarget
- Aggro::Message::OK
- Aggro::Message::PublisherEndpointInquiry
- Aggro::Message::Query
- Aggro::Message::Result
- Aggro::Message::ServerError
- Aggro::Message::StartSaga
- Aggro::Message::UnhandledOperation
- Aggro::Message::UnknownOperation
- Aggro::MessageParser
- Aggro::MessageRouter
- Aggro::NanomsgTransport
- Aggro::Node
- Aggro::NodeList
- Aggro::Projection
- Aggro::Query
- Aggro::Saga
- Aggro::SagaRunner
- Aggro::SagaRunner::StartSaga
- Aggro::SagaStatus
- Aggro::Server
- Aggro::Subscriber
- Aggro::Subscription
- Aggro::Transform
- Aggro::Transform::Boolean
- Aggro::Transform::Date
- Aggro::Transform::Email
- Aggro::Transform::ID
- Aggro::Transform::Integer
- Aggro::Transform::Money
- Aggro::Transform::NOOP
- Aggro::Transform::String
- Aggro::Transform::Time
- Aggro::Transform::TimeInterval
- Aggro::ZeroMQTransport
- Aggro::ZeroMQTransport::Client
- Aggro::ZeroMQTransport::Publisher
- Aggro::ZeroMQTransport::Server
- Aggro::ZeroMQTransport::Server::ServerAlreadyRunning
- Aggro::ZeroMQTransport::Server::Workload
- Aggro::ZeroMQTransport::Subscriber
- Aggro::ZeroMQTransport::Subscriber::SubscriberAlreadyRunning
- MarshalStream
- MarshalStream::StreamError
Methods
- ::new — Aggro::Client
- ::new — Aggro::ClusterConfig
- ::new — Aggro::ConcurrentActor
- ::new — Aggro::EventBus
- ::new — Aggro::EventProxy
- ::new — Aggro::FileStore
- ::new — Aggro::FileStore::Reader
- ::new — Aggro::FileStore::Writer
- ::new — Aggro::Locator
- ::new — MarshalStream
- ::new — Aggro::Message::InvalidTarget
- ::new — Aggro::Message::OK
- ::new — Aggro::Message::ServerError
- ::new — Aggro::Message::UnhandledOperation
- ::new — Aggro::Message::UnknownOperation
- ::new — Aggro::MessageRouter
- ::new — Aggro::SagaStatus
- ::new — Aggro::Server
- ::new — Aggro::Subscriber
- ::new — Aggro::Subscription
- ::new — Aggro::Transform::ID
- ::new — Aggro::ZeroMQTransport::Client
- ::new — Aggro::ZeroMQTransport::Publisher
- ::new — Aggro::ZeroMQTransport::Server
- ::new — Aggro::ZeroMQTransport::Subscriber
- ::new — Aggro::Aggregate
- ::new — Aggro::AttributeDSL
- ::new — Aggro::Projection
- ::parse — Aggro::Message::Ask
- ::parse — Aggro::Message::Command
- ::parse — Aggro::Message::CreateAggregate
- ::parse — Aggro::Message::Endpoint
- ::parse — Aggro::Message::Events
- ::parse — Aggro::Message::GetEvents
- ::parse — Aggro::Message::Heartbeat
- ::parse — Aggro::Message::InvalidTarget
- ::parse — Aggro::Message::OK
- ::parse — Aggro::Message::PublisherEndpointInquiry
- ::parse — Aggro::Message::Query
- ::parse — Aggro::Message::Result
- ::parse — Aggro::Message::ServerError
- ::parse — Aggro::Message::StartSaga
- ::parse — Aggro::Message::UnhandledOperation
- ::parse — Aggro::Message::UnknownOperation
- ::parse_details — Aggro::Message::Command
- ::parse_details — Aggro::Message::Query
- ::parse_details — Aggro::Message::StartSaga
- ::parse_events — Aggro::Message::Events
- #<< — MarshalStream
- #add — Aggro::NodeList
- #add_node — Aggro::ClusterConfig
- #add_subscription — Aggro::ZeroMQTransport::Subscriber
- #add_to_channels — Aggro::Handler::CreateAggregate
- #all — Aggro::FileStore
- #allows — Aggro::Aggregate
- #allows? — Aggro::Aggregate
- #apply_command — Aggro::Aggregate
- #args — Aggro::Message::Command
- #args — Aggro::Message::Query
- #args — Aggro::Message::StartSaga
- #attach_handler — Aggro::MessageRouter
- #attribute — Aggro::AttributeDSL
- #attributes — Aggro::AttributeDSL
- #bind — Aggro::Server
- #bind — Aggro::Subscriber
- #bind — Aggro::BindingDSL
- #bind_block — Aggro::BindingDSL
- #bindings — Aggro::SagaRunner
- #bindings — Aggro::BindingDSL
- #bindings — Aggro::Saga
- #boolean — Aggro::AttributeDSL
- #build_command_message — Aggro::AggregateRef
- #build_create_message — Aggro::AggregateRef
- #build_query_message — Aggro::AggregateRef
- #call — Aggro::Handler::Command
- #call — Aggro::Handler::CreateAggregate
- #call — Aggro::Handler::GetEvents
- #call — Aggro::Handler::Query
- #call — Aggro::Handler::StartSaga
- #cancel — Aggro::Subscription
- #cancel_bindings — Aggro::SagaRunner
- #catchup_local — Aggro::EventBus
- #catchup_remote — Aggro::EventBus
- #catchup_subscriber — Aggro::EventBus
- #channel — Aggro::Handler::Command
- #channel — Aggro::Handler::Query
- #channels — Aggro
- #class_attributes — Aggro
- #client — Aggro::AggregateRef
- #client — Aggro::LocalNode
- #client — Aggro::Node
- #client — Aggro::NanomsgTransport
- #client — Aggro::ZeroMQTransport
- #close — MarshalStream
- #close_socket — Aggro::ZeroMQTransport::Client
- #close_socket — Aggro::ZeroMQTransport::Publisher
- #closed? — MarshalStream
- #cluster_config — Aggro
- #cluster_config_path — Aggro
- #comandee_locator — Aggro::Handler::Command
- #comandee_locator — Aggro::Handler::Query
- #command — Aggro::AggregateRef
- #command — Aggro::Handler::Command
- #command? — Aggro::ConcurrentActor
- #command_class — Aggro::Message::Command
- #command_handlers — Aggro
- #command_handlers — Aggro::Aggregate
- #command_known? — Aggro::Handler::Command
- #commandee_id — Aggro::Handler::Command
- #commandee_local? — Aggro::Handler::Command
- #context — Aggro::ZeroMQTransport
- #create — Aggro::AggregateRef
- #create — Aggro::FileStore
- #create — Aggro::Aggregate
- #create_attrs — Aggro::AttributeDSL
- #create_channel — Aggro::Handler::StartSaga
- #create_loopback_client — Aggro::LocalNode
- #create_saga — Aggro::Handler::StartSaga
- #data_dir — Aggro
- #date — Aggro::AttributeDSL
- #default_filters — Aggro::BindingDSL
- #default_filters — Aggro::Saga
- #default_replication_factor — Aggro::NodeList
- #deserialize — Aggro::Transform::ID
- #deserialize — Aggro::EventSerializer
- #deserialize — Aggro::Transform::Boolean
- #deserialize — Aggro::Transform::Date
- #deserialize — Aggro::Transform::Email
- #deserialize — Aggro::Transform::Integer
- #deserialize — Aggro::Transform::Money
- #deserialize — Aggro::Transform::NOOP
- #deserialize — Aggro::Transform::String
- #deserialize — Aggro::Transform::Time
- #deserialize — Aggro::Transform::TimeInterval
- #did — Aggro::SagaRunner
- #did — Aggro::Aggregate
- #disconnect! — Aggro::Client
- #discover_publisher_endpoint — Aggro::Node
- #each — MarshalStream
- #email — Aggro::AttributeDSL
- #endpoint — Aggro::LocalNode
- #enqueue_request — Aggro::ZeroMQTransport::Server
- #eof — MarshalStream
- #eof? — MarshalStream
- #event_bus — Aggro
- #event_file — Aggro::FileStore
- #event_methods — Aggro::EventDSL
- #events — Aggro::EventDSL
- #exists? — Aggro::FileStore
- #exists_in_channels? — Aggro::Handler::CreateAggregate
- #expand_event — Aggro::Subscription
- #falsey? — Aggro::Transform::Boolean
- #find — Aggro::Aggregate
- #finish — Aggro::ZeroMQTransport::Server::Workload
- #flush_buffer — MarshalStream
- #flush_outbox — MarshalStream
- #forward_command — Aggro::Channel
- #generate_id — Aggro::Transform::ID
- #generate_id — Aggro::AttributeDSL
- #generate_namespace — Aggro::BindingDSL
- #handle_command — Aggro::Server
- #handle_create — Aggro::Server
- #handle_event — Aggro::Subscription
- #handle_events — Aggro::EventBus
- #handle_foreign — Aggro::Handler::Command
- #handle_foreign — Aggro::Handler::CreateAggregate
- #handle_foreign — Aggro::Handler::GetEvents
- #handle_foreign — Aggro::Handler::Query
- #handle_foreign — Aggro::Handler::StartSaga
- #handle_get_events — Aggro::Server
- #handle_heartbeat — Aggro::Server
- #handle_known — Aggro::Handler::Command
- #handle_known — Aggro::Handler::Query
- #handle_known — Aggro::Handler::StartSaga
- #handle_local — Aggro::Handler::Command
- #handle_local — Aggro::Handler::CreateAggregate
- #handle_local — Aggro::Handler::GetEvents
- #handle_local — Aggro::Handler::Query
- #handle_local — Aggro::Handler::StartSaga
- #handle_message — Aggro::Server
- #handle_message — Aggro::Subscriber
- #handle_message — Aggro::ZeroMQTransport::Subscriber
- #handle_publisher_endpoint_inquiry — Aggro::Server
- #handle_query — Aggro::Server
- #handle_query_response — Aggro::AggregateRef
- #handle_raw — Aggro::Server
- #handle_raw — Aggro::Subscriber
- #handle_start_saga — Aggro::Server
- #handle_supported — Aggro::Handler::Query
- #handle_unknown — Aggro::Handler::Command
- #handle_unknown — Aggro::Handler::Query
- #handle_unknown — Aggro::Handler::StartSaga
- #handler_for_command — Aggro::Aggregate
- #handler_for_query — Aggro::Aggregate
- #handler_for_step — Aggro::Saga
- #handles? — Aggro::MessageRouter
- #handles_command? — Aggro::Channel
- #handles_event? — Aggro::Subscription
- #handles_event? — Aggro::EventDSL
- #handles_query? — Aggro::Channel
- #handles_step? — Aggro::Saga
- #hash_ring — Aggro::NodeList
- #id — Aggro::AttributeDSL
- #id_to_event_stream — Aggro::FileStore
- #id_to_reader — Aggro::FileStore
- #index — Aggro::FileStore::Reader
- #index_file — Aggro::FileStore
- #initial — Aggro::Saga
- #initialize_config — Aggro::ClusterConfig
- #initialize_registry — Aggro::FileStore
- #integer — Aggro::AttributeDSL
- #interval? — Aggro::Transform::TimeInterval
- #invoke — Aggro::Subscription
- #linger — Aggro::ZeroMQTransport
- #load_config — Aggro::ClusterConfig
- #local? — Aggro::Handler::CreateAggregate
- #local? — Aggro::Handler::GetEvents
- #local? — Aggro::Locator
- #local_node — Aggro
- #locator — Aggro::AggregateRef
- #locator — Aggro::Handler::CreateAggregate
- #locator — Aggro::Handler::GetEvents
- #locator — Aggro::Handler::StartSaga
- #log — Aggro::Aggregate
- #log — Aggro::Logging
- #logger — Aggro
- #matches_filter? — Aggro::Subscription
- #merge_details_with_command_context — Aggro::EventProxy
- #message_prefix_for_topic — Aggro::Subscriber
- #message_router — Aggro::Server
- #method_definitions — Aggro::BlockHelper
- #method_missing — Aggro::EventProxy
- #money — Aggro::AttributeDSL
- #move_methods_to_namespace — Aggro::BindingDSL
- #name — Aggro::Message::Command
- #name — Aggro::Message::Query
- #name — Aggro::Message::StartSaga
- #namespace? — Aggro::EventDSL
- #node_list — Aggro
- #nodes — Aggro::ClusterConfig
- #nodes — Aggro::Locator
- #nodes — Aggro::NodeList
- #nodes_for — Aggro::NodeList
- #notify_subscription_caught_up — Aggro::Subscription
- #on_message — Aggro::ConcurrentActor
- #open_socket — Aggro::ZeroMQTransport::Publisher
- #parse — Aggro::MessageParser
- #persist_config — Aggro::ClusterConfig
- #port — Aggro
- #post — Aggro::Client
- #post — Aggro::ZeroMQTransport::Client
- #primary_node — Aggro::Locator
- #primary_node — Aggro::Saga
- #projection — Aggro::Aggregate
- #projections — Aggro::Aggregate
- #pub_socket — Aggro::ZeroMQTransport::Publisher
- #publish — Aggro::EventBus
- #publish — Aggro::Server
- #publish — Aggro::ZeroMQTransport::Publisher
- #publisher — Aggro::NanomsgTransport
- #publisher — Aggro::ZeroMQTransport
- #publisher_endpoint — Aggro::LocalNode
- #publisher_endpoint — Aggro::Node
- #publisher_port — Aggro
- #query — Aggro::AggregateRef
- #query — Aggro::Handler::Query
- #query? — Aggro::ConcurrentActor
- #query_class — Aggro::Message::Query
- #query_handlers — Aggro
- #query_handlers — Aggro::Aggregate
- #query_known? — Aggro::Handler::Query
- #queryable_id — Aggro::Handler::Query
- #queryee_local? — Aggro::Handler::Query
- #read — Aggro::FileStore
- #read — Aggro::FileStore::Reader
- #read — MarshalStream
- #read_from_inbox — MarshalStream
- #read_from_stream — MarshalStream
- #read_one — MarshalStream
- #registry — Aggro::FileStore
- #reject — Aggro::SagaRunner
- #reject — Aggro::Saga
- #rejected — Aggro::SagaStatus
- #request_socket — Aggro::ZeroMQTransport::Client
- #reset — Aggro
- #reset_clients — Aggro
- #resolve — Aggro::SagaRunner
- #resolve — Aggro::Saga
- #resolved — Aggro::SagaStatus
- #respond_to_request — Aggro::ZeroMQTransport::Server
- #responds_to — Aggro::Aggregate
- #responds_to? — Aggro::Aggregate
- #restore_from_event_stream — Aggro::Aggregate
- #route — Aggro::MessageRouter
- #run_query — Aggro::Channel
- #run_query — Aggro::Aggregate
- #run_step — Aggro::SagaRunner
- #saga_id — Aggro::Saga
- #saga_known? — Aggro::Handler::StartSaga
- #secondary_nodes — Aggro::Locator
- #send_command — Aggro::AggregateRef
- #send_query — Aggro::AggregateRef
- #serialize — Aggro::Transform::ID
- #serialize — Aggro::EventSerializer
- #serialize — Aggro::Transform::Boolean
- #serialize — Aggro::Transform::Date
- #serialize — Aggro::Transform::Email
- #serialize — Aggro::Transform::Integer
- #serialize — Aggro::Transform::Money
- #serialize — Aggro::Transform::NOOP
- #serialize — Aggro::Transform::String
- #serialize — Aggro::Transform::Time
- #serialize — Aggro::Transform::TimeInterval
- #serialize_events — Aggro::Message::Events
- #serialized_attributes — Aggro::AttributeDSL
- #server — Aggro
- #server — Aggro::NanomsgTransport
- #server — Aggro::ZeroMQTransport
- #server_node= — Aggro::ClusterConfig
- #server_node? — Aggro::ClusterConfig
- #should_generate_id? — Aggro::Transform::ID
- #shutdown — Aggro::EventBus
- #start — Aggro::ZeroMQTransport::Server
- #start — Aggro::ZeroMQTransport::Subscriber
- #start — Aggro::Saga
- #start_command — Aggro::Handler::StartSaga
- #start_master — Aggro::ZeroMQTransport::Server
- #start_on_thread — Aggro::ZeroMQTransport::Subscriber
- #start_projections — Aggro::Aggregate
- #start_worker — Aggro::ZeroMQTransport::Server
- #started — Aggro::SagaStatus
- #step — Aggro::Saga
- #step_handlers — Aggro
- #steps — Aggro::Saga
- #stop — Aggro::Server
- #stop — Aggro::Subscriber
- #stop — Aggro::ZeroMQTransport::Server
- #stop — Aggro::ZeroMQTransport::Subscriber
- #store — Aggro
- #stream — Aggro::FileStore::Reader
- #string — Aggro::AttributeDSL
- #sub_socket — Aggro::ZeroMQTransport::Subscriber
- #subscribe — Aggro::EventBus
- #subscribe_bus_to_publisher — Aggro::EventBus
- #subscribe_to_topic — Aggro::Subscriber
- #subscriber — Aggro::NanomsgTransport
- #subscriber — Aggro::ZeroMQTransport
- #subscriptions — Aggro::EventBus
- #target — Aggro::Channel
- #target_class — Aggro::Channel
- #teardown — Aggro::SagaRunner
- #teardown — Aggro::NanomsgTransport
- #teardown — Aggro::ZeroMQTransport
- #time — Aggro::AttributeDSL
- #time_interval — Aggro::AttributeDSL
- #to_command — Aggro::Message::Command
- #to_details — Aggro::Command
- #to_details — Aggro::Query
- #to_details — Aggro::Saga
- #to_h — Aggro::ClusterConfig
- #to_io — MarshalStream
- #to_query — Aggro::Message::Query
- #to_s — Aggro::LocalNode
- #to_s — Aggro::Message::Ask
- #to_s — Aggro::Message::Command
- #to_s — Aggro::Message::CreateAggregate
- #to_s — Aggro::Message::Endpoint
- #to_s — Aggro::Message::Events
- #to_s — Aggro::Message::GetEvents
- #to_s — Aggro::Message::Heartbeat
- #to_s — Aggro::Message::InvalidTarget
- #to_s — Aggro::Message::OK
- #to_s — Aggro::Message::PublisherEndpointInquiry
- #to_s — Aggro::Message::Query
- #to_s — Aggro::Message::Result
- #to_s — Aggro::Message::ServerError
- #to_s — Aggro::Message::StartSaga
- #to_s — Aggro::Message::UnhandledOperation
- #to_s — Aggro::Message::UnknownOperation
- #to_s — Aggro::Node
- #transition — Aggro::SagaRunner
- #transition — Aggro::Saga
- #transport — Aggro
- #truthy? — Aggro::Transform::Boolean
- #type_for_id — Aggro::FileStore
- #unsubscribe — Aggro::EventBus
- #update_state — Aggro::NodeList
- #with_thread_ids — Aggro::SagaRunner
- #write — Aggro::FileStore
- #write — Aggro::FileStore::Writer
- #write — MarshalStream
- #write_single — Aggro::FileStore
- #write_to_buffer — MarshalStream
- #write_to_index — Aggro::FileStore::Writer
- #write_to_outbox — MarshalStream
- #write_to_stream — MarshalStream