api_v2

package
v0.0.0-...-2a2fe1c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 19, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCollector        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCollector          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCollector = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSampling        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSampling          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSampling = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var SamplingStrategyType_name = map[int32]string{
	0: "PROBABILISTIC",
	1: "RATE_LIMITING",
}
View Source 
var SamplingStrategyType_value = map[string]int32{
	"PROBABILISTIC": 0,
	"RATE_LIMITING": 1,
}

Functions

func RegisterCollectorServiceServer 

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

func RegisterQueryServiceServer 

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

func RegisterSamplingManagerServer 

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

Types

type ArchiveTraceRequest 

type ArchiveTraceRequest struct {
	TraceID              github_com_jaegertracing_jaeger_model.TraceID `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*ArchiveTraceRequest) Descriptor 

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

func (*ArchiveTraceRequest) Marshal 

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

func (*ArchiveTraceRequest) MarshalTo 

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

func (*ArchiveTraceRequest) MarshalToSizedBuffer 

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

func (*ArchiveTraceRequest) ProtoMessage 

func (*ArchiveTraceRequest) ProtoMessage()

func (*ArchiveTraceRequest) Reset 

func (m *ArchiveTraceRequest) Reset()

func (*ArchiveTraceRequest) Size 

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

func (*ArchiveTraceRequest) String 

func (m *ArchiveTraceRequest) String() string

func (*ArchiveTraceRequest) Unmarshal 

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

func (*ArchiveTraceRequest) XXX_DiscardUnknown 

func (m *ArchiveTraceRequest) XXX_DiscardUnknown()

func (*ArchiveTraceRequest) XXX_Marshal 

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

func (*ArchiveTraceRequest) XXX_Merge 

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

func (*ArchiveTraceRequest) XXX_Size 

func (m *ArchiveTraceRequest) XXX_Size() int

func (*ArchiveTraceRequest) XXX_Unmarshal 

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

type ArchiveTraceResponse 

type ArchiveTraceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArchiveTraceResponse) Descriptor 

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

func (*ArchiveTraceResponse) Marshal 

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

func (*ArchiveTraceResponse) MarshalTo 

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

func (*ArchiveTraceResponse) MarshalToSizedBuffer 

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

func (*ArchiveTraceResponse) ProtoMessage 

func (*ArchiveTraceResponse) ProtoMessage()

func (*ArchiveTraceResponse) Reset 

func (m *ArchiveTraceResponse) Reset()

func (*ArchiveTraceResponse) Size 

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

func (*ArchiveTraceResponse) String 

func (m *ArchiveTraceResponse) String() string

func (*ArchiveTraceResponse) Unmarshal 

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

func (*ArchiveTraceResponse) XXX_DiscardUnknown 

func (m *ArchiveTraceResponse) XXX_DiscardUnknown()

func (*ArchiveTraceResponse) XXX_Marshal 

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

func (*ArchiveTraceResponse) XXX_Merge 

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

func (*ArchiveTraceResponse) XXX_Size 

func (m *ArchiveTraceResponse) XXX_Size() int

func (*ArchiveTraceResponse) XXX_Unmarshal 

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

type CollectorServiceClient 

type CollectorServiceClient interface {
	PostSpans(ctx context.Context, in *PostSpansRequest, opts ...grpc.CallOption) (*PostSpansResponse, error)
}

CollectorServiceClient is the client API for CollectorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCollectorServiceClient 

func NewCollectorServiceClient(cc *grpc.ClientConn) CollectorServiceClient

type CollectorServiceServer 

type CollectorServiceServer interface {
	PostSpans(context.Context, *PostSpansRequest) (*PostSpansResponse, error)
}

CollectorServiceServer is the server API for CollectorService service.

type FindTracesRequest 

type FindTracesRequest struct {
	Query                *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*FindTracesRequest) Descriptor 

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

func (*FindTracesRequest) GetQuery 

func (m *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) Marshal 

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

func (*FindTracesRequest) MarshalTo 

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

func (*FindTracesRequest) MarshalToSizedBuffer 

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

func (*FindTracesRequest) ProtoMessage 

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) Reset 

func (m *FindTracesRequest) Reset()

func (*FindTracesRequest) Size 

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

func (*FindTracesRequest) String 

func (m *FindTracesRequest) String() string

func (*FindTracesRequest) Unmarshal 

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

func (*FindTracesRequest) XXX_DiscardUnknown 

func (m *FindTracesRequest) XXX_DiscardUnknown()

func (*FindTracesRequest) XXX_Marshal 

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

func (*FindTracesRequest) XXX_Merge 

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

func (*FindTracesRequest) XXX_Size 

func (m *FindTracesRequest) XXX_Size() int

func (*FindTracesRequest) XXX_Unmarshal 

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

type GetDependenciesRequest 

type GetDependenciesRequest struct {
	StartTime            time.Time `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	EndTime              time.Time `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetDependenciesRequest) Descriptor 

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

func (*GetDependenciesRequest) GetEndTime 

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

func (*GetDependenciesRequest) GetStartTime 

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

func (*GetDependenciesRequest) Marshal 

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

func (*GetDependenciesRequest) MarshalTo 

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

func (*GetDependenciesRequest) MarshalToSizedBuffer 

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

func (*GetDependenciesRequest) ProtoMessage 

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) Reset 

func (m *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) Size 

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

func (*GetDependenciesRequest) String 

func (m *GetDependenciesRequest) String() string

func (*GetDependenciesRequest) Unmarshal 

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

func (*GetDependenciesRequest) XXX_DiscardUnknown 

func (m *GetDependenciesRequest) XXX_DiscardUnknown()

func (*GetDependenciesRequest) XXX_Marshal 

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

func (*GetDependenciesRequest) XXX_Merge 

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

func (*GetDependenciesRequest) XXX_Size 

func (m *GetDependenciesRequest) XXX_Size() int

func (*GetDependenciesRequest) XXX_Unmarshal 

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

type GetDependenciesResponse 

type GetDependenciesResponse struct {
	Dependencies         []model.DependencyLink `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetDependenciesResponse) Descriptor 

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

