Class: Samsara::Alerts::AsyncIncidentsClient
- Inherits:
-
Object
- Object
- Samsara::Alerts::AsyncIncidentsClient
- Defined in:
- lib/samsara_api/alerts/incidents/client.rb
Instance Attribute Summary collapse
Instance Method Summary collapse
- #initialize(request_client:) ⇒ Samsara::Alerts::AsyncIncidentsClient constructor
-
#stream(start_time:, configuration_ids: nil, end_time: nil, after: nil, request_options: nil) ⇒ Object
api.alerts.incidents.stream(start_time: “startTime”).
Constructor Details
#initialize(request_client:) ⇒ Samsara::Alerts::AsyncIncidentsClient
77 78 79 |
# File 'lib/samsara_api/alerts/incidents/client.rb', line 77 def initialize(request_client:) @request_client = request_client end |
Instance Attribute Details
#request_client ⇒ Samsara::AsyncRequestClient (readonly)
72 73 74 |
# File 'lib/samsara_api/alerts/incidents/client.rb', line 72 def request_client @request_client end |
Instance Method Details
#stream(start_time:, configuration_ids: nil, end_time: nil, after: nil, request_options: nil) ⇒ Object
api.alerts.incidents.stream(start_time: “startTime”)
113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 |
# File 'lib/samsara_api/alerts/incidents/client.rb', line 113 def stream(start_time:, configuration_ids: nil, end_time: nil, after: nil, request_options: nil) Async do response = @request_client.conn.get do | req | unless &.timeout_in_seconds.nil? req..timeout = .timeout_in_seconds end unless &.token.nil? req.headers["Authorization"] = .token end req.headers = { **(req.headers || {}), **@request_client.get_headers, **(&.additional_headers || {}) }.compact req.params = { **(&.additional_query_parameters || {}), "startTime": start_time, "configurationIds": configuration_ids, "endTime": end_time, "after": after }.compact unless .nil? || &.additional_body_parameters.nil? req.body = { **(&.additional_body_parameters || {}) }.compact end req.url "#{@request_client.get_url(request_options: request_options)}/alerts/incidents/stream" end Samsara::Types::AlertsGetIncidentsResponseBody.from_json(json_object: response.body) end end |