From 79788531b5455b44c62ebec4e2af6fe27a63c0f2 Mon Sep 17 00:00:00 2001 From: jim-junior Date: Mon, 13 Jul 2026 21:13:39 +0300 Subject: [PATCH] feat: add CreatePipeline function to Client for pipeline creation --- pkg/driver-runtime/resource.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/pkg/driver-runtime/resource.go b/pkg/driver-runtime/resource.go index 58c45d8..e80097d 100644 --- a/pkg/driver-runtime/resource.go +++ b/pkg/driver-runtime/resource.go @@ -146,3 +146,14 @@ func (c *Client) DeleteResourceDefinition(ctx context.Context, name string) (*ty return &resp, nil } + +func (c *Client) CreatePipeline(ctx context.Context, pipeline *types.Pipeline) (*types.Pipeline, error) { + path := "/pipelines" + + var resp types.Pipeline + if err := c.doRequest(ctx, http.MethodPost, path, pipeline, &resp); err != nil { + return nil, fmt.Errorf("CreatePipeline: failed to create pipeline, %w", err) + } + + return &resp, nil +}