Class: SolidObjects::Configuration

Inherits:

Object

Object
SolidObjects::Configuration

show all

Defined in:: lib/solid_objects/configuration.rb,
sig/generated/lib/solid_objects/configuration.rbs

Instance Attribute Summary collapse

#ask_polling_interval ⇒ Object
#authorize_administration ⇒ Object
#authorize_destroy ⇒ Object
#authorize_message ⇒ Object
#authorize_query ⇒ Object
#authorize_subscription ⇒ Object
#broadcast_adapter ⇒ Object
#broadcast_worker_count ⇒ Object
#claim_scan_limit ⇒ Object
#connects_to ⇒ Object
#effect_worker_count ⇒ Object
#idle_deactivation_timeout ⇒ Object
#lease_duration ⇒ Object
#lease_renewal_interval ⇒ Object
#logger ⇒ Object
#max_activation_duration ⇒ Object
#max_attempts ⇒ Object
#max_mailbox_length ⇒ Object
#max_messages_per_activation_pass ⇒ Object
#max_payload_bytes ⇒ Object
#max_result_bytes ⇒ Object
#max_state_bytes ⇒ Object
#polling_interval ⇒ Object
#process_alive_threshold ⇒ Object
#process_heartbeat_interval ⇒ Object
#reminder_scheduler_count ⇒ Object
#retry_delay ⇒ Object
#shutdown_timeout ⇒ Object
#stream_signing_secret ⇒ Object
#table_name_prefix ⇒ Object
#wake_up_adapter ⇒ Object
#worker_count ⇒ Object

Instance Method Summary collapse

#component_counts ⇒ Hash[Symbol, Integer]
#initialize ⇒ Configuration constructor
A new instance of Configuration.
#positive_values ⇒ Hash[Symbol, Numeric]
#validate! ⇒ self

Constructor Details

#initialize ⇒ `Configuration`

Returns a new instance of Configuration.

RBS:

() -> void

# File 'lib/solid_objects/configuration.rb', line 72

def initialize
  @table_name_prefix = "solid_objects_"
  @polling_interval = 0.1
  @ask_polling_interval = 0.05
  @lease_duration = 30.0
  @lease_renewal_interval = 10.0
  @idle_deactivation_timeout = 30.0
  @max_messages_per_activation_pass = 50
  @max_activation_duration = 5.0
  @max_mailbox_length = 10_000
  @claim_scan_limit = 100
  @max_payload_bytes = 1.megabyte
  @max_state_bytes = 5.megabytes
  @max_result_bytes = 1.megabyte
  @max_attempts = 5
  @retry_delay = ->(attempt) { [ 2**(attempt - 1), 60 ].min.to_f }
  @process_heartbeat_interval = 15.0
  @process_alive_threshold = 60.0
  @shutdown_timeout = 15.0
  @worker_count = 1
  @effect_worker_count = 1
  @broadcast_worker_count = 1
  @reminder_scheduler_count = 1
  @connects_to = nil
  @stream_signing_secret = nil
  @broadcast_adapter = nil
  @wake_up_adapter = nil
  @logger = if defined?(Rails) && Rails.respond_to?(:logger) && Rails.logger
    Rails.logger
  else
    Logger.new($stdout)
  end
  @authorize_message = ->(**) { false }
  @authorize_query = ->(**) { false }
  @authorize_destroy = ->(**) { false }
  @authorize_subscription = ->(**) { false }
  @authorize_administration = ->(**) { false }
end

Instance Attribute Details

#ask_polling_interval ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def ask_polling_interval
  @ask_polling_interval
end

#authorize_administration ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def authorize_administration
  @authorize_administration
end

#authorize_destroy ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def authorize_destroy
  @authorize_destroy
end

#authorize_message ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def authorize_message
  @authorize_message
end

#authorize_query ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def authorize_query
  @authorize_query
end

#authorize_subscription ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def authorize_subscription
  @authorize_subscription
end

#broadcast_adapter ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def broadcast_adapter
  @broadcast_adapter
end

#broadcast_worker_count ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def broadcast_worker_count
  @broadcast_worker_count
end

