Skip to content

Commit 10f1298

Browse files
api-clients-generation-pipeline[bot]ci.datadog-api-spec
api-clients-generation-pipeline[bot]
and
ci.datadog-api-spec
authored
Observability Pipelines API is GA now (DataDog#3658)
Co-authored-by: ci.datadog-api-spec <packages@datadoghq.com>
1 parent 3a10899 commit 10f1298

28 files changed

Lines changed: 81 additions & 203 deletions

‎.generator/schemas/v2/openapi.yaml‎

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -83957,8 +83957,6 @@ paths:
8395783957
operator: OR
8395883958
permissions:
8395983959
- observability_pipelines_read
83960-
x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
83961-
to request access.'
8396283960
post:
8396383961
description: Create a new pipeline.
8396483962
operationId: CreatePipeline
@@ -83990,8 +83988,6 @@ paths:
8399083988
operator: OR
8399183989
permissions:
8399283990
- observability_pipelines_deploy
83993-
x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
83994-
to request access.'
8399583991
/api/v2/obs-pipelines/pipelines/validate:
8399683992
post:
8399783993
description: 'Validates a pipeline configuration without creating or updating
@@ -84025,8 +84021,6 @@ paths:
8402584021
operator: OR
8402684022
permissions:
8402784023
- observability_pipelines_read
84028-
x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
84029-
to request access.'
8403084024
/api/v2/obs-pipelines/pipelines/{pipeline_id}:
8403184025
delete:
8403284026
description: Delete a pipeline.
@@ -84068,8 +84062,6 @@ paths:
8406884062
operator: OR
8406984063
permissions:
8407084064
- observability_pipelines_delete
84071-
x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
84072-
to request access.'
8407384065
get:
8407484066
description: Get a specific pipeline by its ID.
8407584067
operationId: GetPipeline
@@ -84102,8 +84094,6 @@ paths:
8410284094
operator: OR
8410384095
permissions:
8410484096
- observability_pipelines_read
84105-
x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
84106-
to request access.'
8410784097
put:
8410884098
description: Update a pipeline.
8410984099
operationId: UpdatePipeline
@@ -84144,8 +84134,6 @@ paths:
8414484134
operator: OR
8414584135
permissions:
8414684136
- observability_pipelines_deploy
84147-
x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
84148-
to request access.'
8414984137
/api/v2/on-call/escalation-policies:
8415084138
post:
8415184139
description: Create a new On-Call escalation policy

‎api/datadog/configuration.go‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -786,12 +786,6 @@ func NewConfiguration() *Configuration {
786786
"v2.UpdateMonitorUserTemplate": false,
787787
"v2.ValidateExistingMonitorUserTemplate": false,
788788
"v2.ValidateMonitorUserTemplate": false,
789-
"v2.CreatePipeline": false,
790-
"v2.DeletePipeline": false,
791-
"v2.GetPipeline": false,
792-
"v2.ListPipelines": false,
793-
"v2.UpdatePipeline": false,
794-
"v2.ValidatePipeline": false,
795789
"v2.ListRoleTemplates": false,
796790
"v2.CreateConnection": false,
797791
"v2.DeleteConnection": false,

‎api/datadogV2/api_observability_pipelines.go‎

Lines changed: 0 additions & 56 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,6 @@ package datadogV2
66

77
import (
88
_context "context"
9-
_fmt "fmt"
10-
_log "log"
119
_nethttp "net/http"
1210
_neturl "net/url"
1311

@@ -26,15 +24,6 @@ func (a *ObservabilityPipelinesApi) CreatePipeline(ctx _context.Context, body Ob
2624
localVarReturnValue ObservabilityPipeline
2725
)
2826

29-
operationId := "v2.CreatePipeline"
30-
isOperationEnabled := a.Client.Cfg.IsUnstableOperationEnabled(operationId)
31-
if !isOperationEnabled {
32-
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: _fmt.Sprintf("Unstable operation '%s' is disabled", operationId)}
33-
}
34-
if isOperationEnabled && a.Client.Cfg.Debug {
35-
_log.Printf("WARNING: Using unstable operation '%s'", operationId)
36-
}
37-
3827
localBasePath, err := a.Client.Cfg.ServerURLWithContext(ctx, "v2.ObservabilityPipelinesApi.CreatePipeline")
3928
if err != nil {
4029
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: err.Error()}
@@ -114,15 +103,6 @@ func (a *ObservabilityPipelinesApi) DeletePipeline(ctx _context.Context, pipelin
114103
localVarPostBody interface{}
115104
)
116105

117-
operationId := "v2.DeletePipeline"
118-
isOperationEnabled := a.Client.Cfg.IsUnstableOperationEnabled(operationId)
119-
if !isOperationEnabled {
120-
return nil, datadog.GenericOpenAPIError{ErrorMessage: _fmt.Sprintf("Unstable operation '%s' is disabled", operationId)}
121-
}
122-
if isOperationEnabled && a.Client.Cfg.Debug {
123-
_log.Printf("WARNING: Using unstable operation '%s'", operationId)
124-
}
125-
126106
localBasePath, err := a.Client.Cfg.ServerURLWithContext(ctx, "v2.ObservabilityPipelinesApi.DeletePipeline")
127107
if err != nil {
128108
return nil, datadog.GenericOpenAPIError{ErrorMessage: err.Error()}
@@ -192,15 +172,6 @@ func (a *ObservabilityPipelinesApi) GetPipeline(ctx _context.Context, pipelineId
192172
localVarReturnValue ObservabilityPipeline
193173
)
194174

195-
operationId := "v2.GetPipeline"
196-
isOperationEnabled := a.Client.Cfg.IsUnstableOperationEnabled(operationId)
197-
if !isOperationEnabled {
198-
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: _fmt.Sprintf("Unstable operation '%s' is disabled", operationId)}
199-
}
200-
if isOperationEnabled && a.Client.Cfg.Debug {
201-
_log.Printf("WARNING: Using unstable operation '%s'", operationId)
202-
}
203-
204175
localBasePath, err := a.Client.Cfg.ServerURLWithContext(ctx, "v2.ObservabilityPipelinesApi.GetPipeline")
205176
if err != nil {
206177
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: err.Error()}
@@ -311,15 +282,6 @@ func (a *ObservabilityPipelinesApi) ListPipelines(ctx _context.Context, o ...Lis
311282
optionalParams = o[0]
312283
}
313284

314-
operationId := "v2.ListPipelines"
315-
isOperationEnabled := a.Client.Cfg.IsUnstableOperationEnabled(operationId)
316-
if !isOperationEnabled {
317-
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: _fmt.Sprintf("Unstable operation '%s' is disabled", operationId)}
318-
}
319-
if isOperationEnabled && a.Client.Cfg.Debug {
320-
_log.Printf("WARNING: Using unstable operation '%s'", operationId)
321-
}
322-
323285
localBasePath, err := a.Client.Cfg.ServerURLWithContext(ctx, "v2.ObservabilityPipelinesApi.ListPipelines")
324286
if err != nil {
325287
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: err.Error()}
@@ -403,15 +365,6 @@ func (a *ObservabilityPipelinesApi) UpdatePipeline(ctx _context.Context, pipelin
403365
localVarReturnValue ObservabilityPipeline
404366
)
405367

406-
operationId := "v2.UpdatePipeline"
407-
isOperationEnabled := a.Client.Cfg.IsUnstableOperationEnabled(operationId)
408-
if !isOperationEnabled {
409-
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: _fmt.Sprintf("Unstable operation '%s' is disabled", operationId)}
410-
}
411-
if isOperationEnabled && a.Client.Cfg.Debug {
412-
_log.Printf("WARNING: Using unstable operation '%s'", operationId)
413-
}
414-
415368
localBasePath, err := a.Client.Cfg.ServerURLWithContext(ctx, "v2.ObservabilityPipelinesApi.UpdatePipeline")
416369
if err != nil {
417370
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: err.Error()}
@@ -494,15 +447,6 @@ func (a *ObservabilityPipelinesApi) ValidatePipeline(ctx _context.Context, body
494447
localVarReturnValue ValidationResponse
495448
)
496449

