Module: HireFire::Macro::Que

Extended by:
Deprecated::Que, Que, Utility
Included in:
Que
Defined in:
lib/hirefire/macro/que.rb

Constant Summary collapse

VERSION_1_0_0 = 
Gem::Version.new("1.0.0")

Instance Method Summary collapse

Methods included from Deprecated::Que

queue

Instance Method Details

#job_queue_latency(*queues) ⇒ Float

Calculates the maximum job queue latency using Que. If no queues are specified, it measures latency across all available queues.

Examples:

Calculate latency across all queues

HireFire::Macro::Que.job_queue_latency

Calculate latency for the “default” queue

HireFire::Macro::Que.job_queue_latency(:default)

Calculate latency across “default” and “mailer” queues

HireFire::Macro::Que.job_queue_latency(:default, :mailer)

Parameters:

  • queues (Array<String, Symbol>) —

    (optional) Names of the queues for latency measurement. If not provided, latency is measured across all queues.

Returns:

  • (Float) —

    Maximum job queue latency in seconds.



26
27
28
29
30
31
32
 
# File 'lib/hirefire/macro/que.rb', line 26

def job_queue_latency(*queues)
  if version < VERSION_1_0_0
    job_queue_latency_v0(*queues)
  else
    job_queue_latency_v1_v2(*queues)
  end
end

#job_queue_size(*queues) ⇒ Integer

Calculates the total job queue size using Que. If no queues are specified, it measures size across all available queues.

Examples:

Calculate size across all queues

HireFire::Macro::Que.job_queue_size

Calculate size for the “default” queue

HireFire::Macro::Que.job_queue_size(:default)

Calculate size across “default” and “mailer” queues

HireFire::Macro::Que.job_queue_size(:default, :mailer)

Parameters:

  • queues (Array<String, Symbol>) —

    (optional) Names of the queues for size measurement. If not provided, size is measured across all queues.

Returns:

  • (Integer) —

    Total job queue size.



46
47
48
49
50
51
52
 
# File 'lib/hirefire/macro/que.rb', line 46

def job_queue_size(*queues)
  if version < VERSION_1_0_0
    job_queue_size_v0(*queues)
  else
    job_queue_size_v1_v2(*queues)
  end
end