#claim_scan_limit ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def claim_scan_limit
  @claim_scan_limit
end

#connects_to ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def connects_to
  @connects_to
end

#effect_worker_count ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def effect_worker_count
  @effect_worker_count
end

#idle_deactivation_timeout ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def idle_deactivation_timeout
  @idle_deactivation_timeout
end

#lease_duration ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def lease_duration
  @lease_duration
end

#lease_renewal_interval ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def lease_renewal_interval
  @lease_renewal_interval
end

#logger ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def logger
  @logger
end

#max_activation_duration ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def max_activation_duration
  @max_activation_duration
end

#max_attempts ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def max_attempts
  @max_attempts
end

#max_mailbox_length ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def max_mailbox_length
  @max_mailbox_length
end

#max_messages_per_activation_pass ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def max_messages_per_activation_pass
  @max_messages_per_activation_pass
end

#max_payload_bytes ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def max_payload_bytes
  @max_payload_bytes
end

#max_result_bytes ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def max_result_bytes
  @max_result_bytes
end

#max_state_bytes ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def max_state_bytes
  @max_state_bytes
end

#polling_interval ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def polling_interval
  @polling_interval
end

#process_alive_threshold ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def process_alive_threshold
  @process_alive_threshold
end

#process_heartbeat_interval ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def process_heartbeat_interval
  @process_heartbeat_interval
end

#reminder_scheduler_count ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def reminder_scheduler_count
  @reminder_scheduler_count
end

#retry_delay ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def retry_delay
  @retry_delay
end

#shutdown_timeout ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def shutdown_timeout
  @shutdown_timeout
end

#stream_signing_secret ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def stream_signing_secret
  @stream_signing_secret
end

#table_name_prefix ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def table_name_prefix
  @table_name_prefix
end

#wake_up_adapter ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def wake_up_adapter
  @wake_up_adapter
end

#worker_count ⇒ `Object`

RBS:

@table_name_prefix: String
@polling_interval: Float
@ask_polling_interval: Float
@lease_duration: Float
@lease_renewal_interval: Float
@idle_deactivation_timeout: Float
@max_messages_per_activation_pass: Integer
@max_activation_duration: Float
@max_mailbox_length: Integer
@claim_scan_limit: Integer
@max_payload_bytes: Integer
@max_state_bytes: Integer
@max_result_bytes: Integer
@max_attempts: Integer
@retry_delay: Proc
@process_heartbeat_interval: Float
@process_alive_threshold: Float
@shutdown_timeout: Float
@worker_count: Integer
@effect_worker_count: Integer
@broadcast_worker_count: Integer
@reminder_scheduler_count: Integer
@connects_to: Hash[Symbol, untyped]?
@logger: untyped
@stream_signing_secret: String?
@broadcast_adapter: Proc?
@wake_up_adapter: untyped
@authorize_message: Proc
@authorize_query: Proc
@authorize_destroy: Proc
@authorize_subscription: Proc
@authorize_administration: Proc

Returns:

(Object)



38
39
40

# File 'lib/solid_objects/configuration.rb', line 38

def worker_count
  @worker_count
end

Instance Method Details

#component_counts ⇒ `Hash[Symbol, Integer]`

RBS:

() -> Hash[Symbol, Integer]

Returns:

(Hash[Symbol, Integer])

# File 'lib/solid_objects/configuration.rb', line 159

def component_counts
  {
    worker_count:,
    effect_worker_count:,
    broadcast_worker_count:,
    reminder_scheduler_count:
  }
end

#positive_values ⇒ `Hash[Symbol, Numeric]`

RBS:

() -> Hash[Symbol, Numeric]

Returns:

(Hash[Symbol, Numeric])

# File 'lib/solid_objects/configuration.rb', line 138

def positive_values
  {
    polling_interval:,
    ask_polling_interval:,
    lease_duration:,
    lease_renewal_interval:,
    max_messages_per_activation_pass:,
    max_activation_duration:,
    max_mailbox_length:,
    claim_scan_limit:,
    max_payload_bytes:,
    max_state_bytes:,
    max_result_bytes:,
    max_attempts:,
    process_heartbeat_interval:,
    process_alive_threshold:,
    shutdown_timeout:
  }