func (*GetDependenciesResponse) GetDependencies 

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

func (*GetDependenciesResponse) Marshal 

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

func (*GetDependenciesResponse) MarshalTo 

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

func (*GetDependenciesResponse) MarshalToSizedBuffer 

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

func (*GetDependenciesResponse) ProtoMessage 

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) Reset 

func (m *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) Size 

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

func (*GetDependenciesResponse) String 

func (m *GetDependenciesResponse) String() string

func (*GetDependenciesResponse) Unmarshal 

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

func (*GetDependenciesResponse) XXX_DiscardUnknown 

func (m *GetDependenciesResponse) XXX_DiscardUnknown()

func (*GetDependenciesResponse) XXX_Marshal 

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

func (*GetDependenciesResponse) XXX_Merge 

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

func (*GetDependenciesResponse) XXX_Size 

func (m *GetDependenciesResponse) XXX_Size() int

func (*GetDependenciesResponse) XXX_Unmarshal 

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

type GetOperationsRequest 

type GetOperationsRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	SpanKind             string   `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetOperationsRequest) Descriptor 

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

func (*GetOperationsRequest) GetService 

func (m *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind 

func (m *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) Marshal 

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

func (*GetOperationsRequest) MarshalTo 

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

func (*GetOperationsRequest) MarshalToSizedBuffer 

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

func (*GetOperationsRequest) ProtoMessage 

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) Reset 

func (m *GetOperationsRequest) Reset()

func (*GetOperationsRequest) Size 

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

func (*GetOperationsRequest) String 

func (m *GetOperationsRequest) String() string

func (*GetOperationsRequest) Unmarshal 

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

func (*GetOperationsRequest) XXX_DiscardUnknown 

func (m *GetOperationsRequest) XXX_DiscardUnknown()

func (*GetOperationsRequest) XXX_Marshal 

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

func (*GetOperationsRequest) XXX_Merge 

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

func (*GetOperationsRequest) XXX_Size 

func (m *GetOperationsRequest) XXX_Size() int

func (*GetOperationsRequest) XXX_Unmarshal 

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

type GetOperationsResponse 

type GetOperationsResponse struct {
	OperationNames       []string     `protobuf:"bytes,1,rep,name=operationNames,proto3" json:"operationNames,omitempty"`
	Operations           []*Operation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetOperationsResponse) Descriptor 

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

func (*GetOperationsResponse) GetOperationNames 

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

func (*GetOperationsResponse) GetOperations 

func (m *GetOperationsResponse) GetOperations() []*Operation

func (*GetOperationsResponse) Marshal 

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

func (*GetOperationsResponse) MarshalTo 

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

func (*GetOperationsResponse) MarshalToSizedBuffer 

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

func (*GetOperationsResponse) ProtoMessage 

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) Reset 

func (m *GetOperationsResponse) Reset()

func (*GetOperationsResponse) Size 

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

func (*GetOperationsResponse) String 

func (m *GetOperationsResponse) String() string

func (*GetOperationsResponse) Unmarshal 

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

func (*GetOperationsResponse) XXX_DiscardUnknown 

func (m *GetOperationsResponse) XXX_DiscardUnknown()

func (*GetOperationsResponse) XXX_Marshal 

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

func (*GetOperationsResponse) XXX_Merge 

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

func (*GetOperationsResponse) XXX_Size 

func (m *GetOperationsResponse) XXX_Size() int

func (*GetOperationsResponse) XXX_Unmarshal 

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

type GetServicesRequest 

type GetServicesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServicesRequest) Descriptor 

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

func (*GetServicesRequest) Marshal 

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

func (*GetServicesRequest) MarshalTo 

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

func (*GetServicesRequest) MarshalToSizedBuffer 

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

func (*GetServicesRequest) ProtoMessage 

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) Reset 

func (m *GetServicesRequest) Reset()

func (*GetServicesRequest) Size 

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

func (*GetServicesRequest) String 

func (m *GetServicesRequest) String() string

func (*GetServicesRequest) Unmarshal 

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

func (*GetServicesRequest) XXX_DiscardUnknown 

func (m *GetServicesRequest) XXX_DiscardUnknown()

func (*GetServicesRequest) XXX_Marshal 

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

func (*GetServicesRequest) XXX_Merge 

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

func (*GetServicesRequest) XXX_Size 

func (m *GetServicesRequest) XXX_Size() int

func (*GetServicesRequest) XXX_Unmarshal 

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

type GetServicesResponse 

type GetServicesResponse struct {
	Services             []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServicesResponse) Descriptor 

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

func (*GetServicesResponse) GetServices 

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

func (*GetServicesResponse) Marshal 

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

func (*GetServicesResponse) MarshalTo 

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

func (*GetServicesResponse) MarshalToSizedBuffer 

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

func (*GetServicesResponse) ProtoMessage 

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) Reset 

func (m *GetServicesResponse) Reset()

func (*GetServicesResponse) Size 

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

func (*GetServicesResponse) String 

func (m *GetServicesResponse) String() string

func (*GetServicesResponse) Unmarshal 

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

func (*GetServicesResponse) XXX_DiscardUnknown 

func (m *GetServicesResponse) XXX_DiscardUnknown()

func (*GetServicesResponse) XXX_Marshal 

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

func (*GetServicesResponse) XXX_Merge 

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

func (*GetServicesResponse) XXX_Size 

func (m *GetServicesResponse) XXX_Size() int

func (*GetServicesResponse) XXX_Unmarshal 

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

type GetTraceRequest 

type GetTraceRequest struct {
	TraceID              github_com_jaegertracing_jaeger_model.TraceID `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*GetTraceRequest) Descriptor 

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

