Class: Etcdv3::Watch
- Includes:
- GRPC::Core::TimeConsts
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/etcdv3-0.11.5/lib/etcdv3/watch.rb
Instance Method Summary collapse
- #deadline(timeout) ⇒ Object
-
#initialize(hostname, credentials, timeout, metadata = {}) ⇒ Watch
constructor
A new instance of Watch.
- #watch(key, range_end, start_revision, block, timeout: nil) ⇒ Object
Methods included from GRPC::Core::TimeConsts
Constructor Details
#initialize(hostname, credentials, timeout, metadata = {}) ⇒ Watch
Returns a new instance of Watch.
5 6 7 8 9 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/etcdv3-0.11.5/lib/etcdv3/watch.rb', line 5 def initialize(hostname, credentials, timeout, = {}) @stub = Etcdserverpb::Watch::Stub.new(hostname, credentials) @timeout = timeout @metadata = end |
Instance Method Details
#deadline(timeout) ⇒ Object
29 30 31 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/etcdv3-0.11.5/lib/etcdv3/watch.rb', line 29 def deadline(timeout) from_relative_time(timeout || @timeout) end |
#watch(key, range_end, start_revision, block, timeout: nil) ⇒ Object
11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/etcdv3-0.11.5/lib/etcdv3/watch.rb', line 11 def watch(key, range_end, start_revision, block, timeout: nil) create_req = Etcdserverpb::WatchCreateRequest.new(key: key) create_req.range_end = range_end if range_end create_req.start_revision = start_revision if start_revision watch_req = Etcdserverpb::WatchRequest.new(create_request: create_req) events = nil @stub.watch([watch_req], metadata: @metadata, deadline: deadline(timeout)).each do |resp| next if resp.events.empty? if block block.call(resp.events) else events = resp.events break end end events end |