end

#validate! ⇒ `self`

RBS:

() -> self

Returns:

(self)

# File 'lib/solid_objects/configuration.rb', line 112

def validate!
  unless table_name_prefix.match?(/\A[a-z][a-z0-9_]*\z/)
    raise ArgumentError, "table_name_prefix must contain lowercase letters, digits, and underscores"
  end

  unless lease_duration > lease_renewal_interval
    raise ArgumentError, "lease_duration must be greater than lease_renewal_interval"
  end

  component_counts.each do |name, value|
    raise ArgumentError, "#{name} must not be negative" if value.negative?
  end
  if component_counts.values.sum.zero?
    raise ArgumentError, "at least one runtime component must be configured"
  end

  positive_values.each do |name, value|
    raise ArgumentError, "#{name} must be positive" unless value.positive?
  end

  self
end

Class: SolidObjects::Configuration

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Configuration

Instance Attribute Details

#ask_polling_interval ⇒ Object

#authorize_administration ⇒ Object

#authorize_destroy ⇒ Object

#authorize_message ⇒ Object

#authorize_query ⇒ Object

#authorize_subscription ⇒ Object

#broadcast_adapter ⇒ Object

#broadcast_worker_count ⇒ Object

#claim_scan_limit ⇒ Object

#connects_to ⇒ Object

#effect_worker_count ⇒ Object

#idle_deactivation_timeout ⇒ Object

#lease_duration ⇒ Object

#lease_renewal_interval ⇒ Object

#logger ⇒ Object

#max_activation_duration ⇒ Object

#max_attempts ⇒ Object

#max_mailbox_length ⇒ Object

#max_messages_per_activation_pass ⇒ Object

#max_payload_bytes ⇒ Object

#max_result_bytes ⇒ Object

#max_state_bytes ⇒ Object

#polling_interval ⇒ Object

#process_alive_threshold ⇒ Object

#process_heartbeat_interval ⇒ Object

#reminder_scheduler_count ⇒ Object

#retry_delay ⇒ Object

#shutdown_timeout ⇒ Object

#stream_signing_secret ⇒ Object

#table_name_prefix ⇒ Object

#wake_up_adapter ⇒ Object

#worker_count ⇒ Object

Instance Method Details

#component_counts ⇒ Hash[Symbol, Integer]

#positive_values ⇒ Hash[Symbol, Numeric]

#validate! ⇒ self

#initialize ⇒ `Configuration`

#ask_polling_interval ⇒ `Object`

#authorize_administration ⇒ `Object`

#authorize_destroy ⇒ `Object`

#authorize_message ⇒ `Object`

#authorize_query ⇒ `Object`

#authorize_subscription ⇒ `Object`

#broadcast_adapter ⇒ `Object`

#broadcast_worker_count ⇒ `Object`

#claim_scan_limit ⇒ `Object`

#connects_to ⇒ `Object`

#effect_worker_count ⇒ `Object`

#idle_deactivation_timeout ⇒ `Object`

#lease_duration ⇒ `Object`

#lease_renewal_interval ⇒ `Object`

#logger ⇒ `Object`

#max_activation_duration ⇒ `Object`

#max_attempts ⇒ `Object`

#max_mailbox_length ⇒ `Object`

#max_messages_per_activation_pass ⇒ `Object`

#max_payload_bytes ⇒ `Object`

#max_result_bytes ⇒ `Object`

#max_state_bytes ⇒ `Object`

#polling_interval ⇒ `Object`

#process_alive_threshold ⇒ `Object`

#process_heartbeat_interval ⇒ `Object`

#reminder_scheduler_count ⇒ `Object`

#retry_delay ⇒ `Object`

#shutdown_timeout ⇒ `Object`

#stream_signing_secret ⇒ `Object`

#table_name_prefix ⇒ `Object`

#wake_up_adapter ⇒ `Object`

#worker_count ⇒ `Object`

#component_counts ⇒ `Hash[Symbol, Integer]`

#positive_values ⇒ `Hash[Symbol, Numeric]`

#validate! ⇒ `self`