Sha256: 6aa612cf30d477b9ad20c854c59eff32394024ff2d261e3cffdc614e983beefa
Contents?: true
Size: 789 Bytes
Versions: 16
Compression:
Stored size: 789 Bytes
Contents
class Etcdv3::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)
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="")
Etcdserverpb::DeleteRangeRequest.new(key: key, range_end: range_end)
end
def put_request(key, value, lease=nil)
kv = Etcdserverpb::PutRequest.new(key: key, value: value)
kv.lease = lease if lease
kv
end
end
end
Version data entries
16 entries across 16 versions & 2 rubygems