1 package dtl
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 ServiceRunnersClient struct {
19 BaseClient
20 }
21
22
23 func NewServiceRunnersClient(subscriptionID string) ServiceRunnersClient {
24 return NewServiceRunnersClientWithBaseURI(DefaultBaseURI, subscriptionID)
25 }
26
27
28
29 func NewServiceRunnersClientWithBaseURI(baseURI string, subscriptionID string) ServiceRunnersClient {
30 return ServiceRunnersClient{NewWithBaseURI(baseURI, subscriptionID)}
31 }
32
33
34
35
36
37
38
39 func (client ServiceRunnersClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, labName string, name string, serviceRunner ServiceRunner) (result ServiceRunner, err error) {
40 if tracing.IsEnabled() {
41 ctx = tracing.StartSpan(ctx, fqdn+"/ServiceRunnersClient.CreateOrUpdate")
42 defer func() {
43 sc := -1
44 if result.Response.Response != nil {
45 sc = result.Response.Response.StatusCode
46 }
47 tracing.EndSpan(ctx, sc, err)
48 }()
49 }
50 req, err := client.CreateOrUpdatePreparer(ctx, resourceGroupName, labName, name, serviceRunner)
51 if err != nil {
52 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "CreateOrUpdate", nil, "Failure preparing request")
53 return
54 }
55
56 resp, err := client.CreateOrUpdateSender(req)
57 if err != nil {
58 result.Response = autorest.Response{Response: resp}
59 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "CreateOrUpdate", resp, "Failure sending request")
60 return
61 }
62
63 result, err = client.CreateOrUpdateResponder(resp)
64 if err != nil {
65 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "CreateOrUpdate", resp, "Failure responding to request")
66 return
67 }
68
69 return
70 }
71
72
73 func (client ServiceRunnersClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, labName string, name string, serviceRunner ServiceRunner) (*http.Request, error) {
74 pathParameters := map[string]interface{}{
75 "labName": autorest.Encode("path", labName),
76 "name": autorest.Encode("path", name),
77 "resourceGroupName": autorest.Encode("path", resourceGroupName),
78 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
79 }
80
81 const APIVersion = "2018-09-15"
82 queryParameters := map[string]interface{}{
83 "api-version": APIVersion,
84 }
85
86 preparer := autorest.CreatePreparer(
87 autorest.AsContentType("application/json; charset=utf-8"),
88 autorest.AsPut(),
89 autorest.WithBaseURL(client.BaseURI),
90 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevTestLab/labs/{labName}/servicerunners/{name}", pathParameters),
91 autorest.WithJSON(serviceRunner),
92 autorest.WithQueryParameters(queryParameters))
93 return preparer.Prepare((&http.Request{}).WithContext(ctx))
94 }
95
96
97
98 func (client ServiceRunnersClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error) {
99 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
100 }
101
102
103
104 func (client ServiceRunnersClient) CreateOrUpdateResponder(resp *http.Response) (result ServiceRunner, err error) {
105 err = autorest.Respond(
106 resp,
107 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusCreated),
108 autorest.ByUnmarshallingJSON(&result),
109 autorest.ByClosing())
110 result.Response = autorest.Response{Response: resp}
111 return
112 }
113
114
115
116
117
118
119 func (client ServiceRunnersClient) Delete(ctx context.Context, resourceGroupName string, labName string, name string) (result autorest.Response, err error) {
120 if tracing.IsEnabled() {
121 ctx = tracing.StartSpan(ctx, fqdn+"/ServiceRunnersClient.Delete")
122 defer func() {
123 sc := -1
124 if result.Response != nil {
125 sc = result.Response.StatusCode
126 }
127 tracing.EndSpan(ctx, sc, err)
128 }()
129 }
130 req, err := client.DeletePreparer(ctx, resourceGroupName, labName, name)
131 if err != nil {
132 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "Delete", nil, "Failure preparing request")
133 return
134 }
135
136 resp, err := client.DeleteSender(req)
137 if err != nil {
138 result.Response = resp
139 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "Delete", resp, "Failure sending request")
140 return
141 }
142
143 result, err = client.DeleteResponder(resp)
144 if err != nil {
145 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "Delete", resp, "Failure responding to request")
146 return
147 }
148
149 return
150 }
151
152
153 func (client ServiceRunnersClient) DeletePreparer(ctx context.Context, resourceGroupName string, labName string, name string) (*http.Request, error) {
154 pathParameters := map[string]interface{}{
155 "labName": autorest.Encode("path", labName),
156 "name": autorest.Encode("path", name),
157 "resourceGroupName": autorest.Encode("path", resourceGroupName),
158 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
159 }
160
161 const APIVersion = "2018-09-15"
162 queryParameters := map[string]interface{}{
163 "api-version": APIVersion,
164 }
165
166 preparer := autorest.CreatePreparer(
167 autorest.AsDelete(),
168 autorest.WithBaseURL(client.BaseURI),
169 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevTestLab/labs/{labName}/servicerunners/{name}", pathParameters),
170 autorest.WithQueryParameters(queryParameters))
171 return preparer.Prepare((&http.Request{}).WithContext(ctx))
172 }
173
174
175
176 func (client ServiceRunnersClient) DeleteSender(req *http.Request) (*http.Response, error) {
177 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
178 }
179
180
181
182 func (client ServiceRunnersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) {
183 err = autorest.Respond(
184 resp,
185 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusNoContent),
186 autorest.ByClosing())
187 result.Response = resp
188 return
189 }
190
191
192
193
194
195
196 func (client ServiceRunnersClient) Get(ctx context.Context, resourceGroupName string, labName string, name string) (result ServiceRunner, err error) {
197 if tracing.IsEnabled() {
198 ctx = tracing.StartSpan(ctx, fqdn+"/ServiceRunnersClient.Get")
199 defer func() {
200 sc := -1
201 if result.Response.Response != nil {
202 sc = result.Response.Response.StatusCode
203 }
204 tracing.EndSpan(ctx, sc, err)
205 }()
206 }
207 req, err := client.GetPreparer(ctx, resourceGroupName, labName, name)
208 if err != nil {
209 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "Get", nil, "Failure preparing request")
210 return
211 }
212
213 resp, err := client.GetSender(req)
214 if err != nil {
215 result.Response = autorest.Response{Response: resp}
216 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "Get", resp, "Failure sending request")
217 return
218 }
219
220 result, err = client.GetResponder(resp)
221 if err != nil {
222 err = autorest.NewErrorWithError(err, "dtl.ServiceRunnersClient", "Get", resp, "Failure responding to request")
223 return
224 }
225
226 return
227 }
228
229
230 func (client ServiceRunnersClient) GetPreparer(ctx context.Context, resourceGroupName string, labName string, name string) (*http.Request, error) {
231 pathParameters := map[string]interface{}{
232 "labName": autorest.Encode("path", labName),
233 "name": autorest.Encode("path", name),
234 "resourceGroupName": autorest.Encode("path", resourceGroupName),
235 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
236 }
237
238 const APIVersion = "2018-09-15"
239 queryParameters := map[string]interface{}{
240 "api-version": APIVersion,
241 }
242
243 preparer := autorest.CreatePreparer(
244 autorest.AsGet(),
245 autorest.WithBaseURL(client.BaseURI),
246 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevTestLab/labs/{labName}/servicerunners/{name}", pathParameters),
247 autorest.WithQueryParameters(queryParameters))
248 return preparer.Prepare((&http.Request{}).WithContext(ctx))
249 }
250
251
252
253 func (client ServiceRunnersClient) GetSender(req *http.Request) (*http.Response, error) {
254 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
255 }
256
257
258
259 func (client ServiceRunnersClient) GetResponder(resp *http.Response) (result ServiceRunner, err error) {
260 err = autorest.Respond(
261 resp,
262 azure.WithErrorUnlessStatusCode(http.StatusOK),
263 autorest.ByUnmarshallingJSON(&result),
264 autorest.ByClosing())
265 result.Response = autorest.Response{Response: resp}
266 return
267 }
268
View as plain text