Module: Pigeon

Extended by:

API::CoreAPI, API::MonitoringAPI, API::OutboxAPI, API::SchemaAPI, API::SecurityAPI, API::TracingAPI

Defined in:

lib/pigeon.rb,
lib/pigeon/api.rb,
lib/pigeon/core.rb,
lib/pigeon/outbox.rb,
lib/pigeon/schema.rb,
lib/pigeon/railtie.rb,
lib/pigeon/tracing.rb,
lib/pigeon/version.rb,
lib/pigeon/security.rb,
lib/pigeon/processor.rb,
lib/pigeon/publisher.rb,
lib/pigeon/trace_api.rb,
lib/pigeon/encryption.rb,
lib/pigeon/monitoring.rb,
lib/pigeon/serializer.rb,
lib/pigeon/health_check.rb,
lib/pigeon/tracing/core.rb,
lib/pigeon/configuration.rb,
lib/pigeon/mock_producer.rb,
lib/pigeon/metrics/collector.rb,
lib/pigeon/tracing/messaging.rb,
lib/pigeon/hanami_integration.rb,
lib/pigeon/health_check/kafka.rb,
lib/pigeon/health_check/queue.rb,
lib/pigeon/models/outbox_message.rb,
lib/pigeon/active_job_integration.rb,
lib/pigeon/health_check/processor.rb,
lib/pigeon/logging/structured_logger.rb,
lib/pigeon/models/adapters/rom_adapter.rb,
lib/pigeon/processor/background_processor.rb,
lib/pigeon/generators/rails/install_generator.rb,
lib/pigeon/generators/rails/migration_generator.rb,
lib/pigeon/generators/hanami/migration_generator.rb,
lib/pigeon/models/adapters/active_record_adapter.rb

Overview

Main module for the Pigeon gem

Defined Under Namespace

Modules: API, ActiveJobIntegration, Core, Encryption, Generators, HanamiIntegration, HealthCheck, Logging, MaskingHelper, Metrics, Models, Monitoring, Outbox, Schema, Security, Serializer, TraceAPI, Tracing Classes: Configuration, Error, MockProducer, Processor, Publisher, Railtie

Constant Summary

VERSION =

"0.1.0"

Method Summary

Methods included from API::TracingAPI

init_tracing, tracer, tracing_available?, with_span

Methods included from API::MonitoringAPI

health_status, kafka_health, last_processing_run, last_processing_run=, last_successful_processing_run, last_successful_processing_run=, log_level, log_level=, logger_with_context, metrics, metrics_collector, metrics_for_monitoring, processor_health, processor_start_time, processor_start_time=, queue_health, reset_metrics

Methods included from API::OutboxAPI

count_outbox_messages_by_status, create_outbox_message, find_oldest_outbox_message_by_status, find_outbox_message, find_outbox_messages_by_status, find_outbox_messages_ready_for_retry, outbox_message_adapter

Methods included from API::SecurityAPI

decrypt, encrypt, mask_payload

Methods included from API::SchemaAPI

register_schema, register_sensitive_field, register_sensitive_fields, schema

Methods included from API::CoreAPI

config, configure, initialize_karafka, karafka_producer, processing?, processor, publisher, start_processing, stop_processing