api_v2

package
v1.55.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2024 License: Apache-2.0 Imports: 15 Imported by: 102

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 added in v1.12.0 

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

func RegisterSamplingManagerServer 

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

Types

type ArchiveTraceRequest added in v1.12.0 

type ArchiveTraceRequest struct {
	TraceID github_com_jaegertracing_jaeger_model.TraceID `` /* 129-byte string literal not displayed */
	// Optional. The start time to search trace ID.
	StartTime *time.Time `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	// Optional. The end time to search trace ID.
	EndTime              *time.Time `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ArchiveTraceRequest) Descriptor added in v1.12.0 

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

func (*ArchiveTraceRequest) GetEndTime added in v1.50.0 

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

func (*ArchiveTraceRequest) GetStartTime added in v1.50.0 

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

func (*ArchiveTraceRequest) Marshal added in v1.12.0 

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

func (*ArchiveTraceRequest) MarshalTo added in v1.12.0 

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

func (*ArchiveTraceRequest) MarshalToSizedBuffer added in v1.24.0 

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

func (*ArchiveTraceRequest) ProtoMessage added in v1.12.0 

func (*ArchiveTraceRequest) ProtoMessage()

func (*ArchiveTraceRequest) Reset added in v1.12.0 

func (m *ArchiveTraceRequest) Reset()

func (*ArchiveTraceRequest) Size added in v1.12.0 

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

func (*ArchiveTraceRequest) String added in v1.12.0 

func (m *ArchiveTraceRequest) String() string

func (*ArchiveTraceRequest) Unmarshal added in v1.12.0 

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

func (*ArchiveTraceRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *ArchiveTraceRequest) XXX_DiscardUnknown()

func (*ArchiveTraceRequest) XXX_Marshal added in v1.12.0 

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

func (*ArchiveTraceRequest) XXX_Merge added in v1.12.0 

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

func (*ArchiveTraceRequest) XXX_Size added in v1.12.0 

func (m *ArchiveTraceRequest) XXX_Size() int

func (*ArchiveTraceRequest) XXX_Unmarshal added in v1.12.0 

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

type ArchiveTraceResponse added in v1.12.0 

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

func (*ArchiveTraceResponse) Descriptor added in v1.12.0 

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

func (*ArchiveTraceResponse) Marshal added in v1.12.0 

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

func (*ArchiveTraceResponse) MarshalTo added in v1.12.0 

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

func (*ArchiveTraceResponse) MarshalToSizedBuffer added in v1.24.0 

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

func (*ArchiveTraceResponse) ProtoMessage added in v1.12.0 

func (*ArchiveTraceResponse) ProtoMessage()

func (*ArchiveTraceResponse) Reset added in v1.12.0 

func (m *ArchiveTraceResponse) Reset()

func (*ArchiveTraceResponse) Size added in v1.12.0 

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

func (*ArchiveTraceResponse) String added in v1.12.0 

func (m *ArchiveTraceResponse) String() string

func (*ArchiveTraceResponse) Unmarshal added in v1.12.0 

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

func (*ArchiveTraceResponse) XXX_DiscardUnknown added in v1.12.0 

func (m *ArchiveTraceResponse) XXX_DiscardUnknown()

func (*ArchiveTraceResponse) XXX_Marshal added in v1.12.0 

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

func (*ArchiveTraceResponse) XXX_Merge added in v1.12.0 

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

func (*ArchiveTraceResponse) XXX_Size added in v1.12.0 

func (m *ArchiveTraceResponse) XXX_Size() int

func (*ArchiveTraceResponse) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

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 added in v1.12.0 

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

func (*FindTracesRequest) GetQuery added in v1.12.0 

func (m *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) Marshal added in v1.12.0 

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

func (*FindTracesRequest) MarshalTo added in v1.12.0 

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

func (*FindTracesRequest) MarshalToSizedBuffer added in v1.24.0 

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

func (*FindTracesRequest) ProtoMessage added in v1.12.0 

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) Reset added in v1.12.0 

func (m *FindTracesRequest) Reset()

func (*FindTracesRequest) Size added in v1.12.0 

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

func (*FindTracesRequest) String added in v1.12.0 

