Path: blob/main/components/supervisor-api/go/token.pb.gw.go
2500 views
// Copyright (c) 2023 Gitpod GmbH. All rights reserved.1// Licensed under the GNU Affero General Public License (AGPL).2// See License.AGPL.txt in the project root for license information.34// Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.5// source: token.proto67/*8Package api is a reverse proxy.910It translates gRPC into RESTful JSON APIs.11*/12package api1314import (15"context"16"io"17"net/http"1819"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"20"github.com/grpc-ecosystem/grpc-gateway/v2/utilities"21"google.golang.org/grpc"22"google.golang.org/grpc/codes"23"google.golang.org/grpc/grpclog"24"google.golang.org/grpc/metadata"25"google.golang.org/grpc/status"26"google.golang.org/protobuf/proto"27)2829// Suppress "imported and not used" errors30var _ codes.Code31var _ io.Reader32var _ status.Status33var _ = runtime.String34var _ = utilities.NewDoubleArray35var _ = metadata.Join3637var (38filter_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}}39)4041func request_TokenService_GetToken_0(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {42var protoReq GetTokenRequest43var metadata runtime.ServerMetadata4445var (46val string47ok bool48err error49_ = err50)5152val, ok = pathParams["kind"]53if !ok {54return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")55}5657protoReq.Kind, err = runtime.String(val)58if err != nil {59return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)60}6162val, ok = pathParams["host"]63if !ok {64return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")65}6667protoReq.Host, err = runtime.String(val)68if err != nil {69return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)70}7172val, ok = pathParams["scope"]73if !ok {74return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "scope")75}7677protoReq.Scope, err = runtime.StringSlice(val, ",")78if err != nil {79return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "scope", err)80}8182if err := req.ParseForm(); err != nil {83return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)84}85if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_GetToken_0); err != nil {86return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)87}8889msg, err := client.GetToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))90return msg, metadata, err9192}9394func 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) {95var protoReq GetTokenRequest96var metadata runtime.ServerMetadata9798var (99val string100ok bool101err error102_ = err103)104105val, ok = pathParams["kind"]106if !ok {107return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")108}109110protoReq.Kind, err = runtime.String(val)111if err != nil {112return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)113}114115val, ok = pathParams["host"]116if !ok {117return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")118}119120protoReq.Host, err = runtime.String(val)121if err != nil {122return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)123}124125val, ok = pathParams["scope"]126if !ok {127return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "scope")128}129130protoReq.Scope, err = runtime.StringSlice(val, ",")131if err != nil {132return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "scope", err)133}134135if err := req.ParseForm(); err != nil {136return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)137}138if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_GetToken_0); err != nil {139return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)140}141142msg, err := server.GetToken(ctx, &protoReq)143return msg, metadata, err144145}146147func request_TokenService_SetToken_0(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {148var protoReq SetTokenRequest149var metadata runtime.ServerMetadata150151newReader, berr := utilities.IOReaderFactory(req.Body)152if berr != nil {153return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)154}155if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {156return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)157}158159var (160val string161ok bool162err error163_ = err164)165166val, ok = pathParams["kind"]167if !ok {168return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")169}170171protoReq.Kind, err = runtime.String(val)172if err != nil {173return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)174}175176val, ok = pathParams["host"]177if !ok {178return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")179}180181protoReq.Host, err = runtime.String(val)182if err != nil {183return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)184}185186msg, err := client.SetToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))187return msg, metadata, err188189}190191func 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) {192var protoReq SetTokenRequest193var metadata runtime.ServerMetadata194195newReader, berr := utilities.IOReaderFactory(req.Body)196if berr != nil {197return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)198}199if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {200return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)201}202203var (204val string205ok bool206err error207_ = err208)209210val, ok = pathParams["kind"]211if !ok {212return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")213}214215protoReq.Kind, err = runtime.String(val)216if err != nil {217return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)218}219220val, ok = pathParams["host"]221if !ok {222return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "host")223}224225protoReq.Host, err = runtime.String(val)226if err != nil {227return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "host", err)228}229230msg, err := server.SetToken(ctx, &protoReq)231return msg, metadata, err232233}234235var (236filter_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}}237)238239func request_TokenService_ClearToken_0(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {240var protoReq ClearTokenRequest241var metadata runtime.ServerMetadata242243var (244val string245ok bool246err error247_ = err248)249250val, ok = pathParams["kind"]251if !ok {252return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")253}254255protoReq.Kind, err = runtime.String(val)256if err != nil {257return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)258}259260val, ok = pathParams["value"]261if !ok {262return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "value")263}264265if protoReq.Token == nil {266protoReq.Token = &ClearTokenRequest_Value{}267} else if _, ok := protoReq.Token.(*ClearTokenRequest_Value); !ok {268return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_Value, but: %t\n", protoReq.Token)269}270protoReq.Token.(*ClearTokenRequest_Value).Value, err = runtime.String(val)271if err != nil {272return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "value", err)273}274275if err := req.ParseForm(); err != nil {276return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)277}278if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_0); err != nil {279return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)280}281282msg, err := client.ClearToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))283return msg, metadata, err284285}286287func 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) {288var protoReq ClearTokenRequest289var metadata runtime.ServerMetadata290291var (292val string293ok bool294err error295_ = err296)297298val, ok = pathParams["kind"]299if !ok {300return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")301}302303protoReq.Kind, err = runtime.String(val)304if err != nil {305return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)306}307308val, ok = pathParams["value"]309if !ok {310return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "value")311}312313if protoReq.Token == nil {314protoReq.Token = &ClearTokenRequest_Value{}315} else if _, ok := protoReq.Token.(*ClearTokenRequest_Value); !ok {316return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_Value, but: %t\n", protoReq.Token)317}318protoReq.Token.(*ClearTokenRequest_Value).Value, err = runtime.String(val)319if err != nil {320return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "value", err)321}322323if err := req.ParseForm(); err != nil {324return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)325}326if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_0); err != nil {327return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)328}329330msg, err := server.ClearToken(ctx, &protoReq)331return msg, metadata, err332333}334335var (336filter_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}}337)338339func request_TokenService_ClearToken_1(ctx context.Context, marshaler runtime.Marshaler, client TokenServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {340var protoReq ClearTokenRequest341var metadata runtime.ServerMetadata342343var (344val string345ok bool346err error347_ = err348)349350val, ok = pathParams["kind"]351if !ok {352return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")353}354355protoReq.Kind, err = runtime.String(val)356if err != nil {357return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)358}359360val, ok = pathParams["all"]361if !ok {362return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "all")363}364365if protoReq.Token == nil {366protoReq.Token = &ClearTokenRequest_All{}367} else if _, ok := protoReq.Token.(*ClearTokenRequest_All); !ok {368return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_All, but: %t\n", protoReq.Token)369}370protoReq.Token.(*ClearTokenRequest_All).All, err = runtime.Bool(val)371if err != nil {372return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "all", err)373}374375if err := req.ParseForm(); err != nil {376return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)377}378if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_1); err != nil {379return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)380}381382msg, err := client.ClearToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))383return msg, metadata, err384385}386387func 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) {388var protoReq ClearTokenRequest389var metadata runtime.ServerMetadata390391var (392val string393ok bool394err error395_ = err396)397398val, ok = pathParams["kind"]399if !ok {400return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "kind")401}402403protoReq.Kind, err = runtime.String(val)404if err != nil {405return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "kind", err)406}407408val, ok = pathParams["all"]409if !ok {410return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "all")411}412413if protoReq.Token == nil {414protoReq.Token = &ClearTokenRequest_All{}415} else if _, ok := protoReq.Token.(*ClearTokenRequest_All); !ok {416return nil, metadata, status.Errorf(codes.InvalidArgument, "expect type: *ClearTokenRequest_All, but: %t\n", protoReq.Token)417}418protoReq.Token.(*ClearTokenRequest_All).All, err = runtime.Bool(val)419if err != nil {420return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "all", err)421}422423if err := req.ParseForm(); err != nil {424return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)425}426if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TokenService_ClearToken_1); err != nil {427return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)428}429430msg, err := server.ClearToken(ctx, &protoReq)431return msg, metadata, err432433}434435// RegisterTokenServiceHandlerServer registers the http handlers for service TokenService to "mux".436// UnaryRPC :call TokenServiceServer directly.437// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.438// Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterTokenServiceHandlerFromEndpoint instead.439func RegisterTokenServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TokenServiceServer) error {440441mux.Handle("GET", pattern_TokenService_GetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {442ctx, cancel := context.WithCancel(req.Context())443defer cancel()444var stream runtime.ServerTransportStream445ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)446inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)447var err error448var annotatedContext context.Context449annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/GetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}/{scope}"))450if err != nil {451runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)452return453}454resp, md, err := local_request_TokenService_GetToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)455md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())456annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)457if err != nil {458runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)459return460}461462forward_TokenService_GetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)463464})465466mux.Handle("POST", pattern_TokenService_SetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {467ctx, cancel := context.WithCancel(req.Context())468defer cancel()469var stream runtime.ServerTransportStream470ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)471inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)472var err error473var annotatedContext context.Context474annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/SetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}"))475if err != nil {476runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)477return478}479resp, md, err := local_request_TokenService_SetToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)480md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())481annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)482if err != nil {483runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)484return485}486487forward_TokenService_SetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)488489})490491mux.Handle("DELETE", pattern_TokenService_ClearToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {492ctx, cancel := context.WithCancel(req.Context())493defer cancel()494var stream runtime.ServerTransportStream495ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)496inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)497var err error498var annotatedContext context.Context499annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{value}"))500if err != nil {501runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)502return503}504resp, md, err := local_request_TokenService_ClearToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)505md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())506annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)507if err != nil {508runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)509return510}511512forward_TokenService_ClearToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)513514})515516mux.Handle("DELETE", pattern_TokenService_ClearToken_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {517ctx, cancel := context.WithCancel(req.Context())518defer cancel()519var stream runtime.ServerTransportStream520ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)521inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)522var err error523var annotatedContext context.Context524annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/clear/all/{all=true}"))525if err != nil {526runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)527return528}529resp, md, err := local_request_TokenService_ClearToken_1(annotatedContext, inboundMarshaler, server, req, pathParams)530md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())531annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)532if err != nil {533runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)534return535}536537forward_TokenService_ClearToken_1(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)538539})540541return nil542}543544// RegisterTokenServiceHandlerFromEndpoint is same as RegisterTokenServiceHandler but545// automatically dials to "endpoint" and closes the connection when "ctx" gets done.546func RegisterTokenServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {547conn, err := grpc.Dial(endpoint, opts...)548if err != nil {549return err550}551defer func() {552if err != nil {553if cerr := conn.Close(); cerr != nil {554grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)555}556return557}558go func() {559<-ctx.Done()560if cerr := conn.Close(); cerr != nil {561grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)562}563}()564}()565566return RegisterTokenServiceHandler(ctx, mux, conn)567}568569// RegisterTokenServiceHandler registers the http handlers for service TokenService to "mux".570// The handlers forward requests to the grpc endpoint over "conn".571func RegisterTokenServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {572return RegisterTokenServiceHandlerClient(ctx, mux, NewTokenServiceClient(conn))573}574575// RegisterTokenServiceHandlerClient registers the http handlers for service TokenService576// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TokenServiceClient".577// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TokenServiceClient"578// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in579// "TokenServiceClient" to call the correct interceptors.580func RegisterTokenServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TokenServiceClient) error {581582mux.Handle("GET", pattern_TokenService_GetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {583ctx, cancel := context.WithCancel(req.Context())584defer cancel()585inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)586var err error587var annotatedContext context.Context588annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/GetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}/{scope}"))589if err != nil {590runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)591return592}593resp, md, err := request_TokenService_GetToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)594annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)595if err != nil {596runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)597return598}599600forward_TokenService_GetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)601602})603604mux.Handle("POST", pattern_TokenService_SetToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {605ctx, cancel := context.WithCancel(req.Context())606defer cancel()607inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)608var err error609var annotatedContext context.Context610annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/SetToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{host}"))611if err != nil {612runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)613return614}615resp, md, err := request_TokenService_SetToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)616annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)617if err != nil {618runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)619return620}621622forward_TokenService_SetToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)623624})625626mux.Handle("DELETE", pattern_TokenService_ClearToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {627ctx, cancel := context.WithCancel(req.Context())628defer cancel()629inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)630var err error631var annotatedContext context.Context632annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/{value}"))633if err != nil {634runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)635return636}637resp, md, err := request_TokenService_ClearToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)638annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)639if err != nil {640runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)641return642}643644forward_TokenService_ClearToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)645646})647648mux.Handle("DELETE", pattern_TokenService_ClearToken_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {649ctx, cancel := context.WithCancel(req.Context())650defer cancel()651inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)652var err error653var annotatedContext context.Context654annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/supervisor.TokenService/ClearToken", runtime.WithHTTPPathPattern("/v1/token/{kind}/clear/all/{all=true}"))655if err != nil {656runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)657return658}659resp, md, err := request_TokenService_ClearToken_1(annotatedContext, inboundMarshaler, client, req, pathParams)660annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)661if err != nil {662runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)663return664}665666forward_TokenService_ClearToken_1(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)667668})669670return nil671}672673var (674pattern_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"}, ""))675676pattern_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"}, ""))677678pattern_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"}, ""))679680pattern_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"}, ""))681)682683var (684forward_TokenService_GetToken_0 = runtime.ForwardResponseMessage685686forward_TokenService_SetToken_0 = runtime.ForwardResponseMessage687688forward_TokenService_ClearToken_0 = runtime.ForwardResponseMessage689690forward_TokenService_ClearToken_1 = runtime.ForwardResponseMessage691)692693694