func (*GetTraceRequest) Marshal 

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

func (*GetTraceRequest) MarshalTo 

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

func (*GetTraceRequest) MarshalToSizedBuffer 

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

func (*GetTraceRequest) ProtoMessage 

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) Reset 

func (m *GetTraceRequest) Reset()

func (*GetTraceRequest) Size 

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

func (*GetTraceRequest) String 

func (m *GetTraceRequest) String() string

func (*GetTraceRequest) Unmarshal 

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

func (*GetTraceRequest) XXX_DiscardUnknown 

func (m *GetTraceRequest) XXX_DiscardUnknown()

func (*GetTraceRequest) XXX_Marshal 

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

func (*GetTraceRequest) XXX_Merge 

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

func (*GetTraceRequest) XXX_Size 

func (m *GetTraceRequest) XXX_Size() int

func (*GetTraceRequest) XXX_Unmarshal 

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

type Operation 

type Operation struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SpanKind             string   `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Operation) Descriptor 

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

func (*Operation) GetName 

func (m *Operation) GetName() string

func (*Operation) GetSpanKind 

func (m *Operation) GetSpanKind() string

func (*Operation) Marshal 

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

func (*Operation) MarshalTo 

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

func (*Operation) MarshalToSizedBuffer 

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

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) Reset 

func (m *Operation) Reset()

func (*Operation) Size 

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

func (*Operation) String 

func (m *Operation) String() string

func (*Operation) Unmarshal 

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

func (*Operation) XXX_DiscardUnknown 

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal 

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

func (*Operation) XXX_Merge 

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

func (*Operation) XXX_Size 

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal 

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

type OperationSamplingStrategy 

type OperationSamplingStrategy struct {
	Operation             string                         `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	ProbabilisticSampling *ProbabilisticSamplingStrategy `protobuf:"bytes,2,opt,name=probabilisticSampling,proto3" json:"probabilisticSampling,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}                       `json:"-"`
	XXX_unrecognized      []byte                         `json:"-"`
	XXX_sizecache         int32                          `json:"-"`
}

OperationSamplingStrategy is a sampling strategy for a given operation (aka endpoint, span name). Only probabilistic sampling is currently supported.

func (*OperationSamplingStrategy) Descriptor 

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

func (*OperationSamplingStrategy) GetOperation 

func (m *OperationSamplingStrategy) GetOperation() string

func (*OperationSamplingStrategy) GetProbabilisticSampling 

func (m *OperationSamplingStrategy) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*OperationSamplingStrategy) Marshal 

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

func (*OperationSamplingStrategy) MarshalTo 

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

func (*OperationSamplingStrategy) MarshalToSizedBuffer 

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

func (*OperationSamplingStrategy) ProtoMessage 

func (*OperationSamplingStrategy) ProtoMessage()

func (*OperationSamplingStrategy) Reset 

func (m *OperationSamplingStrategy) Reset()

func (*OperationSamplingStrategy) Size 

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

func (*OperationSamplingStrategy) String 

func (m *OperationSamplingStrategy) String() string

func (*OperationSamplingStrategy) Unmarshal 

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

func (*OperationSamplingStrategy) XXX_DiscardUnknown 

func (m *OperationSamplingStrategy) XXX_DiscardUnknown()

func (*OperationSamplingStrategy) XXX_Marshal 

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

func (*OperationSamplingStrategy) XXX_Merge 

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

func (*OperationSamplingStrategy) XXX_Size 

func (m *OperationSamplingStrategy) XXX_Size() int

func (*OperationSamplingStrategy) XXX_Unmarshal 

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

type PerOperationSamplingStrategies 

type PerOperationSamplingStrategies struct {
	// defaultSamplingProbability is the sampling probability for spans that do not match
	// any of the perOperationStrategies.
	DefaultSamplingProbability float64 `protobuf:"fixed64,1,opt,name=defaultSamplingProbability,proto3" json:"defaultSamplingProbability,omitempty"`
	// defaultLowerBoundTracesPerSecond defines a lower-bound rate limit used to ensure that
	// there is some minimal amount of traces sampled for an endpoint that might otherwise
	// be never sampled via probabilistic strategies. The limit is local to a service instance,
	// so if a service is deployed with many (N) instances, the effective minimum rate of sampling
	// will be N times higher. This setting applies to ALL operations, whether or not they match
	// one of the perOperationStrategies.
	DefaultLowerBoundTracesPerSecond float64 `protobuf:"fixed64,2,opt,name=defaultLowerBoundTracesPerSecond,proto3" json:"defaultLowerBoundTracesPerSecond,omitempty"`
	// perOperationStrategies describes sampling strategiesf for individual operations within
	// a given service.
	PerOperationStrategies []*OperationSamplingStrategy `protobuf:"bytes,3,rep,name=perOperationStrategies,proto3" json:"perOperationStrategies,omitempty"`
	// defaultUpperBoundTracesPerSecond defines an upper bound rate limit.
	// However, almost no Jaeger SDKs support this parameter.
	DefaultUpperBoundTracesPerSecond float64  `protobuf:"fixed64,4,opt,name=defaultUpperBoundTracesPerSecond,proto3" json:"defaultUpperBoundTracesPerSecond,omitempty"`
	XXX_NoUnkeyedLiteral             struct{} `json:"-"`
	XXX_unrecognized                 []byte   `json:"-"`
	XXX_sizecache                    int32    `json:"-"`
}

PerOperationSamplingStrategies is a combination of strategies for different endpoints as well as some service-wide defaults. It is particularly useful for services whose endpoints receive vastly different traffic, so that any single rate of sampling would result in either too much data for some endpoints or almost no data for other endpoints.

func (*PerOperationSamplingStrategies) Descriptor 

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

func (*PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond 

func (m *PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetDefaultSamplingProbability 

func (m *PerOperationSamplingStrategies) GetDefaultSamplingProbability() float64

func (*PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond 

func (m *PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetPerOperationStrategies 

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

func (*PerOperationSamplingStrategies) Marshal 

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

func (*PerOperationSamplingStrategies) MarshalTo 

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

func (*PerOperationSamplingStrategies) MarshalToSizedBuffer 

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

func (*PerOperationSamplingStrategies) ProtoMessage 

func (*PerOperationSamplingStrategies) ProtoMessage()

func (*PerOperationSamplingStrategies) Reset 

func (m *PerOperationSamplingStrategies) Reset()

func (*PerOperationSamplingStrategies) Size 

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

func (*PerOperationSamplingStrategies) String 

func (m *PerOperationSamplingStrategies) String() string

func (*PerOperationSamplingStrategies) Unmarshal 

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

func (*PerOperationSamplingStrategies) XXX_DiscardUnknown 

func (m *PerOperationSamplingStrategies) XXX_DiscardUnknown()

func (*PerOperationSamplingStrategies) XXX_Marshal 

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

func (*PerOperationSamplingStrategies) XXX_Merge 

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

func (*PerOperationSamplingStrategies) XXX_Size 

func (m *PerOperationSamplingStrategies) XXX_Size() int

func (*PerOperationSamplingStrategies) XXX_Unmarshal 

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

type PostSpansRequest 

type PostSpansRequest struct {
	Batch                model.Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PostSpansRequest) Descriptor 

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

func (*PostSpansRequest) Free 

func (m *PostSpansRequest) Free()

func (*PostSpansRequest) GetBatch 

func (m *PostSpansRequest) GetBatch() model.Batch

func (*PostSpansRequest) Marshal 

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

func (*PostSpansRequest) MarshalTo 

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

func (*PostSpansRequest) MarshalToSizedBuffer 

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

func (*PostSpansRequest) ProtoMessage 

func (*PostSpansRequest) ProtoMessage()

func (*PostSpansRequest) Reset 

func (m *PostSpansRequest) Reset()

func (*PostSpansRequest) Size 

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

func (*PostSpansRequest) String 

func (m *PostSpansRequest) String() string

func (*PostSpansRequest) Unmarshal 

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

func (*PostSpansRequest) XXX_DiscardUnknown 

func (m *PostSpansRequest) XXX_DiscardUnknown()

func (*PostSpansRequest) XXX_Marshal 

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

func (*PostSpansRequest) XXX_Merge 

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

func (*PostSpansRequest) XXX_Size 

func (m *PostSpansRequest) XXX_Size() int

func (*PostSpansRequest) XXX_Unmarshal 

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

type PostSpansResponse 

type PostSpansResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostSpansResponse) Descriptor 

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

func (*PostSpansResponse) Marshal 

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

func (*PostSpansResponse) MarshalTo 

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

func (*PostSpansResponse) MarshalToSizedBuffer 

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

func (*PostSpansResponse) ProtoMessage 

func (*PostSpansResponse) ProtoMessage()

func (*PostSpansResponse) Reset 

func (m *PostSpansResponse) Reset()

func (*PostSpansResponse) Size 

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

func (*PostSpansResponse) String 

func (m *PostSpansResponse) String() string

func (*PostSpansResponse) Unmarshal 

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

func (*PostSpansResponse) XXX_DiscardUnknown 

func (m *PostSpansResponse) XXX_DiscardUnknown()

func (*PostSpansResponse) XXX_Marshal 

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

func (*PostSpansResponse) XXX_Merge 

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

func (*PostSpansResponse) XXX_Size 

func (m *PostSpansResponse) XXX_Size() int

func (*PostSpansResponse) XXX_Unmarshal 

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

type ProbabilisticSamplingStrategy 

type ProbabilisticSamplingStrategy struct {
	// samplingRate is the sampling probability in the range [0.0, 1.0].
	SamplingRate         float64  `protobuf:"fixed64,1,opt,name=samplingRate,proto3" json:"samplingRate,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ProbabilisticSamplingStrategy samples traces with a fixed probability.

