Module: TransactionalOutbox

Extended by:
Dry::Configurable
Includes:
Constants, Exceptions
Defined in:
lib/transactional_outbox.rb,
lib/transactional_outbox/event.rb,
lib/transactional_outbox/relay.rb,
lib/transactional_outbox/railtie.rb,
lib/transactional_outbox/version.rb,
lib/transactional_outbox/database.rb,
lib/transactional_outbox/producer.rb,
lib/transactional_outbox/constants.rb,
lib/transactional_outbox/exceptions.rb,
lib/transactional_outbox/relay/runner.rb,
lib/transactional_outbox/event/builder.rb,
lib/transactional_outbox/relay/monitor.rb,
lib/transactional_outbox/relay/failover.rb,
lib/transactional_outbox/relay/worker_set.rb,
lib/transactional_outbox/database/adapters.rb,
lib/transactional_outbox/event/contextable.rb,
lib/transactional_outbox/event/payloadable.rb,
lib/transactional_outbox/producer/adapters.rb,
lib/transactional_outbox/adapters_container.rb,
lib/transactional_outbox/exponential_backoff.rb,
lib/transactional_outbox/relay/event_processor.rb,
lib/transactional_outbox/database/adapters/base.rb,
lib/transactional_outbox/database/adapters/null.rb,
lib/transactional_outbox/producer/adapters/base.rb,
lib/transactional_outbox/producer/adapters/null.rb,
lib/transactional_outbox/producer/adapters/kafka.rb,
lib/transactional_outbox/relay/graceful_shutdown.rb,
lib/transactional_outbox/relay/worker_set/worker.rb,
lib/transactional_outbox/database/adapters/sequel.rb,
lib/transactional_outbox/relay/worker_set/processor.rb,
lib/transactional_outbox/database/adapters/interface.rb,
lib/transactional_outbox/producer/adapters/interface.rb,
lib/transactional_outbox/database/adapters/active_record.rb,
lib/transactional_outbox/database/adapters/instance_methods.rb,
lib/transactional_outbox/producer/adapters/instance_methods.rb,
lib/generators/transactional_outbox/migration/migration_generator.rb

Defined Under Namespace

Modules: Constants, Exceptions Classes: AdaptersContainer, Database, Event, ExponentialBackoff, MigrationGenerator, Producer, Railtie, Relay

Constant Summary collapse

VERSION = 
"1.0.0beta2"

Constants included from Constants

Constants::BASE_DATABASE_ADAPTERS, Constants::BASE_PRODUCER_ADAPTERS, Constants::DEFAULT_PAYLOAD_BUILDER_BLOCK, Constants::EVENT_NEW_STATUS, Constants::EVENT_PROCESSING_STATUS, Constants::RUNNER_INIT_MONITOR_EVENT, Constants::RUNNER_STOPPED_MONITOR_EVENT, Constants::WORKER_EVENTS_PROCESSED_MONITOR_EVENT, Constants::WORKER_EXCEPTIONS_TOTAL_MONITOR_EVENT, Constants::WORKER_RUN_MONITOR_EVENT, Constants::WORKER_STOPPED_MONITOR_EVENT

Class Method Summary collapse

Class Method Details

.outboxable ⇒ Object 



77
78
79
 
# File 'lib/transactional_outbox.rb', line 77

def outboxable(&)
  Database.new.transaction(&)
end