Book a Demo!
CoCalc Logo Icon
StoreFeaturesDocsShareSupportNewsAboutPoliciesSign UpSign In
gitpod-io
GitHub Repository: gitpod-io/gitpod
Path: blob/main/components/supervisor-api/go/token.pb.gw.go
2500 views
1
// Copyright (c) 2023 Gitpod GmbH. All rights reserved.
2
// Licensed under the GNU Affero General Public License (AGPL).
3
// See License.AGPL.txt in the project root for license information.
4
5
// Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
6
// source: token.proto
7
8
/*
9
Package api is a reverse proxy.
10
11
It translates gRPC into RESTful JSON APIs.
12
*/
13
package api
14
15
import (
16
"context"
17
"io"
18
"net/http"
19
20
"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
21
"github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
22
"google.golang.org/grpc"
23
"google.golang.org/grpc/codes"
24
"google.golang.org/grpc/grpclog"
25
"google.golang.org/grpc/metadata"
26
"google.golang.org/grpc/status"
27
"google.golang.org/protobuf/proto"
28
)
29
30
// Suppress "imported and not used" errors
31
var _ codes.Code
32
var _ io.Reader
33
var _ status.Status
34
var _ = runtime.String
35
var _ = utilities.NewDoubleArray
36
var _ = metadata.Join
37
38
var (
39
filter_TokenService_GetToken_0 = &utilities.DoubleArray{Encoding: map[string]int{"kind": 0, "host": 1, "scope": 2}, Base: []int{1, 1, 2, 3, 0, 0, 0}, Check: []int{0, 1, 1, 1, 2, 3, 4}}
40
)
41
42
func request_TokenService_GetToken_0(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
43
var protoReq GetTokenRequest
44
var metadata runtime.ServerMetadata
45
46
var (
47
val string
48
ok bool
49
err error
50
_ = err
51
)
52
53
val, ok = pathParams["kind"]
54
if !ok {
55
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
56
}
57
58
protoReq.Kind, err = runtime.String(val)
59
if err != nil {
60
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
61
}
62
63
val, ok = pathParams["host"]
64
if !ok {
65
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")
66
}
67
68
protoReq.Host, err = runtime.String(val)
69
if err != nil {
70
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)
71
}
72
73
val, ok = pathParams["scope"]
74
if !ok {
75
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "scope")
76
}
77
78
protoReq.Scope, err = runtime.StringSlice(val, ",")
79
if err != nil {
80
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "scope", err)
81
}
82
83
if err := req.ParseForm(); err != nil {
84
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
85
}
86
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_GetToken_0); err != nil {
87
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
88
}
89
90
msg, err := client.GetToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
91
return msg, metadata, err
92
93
}
94
95
func local_request_TokenService_GetToken_0(ctx context.Context, marshaler runtime.Marshaler, server TokenServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
96
var protoReq GetTokenRequest
97
var metadata runtime.ServerMetadata
98
99
var (
100
val string
101
ok bool
102
err error
103
_ = err
104
)
105
106
val, ok = pathParams["kind"]
107
if !ok {
108
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
109
}
110
111
protoReq.Kind, err = runtime.String(val)
112
if err != nil {
113
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
114
}
115
116
val, ok = pathParams["host"]
117
if !ok {
118
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")
119
}
120
121
protoReq.Host, err = runtime.String(val)
122
if err != nil {
123
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)
124
}
125
126
val, ok = pathParams["scope"]
127
if !ok {
128
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "scope")
129
}
130
131
protoReq.Scope, err = runtime.StringSlice(val, ",")
132
if err != nil {
133
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "scope", err)
134
}
135
136
if err := req.ParseForm(); err != nil {
137
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
138
}
139
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_GetToken_0); err != nil {
140
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
141
}
142
143
msg, err := server.GetToken(ctx, &protoReq)
144
return msg, metadata, err
145
146
}
147
148
func request_TokenService_SetToken_0(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
149
var protoReq SetTokenRequest
150
var metadata runtime.ServerMetadata
151
152
newReader, berr := utilities.IOReaderFactory(req.Body)
153
if berr != nil {
154
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
155
}
156
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
157
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
158
}
159
160
var (
161
val string
162
ok bool
163
err error
164
_ = err
165
)
166
167
val, ok = pathParams["kind"]
168
if !ok {
169
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
170
}
171
172
protoReq.Kind, err = runtime.String(val)
173
if err != nil {
174
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
175
}
176
177
val, ok = pathParams["host"]
178
if !ok {
179
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")
180
}
181
182
protoReq.Host, err = runtime.String(val)
183
if err != nil {
184
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)
185
}
186
187
msg, err := client.SetToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
188
return msg, metadata, err
189
190
}
191
192
func local_request_TokenService_SetToken_0(ctx context.Context, marshaler runtime.Marshaler, server TokenServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
193
var protoReq SetTokenRequest
194
var metadata runtime.ServerMetadata
195
196
newReader, berr := utilities.IOReaderFactory(req.Body)
197
if berr != nil {
198
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
199
}
200
if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
201
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
202
}
203
204
var (
205
val string
206
ok bool
207
err error
208
_ = err
209
)
210
211
val, ok = pathParams["kind"]
212
if !ok {
213
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
214
}
215
216
protoReq.Kind, err = runtime.String(val)
217
if err != nil {
218
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
219
}
220
221
val, ok = pathParams["host"]
222
if !ok {
223
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")
224
}
225
226
protoReq.Host, err = runtime.String(val)
227
if err != nil {
228
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)
229
}
230
231
msg, err := server.SetToken(ctx, &protoReq)
232
return msg, metadata, err
233
234
}
235
236
var (
237
filter_TokenService_ClearToken_0 = &utilities.DoubleArray{Encoding: map[string]int{"kind": 0, "value": 1}, Base: []int{1, 1, 2, 0, 0}, Check: []int{0, 1, 1, 2, 3}}
238
)
239
240
func request_TokenService_ClearToken_0(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
241
var protoReq ClearTokenRequest
242
var metadata runtime.ServerMetadata
243
244
var (
245
val string
246
ok bool
247
err error
248
_ = err
249
)
250
251
val, ok = pathParams["kind"]
252
if !ok {
253
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
254
}
255
256
protoReq.Kind, err = runtime.String(val)
257
if err != nil {
258
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
259
}
260
261
val, ok = pathParams["value"]
262
if !ok {
263
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "value")
264
}
265
266
if protoReq.Token == nil {
267
protoReq.Token = &ClearTokenRequest_Value{}
268
} else if _, ok := protoReq.Token.(*ClearTokenRequest_Value); !ok {
269
return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_Value, but: %t\n", protoReq.Token)
270
}
271
protoReq.Token.(*ClearTokenRequest_Value).Value, err = runtime.String(val)
272
if err != nil {
273
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "value", err)
274
}
275
276
if err := req.ParseForm(); err != nil {
277
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
278
}
279
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_0); err != nil {
280
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
281
}
282
283
msg, err := client.ClearToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
284
return msg, metadata, err
285
286
}
287
288
func local_request_TokenService_ClearToken_0(ctx context.Context, marshaler runtime.Marshaler, server TokenServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
289
var protoReq ClearTokenRequest
290
var metadata runtime.ServerMetadata
291
292
var (
293
val string
294
ok bool
295
err error
296
_ = err
297
)
298
299
val, ok = pathParams["kind"]
300
if !ok {
301
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
302
}
303
304
protoReq.Kind, err = runtime.String(val)
305
if err != nil {
306
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
307
}
308
309
val, ok = pathParams["value"]
310
if !ok {
311
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "value")
312
}
313
314
if protoReq.Token == nil {
315
protoReq.Token = &ClearTokenRequest_Value{}
316
} else if _, ok := protoReq.Token.(*ClearTokenRequest_Value); !ok {
317
return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_Value, but: %t\n", protoReq.Token)
318
}
319
protoReq.Token.(*ClearTokenRequest_Value).Value, err = runtime.String(val)
320
if err != nil {
321
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "value", err)
322
}
323
324
if err := req.ParseForm(); err != nil {
325
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
326
}
327
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_0); err != nil {
328
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
329
}
330
331
msg, err := server.ClearToken(ctx, &protoReq)
332
return msg, metadata, err
333
334
}
335
336
var (
337
filter_TokenService_ClearToken_1 = &utilities.DoubleArray{Encoding: map[string]int{"kind": 0, "all": 1}, Base: []int{1, 1, 2, 0, 0}, Check: []int{0, 1, 1, 2, 3}}
338
)
339
340
func request_TokenService_ClearToken_1(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
341
var protoReq ClearTokenRequest
342
var metadata runtime.ServerMetadata
343
344
var (
345
val string
346
ok bool
347
err error
348
_ = err
349
)
350
351
val, ok = pathParams["kind"]
352
if !ok {
353
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
354
}
355
356
protoReq.Kind, err = runtime.String(val)
357
if err != nil {
358
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
359
}
360
361
val, ok = pathParams["all"]
362
if !ok {
363
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "all")
364
}
365
366
if protoReq.Token == nil {
367
protoReq.Token = &ClearTokenRequest_All{}
368
} else if _, ok := protoReq.Token.(*ClearTokenRequest_All); !ok {
369
return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_All, but: %t\n", protoReq.Token)
370
}
371
protoReq.Token.(*ClearTokenRequest_All).All, err = runtime.Bool(val)
372
if err != nil {
373
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "all", err)
374
}
375
376
if err := req.ParseForm(); err != nil {
377
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
378
}
379
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_1); err != nil {
380
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
381
}
382
383
msg, err := client.ClearToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
384
return msg, metadata, err
385
386
}
387
388
func local_request_TokenService_ClearToken_1(ctx context.Context, marshaler runtime.Marshaler, server TokenServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
389
var protoReq ClearTokenRequest
390
var metadata runtime.ServerMetadata
391
392
var (
393
val string
394
ok bool
395
err error
396
_ = err
397
)
398
399
val, ok = pathParams["kind"]
400
if !ok {
401
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")
402
}
403
404
protoReq.Kind, err = runtime.String(val)
405
if err != nil {
406
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)
407
}
408
409
val, ok = pathParams["all"]
410
if !ok {
411
return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "all")
412
}
413
414
if protoReq.Token == nil {
415
protoReq.Token = &ClearTokenRequest_All{}
416
} else if _, ok := protoReq.Token.(*ClearTokenRequest_All); !ok {
417
return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_All, but: %t\n", protoReq.Token)
418
}
419
protoReq.Token.(*ClearTokenRequest_All).All, err = runtime.Bool(val)
420
if err != nil {
421
return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "all", err)
422
}
423
424
if err := req.ParseForm(); err != nil {
425
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
426
}
427
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_1); err != nil {
428
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
429
}
430
431
msg, err := server.ClearToken(ctx, &protoReq)
432
return msg, metadata, err
433
434
}
435
436
// RegisterTokenServiceHandlerServer registers the http handlers for service TokenService to "mux".
437
// UnaryRPC :call TokenServiceServer directly.
438
// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
439
// Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterTokenServiceHandlerFromEndpoint instead.
440
func RegisterTokenServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TokenServiceServer) error {
441
442
mux.Handle("GET", pattern_TokenService_GetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
443
ctx, cancel := context.WithCancel(req.Context())
444
defer cancel()
445
var stream runtime.ServerTransportStream
446
ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
447
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
448
var err error
449
var annotatedContext context.Context
450
annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/GetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}/{scope}"))
451
if err != nil {
452
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
453
return
454
}
455
resp, md, err := local_request_TokenService_GetToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)
456
md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
457
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
458
if err != nil {
459
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
460
return
461
}
462
463
forward_TokenService_GetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
464
465
})
466
467
mux.Handle("POST", pattern_TokenService_SetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
468
ctx, cancel := context.WithCancel(req.Context())
469
defer cancel()
470
var stream runtime.ServerTransportStream
471
ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
472
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
473
var err error
474
var annotatedContext context.Context
475
annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/SetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}"))
476
if err != nil {
477
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
478
return
479
}
480
resp, md, err := local_request_TokenService_SetToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)
481
md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
482
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
483
if err != nil {
484
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
485
return
486
}
487
488
forward_TokenService_SetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
489
490
})
491
492
mux.Handle("DELETE", pattern_TokenService_ClearToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
493
ctx, cancel := context.WithCancel(req.Context())
494
defer cancel()
495
var stream runtime.ServerTransportStream
496
ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
497
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
498
var err error
499
var annotatedContext context.Context
500
annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{value}"))
501
if err != nil {
502
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
503
return
504
}
505
resp, md, err := local_request_TokenService_ClearToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)
506
md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
507
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
508
if err != nil {
509
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
510
return
511
}
512
513
forward_TokenService_ClearToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
514
515
})
516
517
mux.Handle("DELETE", pattern_TokenService_ClearToken_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
518
ctx, cancel := context.WithCancel(req.Context())
519
defer cancel()
520
var stream runtime.ServerTransportStream
521
ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
522
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
523
var err error
524
var annotatedContext context.Context
525
annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/clear/all/{all=true}"))
526
if err != nil {
527
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
528
return
529
}
530
resp, md, err := local_request_TokenService_ClearToken_1(annotatedContext, inboundMarshaler, server, req, pathParams)
531
md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
532
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
533
if err != nil {
534
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
535
return
536
}
537
538
forward_TokenService_ClearToken_1(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
539
540
})
541
542
return nil
543
}
544
545
// RegisterTokenServiceHandlerFromEndpoint is same as RegisterTokenServiceHandler but
546
// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
547
func RegisterTokenServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
548
conn, err := grpc.Dial(endpoint, opts...)
549
if err != nil {
550
return err
551
}
552
defer func() {
553
if err != nil {
554
if cerr := conn.Close(); cerr != nil {
555
grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
556
}
557
return
558
}
559
go func() {
560
<-ctx.Done()
561
if cerr := conn.Close(); cerr != nil {
562
grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
563
}
564
}()
565
}()
566
567
return RegisterTokenServiceHandler(ctx, mux, conn)
568
}
569
570
// RegisterTokenServiceHandler registers the http handlers for service TokenService to "mux".
571
// The handlers forward requests to the grpc endpoint over "conn".
572
func RegisterTokenServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
573
return RegisterTokenServiceHandlerClient(ctx, mux, NewTokenServiceClient(conn))
574
}
575
576
// RegisterTokenServiceHandlerClient registers the http handlers for service TokenService
577
// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TokenServiceClient".
578
// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TokenServiceClient"
579
// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
580
// "TokenServiceClient" to call the correct interceptors.
581
func RegisterTokenServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TokenServiceClient) error {
582
583
mux.Handle("GET", pattern_TokenService_GetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
584
ctx, cancel := context.WithCancel(req.Context())
585
defer cancel()
586
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
587
var err error
588
var annotatedContext context.Context
589
annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/GetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}/{scope}"))
590
if err != nil {
591
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
592
return
593
}
594
resp, md, err := request_TokenService_GetToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)
595
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
596
if err != nil {
597
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
598
return
599
}
600
601
forward_TokenService_GetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
602
603
})
604
605
mux.Handle("POST", pattern_TokenService_SetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
606
ctx, cancel := context.WithCancel(req.Context())
607
defer cancel()
608
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
609
var err error
610
var annotatedContext context.Context
611
annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/SetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}"))
612
if err != nil {
613
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
614
return
615
}
616
resp, md, err := request_TokenService_SetToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)
617
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
618
if err != nil {
619
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
620
return
621
}
622
623
forward_TokenService_SetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
624
625
})
626
627
mux.Handle("DELETE", pattern_TokenService_ClearToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
628
ctx, cancel := context.WithCancel(req.Context())
629
defer cancel()
630
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
631
var err error
632
var annotatedContext context.Context
633
annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{value}"))
634
if err != nil {
635
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
636
return
637
}
638
resp, md, err := request_TokenService_ClearToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)
639
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
640
if err != nil {
641
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
642
return
643
}
644
645
forward_TokenService_ClearToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
646
647
})
648
649
mux.Handle("DELETE", pattern_TokenService_ClearToken_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
650
ctx, cancel := context.WithCancel(req.Context())
651
defer cancel()
652
inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
653
var err error
654
var annotatedContext context.Context
655
annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/clear/all/{all=true}"))
656
if err != nil {
657
runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
658
return
659
}
660
resp, md, err := request_TokenService_ClearToken_1(annotatedContext, inboundMarshaler, client, req, pathParams)
661
annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
662
if err != nil {
663
runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
664
return
665
}
666
667
forward_TokenService_ClearToken_1(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
668
669
})
670
671
return nil
672
}
673
674
var (
675
pattern_TokenService_GetToken_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 1, 0, 4, 1, 5, 3, 1, 0, 4, 1, 5, 4}, []string{"v1", "token", "kind", "host", "scope"}, ""))
676
677
pattern_TokenService_SetToken_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 1, 0, 4, 1, 5, 3}, []string{"v1", "token", "kind", "host"}, ""))
678
679
pattern_TokenService_ClearToken_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 1, 0, 4, 1, 5, 3}, []string{"v1", "token", "kind", "value"}, ""))
680
681
pattern_TokenService_ClearToken_1 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3, 2, 4, 2, 5, 4, 1, 5, 4}, []string{"v1", "token", "kind", "clear", "all", "true"}, ""))
682
)
683
684
var (
685
forward_TokenService_GetToken_0 = runtime.ForwardResponseMessage
686
687
forward_TokenService_SetToken_0 = runtime.ForwardResponseMessage
688
689
forward_TokenService_ClearToken_0 = runtime.ForwardResponseMessage
690
691
forward_TokenService_ClearToken_1 = runtime.ForwardResponseMessage
692
)
693
694