Class: Zizq::WorkerConfiguration

Inherits:
Struct
  • Object
show all
Defined in:
lib/zizq/worker_configuration.rb,
sig/generated/zizq/worker_configuration.rbs

Overview

Defaults for Zizq::Worker instances. Accessed via Zizq.configuration.worker and typically populated inside an application's Zizq.configure block:

Zizq.configure do |c|
c.url = "https://..."
c.worker.queues = ["emails", "webhooks"]
c.worker.thread_count = 1
c.worker.fiber_count = 25
end

Every field defaults to nil, meaning "use the Worker's own hardcoded default." Anything explicitly passed to Worker.new — or set via CLI flag / env var when launching zizq-worker — overrides whatever is set here.

See Zizq::Worker#initialize for the full resolution order (explicit kwarg → Zizq.configuration.worker → Worker::DEFAULT_*).

Fields:

  • queues — Queues to consume. [] means all queues.
  • thread_count — Number of worker threads.
  • fiber_count — Number of fibers per worker thread.
  • prefetch — Server-side prefetch limit. Defaults to 2 * threads * fibers.
  • retry_min_wait — Minimum reconnect backoff in seconds.
  • retry_max_wait — Maximum reconnect backoff in seconds.
  • retry_multiplier — Multiplicative backoff factor between reconnect attempts.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Attribute Details

#fiber_count ⇒ Object

Returns the value of attribute fiber_count

Returns:

  • (Object) —

    the current value of fiber_count



38
39
40
 
# File 'lib/zizq/worker_configuration.rb', line 38

def fiber_count
  @fiber_count
end

#prefetch ⇒ Object

Returns the value of attribute prefetch

Returns:

  • (Object) —

    the current value of prefetch



38
39
40
 
# File 'lib/zizq/worker_configuration.rb', line 38

def prefetch
  @prefetch
end

#queues ⇒ Object

Returns the value of attribute queues

Returns:

  • (Object) —

    the current value of queues



38
39
40
 
# File 'lib/zizq/worker_configuration.rb', line 38

def queues
  @queues
end

#retry_max_wait ⇒ Object

Returns the value of attribute retry_max_wait

Returns:

  • (Object) —

    the current value of retry_max_wait



38
39
40
 
# File 'lib/zizq/worker_configuration.rb', line 38

def retry_max_wait
  @retry_max_wait
end

#retry_min_wait ⇒ Object

Returns the value of attribute retry_min_wait

Returns:

  • (Object) —

    the current value of retry_min_wait



38
39
40
 
# File 'lib/zizq/worker_configuration.rb', line 38

def retry_min_wait
  @retry_min_wait
end

#retry_multiplier ⇒ Object

Returns the value of attribute retry_multiplier

Returns:

  • (Object) —

    the current value of retry_multiplier



38
39
40
 
# File 'lib/zizq/worker_configuration.rb', line 38

def retry_multiplier
  @retry_multiplier
end

#thread_count ⇒ Object

Returns the value of attribute thread_count

Returns:

  • (Object) —

    the current value of thread_count



38
39
40
 
# File 'lib/zizq/worker_configuration.rb', line 38

def thread_count
  @thread_count
end

Class Method Details

.new(queues:, thread_count:, fiber_count:, prefetch:, retry_min_wait:, retry_max_wait:, retry_multiplier:) ⇒ instance .new(arg0) ⇒ instance

Overloads:

  • .new(queues:, thread_count:, fiber_count:, prefetch:, retry_min_wait:, retry_max_wait:, retry_multiplier:) ⇒ instance

    Parameters:

    • queues: (Array[String], nil)
    • thread_count: (Integer, nil)
    • fiber_count: (Integer, nil)
    • prefetch: (Integer, nil)
    • retry_min_wait: (Float, Integer, nil)
    • retry_max_wait: (Float, Integer, nil)
    • retry_multiplier: (Float, Integer, nil)

    Returns:

    • (instance)
  • .new(arg0) ⇒ instance

    Parameters:

    • arg0 ({ ?queues: Array[String]?, ?thread_count: Integer?, ?fiber_count: Integer?, ?prefetch: Integer?, ?retry_min_wait: (Float | Integer)?, ?retry_max_wait: (Float | Integer)?, ?retry_multiplier: (Float | Integer)? })

    Returns:

    • (instance) 


49
50
 
# File 'sig/generated/zizq/worker_configuration.rbs', line 49

def self.new: (?queues: Array[String]?, ?thread_count: Integer?, ?fiber_count: Integer?, ?prefetch: Integer?, ?retry_min_wait: (Float | Integer)?, ?retry_max_wait: (Float | Integer)?, ?retry_multiplier: (Float | Integer)?) -> instance
| ({ ?queues: Array[String]?, ?thread_count: Integer?, ?fiber_count: Integer?, ?prefetch: Integer?, ?retry_min_wait: (Float | Integer)?, ?retry_max_wait: (Float | Integer)?, ?retry_multiplier: (Float | Integer)? }) -> instance