func (m *FindTracesRequest) String() string

func (*FindTracesRequest) Unmarshal added in v1.12.0 

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

func (*FindTracesRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *FindTracesRequest) XXX_DiscardUnknown()

func (*FindTracesRequest) XXX_Marshal added in v1.12.0 

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

func (*FindTracesRequest) XXX_Merge added in v1.12.0 

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

func (*FindTracesRequest) XXX_Size added in v1.12.0 

func (m *FindTracesRequest) XXX_Size() int

func (*FindTracesRequest) XXX_Unmarshal added in v1.12.0 

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

type GetDependenciesRequest added in v1.12.0 

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 added in v1.12.0 

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

func (*GetDependenciesRequest) GetEndTime added in v1.12.0 

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

func (*GetDependenciesRequest) GetStartTime added in v1.12.0 

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

func (*GetDependenciesRequest) Marshal added in v1.12.0 

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

func (*GetDependenciesRequest) MarshalTo added in v1.12.0 

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

func (*GetDependenciesRequest) MarshalToSizedBuffer added in v1.24.0 

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

func (*GetDependenciesRequest) ProtoMessage added in v1.12.0 

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) Reset added in v1.12.0 

func (m *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) Size added in v1.12.0 

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

func (*GetDependenciesRequest) String added in v1.12.0 

func (m *GetDependenciesRequest) String() string

func (*GetDependenciesRequest) Unmarshal added in v1.12.0 

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

func (*GetDependenciesRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *GetDependenciesRequest) XXX_DiscardUnknown()

func (*GetDependenciesRequest) XXX_Marshal added in v1.12.0 

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

func (*GetDependenciesRequest) XXX_Merge added in v1.12.0 

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

func (*GetDependenciesRequest) XXX_Size added in v1.12.0 

func (m *GetDependenciesRequest) XXX_Size() int

func (*GetDependenciesRequest) XXX_Unmarshal added in v1.12.0 

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

type GetDependenciesResponse added in v1.12.0 

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 added in v1.12.0 

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

func (*GetDependenciesResponse) GetDependencies added in v1.12.0 

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

func (*GetDependenciesResponse) Marshal added in v1.12.0 

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

func (*GetDependenciesResponse) MarshalTo added in v1.12.0 

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

func (*GetDependenciesResponse) MarshalToSizedBuffer added in v1.24.0 

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

func (*GetDependenciesResponse) ProtoMessage added in v1.12.0 

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) Reset added in v1.12.0 

func (m *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) Size added in v1.12.0 

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

func (*GetDependenciesResponse) String added in v1.12.0 

func (m *GetDependenciesResponse) String() string

func (*GetDependenciesResponse) Unmarshal added in v1.12.0 

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

func (*GetDependenciesResponse) XXX_DiscardUnknown added in v1.12.0 

func (m *GetDependenciesResponse) XXX_DiscardUnknown()

func (*GetDependenciesResponse) XXX_Marshal added in v1.12.0 

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

func (*GetDependenciesResponse) XXX_Merge added in v1.12.0 

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

func (*GetDependenciesResponse) XXX_Size added in v1.12.0 

func (m *GetDependenciesResponse) XXX_Size() int

func (*GetDependenciesResponse) XXX_Unmarshal added in v1.12.0 

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

type GetOperationsRequest added in v1.12.0 

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 added in v1.12.0 

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

func (*GetOperationsRequest) GetService added in v1.12.0 

func (m *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind added in v1.16.0 

func (m *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) Marshal added in v1.12.0 

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

func (*GetOperationsRequest) MarshalTo added in v1.12.0 

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

func (*GetOperationsRequest) MarshalToSizedBuffer added in v1.24.0 

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

func (*GetOperationsRequest) ProtoMessage added in v1.12.0 

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) Reset added in v1.12.0 

func (m *GetOperationsRequest) Reset()

func (*GetOperationsRequest) Size added in v1.12.0 

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

func (*GetOperationsRequest) String added in v1.12.0 

func (m *GetOperationsRequest) String() string

func (*GetOperationsRequest) Unmarshal added in v1.12.0 

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

func (*GetOperationsRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *GetOperationsRequest) XXX_DiscardUnknown()

