Module: Kafka::Retryable

Defined in:

lib/kafka/retryable/version.rb,
lib/kafka/retryable.rb,
lib/kafka/retryable/config.rb,
lib/kafka/retryable/policy_finder.rb,
lib/kafka/retryable/handle_failure.rb,
lib/kafka/retryable/errors/invalid_policy.rb,
lib/kafka/retryable/errors/invalid_handling_options.rb,
lib/kafka/retryable/schemas/failure_handler_options.rb

Overview

Current Kafka::Retryable version

Defined Under Namespace

Modules: HandleFailure, MessageDispatcher, Policies, Schemas Classes: Config, InvalidHandlingOptions, InvalidPolicy, PolicyFinder

Constant Summary

VERSION =

'0.2.2'

Class Method Summary

• .config ⇒ Object

  return config object.

• .enabled? ⇒ Boolean
• .setup(&block) ⇒ Object

  Provides a block to override default config.

Class Method Details

.config ⇒ Object

return config object

# File 'lib/kafka/retryable.rb', line 5

def config
  Config.config
end

.enabled? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/kafka/retryable.rb', line 14

def enabled?
 config.failure_handling.enabled
end

.setup(&block) ⇒ Object

Provides a block to override default config

# File 'lib/kafka/retryable.rb', line 10

def setup(&block)
  Config.setup(&block)
end