Add new group by configuration to list stream widget

.apigentools-info

@@ -4,13 +4,13 @@
     "spec_versions": {
         "v1": {
             "apigentools_version": "1.6.4",
-            "regenerated": "2023-01-16 09:24:31.725966",
-            "spec_repo_commit": "7366dfa9"
+            "regenerated": "2023-01-16 10:00:42.109665",
+            "spec_repo_commit": "b299f7d6"
         },
         "v2": {
             "apigentools_version": "1.6.4",
-            "regenerated": "2023-01-16 09:24:31.738986",
-            "spec_repo_commit": "7366dfa9"
+            "regenerated": "2023-01-16 10:00:42.121633",
+            "spec_repo_commit": "b299f7d6"
         }
     }
 }

.generator/schemas/v1/openapi.yaml

@@ -4002,11 +4002,86 @@ components:
       - AUTO
       - COMPACT
       - FULL
+    ListStreamComputeAggregation:
+      description: Aggregation value.
+      enum:
+      - count
+      - cardinality
+      - median
+      - pc75
+      - pc90
+      - pc95
+      - pc98
+      - pc99
+      - sum
+      - min
+      - max
+      - avg
+      - earliest
+      - latest
+      - most_frequent
+      example: count
+      type: string
+      x-enum-varnames:
+      - COUNT
+      - CARDINALITY
+      - MEDIAN
+      - PC75
+      - PC90
+      - PC95
+      - PC98
+      - PC99
+      - SUM
+      - MIN
+      - MAX
+      - AVG
+      - EARLIEST
+      - LATEST
+      - MOST_FREQUENT
+    ListStreamComputeItems:
+      description: List of facets and aggregations which to compute.
+      properties:
+        aggregation:
+          $ref: '#/components/schemas/ListStreamComputeAggregation'
+        facet:
+          description: Facet name.
+          example: resource_name
+          type: string
+      required:
+      - aggregation
+      type: object
+    ListStreamGroupByItems:
+      description: List of facets on which to group.
+      properties:
+        facet:
+          description: Facet name.
+          example: resource_name
+          type: string
+      required:
+      - facet
+      type: object
     ListStreamQuery:
       description: Updated list stream widget.
       properties:
+        compute:
+          description: Compute configuration for the List Stream Widget. Compute can
+            be used only with the logs_transaction_stream (from 1 to 5 items) list
+            stream source.
+          items:
+            $ref: '#/components/schemas/ListStreamComputeItems'
+          maxItems: 5
+          minItems: 1
+          type: array
         data_source:
           $ref: '#/components/schemas/ListStreamSource'
+        group_by:
+          description: Group by configuration for the List Stream Widget. Group by
+            can be used only with logs_pattern_stream (up to 3 items) or logs_transaction_stream
+            (one group by item is required) list stream source.
+          items:
+            $ref: '#/components/schemas/ListStreamGroupByItems'
+          maxItems: 3
+          type: array
         indexes:
           description: List of indexes.
           items:
@@ -4042,6 +4117,7 @@ components:
       - rum_issue_stream
       - apm_issue_stream
       - logs_pattern_stream
+      - logs_transaction_stream
       example: apm_issue_stream
       type: string
       x-enum-varnames:
@@ -4050,6 +4126,7 @@ components:
       - RUM_ISSUE_STREAM
       - APM_ISSUE_STREAM
       - LOGS_PATTERN_STREAM
+      - LOGS_TRANSACTION_STREAM
     ListStreamWidgetDefinition:
       description: 'The list stream visualization displays a table of recent events
         in your application that

api/datadogV1/model_list_stream_compute_aggregation.go

