Module: Mammoth

Defined in:

lib/mammoth.rb,
lib/mammoth/cli.rb,
lib/mammoth/errors.rb,
lib/mammoth/status.rb,
lib/mammoth/version.rb,
lib/mammoth/registry.rb,
lib/mammoth/cdc_source.rb,
lib/mammoth/application.rb,
lib/mammoth/capabilities.rb,
lib/mammoth/route_filter.rb,
lib/mammoth/sqlite_store.rb,
lib/mammoth/webhook_sink.rb,
lib/mammoth/configuration.rb,
lib/mammoth/node_identity.rb,
lib/mammoth/delivery_worker.rb,
lib/mammoth/lifecycle_hooks.rb,
lib/mammoth/checkpoint_store.rb,
lib/mammoth/event_serializer.rb,
lib/mammoth/runtimes/adapter.rb,
lib/mammoth/sources/postgres.rb,
lib/mammoth/dead_letter_store.rb,
lib/mammoth/runtimes/registry.rb,
lib/mammoth/delivery_processor.rb,
lib/mammoth/dead_letter_commands.rb,
lib/mammoth/destinations/adapter.rb,
lib/mammoth/observability_server.rb,
lib/mammoth/replication_consumer.rb,
lib/mammoth/destinations/registry.rb,
lib/mammoth/commands/start_command.rb,
lib/mammoth/fanout_delivery_worker.rb,
lib/mammoth/observability_snapshot.rb,
lib/mammoth/commands/status_command.rb,
lib/mammoth/runtimes/inline_adapter.rb,
lib/mammoth/delivered_envelope_store.rb,
lib/mammoth/commands/validate_command.rb,
lib/mammoth/operational_state/adapter.rb,
lib/mammoth/commands/bootstrap_command.rb,
lib/mammoth/operational_state/registry.rb,
lib/mammoth/concurrent_delivery_runtime.rb,
lib/mammoth/runtimes/concurrent_adapter.rb,
lib/mammoth/destinations/webhook_adapter.rb,
lib/mammoth/commands/dead_letters_command.rb,
lib/mammoth/commands/deliver_sample_command.rb,
lib/mammoth/transaction_envelope_serializer.rb,
lib/mammoth/operational_state/sqlite_adapter.rb

Overview

Mammoth is a self-hosted PostgreSQL event relay.

Mammoth 0.7.x is a single-node PostgreSQL CDC relay with webhook fanout, replayable operational SQLite state, health/metrics endpoints, and explicit extension contracts for state, destination, runtime, lifecycle, configuration, and local command integrations.

Defined Under Namespace

Modules: Commands, Destinations, OperationalState, Runtimes, Sources Classes: Application, CLI, Capabilities, CheckpointStore, ConcurrentDeliveryRuntime, Configuration, ConfigurationError, DeadLetterCommands, DeadLetterStore, DeliveredEnvelopeStore, DeliveryError, DeliveryProcessor, DeliveryWorker, Error, EventSerializer, FanoutDeliveryWorker, LifecycleHooks, NodeIdentity, ObservabilityServer, ObservabilitySnapshot, Registry, ReplicationConsumer, ReplicationError, RouteFilter, SQLiteStore, Status, StoreError, TransactionEnvelopeSerializer, WebhookSink

Constant Summary

VERSION =

Current Mammoth gem version.

"0.7.2"

CdcSource =

Backwards-compatible internal alias for the PostgreSQL CDC source.

New code should use Sources::Postgres. Mammoth keeps this constant so older tests or examples that referenced the transitional CdcSource name continue to work while the product-facing source name moves to PostgreSQL.

Sources::Postgres