Module: RubyEventStore

Defined in:
lib/ruby_event_store/event.rb,
lib/ruby_event_store/client.rb,
lib/ruby_event_store/errors.rb,
lib/ruby_event_store/stream.rb,
lib/ruby_event_store/version.rb,
lib/ruby_event_store/metadata.rb,
lib/ruby_event_store/constants.rb,
lib/ruby_event_store/projection.rb,
lib/ruby_event_store/specification.rb,
lib/ruby_event_store/pub_sub/broker.rb,
lib/ruby_event_store/transform_keys.rb,
lib/ruby_event_store/mappers/default.rb,
lib/ruby_event_store/async_dispatcher.rb,
lib/ruby_event_store/batch_enumerator.rb,
lib/ruby_event_store/expected_version.rb,
lib/ruby_event_store/link_by_metadata.rb,
lib/ruby_event_store/mappers/protobuf.rb,
lib/ruby_event_store/serialized_record.rb,
lib/ruby_event_store/pub_sub/dispatcher.rb,
lib/ruby_event_store/composed_dispatcher.rb,
lib/ruby_event_store/correlated_commands.rb,
lib/ruby_event_store/mappers/null_mapper.rb,
lib/ruby_event_store/async_proxy_strategy.rb,
lib/ruby_event_store/in_memory_repository.rb,
lib/ruby_event_store/specification_reader.rb,
lib/ruby_event_store/specification_result.rb,
lib/ruby_event_store/pub_sub/subscriptions.rb,
lib/ruby_event_store/instrumented_dispatcher.rb,
lib/ruby_event_store/instrumented_repository.rb,
lib/ruby_event_store/deprecated_read_api_runner.rb,
lib/ruby_event_store/immediate_async_dispatcher.rb,
lib/ruby_event_store/spec/event_repository_lint.rb,
lib/ruby_event_store/spec/event_repository_lint.rb,
lib/ruby_event_store/deprecated_read_api_rewriter.rb

Defined Under Namespace

Modules: AsyncProxyStrategy, Mappers, PubSub Classes: AsyncDispatcher, BatchEnumerator, Client, ComposedDispatcher, CorrelatedCommands, DeprecatedReadAPIRewriter, DeprecatedReadAPIRunner, Event, EventNotFound, ExpectedVersion, ImmediateAsyncDispatcher, InMemoryRepository, InstrumentedDispatcher, InstrumentedRepository, LinkByCausationId, LinkByCorrelationId, LinkByEventType, LinkByMetadata, Metadata, Projection, Proto, SRecord, SerializedRecord, Specification, SpecificationReader, SpecificationResult, Stream, TransformKeys

Constant Summary collapse

WrongExpectedEventVersion =
Class.new(StandardError)
InvalidExpectedVersion =
Class.new(StandardError)
IncorrectStreamData =
Class.new(StandardError)
SubscriberNotExist =
Class.new(StandardError)
InvalidPageStart =
Class.new(ArgumentError)
InvalidPageSize =
Class.new(ArgumentError)
EventDuplicatedInStream =
Class.new(StandardError)
NotSupported =
Class.new(StandardError)
ReservedInternalName =
Class.new(StandardError)
InvalidHandler =
Class.new(StandardError)
ProtobufEncodingFailed =
Class.new(StandardError)
VERSION =
"0.35.0"
GLOBAL_STREAM =
Object.new
PAGE_SIZE =
100.freeze
Type1 =
Class.new(RubyEventStore::Event)
Type2 =
Class.new(RubyEventStore::Event)
Type3 =
Class.new(RubyEventStore::Event)