snyk: add maximum executions option for data streams

Author: efd6

packages/snyk/changelog.yml

@@ -1,4 +1,9 @@
 # newer versions go on top
+- version: "2.1.0"
+ changes:
+ - description: Add maximum executions configuration option for data streams.
+ type: enhancement
+ link: https://github.com/elastic/integrations/pull/
 - version: "2.0.0"
  changes:
  - description: Removed legacy audit and vulnerabilities data streams.

packages/snyk/data_stream/audit_logs/agent/stream/cel.yml.hbs

@@ -44,6 +44,9 @@ redact:
  fields:
  - audit_id
  - api_token
+{{#if max_executions}}
+max_executions: {{max_executions}}
+{{/if}}
 program: |
  state.with({
  "Header": {

packages/snyk/data_stream/audit_logs/manifest.yml

@@ -74,6 +74,14 @@ streams:
  multi: false
  required: false
  show_user: false
+ - name: max_executions
+ type: integer
+ title: Maximum Pages Per Interval
+ description: Maximum Pages Per Interval is the maximum number of pages that can be collected at each interval.
+ multi: false
+ required: false
+ show_user: false
+ default: 1000
  - name: tags
  type: text
  title: Tags

packages/snyk/data_stream/issues/agent/stream/cel.yml.hbs

@@ -61,6 +61,9 @@ redact:
  fields:
  - issues_id
  - api_token
+{{#if max_executions}}
+max_executions: {{max_executions}}
+{{/if}}
 program: |
  state.with(get_request(
  state.url.trim_right("/") + state.?cursor.next.orValue(

packages/snyk/data_stream/issues/manifest.yml

@@ -118,6 +118,14 @@ streams:
  multi: false
  required: false
  show_user: false
+ - name: max_executions
+ type: integer
+ title: Maximum Pages Per Interval
+ description: Maximum Pages Per Interval is the maximum number of pages that can be collected at each interval.
+ multi: false
+ required: false
+ show_user: false
+ default: 1000
  - name: tags
  type: text
  title: Tags

packages/snyk/manifest.yml

@@ -1,7 +1,7 @@
 format_version: "3.0.2"
 name: snyk
 title: "Snyk"
-version: "2.0.0"
+version: "2.1.0"
 description: Collect logs from Snyk with Elastic Agent.
 type: integration
 categories: