Class: QueuePulse::Checks::Base

Inherits:

Object

• Object
• QueuePulse::Checks::Base

Defined in:

lib/queue_pulse/checks/base.rb

Overview

Checks are pure-ish: given (config, source, state) they return Alerts. The only side effect they own is updating dedupe/cooldown state at the moment they decide to emit (keeps cooldown logic next to the data that produces it). Delivery is the Monitor's job.

Direct Known Subclasses

Failures, QueueDepth, QueueLatency, StuckJobs, WorkerLiveness

Instance Method Summary

• #call ⇒ Array<QueuePulse::Alert>
• #initialize(config, source, state) ⇒ Base constructor

  A new instance of Base.

Constructor Details

#initialize(config, source, state) ⇒ Base

Returns a new instance of Base.

# File 'lib/queue_pulse/checks/base.rb', line 10

def initialize(config, source, state)
  @config = config
  @source = source
  @state = state
end

Instance Method Details

#call ⇒ Array<QueuePulse::Alert>

Returns:

• (Array<QueuePulse::Alert>)

Raises:

• (NotImplementedError)

# File 'lib/queue_pulse/checks/base.rb', line 17

def call
  raise NotImplementedError
end