Contents

require 'tokyocabinet'

module Moneta
  module Adapters
    # TokyoCabinet backend
    # @api public
    class TokyoCabinet
      include Defaults
      include HashAdapter
      include IncrementSupport
      include CreateSupport
      include EachKeySupport

      # @param [Hash] options
      # @option options [String] :file Database file
      # @option options [Symbol] :type (:hdb) Database type (:bdb and :hdb possible)
      # @option options [::TokyoCabinet::*DB] :backend Use existing backend instance
      def initialize(options = {})
        if options[:backend]
          @backend = options[:backend]
        else
          raise ArgumentError, 'Option :file is required' unless options[:file]
          if options[:type] == :bdb
            @backend = ::TokyoCabinet::BDB.new
            @backend.open(options[:file], ::TokyoCabinet::BDB::OWRITER | ::TokyoCabinet::BDB::OCREAT)
          else
            @backend = ::TokyoCabinet::HDB.new
            @backend.open(options[:file], ::TokyoCabinet::HDB::OWRITER | ::TokyoCabinet::HDB::OCREAT)
          end or raise @backend.errmsg(@backend.ecode)
        end
      end

      # (see Proxy#delete)
      def delete(key, options = {})
        value = load(key, options)
        if value
          @backend.delete(key)
          value
        end
      end

      # (see Proxy#create)
      def create(key, value, options = {})
        @backend.putkeep(key, value)
      end

      # (see Proxy#close)
      def close
        @backend.close
        nil
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
moneta-1.4.2	lib/moneta/adapters/tokyocabinet.rb
moneta-1.4.1	lib/moneta/adapters/tokyocabinet.rb
moneta-1.4.0	lib/moneta/adapters/tokyocabinet.rb
moneta-1.3.0	lib/moneta/adapters/tokyocabinet.rb
moneta-1.2.1	lib/moneta/adapters/tokyocabinet.rb
moneta-1.2.0	lib/moneta/adapters/tokyocabinet.rb
moneta-1.1.1	lib/moneta/adapters/tokyocabinet.rb
moneta-1.1.0	lib/moneta/adapters/tokyocabinet.rb