Sha256: 8cd43b48d981d50fa8a6e404f66101b8c2a7dcbeff8a5b8c70324d009c12cdcd
Contents?: true
Size: 1.95 KB
Versions: 8
Compression:
Stored size: 1.95 KB
Contents
class Etcdv3::Namespace::KV
class Transaction
include Etcdv3::Namespace::Utilities
include Etcdv3::Namespace::KV::Requests
# Available comparison identifiers.
COMPARISON_IDENTIFIERS = {
equal: 0,
greater: 1,
less: 2,
not_equal: 3
}
# Available targets to compare with.
TARGETS = {
version: 0,
create_revision: 1,
mod_revision: 2,
value: 3
}
attr_writer :compare, :success, :failure
def initialize(namespace)
@namespace = namespace
end
def compare
@compare ||= []
end
def success
@success ||= []
end
def failure
@failure ||=[]
end
# Request Operations
# txn.put('my', 'key', lease_id: 1)
def put(key, value, lease=nil)
put_request(key, value, lease)
end
# txn.get('key')
def get(key, opts={})
get_request(key, opts)
end
# txn.del('key')
def del(key, range_end='')
del_request(key, range_end)
end
### Compare Operations
# txn.version('names', :greater, 0 )
def version(key, compare_type, value)
generate_compare(:version, key, compare_type, value)
end
# txn.value('names', :equal, 'wowza' )
def value(key, compare_type, value)
generate_compare(:value, key, compare_type, value)
end
# txn.mod_revision('names', :not_equal, 0)
def mod_revision(key, compare_type, value)
generate_compare(:mod_revision, key, compare_type, value)
end
# txn.create_revision('names', :less, 10)
def create_revision(key, compare_type, value)
generate_compare(:create_revision, key, compare_type, value)
end
private
def generate_compare(target_union, key, compare_type, value)
key = prepend_prefix(@namespace, key)
Etcdserverpb::Compare.new(
key: key,
result: COMPARISON_IDENTIFIERS[compare_type],
target: TARGETS[target_union],
target_union => value
)
end
end
end
Version data entries
8 entries across 8 versions & 2 rubygems