@@ -0,0 +1,135 @@
+// Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+// This product includes software developed at Datadog (https://www.datadoghq.com/).
+// Copyright 2019-Present Datadog, Inc.
+
+package datadogV1
+
+import (
+	"encoding/json"
+	"fmt"
+)
+
+// ListStreamComputeAggregation Aggregation value.
+type ListStreamComputeAggregation string
+
+// List of ListStreamComputeAggregation.
+const (
+	LISTSTREAMCOMPUTEAGGREGATION_COUNT         ListStreamComputeAggregation = "count"
+	LISTSTREAMCOMPUTEAGGREGATION_CARDINALITY   ListStreamComputeAggregation = "cardinality"
+	LISTSTREAMCOMPUTEAGGREGATION_MEDIAN        ListStreamComputeAggregation = "median"
+	LISTSTREAMCOMPUTEAGGREGATION_PC75          ListStreamComputeAggregation = "pc75"
+	LISTSTREAMCOMPUTEAGGREGATION_PC90          ListStreamComputeAggregation = "pc90"
+	LISTSTREAMCOMPUTEAGGREGATION_PC95          ListStreamComputeAggregation = "pc95"
+	LISTSTREAMCOMPUTEAGGREGATION_PC98          ListStreamComputeAggregation = "pc98"
+	LISTSTREAMCOMPUTEAGGREGATION_PC99          ListStreamComputeAggregation = "pc99"
+	LISTSTREAMCOMPUTEAGGREGATION_SUM           ListStreamComputeAggregation = "sum"
+	LISTSTREAMCOMPUTEAGGREGATION_MIN           ListStreamComputeAggregation = "min"
+	LISTSTREAMCOMPUTEAGGREGATION_MAX           ListStreamComputeAggregation = "max"
+	LISTSTREAMCOMPUTEAGGREGATION_AVG           ListStreamComputeAggregation = "avg"
+	LISTSTREAMCOMPUTEAGGREGATION_EARLIEST      ListStreamComputeAggregation = "earliest"
+	LISTSTREAMCOMPUTEAGGREGATION_LATEST        ListStreamComputeAggregation = "latest"
+	LISTSTREAMCOMPUTEAGGREGATION_MOST_FREQUENT ListStreamComputeAggregation = "most_frequent"
+)
+
+var allowedListStreamComputeAggregationEnumValues = []ListStreamComputeAggregation{
+	LISTSTREAMCOMPUTEAGGREGATION_COUNT,
+	LISTSTREAMCOMPUTEAGGREGATION_CARDINALITY,
+	LISTSTREAMCOMPUTEAGGREGATION_MEDIAN,
+	LISTSTREAMCOMPUTEAGGREGATION_PC75,
+	LISTSTREAMCOMPUTEAGGREGATION_PC90,
+	LISTSTREAMCOMPUTEAGGREGATION_PC95,
+	LISTSTREAMCOMPUTEAGGREGATION_PC98,
+	LISTSTREAMCOMPUTEAGGREGATION_PC99,
+	LISTSTREAMCOMPUTEAGGREGATION_SUM,
+	LISTSTREAMCOMPUTEAGGREGATION_MIN,
+	LISTSTREAMCOMPUTEAGGREGATION_MAX,
+	LISTSTREAMCOMPUTEAGGREGATION_AVG,
+	LISTSTREAMCOMPUTEAGGREGATION_EARLIEST,
+	LISTSTREAMCOMPUTEAGGREGATION_LATEST,
+	LISTSTREAMCOMPUTEAGGREGATION_MOST_FREQUENT,
+}
+
+// GetAllowedValues reeturns the list of possible values.
+func (v *ListStreamComputeAggregation) GetAllowedValues() []ListStreamComputeAggregation {
+	return allowedListStreamComputeAggregationEnumValues
+}
+
+// UnmarshalJSON deserializes the given payload.
+func (v *ListStreamComputeAggregation) UnmarshalJSON(src []byte) error {
+	var value string
+	err := json.Unmarshal(src, &value)
+	if err != nil {
+		return err
+	}
+	*v = ListStreamComputeAggregation(value)
+	return nil
+}
+
+// NewListStreamComputeAggregationFromValue returns a pointer to a valid ListStreamComputeAggregation
+// for the value passed as argument, or an error if the value passed is not allowed by the enum.
+func NewListStreamComputeAggregationFromValue(v string) (*ListStreamComputeAggregation, error) {
+	ev := ListStreamComputeAggregation(v)
+	if ev.IsValid() {
+		return &ev, nil
+	}
+	return nil, fmt.Errorf("invalid value '%v' for ListStreamComputeAggregation: valid values are %v", v, allowedListStreamComputeAggregationEnumValues)
+}
+
+// IsValid return true if the value is valid for the enum, false otherwise.
+func (v ListStreamComputeAggregation) IsValid() bool {
+	for _, existing := range allowedListStreamComputeAggregationEnumValues {
+		if existing == v {
+			return true
+		}
+	}
+	return false
+}
+
+// Ptr returns reference to ListStreamComputeAggregation value.
+func (v ListStreamComputeAggregation) Ptr() *ListStreamComputeAggregation {
+	return &v
+}
+
+// NullableListStreamComputeAggregation handles when a null is used for ListStreamComputeAggregation.
+type NullableListStreamComputeAggregation struct {
+	value *ListStreamComputeAggregation
+	isSet bool
+}
+
+// Get returns the associated value.
+func (v NullableListStreamComputeAggregation) Get() *ListStreamComputeAggregation {
+	return v.value
+}
+
+// Set changes the value and indicates it's been called.
+func (v *NullableListStreamComputeAggregation) Set(val *ListStreamComputeAggregation) {
+	v.value = val
+	v.isSet = true
+}
+
+// IsSet returns whether Set has been called.
+func (v NullableListStreamComputeAggregation) IsSet() bool {
+	return v.isSet
+}
+
+// Unset sets the value to nil and resets the set flag.
+func (v *NullableListStreamComputeAggregation) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+// NewNullableListStreamComputeAggregation initializes the struct as if Set has been called.
+func NewNullableListStreamComputeAggregation(val *ListStreamComputeAggregation) *NullableListStreamComputeAggregation {
+	return &NullableListStreamComputeAggregation{value: val, isSet: true}
+}
+
+// MarshalJSON serializes the associated value.
+func (v NullableListStreamComputeAggregation) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+// UnmarshalJSON deserializes the payload and sets the flag as if Set has been called.
+func (v *NullableListStreamComputeAggregation) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}