api_v2

package
v1.63.0 Latest Latest
Warning

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

Go to latest
Published: Nov 10, 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 (*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 (*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

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

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 (*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

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

func (*UnimplementedQueryServiceServer) GetDependencies added in v1.24.0

func (*UnimplementedQueryServiceServer) GetOperations added in v1.24.0

func (*UnimplementedQueryServiceServer) GetServices added in v1.24.0

func (*UnimplementedQueryServiceServer) GetTrace added in v1.24.0

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL