api_v2

Oct 6, 2023

Changes in this version

type ArchiveTraceRequest

+ EndTime *time.Time

+ StartTime *time.Time

+ func (m *ArchiveTraceRequest) GetEndTime() *time.Time

+ func (m *ArchiveTraceRequest) GetStartTime() *time.Time

type GetTraceRequest

+ EndTime *time.Time

+ StartTime *time.Time

+ func (m *GetTraceRequest) GetEndTime() *time.Time

+ func (m *GetTraceRequest) GetStartTime() *time.Time

Jul 7, 2021

Changes in this version

+ var ErrUnexpectedEndOfGroupCollector = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupSampling = fmt.Errorf("proto: unexpected end of group")

type ArchiveTraceRequest

+ func (m *ArchiveTraceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ArchiveTraceResponse

+ func (m *ArchiveTraceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type FindTracesRequest

+ func (m *FindTracesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetDependenciesRequest

+ func (m *GetDependenciesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetDependenciesResponse

+ func (m *GetDependenciesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetOperationsRequest

+ func (m *GetOperationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetOperationsResponse

+ func (m *GetOperationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetServicesRequest

+ func (m *GetServicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetServicesResponse

+ func (m *GetServicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetTraceRequest

+ func (m *GetTraceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Operation

+ func (m *Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

type OperationSamplingStrategy

+ func (m *OperationSamplingStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

type PerOperationSamplingStrategies

+ func (m *PerOperationSamplingStrategies) MarshalToSizedBuffer(dAtA []byte) (int, error)

type PostSpansRequest

+ func (m *PostSpansRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type PostSpansResponse

+ func (m *PostSpansResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ProbabilisticSamplingStrategy

+ func (m *ProbabilisticSamplingStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RateLimitingSamplingStrategy

+ func (m *RateLimitingSamplingStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SamplingStrategyParameters

+ func (m *SamplingStrategyParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SamplingStrategyResponse

+ func (m *SamplingStrategyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SpansResponseChunk

+ func (m *SpansResponseChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceQueryParameters

+ func (m *TraceQueryParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ type UnimplementedCollectorServiceServer struct

+ func (*UnimplementedCollectorServiceServer) PostSpans(ctx context.Context, req *PostSpansRequest) (*PostSpansResponse, error)

+ type UnimplementedQueryServiceServer struct

+ func (*UnimplementedQueryServiceServer) ArchiveTrace(ctx context.Context, req *ArchiveTraceRequest) (*ArchiveTraceResponse, error)

+ func (*UnimplementedQueryServiceServer) FindTraces(req *FindTracesRequest, srv QueryService_FindTracesServer) error

+ func (*UnimplementedQueryServiceServer) GetDependencies(ctx context.Context, req *GetDependenciesRequest) (*GetDependenciesResponse, error)

+ func (*UnimplementedQueryServiceServer) GetOperations(ctx context.Context, req *GetOperationsRequest) (*GetOperationsResponse, error)

+ func (*UnimplementedQueryServiceServer) GetServices(ctx context.Context, req *GetServicesRequest) (*GetServicesResponse, error)

+ func (*UnimplementedQueryServiceServer) GetTrace(req *GetTraceRequest, srv QueryService_GetTraceServer) error

+ type UnimplementedSamplingManagerServer struct

+ func (*UnimplementedSamplingManagerServer) GetSamplingStrategy(ctx context.Context, req *SamplingStrategyParameters) (*SamplingStrategyResponse, error)

May 14, 2020 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Mar 13, 2020 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Feb 24, 2020 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Dec 17, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Changes in this version

type GetOperationsRequest

+ SpanKind string

+ func (m *GetOperationsRequest) GetSpanKind() string

type GetOperationsResponse

+ OperationNames []string

+ func (m *GetOperationsResponse) GetOperationNames() []string

+ type Operation struct

+ Name string

+ SpanKind string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Operation) Descriptor() ([]byte, []int)

+ func (*Operation) ProtoMessage()

+ func (m *Operation) GetName() string

+ func (m *Operation) GetSpanKind() string

+ func (m *Operation) Marshal() (dAtA []byte, err error)

+ func (m *Operation) MarshalTo(dAtA []byte) (int, error)

+ func (m *Operation) Reset()

+ func (m *Operation) Size() (n int)

+ func (m *Operation) String() string

+ func (m *Operation) Unmarshal(dAtA []byte) error

+ func (m *Operation) XXX_DiscardUnknown()

+ func (m *Operation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Operation) XXX_Merge(src proto.Message)

+ func (m *Operation) XXX_Size() int

+ func (m *Operation) XXX_Unmarshal(b []byte) error

Nov 7, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Nov 7, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Sep 2, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Jun 28, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Jun 27, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

May 16, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Changes in this version

+ var ErrIntOverflowCollector = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowSampling = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCollector = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthSampling = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer)

+ type ArchiveTraceRequest struct

+ TraceID github_com_jaegertracing_jaeger_model.TraceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ArchiveTraceRequest) Descriptor() ([]byte, []int)

+ func (*ArchiveTraceRequest) ProtoMessage()

+ func (m *ArchiveTraceRequest) Marshal() (dAtA []byte, err error)

+ func (m *ArchiveTraceRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArchiveTraceRequest) Reset()

+ func (m *ArchiveTraceRequest) Size() (n int)

+ func (m *ArchiveTraceRequest) String() string

+ func (m *ArchiveTraceRequest) Unmarshal(dAtA []byte) error

+ func (m *ArchiveTraceRequest) XXX_DiscardUnknown()

+ func (m *ArchiveTraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArchiveTraceRequest) XXX_Merge(src proto.Message)

+ func (m *ArchiveTraceRequest) XXX_Size() int

+ func (m *ArchiveTraceRequest) XXX_Unmarshal(b []byte) error

+ type ArchiveTraceResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ArchiveTraceResponse) Descriptor() ([]byte, []int)

+ func (*ArchiveTraceResponse) ProtoMessage()

+ func (m *ArchiveTraceResponse) Marshal() (dAtA []byte, err error)

+ func (m *ArchiveTraceResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArchiveTraceResponse) Reset()

+ func (m *ArchiveTraceResponse) Size() (n int)

+ func (m *ArchiveTraceResponse) String() string

+ func (m *ArchiveTraceResponse) Unmarshal(dAtA []byte) error

+ func (m *ArchiveTraceResponse) XXX_DiscardUnknown()

+ func (m *ArchiveTraceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArchiveTraceResponse) XXX_Merge(src proto.Message)

+ func (m *ArchiveTraceResponse) XXX_Size() int

+ func (m *ArchiveTraceResponse) XXX_Unmarshal(b []byte) error

+ type FindTracesRequest struct

+ Query *TraceQueryParameters

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindTracesRequest) Descriptor() ([]byte, []int)

+ func (*FindTracesRequest) ProtoMessage()

+ func (m *FindTracesRequest) GetQuery() *TraceQueryParameters

+ func (m *FindTracesRequest) Marshal() (dAtA []byte, err error)

+ func (m *FindTracesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FindTracesRequest) Reset()

+ func (m *FindTracesRequest) Size() (n int)

+ func (m *FindTracesRequest) String() string

+ func (m *FindTracesRequest) Unmarshal(dAtA []byte) error

+ func (m *FindTracesRequest) XXX_DiscardUnknown()

+ func (m *FindTracesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FindTracesRequest) XXX_Merge(src proto.Message)

+ func (m *FindTracesRequest) XXX_Size() int

+ func (m *FindTracesRequest) XXX_Unmarshal(b []byte) error

+ type GetDependenciesRequest struct

+ EndTime time.Time

+ StartTime time.Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetDependenciesRequest) Descriptor() ([]byte, []int)

+ func (*GetDependenciesRequest) ProtoMessage()

+ func (m *GetDependenciesRequest) GetEndTime() time.Time

+ func (m *GetDependenciesRequest) GetStartTime() time.Time

+ func (m *GetDependenciesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetDependenciesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDependenciesRequest) Reset()

+ func (m *GetDependenciesRequest) Size() (n int)

+ func (m *GetDependenciesRequest) String() string

+ func (m *GetDependenciesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetDependenciesRequest) XXX_DiscardUnknown()

+ func (m *GetDependenciesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetDependenciesRequest) XXX_Merge(src proto.Message)

+ func (m *GetDependenciesRequest) XXX_Size() int

+ func (m *GetDependenciesRequest) XXX_Unmarshal(b []byte) error

+ type GetDependenciesResponse struct

+ Dependencies []model.DependencyLink

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetDependenciesResponse) Descriptor() ([]byte, []int)

+ func (*GetDependenciesResponse) ProtoMessage()

+ func (m *GetDependenciesResponse) GetDependencies() []model.DependencyLink

+ func (m *GetDependenciesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetDependenciesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDependenciesResponse) Reset()

+ func (m *GetDependenciesResponse) Size() (n int)

+ func (m *GetDependenciesResponse) String() string

+ func (m *GetDependenciesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetDependenciesResponse) XXX_DiscardUnknown()

+ func (m *GetDependenciesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetDependenciesResponse) XXX_Merge(src proto.Message)

+ func (m *GetDependenciesResponse) XXX_Size() int

+ func (m *GetDependenciesResponse) XXX_Unmarshal(b []byte) error

+ type GetOperationsRequest struct

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetOperationsRequest) Descriptor() ([]byte, []int)

+ func (*GetOperationsRequest) ProtoMessage()

+ func (m *GetOperationsRequest) GetService() string

+ func (m *GetOperationsRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetOperationsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetOperationsRequest) Reset()

+ func (m *GetOperationsRequest) Size() (n int)

+ func (m *GetOperationsRequest) String() string

+ func (m *GetOperationsRequest) Unmarshal(dAtA []byte) error

+ func (m *GetOperationsRequest) XXX_DiscardUnknown()

+ func (m *GetOperationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetOperationsRequest) XXX_Merge(src proto.Message)

+ func (m *GetOperationsRequest) XXX_Size() int

+ func (m *GetOperationsRequest) XXX_Unmarshal(b []byte) error

+ type GetOperationsResponse struct

+ Operations []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetOperationsResponse) Descriptor() ([]byte, []int)

+ func (*GetOperationsResponse) ProtoMessage()

+ func (m *GetOperationsResponse) GetOperations() []string

+ func (m *GetOperationsResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetOperationsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetOperationsResponse) Reset()

+ func (m *GetOperationsResponse) Size() (n int)

+ func (m *GetOperationsResponse) String() string

+ func (m *GetOperationsResponse) Unmarshal(dAtA []byte) error

+ func (m *GetOperationsResponse) XXX_DiscardUnknown()

+ func (m *GetOperationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetOperationsResponse) XXX_Merge(src proto.Message)

+ func (m *GetOperationsResponse) XXX_Size() int

+ func (m *GetOperationsResponse) XXX_Unmarshal(b []byte) error

+ type GetServicesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetServicesRequest) Descriptor() ([]byte, []int)

+ func (*GetServicesRequest) ProtoMessage()

+ func (m *GetServicesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetServicesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetServicesRequest) Reset()

+ func (m *GetServicesRequest) Size() (n int)

+ func (m *GetServicesRequest) String() string

+ func (m *GetServicesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetServicesRequest) XXX_DiscardUnknown()

+ func (m *GetServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetServicesRequest) XXX_Merge(src proto.Message)

+ func (m *GetServicesRequest) XXX_Size() int

+ func (m *GetServicesRequest) XXX_Unmarshal(b []byte) error

+ type GetServicesResponse struct

+ Services []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetServicesResponse) Descriptor() ([]byte, []int)

+ func (*GetServicesResponse) ProtoMessage()

+ func (m *GetServicesResponse) GetServices() []string

+ func (m *GetServicesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetServicesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetServicesResponse) Reset()

+ func (m *GetServicesResponse) Size() (n int)

+ func (m *GetServicesResponse) String() string

+ func (m *GetServicesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetServicesResponse) XXX_DiscardUnknown()

+ func (m *GetServicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetServicesResponse) XXX_Merge(src proto.Message)

+ func (m *GetServicesResponse) XXX_Size() int

+ func (m *GetServicesResponse) XXX_Unmarshal(b []byte) error

+ type GetTraceRequest struct

+ TraceID github_com_jaegertracing_jaeger_model.TraceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTraceRequest) Descriptor() ([]byte, []int)

+ func (*GetTraceRequest) ProtoMessage()

+ func (m *GetTraceRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTraceRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTraceRequest) Reset()

+ func (m *GetTraceRequest) Size() (n int)

+ func (m *GetTraceRequest) String() string

+ func (m *GetTraceRequest) Unmarshal(dAtA []byte) error

+ func (m *GetTraceRequest) XXX_DiscardUnknown()

+ func (m *GetTraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTraceRequest) XXX_Merge(src proto.Message)

+ func (m *GetTraceRequest) XXX_Size() int

+ func (m *GetTraceRequest) XXX_Unmarshal(b []byte) error

type OperationSamplingStrategy

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *OperationSamplingStrategy) XXX_DiscardUnknown()

+ func (m *OperationSamplingStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OperationSamplingStrategy) XXX_Merge(src proto.Message)

+ func (m *OperationSamplingStrategy) XXX_Size() int

+ func (m *OperationSamplingStrategy) XXX_Unmarshal(b []byte) error

type PerOperationSamplingStrategies

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PerOperationSamplingStrategies) XXX_DiscardUnknown()

+ func (m *PerOperationSamplingStrategies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PerOperationSamplingStrategies) XXX_Merge(src proto.Message)

+ func (m *PerOperationSamplingStrategies) XXX_Size() int

+ func (m *PerOperationSamplingStrategies) XXX_Unmarshal(b []byte) error

type PostSpansRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PostSpansRequest) XXX_DiscardUnknown()

+ func (m *PostSpansRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostSpansRequest) XXX_Merge(src proto.Message)

+ func (m *PostSpansRequest) XXX_Size() int

+ func (m *PostSpansRequest) XXX_Unmarshal(b []byte) error

type PostSpansResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PostSpansResponse) XXX_DiscardUnknown()

+ func (m *PostSpansResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostSpansResponse) XXX_Merge(src proto.Message)

+ func (m *PostSpansResponse) XXX_Size() int

+ func (m *PostSpansResponse) XXX_Unmarshal(b []byte) error

type ProbabilisticSamplingStrategy

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ProbabilisticSamplingStrategy) XXX_DiscardUnknown()

+ func (m *ProbabilisticSamplingStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProbabilisticSamplingStrategy) XXX_Merge(src proto.Message)

+ func (m *ProbabilisticSamplingStrategy) XXX_Size() int

+ func (m *ProbabilisticSamplingStrategy) XXX_Unmarshal(b []byte) error

+ type QueryServiceClient interface

+ ArchiveTrace func(ctx context.Context, in *ArchiveTraceRequest, opts ...grpc.CallOption) (*ArchiveTraceResponse, error)

+ FindTraces func(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (QueryService_FindTracesClient, error)

+ GetDependencies func(ctx context.Context, in *GetDependenciesRequest, opts ...grpc.CallOption) (*GetDependenciesResponse, error)

+ GetOperations func(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error)

+ GetServices func(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error)

+ GetTrace func(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (QueryService_GetTraceClient, error)

+ func NewQueryServiceClient(cc *grpc.ClientConn) QueryServiceClient

+ type QueryServiceServer interface

+ ArchiveTrace func(context.Context, *ArchiveTraceRequest) (*ArchiveTraceResponse, error)

+ FindTraces func(*FindTracesRequest, QueryService_FindTracesServer) error

+ GetDependencies func(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error)

+ GetOperations func(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)

+ GetServices func(context.Context, *GetServicesRequest) (*GetServicesResponse, error)

+ GetTrace func(*GetTraceRequest, QueryService_GetTraceServer) error

+ type QueryService_FindTracesClient interface

+ Recv func() (*SpansResponseChunk, error)

+ type QueryService_FindTracesServer interface

+ Send func(*SpansResponseChunk) error

+ type QueryService_GetTraceClient interface

+ Recv func() (*SpansResponseChunk, error)

+ type QueryService_GetTraceServer interface

+ Send func(*SpansResponseChunk) error

type RateLimitingSamplingStrategy

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RateLimitingSamplingStrategy) XXX_DiscardUnknown()

+ func (m *RateLimitingSamplingStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RateLimitingSamplingStrategy) XXX_Merge(src proto.Message)

+ func (m *RateLimitingSamplingStrategy) XXX_Size() int

+ func (m *RateLimitingSamplingStrategy) XXX_Unmarshal(b []byte) error

type SamplingStrategyParameters

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SamplingStrategyParameters) XXX_DiscardUnknown()

+ func (m *SamplingStrategyParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SamplingStrategyParameters) XXX_Merge(src proto.Message)

+ func (m *SamplingStrategyParameters) XXX_Size() int

+ func (m *SamplingStrategyParameters) XXX_Unmarshal(b []byte) error

type SamplingStrategyResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SamplingStrategyResponse) XXX_DiscardUnknown()

+ func (m *SamplingStrategyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SamplingStrategyResponse) XXX_Merge(src proto.Message)

+ func (m *SamplingStrategyResponse) XXX_Size() int

+ func (m *SamplingStrategyResponse) XXX_Unmarshal(b []byte) error

+ type SpansResponseChunk struct

+ Spans []model.Span

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SpansResponseChunk) Descriptor() ([]byte, []int)

+ func (*SpansResponseChunk) ProtoMessage()

+ func (m *SpansResponseChunk) GetSpans() []model.Span

+ func (m *SpansResponseChunk) Marshal() (dAtA []byte, err error)

+ func (m *SpansResponseChunk) MarshalTo(dAtA []byte) (int, error)

+ func (m *SpansResponseChunk) Reset()

+ func (m *SpansResponseChunk) Size() (n int)

+ func (m *SpansResponseChunk) String() string

+ func (m *SpansResponseChunk) Unmarshal(dAtA []byte) error

+ func (m *SpansResponseChunk) XXX_DiscardUnknown()

+ func (m *SpansResponseChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SpansResponseChunk) XXX_Merge(src proto.Message)

+ func (m *SpansResponseChunk) XXX_Size() int

+ func (m *SpansResponseChunk) XXX_Unmarshal(b []byte) error

+ type TraceQueryParameters struct

+ DurationMax time.Duration

+ DurationMin time.Duration

+ OperationName string

+ SearchDepth int32

+ ServiceName string

+ StartTimeMax time.Time

+ StartTimeMin time.Time

+ Tags map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceQueryParameters) Descriptor() ([]byte, []int)

