Contents

require 'moneta'
require 'moneta/memory'

module DCell
  module Registry
    class MonetaAdapter
      def initialize(options)
        # Convert all options to symbols :/
        options = options.inject({}) { |h,(k,v)| h[k.to_sym] = v; h }

        @env = options[:env] || 'production'
        @namespace = options[:namespace] || "dcell_#{@env}"

        # We might want to use something like a TieredCache later..
        # Memory + BasicFile..
        # @moneta = Moneta::TieredCache.new options
        @moneta = Moneta::Memory.new options

        @node_registry   = Registry.new(@moneta, :nodes)
        @global_registry = Registry.new(@moneta, :globals)
      end

      class Registry
        def initialize(moneta, name)
          @name = name
          @moneta = moneta
        end

        def get(key)
          @moneta[@name][key.to_s]
        end

        def set(key, value)
          @moneta[@name][key.to_s] = value
        end

        def all
          @moneta[@name].keys
        end

        # DCell registry behaviors
        alias_method :nodes, :all
        alias_method :global_keys, :all

        def clear
          @moneta.delete(@name)
        end
      end

      def get_node(node_id);       @node_registry.get(node_id) end
      def set_node(node_id, addr); @node_registry.set(node_id, addr) end
      def nodes;                   @node_registry.nodes end
      def clear_nodes;             @node_registry.clear end

      def get_global(key);        @global_registry.get(key) end
      def set_global(key, value); @global_registry.set(key, value) end
      def global_keys;            @global_registry.global_keys end
      def clear_globals;          @global_registry.clear end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
dcell-0.13.0	lib/dcell/registries/moneta_adapter.rb
dcell-0.13.0.pre	lib/dcell/registries/moneta_adapter.rb
dcell-0.12.0.pre	lib/dcell/registries/moneta_adapter.rb
dcell-0.9.0	lib/dcell/registries/moneta_adapter.rb