Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 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") + var SamplingStrategyType_name = map[int32]string + var SamplingStrategyType_value = map[string]int32 + func RegisterCollectorServiceServer(s *grpc.Server, srv CollectorServiceServer) + func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer) + func RegisterSamplingManagerServer(s *grpc.Server, srv SamplingManagerServer) + 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 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 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 struct + Operation string + ProbabilisticSampling *ProbabilisticSamplingStrategy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 + 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 struct + DefaultLowerBoundTracesPerSecond float64 + DefaultSamplingProbability float64 + DefaultUpperBoundTracesPerSecond float64 + PerOperationStrategies []*OperationSamplingStrategy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 + 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 struct + Batch model.Batch + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PostSpansRequest) Descriptor() ([]byte, []int) + func (*PostSpansRequest) ProtoMessage() + func (m *PostSpansRequest) GetBatch() model.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 + 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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 + 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 struct + SamplingRate float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 + 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 struct + MaxTracesPerSecond int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 + 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 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 + 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 struct + OperationSampling *PerOperationSamplingStrategies + ProbabilisticSampling *ProbabilisticSamplingStrategy + RateLimitingSampling *RateLimitingSamplingStrategy + StrategyType SamplingStrategyType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 + 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 SamplingStrategyType int32 + const SamplingStrategyType_PROBABILISTIC + const SamplingStrategyType_RATE_LIMITING + func (SamplingStrategyType) EnumDescriptor() ([]byte, []int) + func (x SamplingStrategyType) String() string + 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