+ func (*TraceQueryParameters) ProtoMessage()

+ func (m *TraceQueryParameters) GetDurationMax() time.Duration

+ func (m *TraceQueryParameters) GetDurationMin() time.Duration

+ func (m *TraceQueryParameters) GetOperationName() string

+ func (m *TraceQueryParameters) GetSearchDepth() int32

+ func (m *TraceQueryParameters) GetServiceName() string

+ func (m *TraceQueryParameters) GetStartTimeMax() time.Time

+ func (m *TraceQueryParameters) GetStartTimeMin() time.Time

+ func (m *TraceQueryParameters) GetTags() map[string]string

+ func (m *TraceQueryParameters) Marshal() (dAtA []byte, err error)

+ func (m *TraceQueryParameters) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceQueryParameters) Reset()

+ func (m *TraceQueryParameters) Size() (n int)

+ func (m *TraceQueryParameters) String() string

+ func (m *TraceQueryParameters) Unmarshal(dAtA []byte) error

+ func (m *TraceQueryParameters) XXX_DiscardUnknown()

+ func (m *TraceQueryParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceQueryParameters) XXX_Merge(src proto.Message)

+ func (m *TraceQueryParameters) XXX_Size() int

+ func (m *TraceQueryParameters) XXX_Unmarshal(b []byte) error