func (*GetOperationsRequest) XXX_Marshal added in v1.12.0 

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

func (*GetOperationsRequest) XXX_Merge added in v1.12.0 

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

func (*GetOperationsRequest) XXX_Size added in v1.12.0 

func (m *GetOperationsRequest) XXX_Size() int

func (*GetOperationsRequest) XXX_Unmarshal added in v1.12.0 

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

type GetOperationsResponse added in v1.12.0 

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 added in v1.12.0 

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

func (*GetOperationsResponse) GetOperationNames added in v1.16.0 

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

func (*GetOperationsResponse) GetOperations added in v1.12.0 

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

func (*GetOperationsResponse) Marshal added in v1.12.0 

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

func (*GetOperationsResponse) MarshalTo added in v1.12.0 

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

func (*GetOperationsResponse) MarshalToSizedBuffer added in v1.24.0 

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

func (*GetOperationsResponse) ProtoMessage added in v1.12.0 

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) Reset added in v1.12.0 

func (m *GetOperationsResponse) Reset()

func (*GetOperationsResponse) Size added in v1.12.0 

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

func (*GetOperationsResponse) String added in v1.12.0 

func (m *GetOperationsResponse) String() string

func (*GetOperationsResponse) Unmarshal added in v1.12.0 

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

func (*GetOperationsResponse) XXX_DiscardUnknown added in v1.12.0 

func (m *GetOperationsResponse) XXX_DiscardUnknown()

func (*GetOperationsResponse) XXX_Marshal added in v1.12.0 

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

func (*GetOperationsResponse) XXX_Merge added in v1.12.0 

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

func (*GetOperationsResponse) XXX_Size added in v1.12.0 

func (m *GetOperationsResponse) XXX_Size() int

func (*GetOperationsResponse) XXX_Unmarshal added in v1.12.0 

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

type GetServicesRequest added in v1.12.0 

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

func (*GetServicesRequest) Descriptor added in v1.12.0 

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

func (*GetServicesRequest) Marshal added in v1.12.0 

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

func (*GetServicesRequest) MarshalTo added in v1.12.0 

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

func (*GetServicesRequest) MarshalToSizedBuffer added in v1.24.0 

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

func (*GetServicesRequest) ProtoMessage added in v1.12.0 

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) Reset added in v1.12.0 

func (m *GetServicesRequest) Reset()

func (*GetServicesRequest) Size added in v1.12.0 

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

func (*GetServicesRequest) String added in v1.12.0 

func (m *GetServicesRequest) String() string

func (*GetServicesRequest) Unmarshal added in v1.12.0 

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

func (*GetServicesRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *GetServicesRequest) XXX_DiscardUnknown()

func (*GetServicesRequest) XXX_Marshal added in v1.12.0 

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

func (*GetServicesRequest) XXX_Merge added in v1.12.0 

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

func (*GetServicesRequest) XXX_Size added in v1.12.0 

func (m *GetServicesRequest) XXX_Size() int

func (*GetServicesRequest) XXX_Unmarshal added in v1.12.0 

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

type GetServicesResponse added in v1.12.0 

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 added in v1.12.0 

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

func (*GetServicesResponse) GetServices added in v1.12.0 

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

func (*GetServicesResponse) Marshal added in v1.12.0 

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

func (*GetServicesResponse) MarshalTo added in v1.12.0 

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

func (*GetServicesResponse) MarshalToSizedBuffer added in v1.24.0 

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

func (*GetServicesResponse) ProtoMessage added in v1.12.0 

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) Reset added in v1.12.0 

func (m *GetServicesResponse) Reset()

func (*GetServicesResponse) Size added in v1.12.0 

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

func (*GetServicesResponse) String added in v1.12.0 

func (m *GetServicesResponse) String() string

func (*GetServicesResponse) Unmarshal added in v1.12.0 

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

func (*GetServicesResponse) XXX_DiscardUnknown added in v1.12.0 

func (m *GetServicesResponse) XXX_DiscardUnknown()

func (*GetServicesResponse) XXX_Marshal added in v1.12.0 

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

func (*GetServicesResponse) XXX_Merge added in v1.12.0 

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

func (*GetServicesResponse) XXX_Size added in v1.12.0 

