feat: add timeout_seconds option to Kubeclient::Client#watch_entities

README.md

@@ -221,7 +221,7 @@ client = Kubeclient::Client.new(
 
 ### Timeouts
 
-Watching configures the socket to never time out (however, sooner or later all watches terminate).
+Watching configures the socket to never time out by default (however, sooner or later all watches terminate).
 
 One-off actions like `.get_*`, `.delete_*` have a configurable timeout:
 ```ruby
@@ -625,6 +625,13 @@ client.watch_pods allow_watch_bookmarks: true do |notice|
 end
 ```
 
+To limit the maximum duration of a watch on the server, pass the `timeout_seconds:` param.
+```ruby
+client.watch_pods(timeout_seconds: 120, namespace: ns) do |notice|
+ ...
+end
+```
+
 #### All watches come to an end!
 
 While nominally the watch block *looks* like an infinite loop, that's unrealistic. Network connections eventually get severed, and kubernetes apiserver is known to terminate watches.

lib/kubeclient.rb

@@ -77,10 +77,11 @@ class Client
  }.freeze
 
  WATCH_ARGUMENTS = {
- 'labelSelector' => :label_selector,
- 'fieldSelector' => :field_selector,
- 'resourceVersion' => :resource_version,
- 'allowWatchBookmarks' => :allow_watch_bookmarks
+ 'labelSelector' => :label_selector,
+ 'fieldSelector' => :field_selector,
+ 'resourceVersion' => :resource_version,
+ 'allowWatchBookmarks' => :allow_watch_bookmarks,
+ 'timeoutSeconds' => :timeout_seconds
  }.freeze
 
  attr_reader :api_endpoint
@@ -408,6 +409,7 @@ def faraday_client
  # :label_selector (string) - a selector to restrict the list of returned objects by labels.
  # :field_selector (string) - a selector to restrict the list of returned objects by fields.
  # :resource_version (string) - shows changes that occur after passed version of a resource.
+ # :timeout_seconds (integer) - limits the duration of the call
  # :as (:raw|:ros) - defaults to :ros
  # :raw - return the raw response body as a string
  # :ros - return a collection of RecursiveOpenStruct objects
@@ -493,7 +495,7 @@ def delete_entity(resource_name, name, namespace = nil, delete_options: {})
  # :resource_version (string) - sets a limit on the resource versions that can be served
  # :resource_version_match (string) - determines how the resource_version constraint
  # will be applied
- # :timeout_seconds (integer) - limits the duraiton of the call
+ # :timeout_seconds (integer) - limits the duration of the call
  # :continue (string) - a token used to retrieve the next chunk of entities
  # :as (:raw|:ros) - defaults to :ros
  # :raw - return the raw response body as a string