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.
4526 4527 4528 4529 4530 4531 4532 4533 |
# File 'lib/svc.rb', line 4526 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.
4536 4537 4538 4539 4540 4541 4542 4543 4544 4545 4546 4547 4548 4549 4550 4551 4552 4553 4554 4555 4556 4557 4558 4559 4560 4561 4562 4563 4564 4565 4566 4567 4568 4569 4570 4571 4572 |
# File 'lib/svc.rb', line 4536 def list( filter, *args, deadline: nil ) req = V1::ReplayListRequest.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.("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 |