1 package dataprotection
2
3
4
5
6
7
8
9 import (
10 "context"
11 "github.com/Azure/go-autorest/autorest"
12 "github.com/Azure/go-autorest/autorest/azure"
13 "github.com/Azure/go-autorest/tracing"
14 "net/http"
15 )
16
17
18 type OperationStatusClient struct {
19 BaseClient
20 }
21
22
23 func NewOperationStatusClient(subscriptionID string) OperationStatusClient {
24 return NewOperationStatusClientWithBaseURI(DefaultBaseURI, subscriptionID)
25 }
26
27
28
29 func NewOperationStatusClientWithBaseURI(baseURI string, subscriptionID string) OperationStatusClient {
30 return OperationStatusClient{NewWithBaseURI(baseURI, subscriptionID)}
31 }
32
33
34 func (client OperationStatusClient) Get(ctx context.Context, location string, operationID string) (result OperationResource, err error) {
35 if tracing.IsEnabled() {
36 ctx = tracing.StartSpan(ctx, fqdn+"/OperationStatusClient.Get")
37 defer func() {
38 sc := -1
39 if result.Response.Response != nil {
40 sc = result.Response.Response.StatusCode
41 }
42 tracing.EndSpan(ctx, sc, err)
43 }()
44 }
45 req, err := client.GetPreparer(ctx, location, operationID)
46 if err != nil {
47 err = autorest.NewErrorWithError(err, "dataprotection.OperationStatusClient", "Get", nil, "Failure preparing request")
48 return
49 }
50
51 resp, err := client.GetSender(req)
52 if err != nil {
53 result.Response = autorest.Response{Response: resp}
54 err = autorest.NewErrorWithError(err, "dataprotection.OperationStatusClient", "Get", resp, "Failure sending request")
55 return
56 }
57
58 result, err = client.GetResponder(resp)
59 if err != nil {
60 err = autorest.NewErrorWithError(err, "dataprotection.OperationStatusClient", "Get", resp, "Failure responding to request")
61 return
62 }
63
64 return
65 }
66
67
68 func (client OperationStatusClient) GetPreparer(ctx context.Context, location string, operationID string) (*http.Request, error) {
69 pathParameters := map[string]interface{}{
70 "location": autorest.Encode("path", location),
71 "operationId": autorest.Encode("path", operationID),
72 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
73 }
74
75 const APIVersion = "2021-07-01"
76 queryParameters := map[string]interface{}{
77 "api-version": APIVersion,
78 }
79
80 preparer := autorest.CreatePreparer(
81 autorest.AsGet(),
82 autorest.WithBaseURL(client.BaseURI),
83 autorest.WithPathParameters("/subscriptions/{subscriptionId}/providers/Microsoft.DataProtection/locations/{location}/operationStatus/{operationId}", pathParameters),
84 autorest.WithQueryParameters(queryParameters))
85 return preparer.Prepare((&http.Request{}).WithContext(ctx))
86 }
87
88
89
90 func (client OperationStatusClient) GetSender(req *http.Request) (*http.Response, error) {
91 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
92 }
93
94
95
96 func (client OperationStatusClient) GetResponder(resp *http.Response) (result OperationResource, err error) {
97 err = autorest.Respond(
98 resp,
99 azure.WithErrorUnlessStatusCode(http.StatusOK),
100 autorest.ByUnmarshallingJSON(&result),
101 autorest.ByClosing())
102 result.Response = autorest.Response{Response: resp}
103 return
104 }
105
View as plain text