Module: SidekiqPublisher

Defined in:
lib/sidekiq_publisher.rb,
lib/sidekiq_publisher/client.rb,
lib/sidekiq_publisher/engine.rb,
lib/sidekiq_publisher/runner.rb,
lib/sidekiq_publisher/worker.rb,
lib/sidekiq_publisher/testing.rb,
lib/sidekiq_publisher/version.rb,
lib/sidekiq_publisher/publisher.rb,
app/models/sidekiq_publisher/job.rb,
lib/sidekiq_publisher/datadog_apm.rb,
lib/sidekiq_publisher/instrumenter.rb,
lib/sidekiq_publisher/compatibility.rb,
lib/sidekiq_publisher/metrics_reporter.rb,
lib/sidekiq_publisher/exception_reporter.rb,
lib/sidekiq_publisher/report_unpublished_count.rb,
lib/generators/sidekiq_publisher/install_generator.rb

Defined Under Namespace

Modules: Compatibility, DatadogAPM, ExceptionReporter, MetricsReporter, ReportUnpublishedCount, Testing, Worker Classes: Client, Engine, InstallGenerator, Instrumenter, Job, Publisher, Runner

Constant Summary collapse

DEFAULT_BATCH_SIZE =
100
DEFAULT_JOB_RETENTION_PERIOD =
1.day.freeze
VERSION =
"2.2.0"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.batch_sizeObject



28
29
30
# File 'lib/sidekiq_publisher.rb', line 28

def batch_size
  @batch_size || DEFAULT_BATCH_SIZE
end

.exception_reporterObject

Returns the value of attribute exception_reporter.



21
22
23
# File 'lib/sidekiq_publisher.rb', line 21

def exception_reporter
  @exception_reporter
end

.job_retention_periodObject



32
33
34
# File 'lib/sidekiq_publisher.rb', line 32

def job_retention_period
  @job_retention_period || DEFAULT_JOB_RETENTION_PERIOD
end

.loggerObject

Returns the value of attribute logger.



21
22
23
# File 'lib/sidekiq_publisher.rb', line 21

def logger
  @logger
end

.metrics_reporterObject

Returns the value of attribute metrics_reporter.



21
22
23
# File 'lib/sidekiq_publisher.rb', line 21

def metrics_reporter
  @metrics_reporter
end

Class Method Details

.configure {|_self| ... } ⇒ Object

Yields:

  • (_self)

Yield Parameters:



24
25
26
# File 'lib/sidekiq_publisher.rb', line 24

def configure
  yield self
end

.reset!Object

For test purposes



37
38
39
40
41
42
# File 'lib/sidekiq_publisher.rb', line 37

def reset!
  @batch_size = nil
  @job_retention_period = nil
  @exception_reporter = nil
  @metrics_reporter = nil
end