Module: Akasha

Defined in:

lib/akasha/event.rb,
lib/akasha/version.rb,
lib/akasha/aggregate.rb,
lib/akasha/changeset.rb,
lib/akasha/exceptions.rb,
lib/akasha/repository.rb,
lib/akasha/event_router.rb,
lib/akasha/command_router.rb,
lib/akasha/event_listener.rb,
lib/akasha/recorded_event.rb,
lib/akasha/event_router_base.rb,
lib/akasha/async_event_router.rb,
lib/akasha/aggregate/syntax_helpers.rb,
lib/akasha/storage/http_event_store.rb,
lib/akasha/storage/memory_event_store.rb,
lib/akasha/checkpoint/metadata_checkpoint.rb,
lib/akasha/storage/http_event_store/client.rb,
lib/akasha/storage/http_event_store/stream.rb,
lib/akasha/storage/memory_event_store/stream.rb,
lib/akasha/command_router/optimistic_transactor.rb,
lib/akasha/storage/http_event_store/event_serializer.rb,
lib/akasha/storage/http_event_store/response_handler.rb,
lib/akasha/storage/http_event_store/projection_manager.rb

Defined Under Namespace

Modules: Checkpoint, Storage, SyntaxHelpers Classes: Aggregate, AsyncEventRouter, Changeset, CommandRouter, Event, EventListener, EventRouter, EventRouterBase, HttpError, RecordedEvent, Repository

Constant Summary

VERSION =

'0.4.0'.freeze

Error =

Base exception class for all Akasha errors.

Class.new(RuntimeError)

CommandRoutingError =

Base exception class for errors related to routing commands.

Class.new(Error)

HandlerNotFoundError =

No corresponding target for a command.

Class.new(CommandRoutingError)

UnsupportedHandlerError =

Type of the handler found for a command is not supported.

Class.new(CommandRoutingError)

EventRoutingError =

Base exception class for errors related to routing events.

Class.new(Error)

MissingProjectionError =

Projection stream hasn’t been set up yet.

Class.new(EventRoutingError)

ConcurrencyError =

Base exception class for concurrency-related errors.

Class.new(Error)

StaleRevisionError =

Stale aggregate revision number passed with command. It typically means that another actor already updated the aggregate.

Class.new(ConcurrencyError)

ConflictError =

Stream modified while processing a command.

Class.new(ConcurrencyError)

CheckpointStreamNotFoundError =

Missing stream when saving checkpoint.

Class.new(Error)

StorageError =

Base class for all storage backend errors.

Class.new(Error)

InvalidStreamNameError =

Stream name contains invalid characters.

Class.new(StorageError)

HttpClientError =

4xx HTTP status code.

Class.new(HttpError)

HttpServerError =

5xx HTTP status code.

Class.new(HttpError)