func (m *GetServicesResponse) XXX_Size() int

func (*GetServicesResponse) XXX_Unmarshal added in v1.12.0 

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

type GetTraceRequest added in v1.12.0 

type GetTraceRequest struct {
	TraceID github_com_jaegertracing_jaeger_model.TraceID `` /* 129-byte string literal not displayed */
	// Optional. The start time to search trace ID.
	StartTime *time.Time `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	// Optional. The end time to search trace ID.
	EndTime              *time.Time `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetTraceRequest) Descriptor added in v1.12.0 

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

func (*GetTraceRequest) GetEndTime added in v1.50.0 

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

func (*GetTraceRequest) GetStartTime added in v1.50.0 

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

func (*GetTraceRequest) Marshal added in v1.12.0 

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

func (*GetTraceRequest) MarshalTo added in v1.12.0 

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

func (*GetTraceRequest) MarshalToSizedBuffer added in v1.24.0 

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

func (*GetTraceRequest) ProtoMessage added in v1.12.0 

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) Reset added in v1.12.0 

func (m *GetTraceRequest) Reset()

func (*GetTraceRequest) Size added in v1.12.0 

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

func (*GetTraceRequest) String added in v1.12.0 

func (m *GetTraceRequest) String() string

func (*GetTraceRequest) Unmarshal added in v1.12.0 

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

func (*GetTraceRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *GetTraceRequest) XXX_DiscardUnknown()

func (*GetTraceRequest) XXX_Marshal added in v1.12.0 

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

func (*GetTraceRequest) XXX_Merge added in v1.12.0 

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

func (*GetTraceRequest) XXX_Size added in v1.12.0 

func (m *GetTraceRequest) XXX_Size() int

func (*GetTraceRequest) XXX_Unmarshal added in v1.12.0 

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

type Operation added in v1.16.0 

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 added in v1.16.0 

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

func (*Operation) GetName added in v1.16.0 

func (m *Operation) GetName() string

func (*Operation) GetSpanKind added in v1.16.0 

func (m *Operation) GetSpanKind() string

func (*Operation) Marshal added in v1.16.0 

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

func (*Operation) MarshalTo added in v1.16.0 

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

func (*Operation) MarshalToSizedBuffer added in v1.24.0 

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

func (*Operation) ProtoMessage added in v1.16.0 

func (*Operation) ProtoMessage()

func (*Operation) Reset added in v1.16.0 

func (m *Operation) Reset()

func (*Operation) Size added in v1.16.0 

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

func (*Operation) String added in v1.16.0 

func (m *Operation) String() string

func (*Operation) Unmarshal added in v1.16.0 

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

func (*Operation) XXX_DiscardUnknown added in v1.16.0 

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal added in v1.16.0 

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

func (*Operation) XXX_Merge added in v1.16.0 

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

func (*Operation) XXX_Size added in v1.16.0 

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal added in v1.16.0 

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 added in v1.24.0 

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 added in v1.12.0 

func (m *OperationSamplingStrategy) XXX_DiscardUnknown()

func (*OperationSamplingStrategy) XXX_Marshal added in v1.12.0 

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

func (*OperationSamplingStrategy) XXX_Merge added in v1.12.0 

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

func (*OperationSamplingStrategy) XXX_Size added in v1.12.0 

func (m *OperationSamplingStrategy) XXX_Size() int

func (*OperationSamplingStrategy) XXX_Unmarshal added in v1.12.0 

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 added in v1.24.0 

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 added in v1.12.0 

func (m *PerOperationSamplingStrategies) XXX_DiscardUnknown()

func (*PerOperationSamplingStrategies) XXX_Marshal added in v1.12.0 

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

func (*PerOperationSamplingStrategies) XXX_Merge added in v1.12.0 

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

func (*PerOperationSamplingStrategies) XXX_Size added in v1.12.0 

func (m *PerOperationSamplingStrategies) XXX_Size() int

func (*PerOperationSamplingStrategies) XXX_Unmarshal added in v1.12.0 

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) 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 added in v1.24.0 

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 added in v1.12.0 

func (m *PostSpansRequest) XXX_DiscardUnknown()

