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.
2926 2927 2928 2929 2930 2931 2932 2933 |
# File 'lib/svc.rb', line 2926 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.
2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970 2971 2972 |
# File 'lib/svc.rb', line 2936 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 |