sdk/resourcemanager/apimanagement/armapimanagement/workspaceapioperation_client.go (433 lines of code) (raw):

// Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. // Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. package armapimanagement import ( "context" "errors" "github.com/Azure/azure-sdk-for-go/sdk/azcore" "github.com/Azure/azure-sdk-for-go/sdk/azcore/arm" "github.com/Azure/azure-sdk-for-go/sdk/azcore/policy" "github.com/Azure/azure-sdk-for-go/sdk/azcore/runtime" "net/http" "net/url" "strconv" "strings" ) // WorkspaceAPIOperationClient contains the methods for the WorkspaceAPIOperation group. // Don't use this type directly, use NewWorkspaceAPIOperationClient() instead. type WorkspaceAPIOperationClient struct { internal *arm.Client subscriptionID string } // NewWorkspaceAPIOperationClient creates a new instance of WorkspaceAPIOperationClient with the specified values. // - subscriptionID - The ID of the target subscription. The value must be an UUID. // - credential - used to authorize requests. Usually a credential from azidentity. // - options - pass nil to accept the default values. func NewWorkspaceAPIOperationClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*WorkspaceAPIOperationClient, error) { cl, err := arm.NewClient(moduleName, moduleVersion, credential, options) if err != nil { return nil, err } client := &WorkspaceAPIOperationClient{ subscriptionID: subscriptionID, internal: cl, } return client, nil } // CreateOrUpdate - Creates a new operation in the API or updates an existing one. // If the operation fails it returns an *azcore.ResponseError type. // // Generated from API version 2024-05-01 // - resourceGroupName - The name of the resource group. The name is case insensitive. // - serviceName - The name of the API Management service. // - workspaceID - Workspace identifier. Must be unique in the current API Management service instance. // - apiID - API revision identifier. Must be unique in the current API Management service instance. Non-current revision has // ;rev=n as a suffix where n is the revision number. // - operationID - Operation identifier within an API. Must be unique in the current API Management service instance. // - parameters - Create parameters. // - options - WorkspaceAPIOperationClientCreateOrUpdateOptions contains the optional parameters for the WorkspaceAPIOperationClient.CreateOrUpdate // method. func (client *WorkspaceAPIOperationClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, parameters OperationContract, options *WorkspaceAPIOperationClientCreateOrUpdateOptions) (WorkspaceAPIOperationClientCreateOrUpdateResponse, error) { var err error const operationName = "WorkspaceAPIOperationClient.CreateOrUpdate" ctx = context.WithValue(ctx, runtime.CtxAPINameKey{}, operationName) ctx, endSpan := runtime.StartSpan(ctx, operationName, client.internal.Tracer(), nil) defer func() { endSpan(err) }() req, err := client.createOrUpdateCreateRequest(ctx, resourceGroupName, serviceName, workspaceID, apiID, operationID, parameters, options) if err != nil { return WorkspaceAPIOperationClientCreateOrUpdateResponse{}, err } httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return WorkspaceAPIOperationClientCreateOrUpdateResponse{}, err } if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusCreated) { err = runtime.NewResponseError(httpResp) return WorkspaceAPIOperationClientCreateOrUpdateResponse{}, err } resp, err := client.createOrUpdateHandleResponse(httpResp) return resp, err } // createOrUpdateCreateRequest creates the CreateOrUpdate request. func (client *WorkspaceAPIOperationClient) createOrUpdateCreateRequest(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, parameters OperationContract, options *WorkspaceAPIOperationClientCreateOrUpdateOptions) (*policy.Request, error) { urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ApiManagement/service/{serviceName}/workspaces/{workspaceId}/apis/{apiId}/operations/{operationId}" if resourceGroupName == "" { return nil, errors.New("parameter resourceGroupName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) if serviceName == "" { return nil, errors.New("parameter serviceName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{serviceName}", url.PathEscape(serviceName)) if workspaceID == "" { return nil, errors.New("parameter workspaceID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{workspaceId}", url.PathEscape(workspaceID)) if apiID == "" { return nil, errors.New("parameter apiID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{apiId}", url.PathEscape(apiID)) if operationID == "" { return nil, errors.New("parameter operationID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{operationId}", url.PathEscape(operationID)) if client.subscriptionID == "" { return nil, errors.New("parameter client.subscriptionID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) req, err := runtime.NewRequest(ctx, http.MethodPut, runtime.JoinPaths(client.internal.Endpoint(), urlPath)) if err != nil { return nil, err } reqQP := req.Raw().URL.Query() reqQP.Set("api-version", "2024-05-01") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} if options != nil && options.IfMatch != nil { req.Raw().Header["If-Match"] = []string{*options.IfMatch} } if err := runtime.MarshalAsJSON(req, parameters); err != nil { return nil, err } return req, nil } // createOrUpdateHandleResponse handles the CreateOrUpdate response. func (client *WorkspaceAPIOperationClient) createOrUpdateHandleResponse(resp *http.Response) (WorkspaceAPIOperationClientCreateOrUpdateResponse, error) { result := WorkspaceAPIOperationClientCreateOrUpdateResponse{} if val := resp.Header.Get("ETag"); val != "" { result.ETag = &val } if err := runtime.UnmarshalAsJSON(resp, &result.OperationContract); err != nil { return WorkspaceAPIOperationClientCreateOrUpdateResponse{}, err } return result, nil } // Delete - Deletes the specified operation in the API. // If the operation fails it returns an *azcore.ResponseError type. // // Generated from API version 2024-05-01 // - resourceGroupName - The name of the resource group. The name is case insensitive. // - serviceName - The name of the API Management service. // - workspaceID - Workspace identifier. Must be unique in the current API Management service instance. // - apiID - API revision identifier. Must be unique in the current API Management service instance. Non-current revision has // ;rev=n as a suffix where n is the revision number. // - operationID - Operation identifier within an API. Must be unique in the current API Management service instance. // - ifMatch - ETag of the Entity. ETag should match the current entity state from the header response of the GET request or // it should be * for unconditional update. // - options - WorkspaceAPIOperationClientDeleteOptions contains the optional parameters for the WorkspaceAPIOperationClient.Delete // method. func (client *WorkspaceAPIOperationClient) Delete(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, ifMatch string, options *WorkspaceAPIOperationClientDeleteOptions) (WorkspaceAPIOperationClientDeleteResponse, error) { var err error const operationName = "WorkspaceAPIOperationClient.Delete" ctx = context.WithValue(ctx, runtime.CtxAPINameKey{}, operationName) ctx, endSpan := runtime.StartSpan(ctx, operationName, client.internal.Tracer(), nil) defer func() { endSpan(err) }() req, err := client.deleteCreateRequest(ctx, resourceGroupName, serviceName, workspaceID, apiID, operationID, ifMatch, options) if err != nil { return WorkspaceAPIOperationClientDeleteResponse{}, err } httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return WorkspaceAPIOperationClientDeleteResponse{}, err } if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusNoContent) { err = runtime.NewResponseError(httpResp) return WorkspaceAPIOperationClientDeleteResponse{}, err } return WorkspaceAPIOperationClientDeleteResponse{}, nil } // deleteCreateRequest creates the Delete request. func (client *WorkspaceAPIOperationClient) deleteCreateRequest(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, ifMatch string, _ *WorkspaceAPIOperationClientDeleteOptions) (*policy.Request, error) { urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ApiManagement/service/{serviceName}/workspaces/{workspaceId}/apis/{apiId}/operations/{operationId}" if resourceGroupName == "" { return nil, errors.New("parameter resourceGroupName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) if serviceName == "" { return nil, errors.New("parameter serviceName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{serviceName}", url.PathEscape(serviceName)) if workspaceID == "" { return nil, errors.New("parameter workspaceID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{workspaceId}", url.PathEscape(workspaceID)) if apiID == "" { return nil, errors.New("parameter apiID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{apiId}", url.PathEscape(apiID)) if operationID == "" { return nil, errors.New("parameter operationID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{operationId}", url.PathEscape(operationID)) if client.subscriptionID == "" { return nil, errors.New("parameter client.subscriptionID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) req, err := runtime.NewRequest(ctx, http.MethodDelete, runtime.JoinPaths(client.internal.Endpoint(), urlPath)) if err != nil { return nil, err } reqQP := req.Raw().URL.Query() reqQP.Set("api-version", "2024-05-01") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} req.Raw().Header["If-Match"] = []string{ifMatch} return req, nil } // Get - Gets the details of the API Operation specified by its identifier. // If the operation fails it returns an *azcore.ResponseError type. // // Generated from API version 2024-05-01 // - resourceGroupName - The name of the resource group. The name is case insensitive. // - serviceName - The name of the API Management service. // - workspaceID - Workspace identifier. Must be unique in the current API Management service instance. // - apiID - API revision identifier. Must be unique in the current API Management service instance. Non-current revision has // ;rev=n as a suffix where n is the revision number. // - operationID - Operation identifier within an API. Must be unique in the current API Management service instance. // - options - WorkspaceAPIOperationClientGetOptions contains the optional parameters for the WorkspaceAPIOperationClient.Get // method. func (client *WorkspaceAPIOperationClient) Get(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, options *WorkspaceAPIOperationClientGetOptions) (WorkspaceAPIOperationClientGetResponse, error) { var err error const operationName = "WorkspaceAPIOperationClient.Get" ctx = context.WithValue(ctx, runtime.CtxAPINameKey{}, operationName) ctx, endSpan := runtime.StartSpan(ctx, operationName, client.internal.Tracer(), nil) defer func() { endSpan(err) }() req, err := client.getCreateRequest(ctx, resourceGroupName, serviceName, workspaceID, apiID, operationID, options) if err != nil { return WorkspaceAPIOperationClientGetResponse{}, err } httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return WorkspaceAPIOperationClientGetResponse{}, err } if !runtime.HasStatusCode(httpResp, http.StatusOK) { err = runtime.NewResponseError(httpResp) return WorkspaceAPIOperationClientGetResponse{}, err } resp, err := client.getHandleResponse(httpResp) return resp, err } // getCreateRequest creates the Get request. func (client *WorkspaceAPIOperationClient) getCreateRequest(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, _ *WorkspaceAPIOperationClientGetOptions) (*policy.Request, error) { urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ApiManagement/service/{serviceName}/workspaces/{workspaceId}/apis/{apiId}/operations/{operationId}" if resourceGroupName == "" { return nil, errors.New("parameter resourceGroupName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) if serviceName == "" { return nil, errors.New("parameter serviceName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{serviceName}", url.PathEscape(serviceName)) if workspaceID == "" { return nil, errors.New("parameter workspaceID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{workspaceId}", url.PathEscape(workspaceID)) if apiID == "" { return nil, errors.New("parameter apiID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{apiId}", url.PathEscape(apiID)) if operationID == "" { return nil, errors.New("parameter operationID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{operationId}", url.PathEscape(operationID)) if client.subscriptionID == "" { return nil, errors.New("parameter client.subscriptionID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) req, err := runtime.NewRequest(ctx, http.MethodGet, runtime.JoinPaths(client.internal.Endpoint(), urlPath)) if err != nil { return nil, err } reqQP := req.Raw().URL.Query() reqQP.Set("api-version", "2024-05-01") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} return req, nil } // getHandleResponse handles the Get response. func (client *WorkspaceAPIOperationClient) getHandleResponse(resp *http.Response) (WorkspaceAPIOperationClientGetResponse, error) { result := WorkspaceAPIOperationClientGetResponse{} if val := resp.Header.Get("ETag"); val != "" { result.ETag = &val } if err := runtime.UnmarshalAsJSON(resp, &result.OperationContract); err != nil { return WorkspaceAPIOperationClientGetResponse{}, err } return result, nil } // GetEntityTag - Gets the entity state (Etag) version of the API operation specified by its identifier. // // Generated from API version 2024-05-01 // - resourceGroupName - The name of the resource group. The name is case insensitive. // - serviceName - The name of the API Management service. // - workspaceID - Workspace identifier. Must be unique in the current API Management service instance. // - apiID - API revision identifier. Must be unique in the current API Management service instance. Non-current revision has // ;rev=n as a suffix where n is the revision number. // - operationID - Operation identifier within an API. Must be unique in the current API Management service instance. // - options - WorkspaceAPIOperationClientGetEntityTagOptions contains the optional parameters for the WorkspaceAPIOperationClient.GetEntityTag // method. func (client *WorkspaceAPIOperationClient) GetEntityTag(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, options *WorkspaceAPIOperationClientGetEntityTagOptions) (WorkspaceAPIOperationClientGetEntityTagResponse, error) { var err error const operationName = "WorkspaceAPIOperationClient.GetEntityTag" ctx = context.WithValue(ctx, runtime.CtxAPINameKey{}, operationName) ctx, endSpan := runtime.StartSpan(ctx, operationName, client.internal.Tracer(), nil) defer func() { endSpan(err) }() req, err := client.getEntityTagCreateRequest(ctx, resourceGroupName, serviceName, workspaceID, apiID, operationID, options) if err != nil { return WorkspaceAPIOperationClientGetEntityTagResponse{}, err } httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return WorkspaceAPIOperationClientGetEntityTagResponse{}, err } if !runtime.HasStatusCode(httpResp, http.StatusOK) { err = runtime.NewResponseError(httpResp) return WorkspaceAPIOperationClientGetEntityTagResponse{}, err } resp, err := client.getEntityTagHandleResponse(httpResp) return resp, err } // getEntityTagCreateRequest creates the GetEntityTag request. func (client *WorkspaceAPIOperationClient) getEntityTagCreateRequest(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, _ *WorkspaceAPIOperationClientGetEntityTagOptions) (*policy.Request, error) { urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ApiManagement/service/{serviceName}/workspaces/{workspaceId}/apis/{apiId}/operations/{operationId}" if resourceGroupName == "" { return nil, errors.New("parameter resourceGroupName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) if serviceName == "" { return nil, errors.New("parameter serviceName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{serviceName}", url.PathEscape(serviceName)) if workspaceID == "" { return nil, errors.New("parameter workspaceID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{workspaceId}", url.PathEscape(workspaceID)) if apiID == "" { return nil, errors.New("parameter apiID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{apiId}", url.PathEscape(apiID)) if operationID == "" { return nil, errors.New("parameter operationID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{operationId}", url.PathEscape(operationID)) if client.subscriptionID == "" { return nil, errors.New("parameter client.subscriptionID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) req, err := runtime.NewRequest(ctx, http.MethodHead, runtime.JoinPaths(client.internal.Endpoint(), urlPath)) if err != nil { return nil, err } reqQP := req.Raw().URL.Query() reqQP.Set("api-version", "2024-05-01") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} return req, nil } // getEntityTagHandleResponse handles the GetEntityTag response. func (client *WorkspaceAPIOperationClient) getEntityTagHandleResponse(resp *http.Response) (WorkspaceAPIOperationClientGetEntityTagResponse, error) { result := WorkspaceAPIOperationClientGetEntityTagResponse{Success: resp.StatusCode >= 200 && resp.StatusCode < 300} if val := resp.Header.Get("ETag"); val != "" { result.ETag = &val } return result, nil } // NewListByAPIPager - Lists a collection of the operations for the specified API. // // Generated from API version 2024-05-01 // - resourceGroupName - The name of the resource group. The name is case insensitive. // - serviceName - The name of the API Management service. // - workspaceID - Workspace identifier. Must be unique in the current API Management service instance. // - apiID - API revision identifier. Must be unique in the current API Management service instance. Non-current revision has // ;rev=n as a suffix where n is the revision number. // - options - WorkspaceAPIOperationClientListByAPIOptions contains the optional parameters for the WorkspaceAPIOperationClient.NewListByAPIPager // method. func (client *WorkspaceAPIOperationClient) NewListByAPIPager(resourceGroupName string, serviceName string, workspaceID string, apiID string, options *WorkspaceAPIOperationClientListByAPIOptions) *runtime.Pager[WorkspaceAPIOperationClientListByAPIResponse] { return runtime.NewPager(runtime.PagingHandler[WorkspaceAPIOperationClientListByAPIResponse]{ More: func(page WorkspaceAPIOperationClientListByAPIResponse) bool { return page.NextLink != nil && len(*page.NextLink) > 0 }, Fetcher: func(ctx context.Context, page *WorkspaceAPIOperationClientListByAPIResponse) (WorkspaceAPIOperationClientListByAPIResponse, error) { ctx = context.WithValue(ctx, runtime.CtxAPINameKey{}, "WorkspaceAPIOperationClient.NewListByAPIPager") nextLink := "" if page != nil { nextLink = *page.NextLink } resp, err := runtime.FetcherForNextLink(ctx, client.internal.Pipeline(), nextLink, func(ctx context.Context) (*policy.Request, error) { return client.listByAPICreateRequest(ctx, resourceGroupName, serviceName, workspaceID, apiID, options) }, nil) if err != nil { return WorkspaceAPIOperationClientListByAPIResponse{}, err } return client.listByAPIHandleResponse(resp) }, Tracer: client.internal.Tracer(), }) } // listByAPICreateRequest creates the ListByAPI request. func (client *WorkspaceAPIOperationClient) listByAPICreateRequest(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, options *WorkspaceAPIOperationClientListByAPIOptions) (*policy.Request, error) { urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ApiManagement/service/{serviceName}/workspaces/{workspaceId}/apis/{apiId}/operations" if resourceGroupName == "" { return nil, errors.New("parameter resourceGroupName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) if serviceName == "" { return nil, errors.New("parameter serviceName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{serviceName}", url.PathEscape(serviceName)) if workspaceID == "" { return nil, errors.New("parameter workspaceID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{workspaceId}", url.PathEscape(workspaceID)) if apiID == "" { return nil, errors.New("parameter apiID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{apiId}", url.PathEscape(apiID)) if client.subscriptionID == "" { return nil, errors.New("parameter client.subscriptionID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) req, err := runtime.NewRequest(ctx, http.MethodGet, runtime.JoinPaths(client.internal.Endpoint(), urlPath)) if err != nil { return nil, err } reqQP := req.Raw().URL.Query() if options != nil && options.Filter != nil { reqQP.Set("$filter", *options.Filter) } if options != nil && options.Skip != nil { reqQP.Set("$skip", strconv.FormatInt(int64(*options.Skip), 10)) } if options != nil && options.Top != nil { reqQP.Set("$top", strconv.FormatInt(int64(*options.Top), 10)) } reqQP.Set("api-version", "2024-05-01") if options != nil && options.Tags != nil { reqQP.Set("tags", *options.Tags) } req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} return req, nil } // listByAPIHandleResponse handles the ListByAPI response. func (client *WorkspaceAPIOperationClient) listByAPIHandleResponse(resp *http.Response) (WorkspaceAPIOperationClientListByAPIResponse, error) { result := WorkspaceAPIOperationClientListByAPIResponse{} if err := runtime.UnmarshalAsJSON(resp, &result.OperationCollection); err != nil { return WorkspaceAPIOperationClientListByAPIResponse{}, err } return result, nil } // Update - Updates the details of the operation in the API specified by its identifier. // If the operation fails it returns an *azcore.ResponseError type. // // Generated from API version 2024-05-01 // - resourceGroupName - The name of the resource group. The name is case insensitive. // - serviceName - The name of the API Management service. // - workspaceID - Workspace identifier. Must be unique in the current API Management service instance. // - apiID - API revision identifier. Must be unique in the current API Management service instance. Non-current revision has // ;rev=n as a suffix where n is the revision number. // - operationID - Operation identifier within an API. Must be unique in the current API Management service instance. // - ifMatch - ETag of the Entity. ETag should match the current entity state from the header response of the GET request or // it should be * for unconditional update. // - parameters - API Operation Update parameters. // - options - WorkspaceAPIOperationClientUpdateOptions contains the optional parameters for the WorkspaceAPIOperationClient.Update // method. func (client *WorkspaceAPIOperationClient) Update(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, ifMatch string, parameters OperationUpdateContract, options *WorkspaceAPIOperationClientUpdateOptions) (WorkspaceAPIOperationClientUpdateResponse, error) { var err error const operationName = "WorkspaceAPIOperationClient.Update" ctx = context.WithValue(ctx, runtime.CtxAPINameKey{}, operationName) ctx, endSpan := runtime.StartSpan(ctx, operationName, client.internal.Tracer(), nil) defer func() { endSpan(err) }() req, err := client.updateCreateRequest(ctx, resourceGroupName, serviceName, workspaceID, apiID, operationID, ifMatch, parameters, options) if err != nil { return WorkspaceAPIOperationClientUpdateResponse{}, err } httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return WorkspaceAPIOperationClientUpdateResponse{}, err } if !runtime.HasStatusCode(httpResp, http.StatusOK) { err = runtime.NewResponseError(httpResp) return WorkspaceAPIOperationClientUpdateResponse{}, err } resp, err := client.updateHandleResponse(httpResp) return resp, err } // updateCreateRequest creates the Update request. func (client *WorkspaceAPIOperationClient) updateCreateRequest(ctx context.Context, resourceGroupName string, serviceName string, workspaceID string, apiID string, operationID string, ifMatch string, parameters OperationUpdateContract, _ *WorkspaceAPIOperationClientUpdateOptions) (*policy.Request, error) { urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ApiManagement/service/{serviceName}/workspaces/{workspaceId}/apis/{apiId}/operations/{operationId}" if resourceGroupName == "" { return nil, errors.New("parameter resourceGroupName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) if serviceName == "" { return nil, errors.New("parameter serviceName cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{serviceName}", url.PathEscape(serviceName)) if workspaceID == "" { return nil, errors.New("parameter workspaceID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{workspaceId}", url.PathEscape(workspaceID)) if apiID == "" { return nil, errors.New("parameter apiID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{apiId}", url.PathEscape(apiID)) if operationID == "" { return nil, errors.New("parameter operationID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{operationId}", url.PathEscape(operationID)) if client.subscriptionID == "" { return nil, errors.New("parameter client.subscriptionID cannot be empty") } urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) req, err := runtime.NewRequest(ctx, http.MethodPatch, runtime.JoinPaths(client.internal.Endpoint(), urlPath)) if err != nil { return nil, err } reqQP := req.Raw().URL.Query() reqQP.Set("api-version", "2024-05-01") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} req.Raw().Header["If-Match"] = []string{ifMatch} if err := runtime.MarshalAsJSON(req, parameters); err != nil { return nil, err } return req, nil } // updateHandleResponse handles the Update response. func (client *WorkspaceAPIOperationClient) updateHandleResponse(resp *http.Response) (WorkspaceAPIOperationClientUpdateResponse, error) { result := WorkspaceAPIOperationClientUpdateResponse{} if val := resp.Header.Get("ETag"); val != "" { result.ETag = &val } if err := runtime.UnmarshalAsJSON(resp, &result.OperationContract); err != nil { return WorkspaceAPIOperationClientUpdateResponse{}, err } return result, nil }