Class: SDM::Replays
Overview
A Replay captures the data transferred over a long-running SSH, RDP, or Kubernetes interactive session (otherwise referred to as a query). The Replays service is read-only.
See ReplayChunk.
Instance Method Summary collapse
-
#initialize(channel, parent) ⇒ Replays
constructor
A new instance of Replays.
-
#list(filter, *args, deadline: nil) ⇒ Object
List gets a list of ReplayChunks for the Query ID specified by the filter criteria.
Constructor Details
#initialize(channel, parent) ⇒ Replays
Returns a new instance of Replays.
2004 2005 2006 2007 2008 2009 2010 2011 |
# File 'lib/svc.rb', line 2004 def initialize(channel, parent) begin @stub = V1::Replays::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 ReplayChunks for the Query ID specified by the filter criteria.
2014 2015 2016 2017 2018 2019 2020 2021 2022 2023 2024 2025 2026 2027 2028 2029 2030 2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049 2050 2051 |
# File 'lib/svc.rb', line 2014 def list( filter, *args, deadline: nil ) req = V1::ReplayListRequest.new() req. = V1::ListRequestMetadata.new() page_size_option = @parent.["PageSize"] if page_size_option.is_a? Integer req..limit = page_size_option 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.("Replays.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.chunks.each do |plumbing_item| g.yield Plumbing::convert_replay_chunk_to_porcelain(plumbing_item) end break if plumbing_response..next_cursor == "" req..cursor = plumbing_response..next_cursor end } resp end |