func (*ProbabilisticSamplingStrategy) Descriptor 

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

func (*ProbabilisticSamplingStrategy) GetSamplingRate 

func (m *ProbabilisticSamplingStrategy) GetSamplingRate() float64

func (*ProbabilisticSamplingStrategy) Marshal 

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

func (*ProbabilisticSamplingStrategy) MarshalTo 

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

func (*ProbabilisticSamplingStrategy) MarshalToSizedBuffer 

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

func (*ProbabilisticSamplingStrategy) ProtoMessage 

func (*ProbabilisticSamplingStrategy) ProtoMessage()

func (*ProbabilisticSamplingStrategy) Reset 

func (m *ProbabilisticSamplingStrategy) Reset()

func (*ProbabilisticSamplingStrategy) Size 

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

func (*ProbabilisticSamplingStrategy) String 

func (m *ProbabilisticSamplingStrategy) String() string

func (*ProbabilisticSamplingStrategy) Unmarshal 

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

func (*ProbabilisticSamplingStrategy) XXX_DiscardUnknown 

func (m *ProbabilisticSamplingStrategy) XXX_DiscardUnknown()

func (*ProbabilisticSamplingStrategy) XXX_Marshal 

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

func (*ProbabilisticSamplingStrategy) XXX_Merge 

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

