Class: Etcdv3::KV

Inherits:
Object
  • Object
show all
Includes:
Requests
Defined in:
lib/etcdv3/kv.rb,
lib/etcdv3/kv/requests.rb,
lib/etcdv3/kv/transaction.rb

Defined Under Namespace

Modules: Requests Classes: Transaction

Constant Summary

Constants included from Requests

Requests::SORT_ORDER, Requests::SORT_TARGET

Instance Method Summary collapse

Methods included from Requests

#del_request, #get_request, #put_request

Constructor Details

#initialize(hostname, credentials, timeout, metadata = {}) ⇒ KV 



6
7
8
9
10
 
# File 'lib/etcdv3/kv.rb', line 6

def initialize(hostname, credentials, timeout, metadata={})
  @stub = Etcdserverpb::KV::Stub.new(hostname, credentials)
  @timeout = timeout
  @metadata = metadata
end

Instance Method Details

#del(key, range_end: '', timeout: nil) ⇒ Object 



17
18
19
 
# File 'lib/etcdv3/kv.rb', line 17

def del(key, range_end: '', timeout: nil)
  @stub.delete_range(del_request(key, range_end), metadata: @metadata, deadline: deadline(timeout))
end

#get(key, opts = {}) ⇒ Object 



12
13
14
15
 
# File 'lib/etcdv3/kv.rb', line 12

def get(key, opts={})
  timeout = opts.delete(:timeout)
  @stub.range(get_request(key, opts), metadata: @metadata, deadline: deadline(timeout))
end

#put(key, value, lease: nil, timeout: nil) ⇒ Object 



21
22
23
 
# File 'lib/etcdv3/kv.rb', line 21

def put(key, value, lease: nil, timeout: nil)
  @stub.put(put_request(key, value, lease), metadata: @metadata, deadline: deadline(timeout))
end

#transaction(block, timeout: nil) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
 
# File 'lib/etcdv3/kv.rb', line 25

def transaction(block, timeout: nil)
  txn = Etcdv3::KV::Transaction.new
  block.call(txn)
  request = Etcdserverpb::TxnRequest.new(
    compare: txn.compare,
    success: generate_request_ops(txn.success),
    failure: generate_request_ops(txn.failure)
  )
  @stub.txn(request, metadata: @metadata, deadline: deadline(timeout))
end