Module: Sequent::Core

Defined in:

lib/sequent/core/event.rb,
lib/sequent/core/command.rb,
lib/sequent/core/workflow.rb,
lib/sequent/core/projector.rb,
lib/sequent/core/sequent_oj.rb,
lib/sequent/core/event_store.rb,
lib/sequent/core/event_record.rb,
lib/sequent/core/value_object.rb,
lib/sequent/core/current_event.rb,
lib/sequent/core/stream_record.rb,
lib/sequent/core/aggregate_root.rb,
lib/sequent/core/command_record.rb,
lib/sequent/core/helpers/secret.rb,
lib/sequent/core/snapshot_store.rb,
lib/sequent/core/aggregate_roots.rb,
lib/sequent/core/command_service.rb,
lib/sequent/core/event_publisher.rb,
lib/sequent/core/snapshot_record.rb,
lib/sequent/core/helpers/copyable.rb,
lib/sequent/core/helpers/mergable.rb,
lib/sequent/core/middleware/chain.rb,
lib/sequent/core/helpers/uuid_helper.rb,
lib/sequent/core/aggregate_repository.rb,
lib/sequent/core/base_command_handler.rb,
lib/sequent/core/persistors/persistor.rb,
lib/sequent/core/aggregate_snapshotter.rb,
lib/sequent/core/helpers/equal_support.rb,
lib/sequent/core/helpers/param_support.rb,
lib/sequent/core/helpers/pgsql_helpers.rb,
lib/sequent/core/random_uuid_generator.rb,
lib/sequent/core/helpers/date_validator.rb,
lib/sequent/core/helpers/message_router.rb,
lib/sequent/core/helpers/string_support.rb,
lib/sequent/core/helpers/time_validator.rb,
lib/sequent/core/helpers/array_with_type.rb,
lib/sequent/core/helpers/message_handler.rb,
lib/sequent/core/helpers/string_validator.rb,
lib/sequent/core/helpers/value_validators.rb,
lib/sequent/core/helpers/attr_matchers/dsl.rb,
lib/sequent/core/helpers/attribute_support.rb,
lib/sequent/core/helpers/boolean_validator.rb,
lib/sequent/core/helpers/autoset_attributes.rb,
lib/sequent/core/helpers/default_validators.rb,
lib/sequent/core/helpers/date_time_validator.rb,
lib/sequent/core/helpers/attr_matchers/equals.rb,
lib/sequent/core/helpers/message_matchers/any.rb,
lib/sequent/core/helpers/message_matchers/dsl.rb,
lib/sequent/core/transactions/no_transactions.rb,
lib/sequent/core/helpers/association_validator.rb,
lib/sequent/core/helpers/message_matchers/is_a.rb,
lib/sequent/core/helpers/attr_matchers/less_than.rb,
lib/sequent/core/helpers/string_to_value_parsers.rb,
lib/sequent/core/helpers/type_conversion_support.rb,
lib/sequent/core/helpers/attr_matchers/not_equals.rb,
lib/sequent/core/helpers/attr_matchers/greater_than.rb,
lib/sequent/core/helpers/message_matchers/has_attrs.rb,
lib/sequent/core/persistors/active_record_persistor.rb,
lib/sequent/core/helpers/message_matchers/except_opt.rb,
lib/sequent/core/helpers/message_matchers/instance_of.rb,
lib/sequent/core/helpers/attr_matchers/less_than_equals.rb,
lib/sequent/core/helpers/message_handler_option_registry.rb,
lib/sequent/core/helpers/attr_matchers/argument_serializer.rb,
lib/sequent/core/helpers/attr_matchers/greater_than_equals.rb,
lib/sequent/core/helpers/message_matchers/argument_coercer.rb,
lib/sequent/core/helpers/message_matchers/argument_serializer.rb,
lib/sequent/core/persistors/replay_optimized_postgres_persistor.rb,
lib/sequent/core/transactions/active_record_transaction_provider.rb,
lib/sequent/core/transactions/read_only_active_record_transaction_provider.rb

Defined Under Namespace

Modules: Helpers, Middleware, Migratable, Persistors, RandomUuidGenerator, SerializesCommand, SerializesEvent, SnapshotConfiguration, SnapshotStore, Transactions, UpdateSequenceNumber Classes: AggregateRepository, AggregateRoot, AggregateRoots, AggregateSnapshotter, BaseCommand, BaseCommandHandler, Command, CommandNotValid, CommandRecord, CommandService, Commands, CurrentEvent, Event, EventPublisher, EventRecord, EventRecordHooks, EventStore, Oj, Projector, Projectors, SnapshotCommand, SnapshotEvent, SnapshotRecord, StreamRecord, TakeSnapshot, UpdateCommand, ValueObject, Workflow, Workflows

Constant Summary

EventStream =

Data.define(:aggregate_type, :aggregate_id, :events_partition_key, :snapshot_outdated_at) do
  def initialize(aggregate_type:, aggregate_id:, events_partition_key: '', snapshot_outdated_at: nil)
    super
  end
end

TypeConversionError =

Class.new(RuntimeError)