Class: SDM::NodesHistory
- Inherits:
-
Object
- Object
- SDM::NodesHistory
- Extended by:
- Gem::Deprecate
- Defined in:
- lib/svc.rb
Overview
NodesHistory records all changes to the state of a Node.
See NodeHistory.
Instance Method Summary collapse
-
#initialize(channel, parent) ⇒ NodesHistory
constructor
A new instance of NodesHistory.
-
#list(filter, *args, deadline: nil) ⇒ Object
List gets a list of NodeHistory records matching a given set of criteria.
Constructor Details
#initialize(channel, parent) ⇒ NodesHistory
Returns a new instance of NodesHistory.
2333 2334 2335 2336 2337 2338 2339 2340 |
# File 'lib/svc.rb', line 2333 def initialize(channel, parent) begin @stub = V1::NodesHistory::Stub.new(nil, nil, channel_override: channel) rescue => exception raise Plumbing::convert_error_to_porcelain(exception) end @parent = parent end |
Instance Method Details
#list(filter, *args, deadline: nil) ⇒ Object
List gets a list of NodeHistory records matching a given set of criteria.
2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369 2370 2371 2372 2373 2374 2375 2376 2377 2378 2379 |
# File 'lib/svc.rb', line 2343 def list( filter, *args, deadline: nil ) req = V1::NodeHistoryListRequest.new() req. = V1::ListRequestMetadata.new() if @parent.page_limit > 0 req..limit = @parent.page_limit end if not @parent.snapshot_time.nil? req..snapshot_at = @parent.snapshot_time end req.filter = Plumbing::quote_filter_args(filter, *args) resp = Enumerator::Generator.new { |g| tries = 0 loop do begin plumbing_response = @stub.list(req, metadata: @parent.("NodesHistory.List", req), deadline: deadline) rescue => exception if (@parent.shouldRetry(tries, exception)) tries + +@parent.jitterSleep(tries) next end raise Plumbing::convert_error_to_porcelain(exception) end tries = 0 plumbing_response.history.each do |plumbing_item| g.yield Plumbing::convert_node_history_to_porcelain(plumbing_item) end break if plumbing_response..next_cursor == "" req..cursor = plumbing_response..next_cursor end } resp end |