Sha256: 53bde622b02eb49517c45748acb086a2dfd2339f99e507671ffdf61696297417
Contents?: true
Size: 1.67 KB
Versions: 8
Compression:
Stored size: 1.67 KB
Contents
class Etcdv3::Namespace::KV
module Requests
SORT_TARGET = {
key: 0,
version: 1,
create: 2,
mod: 3,
value: 4
}
SORT_ORDER = {
none: 0,
ascend: 1,
descend: 2
}
def get_request(key, opts)
key = prepend_prefix(@namespace, key)
# In order to enforce the scope of the specified namespace, we are going to
# intercept the zero-byte reference and re-target everything under the given namespace.
if opts[:range_end] =~ /\x00/
opts[:range_end] = (@namespace[0..-2] + (@namespace[-1].ord + 1).chr)
else
opts[:range_end] = prepend_prefix(@namespace, opts[:range_end]) if opts[:range_end]
end
opts[:sort_order] = SORT_ORDER[opts[:sort_order]] \
if opts[:sort_order]
opts[:sort_target] = SORT_TARGET[opts[:sort_target]] \
if opts[:sort_target]
opts[:key] = key
Etcdserverpb::RangeRequest.new(opts)
end
def del_request(key, range_end=nil)
key = prepend_prefix(@namespace, key)
# In order to enforce the scope of the specified namespace, we are going to
# intercept the zero-byte reference and re-target everything under the given namespace.
if range_end =~ /\x00/
range_end = (@namespace[0..-2] + (@namespace[-1].ord + 1).chr)
else
range_end = prepend_prefix(@namespace, range_end) if range_end
end
Etcdserverpb::DeleteRangeRequest.new(key: key, range_end: range_end)
end
def put_request(key, value, lease=nil)
key = prepend_prefix(@namespace, key)
kv = Etcdserverpb::PutRequest.new(key: key, value: value)
kv.lease = lease if lease
kv
end
end
end
Version data entries
8 entries across 8 versions & 2 rubygems