Mar 7, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Feb 21, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Feb 15, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Jan 21, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Changes in this version

+ var ErrIntOverflowApiV2 = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthApiV2 = fmt.Errorf("proto: negative length found during unmarshaling")

+ var SamplingStrategyType_name = map[int32]string

+ var SamplingStrategyType_value = map[string]int32

+ func RegisterCollectorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterCollectorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CollectorServiceClient) error

+ func RegisterCollectorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterCollectorServiceServer(s *grpc.Server, srv CollectorServiceServer)

+ func RegisterSamplingManagerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterSamplingManagerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SamplingManagerClient) error

+ func RegisterSamplingManagerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterSamplingManagerServer(s *grpc.Server, srv SamplingManagerServer)

+ type CollectorServiceClient interface

+ PostSpans func(ctx context.Context, in *PostSpansRequest, opts ...grpc.CallOption) (*PostSpansResponse, error)

+ func NewCollectorServiceClient(cc *grpc.ClientConn) CollectorServiceClient

+ type CollectorServiceServer interface

+ PostSpans func(context.Context, *PostSpansRequest) (*PostSpansResponse, error)

+ type OperationSamplingStrategy struct

+ Operation string

+ ProbabilisticSampling *ProbabilisticSamplingStrategy

+ func (*OperationSamplingStrategy) Descriptor() ([]byte, []int)

