diff --git a/plugin/storage/grpc/config/config.go b/plugin/storage/grpc/config/config.go index e8890d360a5d..4a30af7eb76b 100644 --- a/plugin/storage/grpc/config/config.go +++ b/plugin/storage/grpc/config/config.go @@ -19,8 +19,8 @@ import ( "os/exec" "runtime" - "github.com/hashicorp/go-hclog" - "github.com/hashicorp/go-plugin" + hclog "github.com/hashicorp/go-hclog" + plugin "github.com/hashicorp/go-plugin" "github.com/jaegertracing/jaeger/plugin/storage/grpc/shared" ) @@ -29,6 +29,7 @@ import ( type Configuration struct { PluginBinary string `yaml:"binary"` PluginConfigurationFile string `yaml:"configuration-file"` + AllowTokenFromContext bool `yaml:"allow-token-from-context"` } // Build instantiates a StoragePlugin @@ -39,7 +40,7 @@ func (c *Configuration) Build() (shared.StoragePlugin, error) { client := plugin.NewClient(&plugin.ClientConfig{ HandshakeConfig: shared.Handshake, VersionedPlugins: map[int]plugin.PluginSet{ - 1: shared.PluginMap, + 1: shared.GetPluginMap(c.AllowTokenFromContext), }, Cmd: cmd, AllowedProtocols: []plugin.Protocol{plugin.ProtocolGRPC}, diff --git a/plugin/storage/grpc/options.go b/plugin/storage/grpc/options.go index 82cac8d93117..24b56594e7f9 100644 --- a/plugin/storage/grpc/options.go +++ b/plugin/storage/grpc/options.go @@ -17,6 +17,7 @@ package grpc import ( "flag" + "github.com/jaegertracing/jaeger/storage/spanstore" "github.com/spf13/viper" "github.com/jaegertracing/jaeger/plugin/storage/grpc/config" @@ -41,4 +42,6 @@ func (opt *Options) AddFlags(flagSet *flag.FlagSet) { func (opt *Options) InitFromViper(v *viper.Viper) { opt.Configuration.PluginBinary = v.GetString(pluginBinary) opt.Configuration.PluginConfigurationFile = v.GetString(pluginConfigurationFile) + // TODO: Need to figure out a better way for do this. (same as ElasticSearch storage) + opt.Configuration.AllowTokenFromContext = v.GetBool(spanstore.StoragePropagationKey) } diff --git a/plugin/storage/grpc/proto/storage.proto b/plugin/storage/grpc/proto/storage.proto index 0c347883dcf7..9cfe3102965c 100644 --- a/plugin/storage/grpc/proto/storage.proto +++ b/plugin/storage/grpc/proto/storage.proto @@ -66,9 +66,12 @@ message GetTraceRequest { (gogoproto.customtype) = "github.com/jaegertracing/jaeger/model.TraceID", (gogoproto.customname) = "TraceID" ]; + string bearerToken = 2; } -message GetServicesRequest {} +message GetServicesRequest { + string bearerToken = 1; +} message GetServicesResponse { repeated string services = 1; @@ -76,6 +79,7 @@ message GetServicesResponse { message GetOperationsRequest { string service = 1; + string bearerToken = 2; } message GetOperationsResponse { @@ -107,6 +111,7 @@ message TraceQueryParameters { message FindTracesRequest { TraceQueryParameters query = 1; + string bearerToken = 2; } message SpansResponseChunk { @@ -117,6 +122,7 @@ message SpansResponseChunk { message FindTraceIDsRequest { TraceQueryParameters query = 1; + string bearerToken = 2; } message FindTraceIDsResponse { diff --git a/plugin/storage/grpc/shared/grpc_client.go b/plugin/storage/grpc/shared/grpc_client.go index 8cf0f6edfa26..68094d580a0a 100644 --- a/plugin/storage/grpc/shared/grpc_client.go +++ b/plugin/storage/grpc/shared/grpc_client.go @@ -29,9 +29,20 @@ import ( // grpcClient implements shared.StoragePlugin and reads/writes spans and dependencies type grpcClient struct { - readerClient storage_v1.SpanReaderPluginClient - writerClient storage_v1.SpanWriterPluginClient - depsReaderClient storage_v1.DependenciesReaderPluginClient + allowTokenFromContext bool + readerClient storage_v1.SpanReaderPluginClient + writerClient storage_v1.SpanWriterPluginClient + depsReaderClient storage_v1.DependenciesReaderPluginClient +} + +// getBearerTokenToForward determines is there is a bearer token to forward +// and returns it only when it, only when bearer token forward is allowed. +func (c *grpcClient) getBearerTokenToForward(ctx context.Context) string { + ctxBearerToken, hasToken := spanstore.GetBearerToken(ctx) + if hasToken && c.allowTokenFromContext { + return ctxBearerToken + } + return "" } // DependencyReader implements shared.StoragePlugin. @@ -51,8 +62,10 @@ func (c *grpcClient) SpanWriter() spanstore.Writer { // GetTrace takes a traceID and returns a Trace associated with that traceID func (c *grpcClient) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error) { + stream, err := c.readerClient.GetTrace(ctx, &storage_v1.GetTraceRequest{ - TraceID: traceID, + TraceID: traceID, + BearerToken: c.getBearerTokenToForward(ctx), }) if err != nil { return nil, errors.Wrap(err, "plugin error") @@ -74,7 +87,9 @@ func (c *grpcClient) GetTrace(ctx context.Context, traceID model.TraceID) (*mode // GetServices returns a list of all known services func (c *grpcClient) GetServices(ctx context.Context) ([]string, error) { - resp, err := c.readerClient.GetServices(ctx, &storage_v1.GetServicesRequest{}) + resp, err := c.readerClient.GetServices(ctx, &storage_v1.GetServicesRequest{ + BearerToken: c.getBearerTokenToForward(ctx), + }) if err != nil { return nil, errors.Wrap(err, "plugin error") } @@ -85,7 +100,8 @@ func (c *grpcClient) GetServices(ctx context.Context) ([]string, error) { // GetOperations returns the operations of a given service func (c *grpcClient) GetOperations(ctx context.Context, service string) ([]string, error) { resp, err := c.readerClient.GetOperations(ctx, &storage_v1.GetOperationsRequest{ - Service: service, + Service: service, + BearerToken: c.getBearerTokenToForward(ctx), }) if err != nil { return nil, errors.Wrap(err, "plugin error") @@ -107,6 +123,7 @@ func (c *grpcClient) FindTraces(ctx context.Context, query *spanstore.TraceQuery DurationMax: query.DurationMax, NumTraces: int32(query.NumTraces), }, + BearerToken: c.getBearerTokenToForward(ctx), }) if err != nil { return nil, errors.Wrap(err, "plugin error") @@ -145,6 +162,7 @@ func (c *grpcClient) FindTraceIDs(ctx context.Context, query *spanstore.TraceQue DurationMax: query.DurationMax, NumTraces: int32(query.NumTraces), }, + BearerToken: c.getBearerTokenToForward(ctx), }) if err != nil { return nil, errors.Wrap(err, "plugin error") diff --git a/plugin/storage/grpc/shared/grpc_server.go b/plugin/storage/grpc/shared/grpc_server.go index 1db0ee1aa28d..1e0d403686c4 100644 --- a/plugin/storage/grpc/shared/grpc_server.go +++ b/plugin/storage/grpc/shared/grpc_server.go @@ -31,6 +31,17 @@ type grpcServer struct { Impl StoragePlugin } +// getMaybeBearerTokenContext returns a context with bearer token, if token string is not empty +// the assumption is that if the token has arrived on the wire, the grpcClient +// verified that bearer token forward was enabled. +// If token is empty, returns original context. +func (s *grpcServer) getMaybeBearerTokenContext(ctx context.Context, token string) context.Context { + if token != "" { + return spanstore.ContextWithBearerToken(ctx, token) + } + return ctx +} + // GetDependencies returns all interservice dependencies func (s *grpcServer) GetDependencies(ctx context.Context, r *storage_v1.GetDependenciesRequest) (*storage_v1.GetDependenciesResponse, error) { deps, err := s.Impl.DependencyReader().GetDependencies(r.EndTime, r.EndTime.Sub(r.StartTime)) @@ -53,7 +64,8 @@ func (s *grpcServer) WriteSpan(ctx context.Context, r *storage_v1.WriteSpanReque // GetTrace takes a traceID and streams a Trace associated with that traceID func (s *grpcServer) GetTrace(r *storage_v1.GetTraceRequest, stream storage_v1.SpanReaderPlugin_GetTraceServer) error { - trace, err := s.Impl.SpanReader().GetTrace(stream.Context(), r.TraceID) + opCtx := s.getMaybeBearerTokenContext(stream.Context(), r.BearerToken) + trace, err := s.Impl.SpanReader().GetTrace(opCtx, r.TraceID) if err != nil { return err } @@ -68,7 +80,8 @@ func (s *grpcServer) GetTrace(r *storage_v1.GetTraceRequest, stream storage_v1.S // GetServices returns a list of all known services func (s *grpcServer) GetServices(ctx context.Context, r *storage_v1.GetServicesRequest) (*storage_v1.GetServicesResponse, error) { - services, err := s.Impl.SpanReader().GetServices(ctx) + opCtx := s.getMaybeBearerTokenContext(ctx, r.BearerToken) + services, err := s.Impl.SpanReader().GetServices(opCtx) if err != nil { return nil, err } @@ -79,7 +92,8 @@ func (s *grpcServer) GetServices(ctx context.Context, r *storage_v1.GetServicesR // GetOperations returns the operations of a given service func (s *grpcServer) GetOperations(ctx context.Context, r *storage_v1.GetOperationsRequest) (*storage_v1.GetOperationsResponse, error) { - operations, err := s.Impl.SpanReader().GetOperations(ctx, r.Service) + opCtx := s.getMaybeBearerTokenContext(ctx, r.BearerToken) + operations, err := s.Impl.SpanReader().GetOperations(opCtx, r.Service) if err != nil { return nil, err } @@ -90,7 +104,8 @@ func (s *grpcServer) GetOperations(ctx context.Context, r *storage_v1.GetOperati // FindTraces streams traces that match the traceQuery func (s *grpcServer) FindTraces(r *storage_v1.FindTracesRequest, stream storage_v1.SpanReaderPlugin_FindTracesServer) error { - traces, err := s.Impl.SpanReader().FindTraces(stream.Context(), &spanstore.TraceQueryParameters{ + opCtx := s.getMaybeBearerTokenContext(stream.Context(), r.BearerToken) + traces, err := s.Impl.SpanReader().FindTraces(opCtx, &spanstore.TraceQueryParameters{ ServiceName: r.Query.ServiceName, OperationName: r.Query.OperationName, Tags: r.Query.Tags, @@ -116,7 +131,8 @@ func (s *grpcServer) FindTraces(r *storage_v1.FindTracesRequest, stream storage_ // FindTraceIDs retrieves traceIDs that match the traceQuery func (s *grpcServer) FindTraceIDs(ctx context.Context, r *storage_v1.FindTraceIDsRequest) (*storage_v1.FindTraceIDsResponse, error) { - traceIDs, err := s.Impl.SpanReader().FindTraceIDs(ctx, &spanstore.TraceQueryParameters{ + opCtx := s.getMaybeBearerTokenContext(ctx, r.BearerToken) + traceIDs, err := s.Impl.SpanReader().FindTraceIDs(opCtx, &spanstore.TraceQueryParameters{ ServiceName: r.Query.ServiceName, OperationName: r.Query.OperationName, Tags: r.Query.Tags, diff --git a/plugin/storage/grpc/shared/interface.go b/plugin/storage/grpc/shared/interface.go index 24d628541518..58139fc67d33 100644 --- a/plugin/storage/grpc/shared/interface.go +++ b/plugin/storage/grpc/shared/interface.go @@ -17,7 +17,7 @@ package shared import ( "context" - "github.com/hashicorp/go-plugin" + plugin "github.com/hashicorp/go-plugin" "google.golang.org/grpc" "github.com/jaegertracing/jaeger/proto-gen/storage_v1" @@ -34,9 +34,13 @@ var Handshake = plugin.HandshakeConfig{ MagicCookieValue: "jaeger", } -// PluginMap is the map of plugins we can dispense. -var PluginMap = map[string]plugin.Plugin{ - StoragePluginIdentifier: &StorageGRPCPlugin{}, +// GetPluginMap returns a plugin map. +func GetPluginMap(allowTokenFromContext bool) map[string]plugin.Plugin { + return map[string]plugin.Plugin{ + StoragePluginIdentifier: &StorageGRPCPlugin{ + allowTokenFromContext: allowTokenFromContext, + }, + } } // StoragePlugin is the interface we're exposing as a plugin. @@ -48,6 +52,7 @@ type StoragePlugin interface { // StorageGRPCPlugin is the implementation of plugin.GRPCPlugin so we can serve/consume this. type StorageGRPCPlugin struct { + allowTokenFromContext bool plugin.Plugin // Concrete implementation, written in Go. This is only used for plugins // that are written in Go. @@ -64,10 +69,11 @@ func (p *StorageGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server } // GRPCClient is used by go-plugin to create a grpc plugin client -func (*StorageGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) { +func (p *StorageGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) { return &grpcClient{ - readerClient: storage_v1.NewSpanReaderPluginClient(c), - writerClient: storage_v1.NewSpanWriterPluginClient(c), - depsReaderClient: storage_v1.NewDependenciesReaderPluginClient(c), + allowTokenFromContext: p.allowTokenFromContext, + readerClient: storage_v1.NewSpanReaderPluginClient(c), + writerClient: storage_v1.NewSpanWriterPluginClient(c), + depsReaderClient: storage_v1.NewDependenciesReaderPluginClient(c), }, nil } diff --git a/proto-gen/storage_v1/storage.pb.go b/proto-gen/storage_v1/storage.pb.go index 4452ef3c715e..6c928d9fc3df 100644 --- a/proto-gen/storage_v1/storage.pb.go +++ b/proto-gen/storage_v1/storage.pb.go @@ -223,6 +223,7 @@ var xxx_messageInfo_WriteSpanResponse proto.InternalMessageInfo type GetTraceRequest struct { TraceID github_com_jaegertracing_jaeger_model.TraceID `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3,customtype=github.com/jaegertracing/jaeger/model.TraceID" json:"trace_id"` + BearerToken string `protobuf:"bytes,2,opt,name=bearerToken,proto3" json:"bearerToken,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -261,7 +262,15 @@ func (m *GetTraceRequest) XXX_DiscardUnknown() { var xxx_messageInfo_GetTraceRequest proto.InternalMessageInfo +func (m *GetTraceRequest) GetBearerToken() string { + if m != nil { + return m.BearerToken + } + return "" +} + type GetServicesRequest struct { + BearerToken string `protobuf:"bytes,1,opt,name=bearerToken,proto3" json:"bearerToken,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -300,6 +309,13 @@ func (m *GetServicesRequest) XXX_DiscardUnknown() { var xxx_messageInfo_GetServicesRequest proto.InternalMessageInfo +func (m *GetServicesRequest) GetBearerToken() string { + if m != nil { + return m.BearerToken + } + return "" +} + type GetServicesResponse struct { Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -349,6 +365,7 @@ func (m *GetServicesResponse) GetServices() []string { type GetOperationsRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` + BearerToken string `protobuf:"bytes,2,opt,name=bearerToken,proto3" json:"bearerToken,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -394,6 +411,13 @@ func (m *GetOperationsRequest) GetService() string { return "" } +func (m *GetOperationsRequest) GetBearerToken() string { + if m != nil { + return m.BearerToken + } + return "" +} + type GetOperationsResponse struct { Operations []string `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -546,6 +570,7 @@ func (m *TraceQueryParameters) GetNumTraces() int32 { type FindTracesRequest struct { Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` + BearerToken string `protobuf:"bytes,2,opt,name=bearerToken,proto3" json:"bearerToken,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -591,6 +616,13 @@ func (m *FindTracesRequest) GetQuery() *TraceQueryParameters { return nil } +func (m *FindTracesRequest) GetBearerToken() string { + if m != nil { + return m.BearerToken + } + return "" +} + type SpansResponseChunk struct { Spans []model.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -640,6 +672,7 @@ func (m *SpansResponseChunk) GetSpans() []model.Span { type FindTraceIDsRequest struct { Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` + BearerToken string `protobuf:"bytes,2,opt,name=bearerToken,proto3" json:"bearerToken,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -685,6 +718,13 @@ func (m *FindTraceIDsRequest) GetQuery() *TraceQueryParameters { return nil } +func (m *FindTraceIDsRequest) GetBearerToken() string { + if m != nil { + return m.BearerToken + } + return "" +} + type FindTraceIDsResponse struct { TraceIDs []github_com_jaegertracing_jaeger_model.TraceID `protobuf:"bytes,1,rep,name=trace_ids,json=traceIds,proto3,customtype=github.com/jaegertracing/jaeger/model.TraceID" json:"trace_ids"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -762,64 +802,66 @@ func init() { proto.RegisterFile("storage.proto", fileDescriptor_0d2c4ccf1453ffd func init() { golang_proto.RegisterFile("storage.proto", fileDescriptor_0d2c4ccf1453ffdb) } var fileDescriptor_0d2c4ccf1453ffdb = []byte{ - // 905 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0x4f, 0x6f, 0xe3, 0x44, - 0x14, 0xc7, 0x6d, 0xb2, 0x71, 0x5e, 0xd2, 0xa5, 0x9d, 0x06, 0x30, 0x16, 0x9b, 0x14, 0x43, 0xb7, - 0x05, 0x09, 0x67, 0x1b, 0x0e, 0x8b, 0x40, 0x08, 0xc8, 0xa6, 0x1b, 0x15, 0xf1, 0x67, 0xf1, 0x46, - 0xac, 0xc4, 0x22, 0xac, 0x49, 0x3c, 0xb8, 0xde, 0xc6, 0x63, 0xaf, 0x3d, 0x8e, 0x92, 0x3b, 0x1f, - 0x80, 0x23, 0x27, 0xae, 0x7c, 0x0d, 0x8e, 0x7b, 0xe4, 0xcc, 0xa1, 0xa0, 0x70, 0xe4, 0x4b, 0x20, - 0xcf, 0x8c, 0xdd, 0xfc, 0xb1, 0xb6, 0xdd, 0x8a, 0x9b, 0xe7, 0xcd, 0xef, 0xfd, 0xde, 0x9b, 0xf7, - 0xe7, 0x97, 0xc0, 0x56, 0xcc, 0x82, 0x08, 0xbb, 0xc4, 0x0c, 0xa3, 0x80, 0x05, 0x68, 0xe7, 0x09, - 0x26, 0x2e, 0x89, 0xcc, 0xcc, 0x3a, 0x39, 0xd2, 0x1b, 0x6e, 0xe0, 0x06, 0xfc, 0xb6, 0x9d, 0x7e, - 0x09, 0xa0, 0xde, 0x72, 0x83, 0xc0, 0x1d, 0x93, 0x36, 0x3f, 0x0d, 0x93, 0x1f, 0xdb, 0xcc, 0xf3, - 0x49, 0xcc, 0xb0, 0x1f, 0x4a, 0x40, 0x73, 0x15, 0xe0, 0x24, 0x11, 0x66, 0x5e, 0x40, 0xe5, 0x7d, - 0xcd, 0x0f, 0x1c, 0x32, 0x16, 0x07, 0xe3, 0x57, 0x05, 0x5e, 0xed, 0x13, 0xd6, 0x23, 0x21, 0xa1, - 0x0e, 0xa1, 0x23, 0x8f, 0xc4, 0x16, 0x79, 0x9a, 0x90, 0x98, 0xa1, 0x7b, 0x00, 0x31, 0xc3, 0x11, - 0xb3, 0xd3, 0x00, 0x9a, 0xb2, 0xa7, 0x1c, 0xd6, 0x3a, 0xba, 0x29, 0xc8, 0xcd, 0x8c, 0xdc, 0x1c, - 0x64, 0xd1, 0xbb, 0xea, 0xb3, 0xf3, 0xd6, 0x4b, 0x3f, 0xff, 0xd5, 0x52, 0xac, 0x2a, 0xf7, 0x4b, - 0x6f, 0xd0, 0x27, 0xa0, 0x12, 0xea, 0x08, 0x8a, 0x8d, 0x17, 0xa0, 0xa8, 0x10, 0xea, 0xa4, 0x76, - 0x63, 0x08, 0xaf, 0xad, 0xe5, 0x17, 0x87, 0x01, 0x8d, 0x09, 0xea, 0x43, 0xdd, 0x59, 0xb0, 0x6b, - 0xca, 0xde, 0xe6, 0x61, 0xad, 0x73, 0xcb, 0x94, 0x95, 0xc4, 0xa1, 0x67, 0x4f, 0x3a, 0x66, 0xee, - 0x3a, 0xfb, 0xc2, 0xa3, 0x67, 0xdd, 0x52, 0x1a, 0xc2, 0x5a, 0x72, 0x34, 0x3e, 0x82, 0xed, 0x47, - 0x91, 0xc7, 0xc8, 0xc3, 0x10, 0xd3, 0xec, 0xf5, 0x07, 0x50, 0x8a, 0x43, 0x4c, 0xe5, 0xbb, 0x77, - 0x57, 0x48, 0x39, 0x92, 0x03, 0x8c, 0x5d, 0xd8, 0x59, 0x70, 0x16, 0xa9, 0x19, 0x14, 0x5e, 0xee, - 0x13, 0x36, 0x88, 0xf0, 0x88, 0x64, 0x84, 0x8f, 0x41, 0x65, 0xe9, 0xd9, 0xf6, 0x1c, 0x4e, 0x5a, - 0xef, 0x7e, 0x9a, 0xa6, 0xf2, 0xe7, 0x79, 0xeb, 0x3d, 0xd7, 0x63, 0xa7, 0xc9, 0xd0, 0x1c, 0x05, - 0x7e, 0x5b, 0x84, 0x49, 0x81, 0x1e, 0x75, 0xe5, 0xa9, 0x2d, 0x1a, 0xc6, 0xd9, 0x4e, 0x7a, 0xf3, - 0xf3, 0x56, 0x45, 0x7e, 0x5a, 0x15, 0xce, 0x78, 0xe2, 0x18, 0x0d, 0x40, 0x7d, 0xc2, 0x1e, 0x92, - 0x68, 0xe2, 0x8d, 0xf2, 0x0e, 0x1a, 0x47, 0xb0, 0xbb, 0x64, 0x95, 0x75, 0xd3, 0x41, 0x8d, 0xa5, - 0x8d, 0xd7, 0xac, 0x6a, 0xe5, 0x67, 0xe3, 0x0e, 0x34, 0xfa, 0x84, 0x7d, 0x1d, 0x12, 0x31, 0x32, - 0xf9, 0x30, 0x68, 0x50, 0x91, 0x18, 0x9e, 0x7c, 0xd5, 0xca, 0x8e, 0xc6, 0x5d, 0x78, 0x65, 0xc5, - 0x43, 0x86, 0x69, 0x02, 0x04, 0xb9, 0x55, 0x06, 0x5a, 0xb0, 0x18, 0xbf, 0x95, 0xa0, 0xc1, 0x1f, - 0xf2, 0x4d, 0x42, 0xa2, 0xd9, 0x03, 0x1c, 0x61, 0x9f, 0x30, 0x12, 0xc5, 0xe8, 0x4d, 0xa8, 0x4b, - 0x72, 0x9b, 0x62, 0x3f, 0x0b, 0x58, 0x93, 0xb6, 0xaf, 0xb0, 0x4f, 0xd0, 0x3e, 0xdc, 0xcc, 0x99, - 0x04, 0x68, 0x83, 0x83, 0xb6, 0x72, 0x2b, 0x87, 0x1d, 0x43, 0x89, 0x61, 0x37, 0xd6, 0x36, 0xf9, - 0x64, 0x1c, 0x99, 0x6b, 0x3b, 0x66, 0x16, 0x25, 0x60, 0x0e, 0xb0, 0x1b, 0x1f, 0x53, 0x16, 0xcd, - 0x2c, 0xee, 0x8e, 0x3e, 0x87, 0x9b, 0x17, 0x9b, 0x60, 0xfb, 0x1e, 0xd5, 0x4a, 0x2f, 0x30, 0xca, - 0xf5, 0x7c, 0x1b, 0xbe, 0xf4, 0xe8, 0x2a, 0x17, 0x9e, 0x6a, 0xe5, 0xeb, 0x71, 0xe1, 0x29, 0xba, - 0x0f, 0xf5, 0x6c, 0xb7, 0x79, 0x56, 0x37, 0x38, 0xd3, 0xeb, 0x6b, 0x4c, 0x3d, 0x09, 0x12, 0x44, - 0xbf, 0xa4, 0x44, 0xb5, 0xcc, 0x31, 0xcd, 0x69, 0x89, 0x07, 0x4f, 0xb5, 0xca, 0x75, 0x78, 0xf0, - 0x14, 0xdd, 0x02, 0xa0, 0x89, 0x6f, 0xf3, 0xa1, 0x8c, 0x35, 0x75, 0x4f, 0x39, 0x2c, 0x5b, 0x55, - 0x9a, 0xf8, 0xbc, 0xc8, 0xb1, 0x7e, 0x17, 0xaa, 0x79, 0x65, 0xd1, 0x36, 0x6c, 0x9e, 0x91, 0x99, - 0xec, 0x6d, 0xfa, 0x89, 0x1a, 0x50, 0x9e, 0xe0, 0x71, 0x92, 0xb5, 0x52, 0x1c, 0x3e, 0xdc, 0xf8, - 0x40, 0x31, 0x2c, 0xd8, 0xb9, 0xef, 0x51, 0x47, 0xd0, 0x64, 0x13, 0xf9, 0x31, 0x94, 0x9f, 0xa6, - 0x7d, 0x93, 0x1b, 0x7a, 0x70, 0xc5, 0xe6, 0x5a, 0xc2, 0xcb, 0x38, 0x06, 0x94, 0x6e, 0x6c, 0x3e, - 0xae, 0xf7, 0x4e, 0x13, 0x7a, 0x86, 0xda, 0x50, 0x4e, 0x97, 0x3a, 0xd3, 0x92, 0xa2, 0xb5, 0x97, - 0x0a, 0x22, 0x70, 0xc6, 0x00, 0x76, 0xf3, 0xd4, 0x4e, 0x7a, 0xff, 0x57, 0x72, 0x13, 0x68, 0x2c, - 0xb3, 0xca, 0x95, 0xfa, 0x01, 0xaa, 0x99, 0x86, 0x88, 0x14, 0xeb, 0xdd, 0xcf, 0xae, 0x2b, 0x22, - 0x6a, 0xce, 0xae, 0x4a, 0x15, 0x89, 0x3b, 0x4f, 0x60, 0x3b, 0x7d, 0x22, 0xd7, 0xb3, 0xe8, 0xc1, - 0x38, 0x71, 0x3d, 0x8a, 0xbe, 0x85, 0x6a, 0xae, 0x6f, 0xe8, 0xad, 0x82, 0x87, 0xac, 0x4a, 0xa7, - 0xfe, 0xf6, 0xf3, 0x41, 0xe2, 0x2d, 0x9d, 0x7f, 0x37, 0x45, 0x30, 0x8b, 0x60, 0x27, 0x0f, 0xf6, - 0x08, 0xd4, 0x4c, 0x37, 0x91, 0x51, 0x40, 0xb3, 0x22, 0xaa, 0xfa, 0x7e, 0x01, 0x66, 0xbd, 0xad, - 0x77, 0x14, 0xf4, 0x3d, 0xd4, 0x16, 0xa4, 0x10, 0xed, 0x17, 0x73, 0xaf, 0x08, 0xa8, 0x7e, 0xfb, - 0x32, 0x98, 0xec, 0xcb, 0x10, 0xb6, 0x96, 0x34, 0x10, 0x1d, 0x14, 0x3b, 0xae, 0xe9, 0xaa, 0x7e, - 0x78, 0x39, 0x50, 0xc6, 0x78, 0x0c, 0x70, 0xb1, 0x04, 0xa8, 0xa8, 0xc6, 0x6b, 0x3b, 0x72, 0xf5, - 0xf2, 0xd8, 0x50, 0x5f, 0x1c, 0x38, 0x74, 0xfb, 0x79, 0xf4, 0x17, 0x73, 0xae, 0x1f, 0x5c, 0x8a, - 0x93, 0xdd, 0xfe, 0x49, 0x01, 0x6d, 0xf9, 0x47, 0x7c, 0xa1, 0xeb, 0xa7, 0xfc, 0xd7, 0x72, 0xf1, - 0x1a, 0xbd, 0x53, 0x5c, 0x97, 0x82, 0xff, 0x29, 0xfa, 0xbb, 0x57, 0x81, 0x8a, 0x34, 0xba, 0x6f, - 0x3c, 0x9b, 0x37, 0x95, 0x3f, 0xe6, 0x4d, 0xe5, 0xef, 0x79, 0x53, 0xf9, 0xfd, 0x9f, 0xa6, 0xf2, - 0x1d, 0x48, 0x2f, 0x7b, 0x72, 0x34, 0xbc, 0xc1, 0x95, 0xee, 0xfd, 0xff, 0x02, 0x00, 0x00, 0xff, - 0xff, 0x7d, 0x2c, 0x50, 0x42, 0x9b, 0x09, 0x00, 0x00, + // 930 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x56, 0x4f, 0x73, 0xdb, 0x44, + 0x14, 0x47, 0x8d, 0x5d, 0xdb, 0xcf, 0x4e, 0x49, 0x36, 0x06, 0x84, 0x86, 0xda, 0x41, 0x90, 0x26, + 0x30, 0x83, 0x4c, 0xcc, 0x0c, 0x65, 0x60, 0x18, 0xc0, 0x4d, 0xea, 0x09, 0xc3, 0x9f, 0xa2, 0x66, + 0xe8, 0x0c, 0x65, 0xf0, 0xac, 0xa3, 0x87, 0xa2, 0x26, 0x5a, 0xb9, 0xd2, 0xca, 0x93, 0xdc, 0xf9, + 0x00, 0x3d, 0x72, 0xe2, 0xca, 0xd7, 0xe0, 0xd8, 0x23, 0x67, 0x0e, 0x81, 0x09, 0x47, 0xbe, 0x04, + 0xa3, 0xdd, 0x95, 0x22, 0xcb, 0x9a, 0xc6, 0xcd, 0xa1, 0x37, 0xed, 0xdb, 0xdf, 0xfb, 0xbd, 0xb7, + 0xef, 0xcf, 0xcf, 0x86, 0xe5, 0x88, 0x07, 0x21, 0x75, 0xd1, 0x9a, 0x84, 0x01, 0x0f, 0xc8, 0xea, + 0x23, 0x8a, 0x2e, 0x86, 0x56, 0x6a, 0x9d, 0x6e, 0x1b, 0x6d, 0x37, 0x70, 0x03, 0x71, 0xdb, 0x4b, + 0xbe, 0x24, 0xd0, 0xe8, 0xba, 0x41, 0xe0, 0x1e, 0x63, 0x4f, 0x9c, 0xc6, 0xf1, 0xcf, 0x3d, 0xee, + 0xf9, 0x18, 0x71, 0xea, 0x4f, 0x14, 0xa0, 0x53, 0x04, 0x38, 0x71, 0x48, 0xb9, 0x17, 0x30, 0x75, + 0xdf, 0xf4, 0x03, 0x07, 0x8f, 0xe5, 0xc1, 0xfc, 0x4d, 0x83, 0x57, 0x87, 0xc8, 0x77, 0x70, 0x82, + 0xcc, 0x41, 0x76, 0xe0, 0x61, 0x64, 0xe3, 0xe3, 0x18, 0x23, 0x4e, 0xee, 0x00, 0x44, 0x9c, 0x86, + 0x7c, 0x94, 0x04, 0xd0, 0xb5, 0x75, 0x6d, 0xab, 0xd9, 0x37, 0x2c, 0x49, 0x6e, 0xa5, 0xe4, 0xd6, + 0x7e, 0x1a, 0x7d, 0x50, 0x7f, 0x7a, 0xd6, 0x7d, 0xe9, 0xc9, 0xdf, 0x5d, 0xcd, 0x6e, 0x08, 0xbf, + 0xe4, 0x86, 0x7c, 0x06, 0x75, 0x64, 0x8e, 0xa4, 0xb8, 0xf6, 0x1c, 0x14, 0x35, 0x64, 0x4e, 0x62, + 0x37, 0xc7, 0xf0, 0xda, 0x5c, 0x7e, 0xd1, 0x24, 0x60, 0x11, 0x92, 0x21, 0xb4, 0x9c, 0x9c, 0x5d, + 0xd7, 0xd6, 0x97, 0xb6, 0x9a, 0xfd, 0x9b, 0x96, 0xaa, 0x24, 0x9d, 0x78, 0xa3, 0x69, 0xdf, 0xca, + 0x5c, 0x4f, 0xbf, 0xf2, 0xd8, 0xd1, 0xa0, 0x92, 0x84, 0xb0, 0x67, 0x1c, 0xcd, 0x4f, 0x60, 0xe5, + 0x41, 0xe8, 0x71, 0xbc, 0x3f, 0xa1, 0x2c, 0x7d, 0xfd, 0x26, 0x54, 0xa2, 0x09, 0x65, 0xea, 0xdd, + 0x6b, 0x05, 0x52, 0x81, 0x14, 0x00, 0x73, 0x0d, 0x56, 0x73, 0xce, 0x32, 0x35, 0xf3, 0x89, 0x06, + 0x2f, 0x0f, 0x91, 0xef, 0x87, 0xf4, 0x00, 0x53, 0xc6, 0x87, 0x50, 0xe7, 0xc9, 0x79, 0xe4, 0x39, + 0x82, 0xb5, 0x35, 0xf8, 0x3c, 0xc9, 0xe5, 0xaf, 0xb3, 0xee, 0x7b, 0xae, 0xc7, 0x0f, 0xe3, 0xb1, + 0x75, 0x10, 0xf8, 0x3d, 0x19, 0x27, 0x01, 0x7a, 0xcc, 0x55, 0xa7, 0x9e, 0xec, 0x98, 0x60, 0xdb, + 0xdb, 0x39, 0x3f, 0xeb, 0xd6, 0xd4, 0xa7, 0x5d, 0x13, 0x8c, 0x7b, 0x0e, 0x59, 0x87, 0xe6, 0x18, + 0x69, 0x88, 0xe1, 0x7e, 0x70, 0x84, 0x4c, 0x94, 0xba, 0x61, 0xe7, 0x4d, 0xe6, 0x87, 0x40, 0x86, + 0xc8, 0xef, 0x63, 0x38, 0xf5, 0x0e, 0x2e, 0x9a, 0x5c, 0xf0, 0xd3, 0xe6, 0xfd, 0xb6, 0x61, 0x6d, + 0xc6, 0x4f, 0x15, 0xdf, 0x80, 0x7a, 0xa4, 0x6c, 0xa2, 0xf0, 0x0d, 0x3b, 0x3b, 0x9b, 0x36, 0xb4, + 0x87, 0xc8, 0xbf, 0x9d, 0xa0, 0x9c, 0xbb, 0x2c, 0x98, 0x0e, 0x35, 0x85, 0x51, 0x81, 0xd2, 0xe3, + 0x02, 0xe9, 0xdf, 0x86, 0x57, 0x0a, 0x9c, 0x2a, 0x91, 0x0e, 0x40, 0x90, 0x59, 0x55, 0x2a, 0x39, + 0x8b, 0xf9, 0x7b, 0x05, 0xda, 0xa2, 0x5c, 0xdf, 0xc5, 0x18, 0x9e, 0xde, 0xa3, 0x21, 0xf5, 0x91, + 0x63, 0x18, 0x91, 0x37, 0xa1, 0xa5, 0xc2, 0x8f, 0x18, 0xf5, 0xd3, 0x94, 0x9a, 0xca, 0xf6, 0x0d, + 0xf5, 0x91, 0x6c, 0xc0, 0x8d, 0x8c, 0x49, 0x82, 0x64, 0x66, 0xcb, 0x99, 0x55, 0xc0, 0x76, 0xa1, + 0xc2, 0xa9, 0x1b, 0xe9, 0x4b, 0x62, 0x00, 0xb7, 0xad, 0xb9, 0x55, 0xb6, 0xca, 0x12, 0xb0, 0xf6, + 0xa9, 0x1b, 0xed, 0x32, 0x1e, 0x9e, 0xda, 0xc2, 0x9d, 0x7c, 0x09, 0x37, 0x2e, 0x16, 0x6e, 0xe4, + 0x7b, 0x4c, 0xaf, 0x3c, 0xc7, 0xc6, 0xb4, 0xb2, 0xa5, 0xfb, 0xda, 0x63, 0x45, 0x2e, 0x7a, 0xa2, + 0x57, 0xaf, 0xc6, 0x45, 0x4f, 0xc8, 0x5d, 0x68, 0xa5, 0x12, 0x22, 0xb2, 0xba, 0x2e, 0x98, 0x5e, + 0x9f, 0x63, 0xda, 0x51, 0x20, 0x49, 0xf4, 0x6b, 0x42, 0xd4, 0x4c, 0x1d, 0x93, 0x9c, 0x66, 0x78, + 0xe8, 0x89, 0x5e, 0xbb, 0x0a, 0x0f, 0x3d, 0x21, 0x37, 0x01, 0x58, 0xec, 0x8f, 0xc4, 0xe8, 0x47, + 0x7a, 0x7d, 0x5d, 0xdb, 0xaa, 0xda, 0x0d, 0x16, 0xfb, 0xa2, 0xc8, 0x91, 0x71, 0x1b, 0x1a, 0x59, + 0x65, 0xc9, 0x0a, 0x2c, 0x1d, 0xe1, 0xa9, 0xea, 0x6d, 0xf2, 0x49, 0xda, 0x50, 0x9d, 0xd2, 0xe3, + 0x38, 0x6d, 0xa5, 0x3c, 0x7c, 0x7c, 0xed, 0x23, 0xcd, 0xe4, 0xb0, 0x7a, 0xd7, 0x63, 0x8e, 0xa4, + 0x49, 0x67, 0xf6, 0x53, 0xa8, 0x3e, 0x4e, 0xfa, 0xa6, 0x84, 0x60, 0x73, 0xc1, 0xe6, 0xda, 0xd2, + 0x6b, 0x81, 0xc1, 0xde, 0x05, 0x92, 0x48, 0x47, 0x36, 0xd0, 0x77, 0x0e, 0x63, 0x76, 0x44, 0x7a, + 0x50, 0x4d, 0xd4, 0x25, 0x15, 0xb5, 0x32, 0xfd, 0x51, 0x52, 0x26, 0x71, 0xe6, 0x14, 0xd6, 0xb2, + 0xe4, 0xf7, 0x76, 0x5e, 0x5c, 0xfa, 0x53, 0x68, 0xcf, 0xc6, 0x55, 0x6b, 0xf9, 0x13, 0x34, 0x52, + 0xb5, 0x93, 0x8f, 0x68, 0x0d, 0xbe, 0xb8, 0xaa, 0xdc, 0xd5, 0x33, 0xf6, 0xba, 0xd2, 0xbb, 0xa8, + 0xff, 0x08, 0x56, 0x92, 0x22, 0x08, 0xe9, 0x0d, 0xef, 0x1d, 0xc7, 0xae, 0xc7, 0xc8, 0xf7, 0xd0, + 0xc8, 0xa4, 0x98, 0xbc, 0x55, 0xf2, 0xd4, 0xa2, 0xca, 0x1b, 0x6f, 0x3f, 0x1b, 0x24, 0xdf, 0xd2, + 0xff, 0x6f, 0x49, 0x06, 0xb3, 0x91, 0x3a, 0x59, 0xb0, 0x07, 0x50, 0x4f, 0x15, 0x9e, 0x98, 0x25, + 0x34, 0x05, 0xf9, 0x37, 0x36, 0x4a, 0x30, 0xf3, 0x8d, 0x7f, 0x5f, 0x23, 0x3f, 0x42, 0x33, 0x27, + 0xb8, 0x64, 0xa3, 0x9c, 0xbb, 0x20, 0xe4, 0xc6, 0xad, 0xcb, 0x60, 0xaa, 0x2f, 0x63, 0x58, 0x9e, + 0xd1, 0x51, 0xb2, 0x59, 0xee, 0x38, 0xa7, 0xde, 0xc6, 0xd6, 0xe5, 0x40, 0x15, 0xe3, 0x21, 0xc0, + 0xc5, 0x22, 0x91, 0xb2, 0x1a, 0xcf, 0xed, 0xd9, 0xe2, 0xe5, 0x19, 0x41, 0x2b, 0x3f, 0x70, 0xe4, + 0xd6, 0xb3, 0xe8, 0x2f, 0x36, 0xc1, 0xd8, 0xbc, 0x14, 0xa7, 0xba, 0xfd, 0x8b, 0x06, 0xfa, 0xec, + 0xff, 0x8d, 0x5c, 0xd7, 0x0f, 0xc5, 0xef, 0x7a, 0xfe, 0x9a, 0xbc, 0x53, 0x5e, 0x97, 0x92, 0xbf, + 0x54, 0xc6, 0xbb, 0x8b, 0x40, 0x65, 0x1a, 0x83, 0x37, 0x9e, 0x9e, 0x77, 0xb4, 0x3f, 0xcf, 0x3b, + 0xda, 0x3f, 0xe7, 0x1d, 0xed, 0x8f, 0x7f, 0x3b, 0xda, 0x0f, 0xa0, 0xbc, 0x46, 0xd3, 0xed, 0xf1, + 0x75, 0xa1, 0x96, 0x1f, 0xfc, 0x1f, 0x00, 0x00, 0xff, 0xff, 0x49, 0x09, 0xb9, 0x65, 0x46, 0x0a, + 0x00, 0x00, } // Reference imports to suppress errors if they are not otherwise used. @@ -1360,6 +1402,12 @@ func (m *GetTraceRequest) MarshalTo(dAtA []byte) (int, error) { return 0, err } i += n4 + if len(m.BearerToken) > 0 { + dAtA[i] = 0x12 + i++ + i = encodeVarintStorage(dAtA, i, uint64(len(m.BearerToken))) + i += copy(dAtA[i:], m.BearerToken) + } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -1381,6 +1429,12 @@ func (m *GetServicesRequest) MarshalTo(dAtA []byte) (int, error) { _ = i var l int _ = l + if len(m.BearerToken) > 0 { + dAtA[i] = 0xa + i++ + i = encodeVarintStorage(dAtA, i, uint64(len(m.BearerToken))) + i += copy(dAtA[i:], m.BearerToken) + } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -1444,6 +1498,12 @@ func (m *GetOperationsRequest) MarshalTo(dAtA []byte) (int, error) { i = encodeVarintStorage(dAtA, i, uint64(len(m.Service))) i += copy(dAtA[i:], m.Service) } + if len(m.BearerToken) > 0 { + dAtA[i] = 0x12 + i++ + i = encodeVarintStorage(dAtA, i, uint64(len(m.BearerToken))) + i += copy(dAtA[i:], m.BearerToken) + } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -1598,6 +1658,12 @@ func (m *FindTracesRequest) MarshalTo(dAtA []byte) (int, error) { } i += n9 } + if len(m.BearerToken) > 0 { + dAtA[i] = 0x12 + i++ + i = encodeVarintStorage(dAtA, i, uint64(len(m.BearerToken))) + i += copy(dAtA[i:], m.BearerToken) + } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -1662,6 +1728,12 @@ func (m *FindTraceIDsRequest) MarshalTo(dAtA []byte) (int, error) { } i += n10 } + if len(m.BearerToken) > 0 { + dAtA[i] = 0x12 + i++ + i = encodeVarintStorage(dAtA, i, uint64(len(m.BearerToken))) + i += copy(dAtA[i:], m.BearerToken) + } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -1780,6 +1852,10 @@ func (m *GetTraceRequest) Size() (n int) { _ = l l = m.TraceID.Size() n += 1 + l + sovStorage(uint64(l)) + l = len(m.BearerToken) + if l > 0 { + n += 1 + l + sovStorage(uint64(l)) + } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -1792,6 +1868,10 @@ func (m *GetServicesRequest) Size() (n int) { } var l int _ = l + l = len(m.BearerToken) + if l > 0 { + n += 1 + l + sovStorage(uint64(l)) + } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -1826,6 +1906,10 @@ func (m *GetOperationsRequest) Size() (n int) { if l > 0 { n += 1 + l + sovStorage(uint64(l)) } + l = len(m.BearerToken) + if l > 0 { + n += 1 + l + sovStorage(uint64(l)) + } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -1899,6 +1983,10 @@ func (m *FindTracesRequest) Size() (n int) { l = m.Query.Size() n += 1 + l + sovStorage(uint64(l)) } + l = len(m.BearerToken) + if l > 0 { + n += 1 + l + sovStorage(uint64(l)) + } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -1933,6 +2021,10 @@ func (m *FindTraceIDsRequest) Size() (n int) { l = m.Query.Size() n += 1 + l + sovStorage(uint64(l)) } + l = len(m.BearerToken) + if l > 0 { + n += 1 + l + sovStorage(uint64(l)) + } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -2384,6 +2476,38 @@ func (m *GetTraceRequest) Unmarshal(dAtA []byte) error { return err } iNdEx = postIndex + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field BearerToken", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowStorage + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return ErrInvalidLengthStorage + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthStorage + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.BearerToken = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipStorage(dAtA[iNdEx:]) @@ -2438,6 +2562,38 @@ func (m *GetServicesRequest) Unmarshal(dAtA []byte) error { return fmt.Errorf("proto: GetServicesRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field BearerToken", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowStorage + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return ErrInvalidLengthStorage + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthStorage + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.BearerToken = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipStorage(dAtA[iNdEx:]) @@ -2610,6 +2766,38 @@ func (m *GetOperationsRequest) Unmarshal(dAtA []byte) error { } m.Service = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field BearerToken", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowStorage + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return ErrInvalidLengthStorage + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthStorage + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.BearerToken = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipStorage(dAtA[iNdEx:]) @@ -3182,6 +3370,38 @@ func (m *FindTracesRequest) Unmarshal(dAtA []byte) error { return err } iNdEx = postIndex + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field BearerToken", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowStorage + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return ErrInvalidLengthStorage + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthStorage + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.BearerToken = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipStorage(dAtA[iNdEx:]) @@ -3360,6 +3580,38 @@ func (m *FindTraceIDsRequest) Unmarshal(dAtA []byte) error { return err } iNdEx = postIndex + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field BearerToken", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowStorage + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return ErrInvalidLengthStorage + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthStorage + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.BearerToken = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipStorage(dAtA[iNdEx:])