func (*ProbabilisticSamplingStrategy) XXX_Size 

func (m *ProbabilisticSamplingStrategy) XXX_Size() int

func (*ProbabilisticSamplingStrategy) XXX_Unmarshal 

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

type QueryServiceClient 

type QueryServiceClient interface {
	GetTrace(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (QueryService_GetTraceClient, error)
	ArchiveTrace(ctx context.Context, in *ArchiveTraceRequest, opts ...grpc.CallOption) (*ArchiveTraceResponse, error)
	FindTraces(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (QueryService_FindTracesClient, error)
	GetServices(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error)
	GetOperations(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error)
	GetDependencies(ctx context.Context, in *GetDependenciesRequest, opts ...grpc.CallOption) (*GetDependenciesResponse, error)
}

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryServiceClient 

func NewQueryServiceClient(cc *grpc.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	GetTrace(*GetTraceRequest, QueryService_GetTraceServer) error
	ArchiveTrace(context.Context, *ArchiveTraceRequest) (*ArchiveTraceResponse, error)
	FindTraces(*FindTracesRequest, QueryService_FindTracesServer) error
	GetServices(context.Context, *GetServicesRequest) (*GetServicesResponse, error)
	GetOperations(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)
	GetDependencies(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type QueryService_FindTracesClient 

type QueryService_FindTracesClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type QueryService_FindTracesServer 

type QueryService_FindTracesServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type QueryService_GetTraceClient 

type QueryService_GetTraceClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type QueryService_GetTraceServer 

type QueryService_GetTraceServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type RateLimitingSamplingStrategy 

type RateLimitingSamplingStrategy struct {
	// TODO this field type should be changed to double, to support rates like 1 per minute.
	MaxTracesPerSecond   int32    `protobuf:"varint,1,opt,name=maxTracesPerSecond,proto3" json:"maxTracesPerSecond,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RateLimitingSamplingStrategy samples a fixed number of traces per time interval. The typical implementations use the leaky bucket algorithm.

func (*RateLimitingSamplingStrategy) Descriptor 

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

func (*RateLimitingSamplingStrategy) GetMaxTracesPerSecond 

func (m *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int32

func (*RateLimitingSamplingStrategy) Marshal 

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

func (*RateLimitingSamplingStrategy) MarshalTo 

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

func (*RateLimitingSamplingStrategy) MarshalToSizedBuffer 

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

func (*RateLimitingSamplingStrategy) ProtoMessage 

func (*RateLimitingSamplingStrategy) ProtoMessage()

func (*RateLimitingSamplingStrategy) Reset 

func (m *RateLimitingSamplingStrategy) Reset()

func (*RateLimitingSamplingStrategy) Size 

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

func (*RateLimitingSamplingStrategy) String 

func (m *RateLimitingSamplingStrategy) String() string

func (*RateLimitingSamplingStrategy) Unmarshal 

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

func (*RateLimitingSamplingStrategy) XXX_DiscardUnknown 

func (m *RateLimitingSamplingStrategy) XXX_DiscardUnknown()

func (*RateLimitingSamplingStrategy) XXX_Marshal 

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

func (*RateLimitingSamplingStrategy) XXX_Merge 

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

func (*RateLimitingSamplingStrategy) XXX_Size 

func (m *RateLimitingSamplingStrategy) XXX_Size() int

func (*RateLimitingSamplingStrategy) XXX_Unmarshal 

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

type SamplingManagerClient 

type SamplingManagerClient interface {
	GetSamplingStrategy(ctx context.Context, in *SamplingStrategyParameters, opts ...grpc.CallOption) (*SamplingStrategyResponse, error)
}

SamplingManagerClient is the client API for SamplingManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSamplingManagerClient 

func NewSamplingManagerClient(cc *grpc.ClientConn) SamplingManagerClient

type SamplingManagerServer 

type SamplingManagerServer interface {
	GetSamplingStrategy(context.Context, *SamplingStrategyParameters) (*SamplingStrategyResponse, error)
}

SamplingManagerServer is the server API for SamplingManager service.

type SamplingStrategyParameters 

type SamplingStrategyParameters struct {
	// serviceName is a required argument.
	ServiceName          string   `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SamplingStrategyParameters defines request parameters for remote sampler.

func (*SamplingStrategyParameters) Descriptor 

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

func (*SamplingStrategyParameters) GetServiceName 

func (m *SamplingStrategyParameters) GetServiceName() string

func (*SamplingStrategyParameters) Marshal 

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

func (*SamplingStrategyParameters) MarshalTo 

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

func (*SamplingStrategyParameters) MarshalToSizedBuffer 

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

func (*SamplingStrategyParameters) ProtoMessage 

func (*SamplingStrategyParameters) ProtoMessage()

func (*SamplingStrategyParameters) Reset 

func (m *SamplingStrategyParameters) Reset()

func (*SamplingStrategyParameters) Size 

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

func (*SamplingStrategyParameters) String 

func (m *SamplingStrategyParameters) String() string

func (*SamplingStrategyParameters) Unmarshal 

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

func (*SamplingStrategyParameters) XXX_DiscardUnknown 

func (m *SamplingStrategyParameters) XXX_DiscardUnknown()

func (*SamplingStrategyParameters) XXX_Marshal 

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

func (*SamplingStrategyParameters) XXX_Merge 

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

func (*SamplingStrategyParameters) XXX_Size 

func (m *SamplingStrategyParameters) XXX_Size() int

func (*SamplingStrategyParameters) XXX_Unmarshal 

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

type SamplingStrategyResponse 

type SamplingStrategyResponse struct {
	// Legacy field that was meant to indicate which one of the strategy fields
	// below is present. This enum was not extended when per-operation strategy
	// was introduced, because extending enum has backwards compatiblity issues.
	// The recommended approach for consumers is to ignore this field and instead
	// checks the other fields being not null (starting with operationSampling).
	// For producers, it is recommended to set this field correctly for probabilistic
	// and rate-limiting strategies, but if per-operation strategy is returned,
	// the enum can be set to 0 (probabilistic).
	StrategyType          SamplingStrategyType            `protobuf:"varint,1,opt,name=strategyType,proto3,enum=jaeger.api_v2.SamplingStrategyType" json:"strategyType,omitempty"`
	ProbabilisticSampling *ProbabilisticSamplingStrategy  `protobuf:"bytes,2,opt,name=probabilisticSampling,proto3" json:"probabilisticSampling,omitempty"`
	RateLimitingSampling  *RateLimitingSamplingStrategy   `protobuf:"bytes,3,opt,name=rateLimitingSampling,proto3" json:"rateLimitingSampling,omitempty"`
	OperationSampling     *PerOperationSamplingStrategies `protobuf:"bytes,4,opt,name=operationSampling,proto3" json:"operationSampling,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}                        `json:"-"`
	XXX_unrecognized      []byte                          `json:"-"`
	XXX_sizecache         int32                           `json:"-"`
}

SamplingStrategyResponse contains an overall sampling strategy for a given service. This type should be treated as a union where only one of the strategy field is present.

func (*SamplingStrategyResponse) Descriptor 

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

func (*SamplingStrategyResponse) GetOperationSampling 

func (m *SamplingStrategyResponse) GetOperationSampling() *PerOperationSamplingStrategies

func (*SamplingStrategyResponse) GetProbabilisticSampling 

func (m *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*SamplingStrategyResponse) GetRateLimitingSampling 

func (m *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy

func (*SamplingStrategyResponse) GetStrategyType 

func (m *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType

func (*SamplingStrategyResponse) Marshal 

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

func (*SamplingStrategyResponse) MarshalTo 

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

func (*SamplingStrategyResponse) MarshalToSizedBuffer 

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

func (*SamplingStrategyResponse) ProtoMessage 

func (*SamplingStrategyResponse) ProtoMessage()

func (*SamplingStrategyResponse) Reset 

func (m *SamplingStrategyResponse) Reset()

func (*SamplingStrategyResponse) Size 

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

func (*SamplingStrategyResponse) String 

func (m *SamplingStrategyResponse) String() string

func (*SamplingStrategyResponse) Unmarshal 

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

func (*SamplingStrategyResponse) XXX_DiscardUnknown 

func (m *SamplingStrategyResponse) XXX_DiscardUnknown()

func (*SamplingStrategyResponse) XXX_Marshal 

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

func (*SamplingStrategyResponse) XXX_Merge 

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

func (*SamplingStrategyResponse) XXX_Size 

func (m *SamplingStrategyResponse) XXX_Size() int

func (*SamplingStrategyResponse) XXX_Unmarshal 

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

type SamplingStrategyType 

type SamplingStrategyType int32

See description of the SamplingStrategyResponse.strategyType field. 

const (
	SamplingStrategyType_PROBABILISTIC SamplingStrategyType = 0
	SamplingStrategyType_RATE_LIMITING SamplingStrategyType = 1
)

func (SamplingStrategyType) EnumDescriptor 

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

func (SamplingStrategyType) String 

func (x SamplingStrategyType) String() string

type SpansResponseChunk 

type SpansResponseChunk struct {
	Spans                []model.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SpansResponseChunk) Descriptor 

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

func (*SpansResponseChunk) GetSpans 

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

func (*SpansResponseChunk) Marshal 

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

func (*SpansResponseChunk) MarshalTo 

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

func (*SpansResponseChunk) MarshalToSizedBuffer 

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

func (*SpansResponseChunk) ProtoMessage 

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) Reset 

func (m *SpansResponseChunk) Reset()

func (*SpansResponseChunk) Size 

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

func (*SpansResponseChunk) String 

func (m *SpansResponseChunk) String() string

func (*SpansResponseChunk) Unmarshal 

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

func (*SpansResponseChunk) XXX_DiscardUnknown 

func (m *SpansResponseChunk) XXX_DiscardUnknown()

func (*SpansResponseChunk) XXX_Marshal 

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

func (*SpansResponseChunk) XXX_Merge 

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

func (*SpansResponseChunk) XXX_Size 

func (m *SpansResponseChunk) XXX_Size() int

func (*SpansResponseChunk) XXX_Unmarshal 

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

type TraceQueryParameters 

type TraceQueryParameters struct {
	ServiceName          string            `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	OperationName        string            `protobuf:"bytes,2,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	StartTimeMin         time.Time         `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3,stdtime" json:"start_time_min"`
	StartTimeMax         time.Time         `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3,stdtime" json:"start_time_max"`
	DurationMin          time.Duration     `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3,stdduration" json:"duration_min"`
	DurationMax          time.Duration     `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3,stdduration" json:"duration_max"`
	SearchDepth          int32             `protobuf:"varint,8,opt,name=search_depth,json=searchDepth,proto3" json:"search_depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TraceQueryParameters) Descriptor 

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

func (*TraceQueryParameters) GetDurationMax 

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

func (*TraceQueryParameters) GetDurationMin 

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

func (*TraceQueryParameters) GetOperationName 

func (m *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetSearchDepth 

func (m *TraceQueryParameters) GetSearchDepth() int32

func (*TraceQueryParameters) GetServiceName 

func (m *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax 

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

func (*TraceQueryParameters) GetStartTimeMin 

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

func (*TraceQueryParameters) GetTags 

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

func (*TraceQueryParameters) Marshal 

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

func (*TraceQueryParameters) MarshalTo 

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

func (*TraceQueryParameters) MarshalToSizedBuffer 

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

func (*TraceQueryParameters) ProtoMessage 

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) Reset 

func (m *TraceQueryParameters) Reset()

func (*TraceQueryParameters) Size 

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

func (*TraceQueryParameters) String 

func (m *TraceQueryParameters) String() string

func (*TraceQueryParameters) Unmarshal 

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

func (*TraceQueryParameters) XXX_DiscardUnknown 

func (m *TraceQueryParameters) XXX_DiscardUnknown()

func (*TraceQueryParameters) XXX_Marshal 

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

func (*TraceQueryParameters) XXX_Merge 

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

func (*TraceQueryParameters) XXX_Size 

func (m *TraceQueryParameters) XXX_Size() int

func (*TraceQueryParameters) XXX_Unmarshal 

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

type UnimplementedCollectorServiceServer 

type UnimplementedCollectorServiceServer struct {
}

UnimplementedCollectorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCollectorServiceServer) PostSpans 

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

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) ArchiveTrace 

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

func (*UnimplementedQueryServiceServer) FindTraces 

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

func (*UnimplementedQueryServiceServer) GetDependencies 

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

func (*UnimplementedQueryServiceServer) GetOperations 

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

func (*UnimplementedQueryServiceServer) GetServices 

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

func (*UnimplementedQueryServiceServer) GetTrace 

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

type UnimplementedSamplingManagerServer 

type UnimplementedSamplingManagerServer struct {
}

UnimplementedSamplingManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSamplingManagerServer) GetSamplingStrategy 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.