func (*PostSpansRequest) XXX_Marshal added in v1.12.0 

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

func (*PostSpansRequest) XXX_Merge added in v1.12.0 

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

func (*PostSpansRequest) XXX_Size added in v1.12.0 

func (m *PostSpansRequest) XXX_Size() int

func (*PostSpansRequest) XXX_Unmarshal added in v1.12.0 

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 added in v1.24.0 

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 added in v1.12.0 

func (m *PostSpansResponse) XXX_DiscardUnknown()

func (*PostSpansResponse) XXX_Marshal added in v1.12.0 

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

func (*PostSpansResponse) XXX_Merge added in v1.12.0 

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

func (*PostSpansResponse) XXX_Size added in v1.12.0 

func (m *PostSpansResponse) XXX_Size() int

func (*PostSpansResponse) XXX_Unmarshal added in v1.12.0 

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 added in v1.24.0 

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 added in v1.12.0 

func (m *ProbabilisticSamplingStrategy) XXX_DiscardUnknown()

func (*ProbabilisticSamplingStrategy) XXX_Marshal added in v1.12.0 

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

func (*ProbabilisticSamplingStrategy) XXX_Merge added in v1.12.0 

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

func (*ProbabilisticSamplingStrategy) XXX_Size added in v1.12.0 

func (m *ProbabilisticSamplingStrategy) XXX_Size() int

func (*ProbabilisticSamplingStrategy) XXX_Unmarshal added in v1.12.0 

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

type QueryServiceClient added in v1.12.0 

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 added in v1.12.0 

func NewQueryServiceClient(cc *grpc.ClientConn) QueryServiceClient

type QueryServiceServer added in v1.12.0 

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 added in v1.12.0 

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

type QueryService_FindTracesServer added in v1.12.0 

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

type QueryService_GetTraceClient added in v1.12.0 

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

type QueryService_GetTraceServer added in v1.12.0 

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 added in v1.24.0 

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 added in v1.12.0 

func (m *RateLimitingSamplingStrategy) XXX_DiscardUnknown()

func (*RateLimitingSamplingStrategy) XXX_Marshal added in v1.12.0 

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

func (*RateLimitingSamplingStrategy) XXX_Merge added in v1.12.0 

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

func (*RateLimitingSamplingStrategy) XXX_Size added in v1.12.0 

func (m *RateLimitingSamplingStrategy) XXX_Size() int

func (*RateLimitingSamplingStrategy) XXX_Unmarshal added in v1.12.0 

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 added in v1.24.0 

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 added in v1.12.0 

func (m *SamplingStrategyParameters) XXX_DiscardUnknown()

func (*SamplingStrategyParameters) XXX_Marshal added in v1.12.0 

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

func (*SamplingStrategyParameters) XXX_Merge added in v1.12.0 

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

func (*SamplingStrategyParameters) XXX_Size added in v1.12.0 

func (m *SamplingStrategyParameters) XXX_Size() int

func (*SamplingStrategyParameters) XXX_Unmarshal added in v1.12.0 

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 added in v1.24.0 

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 added in v1.12.0 

func (m *SamplingStrategyResponse) XXX_DiscardUnknown()

func (*SamplingStrategyResponse) XXX_Marshal added in v1.12.0 

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

func (*SamplingStrategyResponse) XXX_Merge added in v1.12.0 

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

func (*SamplingStrategyResponse) XXX_Size added in v1.12.0 

func (m *SamplingStrategyResponse) XXX_Size() int

func (*SamplingStrategyResponse) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

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 added in v1.12.0 

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

func (*SpansResponseChunk) GetSpans added in v1.12.0 

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

func (*SpansResponseChunk) Marshal added in v1.12.0 

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

func (*SpansResponseChunk) MarshalTo added in v1.12.0 

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

func (*SpansResponseChunk) MarshalToSizedBuffer added in v1.24.0 

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

func (*SpansResponseChunk) ProtoMessage added in v1.12.0 

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) Reset added in v1.12.0 

func (m *SpansResponseChunk) Reset()

func (*SpansResponseChunk) Size added in v1.12.0 

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

func (*SpansResponseChunk) String added in v1.12.0 

func (m *SpansResponseChunk) String() string