+ func (*OperationSamplingStrategy) ProtoMessage()

+ func (m *OperationSamplingStrategy) GetOperation() string

+ func (m *OperationSamplingStrategy) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

+ func (m *OperationSamplingStrategy) Marshal() (dAtA []byte, err error)

+ func (m *OperationSamplingStrategy) MarshalTo(dAtA []byte) (int, error)

+ func (m *OperationSamplingStrategy) Reset()

+ func (m *OperationSamplingStrategy) Size() (n int)

+ func (m *OperationSamplingStrategy) String() string

+ func (m *OperationSamplingStrategy) Unmarshal(dAtA []byte) error

+ type PerOperationSamplingStrategies struct

+ DefaultLowerBoundTracesPerSecond float64

+ DefaultSamplingProbability float64

+ DefaultUpperBoundTracesPerSecond float64

+ PerOperationStrategies []*OperationSamplingStrategy

+ func (*PerOperationSamplingStrategies) Descriptor() ([]byte, []int)

+ func (*PerOperationSamplingStrategies) ProtoMessage()

+ func (m *PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond() float64

+ func (m *PerOperationSamplingStrategies) GetDefaultSamplingProbability() float64

+ func (m *PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond() float64

+ func (m *PerOperationSamplingStrategies) GetPerOperationStrategies() []*OperationSamplingStrategy

+ func (m *PerOperationSamplingStrategies) Marshal() (dAtA []byte, err error)

+ func (m *PerOperationSamplingStrategies) MarshalTo(dAtA []byte) (int, error)

+ func (m *PerOperationSamplingStrategies) Reset()

+ func (m *PerOperationSamplingStrategies) Size() (n int)

+ func (m *PerOperationSamplingStrategies) String() string

+ func (m *PerOperationSamplingStrategies) Unmarshal(dAtA []byte) error

+ type PostSpansRequest struct

+ Batch jaeger_api_v2.Batch

+ func (*PostSpansRequest) Descriptor() ([]byte, []int)

+ func (*PostSpansRequest) ProtoMessage()

+ func (m *PostSpansRequest) GetBatch() jaeger_api_v2.Batch

+ func (m *PostSpansRequest) Marshal() (dAtA []byte, err error)

+ func (m *PostSpansRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostSpansRequest) Reset()

+ func (m *PostSpansRequest) Size() (n int)

+ func (m *PostSpansRequest) String() string

+ func (m *PostSpansRequest) Unmarshal(dAtA []byte) error

+ type PostSpansResponse struct

+ func (*PostSpansResponse) Descriptor() ([]byte, []int)

+ func (*PostSpansResponse) ProtoMessage()

+ func (m *PostSpansResponse) Marshal() (dAtA []byte, err error)

+ func (m *PostSpansResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostSpansResponse) Reset()

+ func (m *PostSpansResponse) Size() (n int)

+ func (m *PostSpansResponse) String() string

+ func (m *PostSpansResponse) Unmarshal(dAtA []byte) error

+ type ProbabilisticSamplingStrategy struct

+ SamplingRate float64

+ func (*ProbabilisticSamplingStrategy) Descriptor() ([]byte, []int)

+ func (*ProbabilisticSamplingStrategy) ProtoMessage()

+ func (m *ProbabilisticSamplingStrategy) GetSamplingRate() float64

+ func (m *ProbabilisticSamplingStrategy) Marshal() (dAtA []byte, err error)

+ func (m *ProbabilisticSamplingStrategy) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProbabilisticSamplingStrategy) Reset()

+ func (m *ProbabilisticSamplingStrategy) Size() (n int)

+ func (m *ProbabilisticSamplingStrategy) String() string

+ func (m *ProbabilisticSamplingStrategy) Unmarshal(dAtA []byte) error

+ type RateLimitingSamplingStrategy struct

+ MaxTracesPerSecond int32

+ func (*RateLimitingSamplingStrategy) Descriptor() ([]byte, []int)

+ func (*RateLimitingSamplingStrategy) ProtoMessage()

+ func (m *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int32

+ func (m *RateLimitingSamplingStrategy) Marshal() (dAtA []byte, err error)

+ func (m *RateLimitingSamplingStrategy) MarshalTo(dAtA []byte) (int, error)

+ func (m *RateLimitingSamplingStrategy) Reset()

+ func (m *RateLimitingSamplingStrategy) Size() (n int)

+ func (m *RateLimitingSamplingStrategy) String() string

+ func (m *RateLimitingSamplingStrategy) Unmarshal(dAtA []byte) error

+ type SamplingManagerClient interface

+ GetSamplingStrategy func(ctx context.Context, in *SamplingStrategyParameters, opts ...grpc.CallOption) (*SamplingStrategyResponse, error)

+ func NewSamplingManagerClient(cc *grpc.ClientConn) SamplingManagerClient

+ type SamplingManagerServer interface

+ GetSamplingStrategy func(context.Context, *SamplingStrategyParameters) (*SamplingStrategyResponse, error)

+ type SamplingStrategyParameters struct

+ ServiceName string

+ func (*SamplingStrategyParameters) Descriptor() ([]byte, []int)

+ func (*SamplingStrategyParameters) ProtoMessage()

+ func (m *SamplingStrategyParameters) GetServiceName() string

+ func (m *SamplingStrategyParameters) Marshal() (dAtA []byte, err error)

+ func (m *SamplingStrategyParameters) MarshalTo(dAtA []byte) (int, error)

+ func (m *SamplingStrategyParameters) Reset()

+ func (m *SamplingStrategyParameters) Size() (n int)

+ func (m *SamplingStrategyParameters) String() string

+ func (m *SamplingStrategyParameters) Unmarshal(dAtA []byte) error

+ type SamplingStrategyResponse struct

+ OperationSampling *PerOperationSamplingStrategies

+ ProbabilisticSampling *ProbabilisticSamplingStrategy

+ RateLimitingSampling *RateLimitingSamplingStrategy

+ StrategyType SamplingStrategyType

+ func (*SamplingStrategyResponse) Descriptor() ([]byte, []int)

+ func (*SamplingStrategyResponse) ProtoMessage()

+ func (m *SamplingStrategyResponse) GetOperationSampling() *PerOperationSamplingStrategies

+ func (m *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

+ func (m *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy

+ func (m *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType

+ func (m *SamplingStrategyResponse) Marshal() (dAtA []byte, err error)

+ func (m *SamplingStrategyResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SamplingStrategyResponse) Reset()

+ func (m *SamplingStrategyResponse) Size() (n int)

+ func (m *SamplingStrategyResponse) String() string

+ func (m *SamplingStrategyResponse) Unmarshal(dAtA []byte) error

+ type SamplingStrategyType int32

+ const SamplingStrategyType_PROBABILISTIC

+ const SamplingStrategyType_RATE_LIMITING

+ func (SamplingStrategyType) EnumDescriptor() ([]byte, []int)

+ func (x SamplingStrategyType) String() string