Method List

Classes Methods Files

Search:

#add Aggro::NodeList
#add_node Aggro::ClusterConfig
#add_subscription Aggro::ZeroMQTransport::Subscriber
#all Aggro::FileStore
#args Aggro::Message::StartSaga
#args Aggro::Message::Command
#args Aggro::Message::Query
#attach_handler Aggro::MessageRouter
#attributes Aggro::AttributeDSL
#bind Aggro::BindingDSL
#bind Aggro::Subscriber
#bind Aggro::Server
#bindings Aggro::SagaRunner
#bindings Aggro::Saga
#call Aggro::Handler::GetEvents
#call Aggro::Handler::Command
#call Aggro::Handler::Query
#call Aggro::Handler::StartSaga
#call Aggro::Handler::CreateAggregate
#cancel Aggro::Subscription
#cancel_bindings Aggro::SagaRunner
#caught_up Aggro::Subscription
#cause Aggro::QueryError
channels Aggro
class_attributes Aggro
#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
#command Aggro::AggregateRef
#command_class Aggro::Message::Command
command_handlers Aggro
#commandee_id Aggro::Message::Command
context Aggro::ZeroMQTransport
#create Aggro::FileStore
#create Aggro::AggregateRef
#data Aggro::EventArgument
data_dir Aggro
#default_filters Aggro::Saga
deserialize Aggro::Transform::Money
#deserialize Aggro::Transform::ID
deserialize Aggro::Transform::Time
deserialize Aggro::Transform::Date
deserialize Aggro::Transform::NOOP
deserialize Aggro::Transform::Integer
deserialize Aggro::EventSerializer
deserialize Aggro::Transform::TimeInterval
deserialize Aggro::Transform::Email
deserialize Aggro::Transform::Boolean
deserialize Aggro::Transform::String
#details Aggro::Message::Command
#details Aggro::Message::StartSaga
#details Aggro::Message::Query
#details Aggro::Event
#disconnect! Aggro::Client
#each MarshalStream
#endpoint Aggro::Message::Endpoint
#endpoint Aggro::Node
#endpoint Aggro::LocalNode
#eof? MarshalStream
event_bus Aggro
#events Aggro::Message::Events
#events Aggro::EventStream
#exists? Aggro::FileStore
falsey? Aggro::Transform::Boolean
#finish Aggro::ZeroMQTransport::Server::Workload
#flush_buffer MarshalStream
#flush_outbox MarshalStream
#forward_command Aggro::Channel
#from_version Aggro::Message::GetEvents
#handle_event Aggro::Subscription
#handle_message Aggro::Server
#handle_message Aggro::Subscriber
#handles? Aggro::MessageRouter
#handles_command? Aggro::Channel
#handles_event? Aggro::EventDSL
#handles_query? Aggro::Channel
#id Aggro::Channel
#id Aggro::Message::GetEvents
#id Aggro::Node
#id Aggro::AggregateRef
#id Aggro::EventStream
#id Aggro::Message::Events
#id Aggro::ClientNode
#id Aggro::Message::CreateAggregate
#id Aggro::LocalNode
#id Aggro::Message::StartSaga
#identity Aggro::ZeroMQTransport::Server::Workload
#initialize Aggro::EventBus
#initialize Aggro::ZeroMQTransport::Subscriber
#initialize Aggro::Aggregate
#initialize Aggro::ZeroMQTransport::Publisher
#initialize Aggro::Transform::ID
#initialize Aggro::Projection
#initialize Aggro::Subscriber
#initialize Aggro::Subscription
#initialize Aggro::ConcurrentActor
#initialize MarshalStream
#initialize Aggro::ZeroMQTransport::Server
#initialize Aggro::SagaStatus
#initialize Aggro::EventProxy
#initialize Aggro::FileStore
#initialize Aggro::Locator
#initialize Aggro::ZeroMQTransport::Client
#initialize Aggro::Server
#initialize Aggro::AttributeDSL
#initialize Aggro::MessageRouter
#initialize Aggro::ClusterConfig
#initialize Aggro::Client
#initialize Aggro::FileStore::Reader
#initialize Aggro::FileStore::Writer
interval? Aggro::Transform::TimeInterval
#io MarshalStream
linger Aggro::ZeroMQTransport
#local? Aggro::Locator
local_node Aggro
#log Aggro::Logging
logger Aggro
#max_outbox MarshalStream
#message Aggro::Handler::StartSaga
#message Aggro::ZeroMQTransport::Server::Workload
#message Aggro::Handler::Command
#message Aggro::Handler::Query
#message Aggro::Handler::CreateAggregate
#message Aggro::Handler::GetEvents
method_definitions Aggro::BlockHelper
#method_missing Aggro::EventProxy
#mutex Aggro::ZeroMQTransport::Server::Workload
#name Aggro::Message::Command
#name Aggro::Message::StartSaga
#name Aggro::Event
#name Aggro::Message::Query
new Aggro::Message::UnhandledOperation
new Aggro::Message::OK
new Aggro::Message::UnknownOperation
new Aggro::Message::ServerError
new Aggro::Message::InvalidTarget
#node_id Aggro::Message::Ask
node_list Aggro
#node_name Aggro::ClusterConfig
#nodes Aggro::NodeList
#nodes Aggro::Locator
#nodes Aggro::ClusterConfig
#nodes_for Aggro::NodeList
#notify_subscription_caught_up Aggro::Subscription
#occured_at Aggro::Event
#on_message Aggro::ConcurrentActor
#open_socket Aggro::ZeroMQTransport::Publisher
parse Aggro::Message::Ask
parse Aggro::Message::PublisherEndpointInquiry
parse Aggro::Message::OK
parse Aggro::Message::StartSaga
parse Aggro::Message::UnhandledOperation
parse Aggro::Message::ServerError
parse Aggro::Message::UnknownOperation
parse Aggro::Message::GetEvents
parse Aggro::Message::CreateAggregate
parse Aggro::Message::Command
parse Aggro::Message::InvalidTarget
parse Aggro::Message::Events
parse Aggro::Message::Heartbeat
parse Aggro::Message::Query
parse Aggro::Message::Endpoint
parse Aggro::Message::Result
parse Aggro::MessageParser
parse_details Aggro::Message::StartSaga
parse_details Aggro::Message::Command
parse_details Aggro::Message::Query
parse_events Aggro::Message::Events
port Aggro
#post Aggro::ZeroMQTransport::Client
#post Aggro::Client
#primary_node Aggro::Locator
#publish Aggro::EventBus
#publish Aggro::ZeroMQTransport::Publisher
#publish Aggro::Server
publisher Aggro::ZeroMQTransport
publisher Aggro::NanomsgTransport
#publisher_endpoint Aggro::LocalNode
#publisher_endpoint Aggro::Node
publisher_port Aggro
#query Aggro::AggregateRef
#query_class Aggro::Message::Query
query_handlers Aggro
#queryable_id Aggro::Message::Query
#read MarshalStream
#read Aggro::FileStore
#read Aggro::FileStore::Reader
#read_from_stream MarshalStream
#read_one MarshalStream
#registry Aggro::FileStore
#reject Aggro::SagaRunner
#remote_publishers Aggro::EventBus
reset Aggro
reset_clients Aggro
#resolve Aggro::SagaRunner
#result Aggro::Message::Result
#route Aggro::MessageRouter
#run_query Aggro::Channel
#saga_id Aggro::Saga
#secondary_nodes Aggro::Locator
#sender Aggro::Message::PublisherEndpointInquiry
#sender Aggro::Message::Command
#sender Aggro::Message::Query
#sender Aggro::Message::StartSaga
#sender Aggro::Message::Heartbeat
#sender Aggro::Message::GetEvents
#sender Aggro::Message::CreateAggregate
serialize Aggro::Transform::Date
serialize Aggro::Transform::NOOP
serialize Aggro::Transform::Integer
#serialize Aggro::Transform::ID
serialize Aggro::Transform::Boolean
serialize Aggro::Transform::TimeInterval
serialize Aggro::Transform::String
serialize Aggro::EventSerializer
serialize Aggro::Transform::Money
serialize Aggro::Transform::Email
serialize Aggro::Transform::Time
#serialize_events Aggro::Message::Events
#serialized_attributes Aggro::AttributeDSL
#server Aggro::Handler::GetEvents
server Aggro::NanomsgTransport
#server Aggro::Handler::StartSaga
#server Aggro::Handler::Query
#server Aggro::Handler::CreateAggregate
server Aggro
#server Aggro::Handler::Command
server Aggro::ZeroMQTransport
#server_node= Aggro::ClusterConfig
#server_node? Aggro::ClusterConfig
#shutdown Aggro::EventBus
#socket Aggro::ZeroMQTransport::Server::Workload
#start Aggro::ZeroMQTransport::Subscriber
#start Aggro::ZeroMQTransport::Server
#start Aggro::Saga
#state Aggro::NodeList
step_handlers Aggro
#stop Aggro::Subscriber
#stop Aggro::ZeroMQTransport::Server
#stop Aggro::Server
#stop Aggro::ZeroMQTransport::Subscriber
store Aggro
#subscribe Aggro::EventBus
#subscribe_to_topic Aggro::Subscriber
subscriber Aggro::NanomsgTransport
subscriber Aggro::ZeroMQTransport
teardown Aggro::NanomsgTransport
teardown Aggro::ZeroMQTransport
#to_command Aggro::Message::Command
#to_details Aggro::Command
#to_details Aggro::Query
#to_io MarshalStream
#to_query Aggro::Message::Query
#to_s Aggro::Message::Result
#to_s Aggro::Message::Events
#to_s Aggro::Message::UnhandledOperation
#to_s Aggro::Message::Query
#to_s Aggro::Message::ServerError
#to_s Aggro::Message::Ask
#to_s Aggro::Message::OK
#to_s Aggro::LocalNode
#to_s Aggro::Node
#to_s Aggro::Message::PublisherEndpointInquiry
#to_s Aggro::Message::StartSaga
#to_s Aggro::Message::CreateAggregate
#to_s Aggro::Message::UnknownOperation
#to_s Aggro::Message::GetEvents
#to_s Aggro::Message::Heartbeat
#to_s Aggro::Message::Endpoint
#to_s Aggro::Message::Command
#to_s Aggro::Message::InvalidTarget
#transition Aggro::SagaRunner
transport Aggro
truthy? Aggro::Transform::Boolean
#type Aggro::AggregateRef
#type Aggro::Channel
#type Aggro::EventArgument
#type Aggro::EventStream
#type Aggro::Message::CreateAggregate
#unsubscribe Aggro::EventBus
#write Aggro::FileStore::Writer
#write MarshalStream
#write Aggro::FileStore
#write_single Aggro::FileStore
#write_to_buffer MarshalStream
#write_to_outbox MarshalStream
#write_to_stream MarshalStream