497-
operationId := "v2.ValidatePipeline"
498-
isOperationEnabled := a.Client.Cfg.IsUnstableOperationEnabled(operationId)
499-
if !isOperationEnabled {
500-
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: _fmt.Sprintf("Unstable operation '%s' is disabled", operationId)}
501-
}
502-
if isOperationEnabled && a.Client.Cfg.Debug {
503-
_log.Printf("WARNING: Using unstable operation '%s'", operationId)
504-
}
505-
506450
localBasePath, err := a.Client.Cfg.ServerURLWithContext(ctx, "v2.ObservabilityPipelinesApi.ValidatePipeline")
507451
if err != nil {
508452
return localVarReturnValue, nil, datadog.GenericOpenAPIError{ErrorMessage: err.Error()}

‎examples/v2/observability-pipelines/CreatePipeline.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,6 @@ func main() {
6161
}
6262
ctx := datadog.NewDefaultContext(context.Background())
6363
configuration := datadog.NewConfiguration()
64-
configuration.SetUnstableOperationEnabled("v2.CreatePipeline", true)
6564
apiClient := datadog.NewAPIClient(configuration)
6665
api := datadogV2.NewObservabilityPipelinesApi(apiClient)
6766
resp, r, err := api.CreatePipeline(ctx, body)

‎examples/v2/observability-pipelines/DeletePipeline.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ func main() {
1717

1818
ctx := datadog.NewDefaultContext(context.Background())
1919
configuration := datadog.NewConfiguration()
20-
configuration.SetUnstableOperationEnabled("v2.DeletePipeline", true)
2120
apiClient := datadog.NewAPIClient(configuration)
2221
api := datadogV2.NewObservabilityPipelinesApi(apiClient)
2322
r, err := api.DeletePipeline(ctx, PipelineDataID)

‎examples/v2/observability-pipelines/GetPipeline.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ func main() {
1818

1919
ctx := datadog.NewDefaultContext(context.Background())
2020
configuration := datadog.NewConfiguration()
21-
configuration.SetUnstableOperationEnabled("v2.GetPipeline", true)
2221
apiClient := datadog.NewAPIClient(configuration)
2322
api := datadogV2.NewObservabilityPipelinesApi(apiClient)
2423
resp, r, err := api.GetPipeline(ctx, PipelineDataID)

‎examples/v2/observability-pipelines/ListPipelines.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@ import (
1515
func main() {
1616
ctx := datadog.NewDefaultContext(context.Background())
1717
configuration := datadog.NewConfiguration()
18-
configuration.SetUnstableOperationEnabled("v2.ListPipelines", true)
1918
apiClient := datadog.NewAPIClient(configuration)
2019
api := datadogV2.NewObservabilityPipelinesApi(apiClient)
2120
resp, r, err := api.ListPipelines(ctx, *datadogV2.NewListPipelinesOptionalParameters())

‎examples/v2/observability-pipelines/UpdatePipeline.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,6 @@ func main() {
6565
}
6666
ctx := datadog.NewDefaultContext(context.Background())
6767
configuration := datadog.NewConfiguration()
68-
configuration.SetUnstableOperationEnabled("v2.UpdatePipeline", true)
6968
apiClient := datadog.NewAPIClient(configuration)
7069
api := datadogV2.NewObservabilityPipelinesApi(apiClient)
7170
resp, r, err := api.UpdatePipeline(ctx, PipelineDataID, body)

‎examples/v2/observability-pipelines/ValidatePipeline.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,6 @@ func main() {
6161
}
6262
ctx := datadog.NewDefaultContext(context.Background())
6363
configuration := datadog.NewConfiguration()
64-
configuration.SetUnstableOperationEnabled("v2.ValidatePipeline", true)
6564
apiClient := datadog.NewAPIClient(configuration)
6665
api := datadogV2.NewObservabilityPipelinesApi(apiClient)
6766
resp, r, err := api.ValidatePipeline(ctx, body)

‎tests/scenarios/cassettes/TestScenarios/v2/Feature_Observability_Pipelines/Scenario_Create_a_new_pipeline_returns_Bad_Request_response.freeze‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
2026-01-09T15:42:36.842Z
1+
2026-01-30T16:23:40.491Z

0 commit comments

Comments
 (0)