Module: Sbmt

Defined in:

app/interactors/sbmt/outbox/create_outbox_batch.rb,
lib/sbmt/outbox.rb,
lib/sbmt/outbox/cli.rb,
lib/sbmt/outbox/engine.rb,
lib/sbmt/outbox/errors.rb,
lib/sbmt/outbox/logger.rb,
lib/sbmt/outbox/version.rb,
lib/sbmt/outbox/ascii_art.rb,
lib/sbmt/outbox/v1/worker.rb,
lib/sbmt/outbox/v2/poller.rb,
lib/sbmt/outbox/v2/worker.rb,
lib/sbmt/outbox/probes/probe.rb,
lib/sbmt/outbox/v1/throttler.rb,
lib/sbmt/outbox/v2/processor.rb,
lib/sbmt/outbox/v2/redis_job.rb,
lib/sbmt/outbox/v2/throttler.rb,
lib/sbmt/outbox/error_tracker.rb,
lib/sbmt/outbox/metrics/utils.rb,
lib/sbmt/outbox/v2/tasks/base.rb,
lib/sbmt/outbox/v2/tasks/poll.rb,
lib/sbmt/outbox/probes/metrics.rb,
lib/sbmt/outbox/v1/thread_pool.rb,
lib/sbmt/outbox/v2/thread_pool.rb,
app/models/sbmt/outbox/base_item.rb,
lib/sbmt/outbox/v2/box_processor.rb,
lib/sbmt/outbox/v2/tasks/default.rb,
lib/sbmt/outbox/v2/tasks/process.rb,
app/models/sbmt/outbox/inbox_item.rb,
lib/sbmt/outbox/database_switcher.rb,
lib/sbmt/outbox/middleware/runner.rb,
lib/sbmt/outbox/v2/poll_throttler.rb,
app/models/sbmt/outbox/outbox_item.rb,
lib/sbmt/outbox/middleware/builder.rb,
app/models/sbmt/outbox/api/box_class.rb,
lib/sbmt/outbox/redis_client_factory.rb,
app/models/sbmt/outbox/api/inbox_class.rb,
lib/sbmt/outbox/v2/poll_throttler/base.rb,
lib/sbmt/outbox/v2/poll_throttler/noop.rb,
app/models/sbmt/outbox/api/outbox_class.rb,
app/models/sbmt/outbox/base_item_config.rb,
app/interactors/sbmt/outbox/process_item.rb,
app/models/sbmt/outbox/inbox_item_config.rb,
app/models/sbmt/outbox/outbox_item_config.rb,
app/interactors/sbmt/outbox/dry_interactor.rb,
app/controllers/sbmt/outbox/root_controller.rb,
lib/sbmt/outbox/v2/poll_throttler/composite.rb,
app/interactors/sbmt/outbox/base_create_item.rb,
lib/sbmt/outbox/v2/poll_throttler/paused_box.rb,
app/interactors/sbmt/outbox/create_inbox_item.rb,
app/models/sbmt/outbox/api/application_record.rb,
lib/sbmt/outbox/middleware/sentry/transaction.rb,
lib/sbmt/outbox/v2/poll_throttler/fixed_delay.rb,
app/interactors/sbmt/outbox/create_outbox_item.rb,
lib/sbmt/outbox/v2/poll_throttler/rate_limited.rb,
app/controllers/sbmt/outbox/api/base_controller.rb,
app/jobs/sbmt/outbox/base_delete_stale_items_job.rb,
app/interactors/sbmt/outbox/retry_strategies/base.rb,
app/jobs/sbmt/outbox/delete_stale_inbox_items_job.rb,
app/jobs/sbmt/outbox/delete_stale_outbox_items_job.rb,
lib/sbmt/outbox/v2/poll_throttler/redis_queue_size.rb,
app/interactors/sbmt/outbox/retry_strategies/no_delay.rb,
lib/sbmt/outbox/instrumentation/open_telemetry_loader.rb,
lib/sbmt/outbox/v2/poll_throttler/redis_queue_time_lag.rb,
app/controllers/sbmt/outbox/api/inbox_classes_controller.rb,
app/controllers/sbmt/outbox/api/outbox_classes_controller.rb,
app/interactors/sbmt/outbox/retry_strategies/compacted_log.rb,
app/interactors/sbmt/outbox/retry_strategies/latest_available.rb,
app/interactors/sbmt/outbox/retry_strategies/exponential_backoff.rb,
lib/sbmt/outbox/middleware/sentry/tracing_item_process_middleware.rb,
app/interactors/sbmt/outbox/partition_strategies/hash_partitioning.rb,
lib/sbmt/outbox/middleware/sentry/tracing_batch_process_middleware.rb,
app/interactors/sbmt/outbox/partition_strategies/number_partitioning.rb,
lib/sbmt/outbox/middleware/open_telemetry/tracing_create_item_middleware.rb,
lib/sbmt/outbox/middleware/open_telemetry/tracing_create_batch_middleware.rb,
lib/sbmt/outbox/middleware/open_telemetry/tracing_item_process_middleware.rb,
lib/sbmt/outbox/middleware/execution_context/context_item_process_middleware.rb

Overview

Provides ability to insert records in batches. It allows to have different headers, event_key and partition_by between set of attributes, but for predictability of metrics results better to have same headers across items

Defined Under Namespace

Modules: Outbox