summaryrefslogtreecommitdiffstats
path: root/storage/mroonga/vendor/groonga/plugins/sharding/logical_parameters.rb
blob: 75ff569bf7c7a6d85c3c06ba92c8c00bde6410ef (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
module Groonga
  module Sharding
    class LogicalParametersCommand < Command
      register("logical_parameters",
               [
                 "range_index",
               ])

      def run_body(input)
        range_index = parse_range_index(input[:range_index])

        parameters = [
          :range_index,
        ]
        writer.map("parameters", parameters.size) do
          parameters.each do |name|
            writer.write(name.to_s)
            writer.write(Parameters.__send__(name))
          end
        end

        Parameters.range_index = range_index if range_index
      end

      private
      def parse_range_index(value)
        case value
        when nil
          nil
        when "auto"
          :auto
        when "always"
          :always
        when "never"
          :never
        else
          message = "[logical_parameters][range_index] "
          message << "must be auto, always or never: <#{value}>"
          raise InvalidArgument, message
        end
      end
    end
  end
end