func (*SpansResponseChunk) Unmarshal added in v1.12.0 

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

func (*SpansResponseChunk) XXX_DiscardUnknown added in v1.12.0 

func (m *SpansResponseChunk) XXX_DiscardUnknown()

func (*SpansResponseChunk) XXX_Marshal added in v1.12.0 

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

func (*SpansResponseChunk) XXX_Merge added in v1.12.0 

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

func (*SpansResponseChunk) XXX_Size added in v1.12.0 

func (m *SpansResponseChunk) XXX_Size() int

func (*SpansResponseChunk) XXX_Unmarshal added in v1.12.0 

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

type TraceQueryParameters added in v1.12.0 

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:"-"`
}

Query parameters to find traces. Except for num_traces, all fields should be treated as forming a conjunction, e.g., "service_name='X' AND operation_name='Y' AND ...". All fields are matched against individual spans, not at the trace level. The returned results contain traces where at least one span matches the conditions. When num_traces results in fewer traces returned, there is no required ordering.

Note: num_traces should restrict the number of traces returned, but not all backends interpret it this way. For instance, in Cassandra this limits the number of _spans_ that match the conditions, and the resulting number of traces can be less.

Note: some storage implementations do not guarantee the correct implementation of all parameters.

func (*TraceQueryParameters) Descriptor added in v1.12.0 

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

func (*TraceQueryParameters) GetDurationMax added in v1.12.0 

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

func (*TraceQueryParameters) GetDurationMin added in v1.12.0 

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

func (*TraceQueryParameters) GetOperationName added in v1.12.0 

func (m *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetSearchDepth added in v1.12.0 

func (m *TraceQueryParameters) GetSearchDepth() int32

func (*TraceQueryParameters) GetServiceName added in v1.12.0 

func (m *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax added in v1.12.0 

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

func (*TraceQueryParameters) GetStartTimeMin added in v1.12.0 

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

func (*TraceQueryParameters) GetTags added in v1.12.0 

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

func (*TraceQueryParameters) Marshal added in v1.12.0 

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

func (*TraceQueryParameters) MarshalTo added in v1.12.0 

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

func (*TraceQueryParameters) MarshalToSizedBuffer added in v1.24.0 

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

func (*TraceQueryParameters) ProtoMessage added in v1.12.0 

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) Reset added in v1.12.0 

func (m *TraceQueryParameters) Reset()

func (*TraceQueryParameters) Size added in v1.12.0 

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

func (*TraceQueryParameters) String added in v1.12.0 

func (m *TraceQueryParameters) String() string

func (*TraceQueryParameters) Unmarshal added in v1.12.0 

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

func (*TraceQueryParameters) XXX_DiscardUnknown added in v1.12.0 

func (m *TraceQueryParameters) XXX_DiscardUnknown()

func (*TraceQueryParameters) XXX_Marshal added in v1.12.0 

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

func (*TraceQueryParameters) XXX_Merge added in v1.12.0 

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

func (*TraceQueryParameters) XXX_Size added in v1.12.0 

func (m *TraceQueryParameters) XXX_Size() int

func (*TraceQueryParameters) XXX_Unmarshal added in v1.12.0 

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

type UnimplementedCollectorServiceServer added in v1.24.0 

type UnimplementedCollectorServiceServer struct {
}

UnimplementedCollectorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCollectorServiceServer) PostSpans added in v1.24.0 

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

type UnimplementedQueryServiceServer added in v1.24.0 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) ArchiveTrace added in v1.24.0 

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

func (*UnimplementedQueryServiceServer) FindTraces added in v1.24.0 

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

func (*UnimplementedQueryServiceServer) GetDependencies added in v1.24.0 

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

func (*UnimplementedQueryServiceServer) GetOperations added in v1.24.0 

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

func (*UnimplementedQueryServiceServer) GetServices added in v1.24.0 

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

func (*UnimplementedQueryServiceServer) GetTrace added in v1.24.0 

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

type UnimplementedSamplingManagerServer added in v1.24.0 

type UnimplementedSamplingManagerServer struct {
}

UnimplementedSamplingManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSamplingManagerServer) GetSamplingStrategy added in v1.24.0 

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.