Sha256: 857ee1238560a66ee20feb87a25360731664614c38d4d8cb34837e95e050f025

Contents?: true

Size: 764 Bytes

Versions: 2

Compression:

Stored size: 764 Bytes

Contents

# frozen_string_literal: true

module Qyu
  # Qyu::Config
  class Config
    attr_reader :queue, :store

    class ServiceConfig
      class << self
        def register(adapter_class)
          types[adapter_class::TYPE] = adapter_class
        end

        def valid?(config)
          types[config[:type]].valid_config?(config)
        end

        def types
          @__types ||= {}
        end
      end
    end

    class QueueConfig < ServiceConfig; end
    class StoreConfig < ServiceConfig; end

    def initialize(queue:, store:)
      fail 'Invalid message queue configuration' unless QueueConfig.valid?(queue)
      fail 'Invalid state store configuration' unless StoreConfig.valid?(store)

      @queue = queue
      @store = store
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
qyu-1.0.1 lib/qyu/config.rb
qyu-1.0.0 lib/qyu/config.rb