jaeger

package
v0.0.0-...-3736fb9 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SamplingStrategyType_name = map[int32]string{
		0: "PROBABILISTIC",
		1: "RATE_LIMITING",
	}
	SamplingStrategyType_value = map[string]int32{
		"PROBABILISTIC": 0,
		"RATE_LIMITING": 1,
	}
)

Enum value maps for SamplingStrategyType.

View Source 
var CollectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.api_v2.CollectorService",
	HandlerType: (*CollectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PostSpans",
			Handler:    _CollectorService_PostSpans_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jaeger/collector.proto",
}

CollectorService_ServiceDesc is the grpc.ServiceDesc for CollectorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_jaeger_collector_proto protoreflect.FileDescriptor
View Source 
var File_jaeger_query_proto protoreflect.FileDescriptor
View Source 
var File_jaeger_sampling_proto protoreflect.FileDescriptor
View Source 
var QueryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.api_v2.QueryService",
	HandlerType: (*QueryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ArchiveTrace",
			Handler:    _QueryService_ArchiveTrace_Handler,
		},
		{
			MethodName: "GetServices",
			Handler:    _QueryService_GetServices_Handler,
		},
		{
			MethodName: "GetOperations",
			Handler:    _QueryService_GetOperations_Handler,
		},
		{
			MethodName: "GetDependencies",
			Handler:    _QueryService_GetDependencies_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetTrace",
			Handler:       _QueryService_GetTrace_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "FindTraces",
			Handler:       _QueryService_FindTraces_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "jaeger/query.proto",
}

QueryService_ServiceDesc is the grpc.ServiceDesc for QueryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var SamplingManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.api_v2.SamplingManager",
	HandlerType: (*SamplingManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSamplingStrategy",
			Handler:    _SamplingManager_GetSamplingStrategy_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jaeger/sampling.proto",
}

SamplingManager_ServiceDesc is the grpc.ServiceDesc for SamplingManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCollectorServiceServer 

func RegisterCollectorServiceServer(s grpc.ServiceRegistrar, srv CollectorServiceServer)

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s grpc.ServiceRegistrar, srv QueryServiceServer)

func RegisterSamplingManagerServer 

func RegisterSamplingManagerServer(s grpc.ServiceRegistrar, srv SamplingManagerServer)

Types

type ArchiveTraceRequest 

type ArchiveTraceRequest struct {
	TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveTraceRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveTraceRequest.ProtoReflect.Descriptor instead.

func (*ArchiveTraceRequest) GetTraceId 

func (x *ArchiveTraceRequest) GetTraceId() []byte

func (*ArchiveTraceRequest) ProtoMessage 

func (*ArchiveTraceRequest) ProtoMessage()

func (*ArchiveTraceRequest) ProtoReflect 

func (x *ArchiveTraceRequest) ProtoReflect() protoreflect.Message

func (*ArchiveTraceRequest) Reset 

func (x *ArchiveTraceRequest) Reset()

func (*ArchiveTraceRequest) String 

func (x *ArchiveTraceRequest) String() string

type ArchiveTraceResponse 

type ArchiveTraceResponse struct {
	// contains filtered or unexported fields
}

func (*ArchiveTraceResponse) Descriptor deprecated 

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

Deprecated: Use ArchiveTraceResponse.ProtoReflect.Descriptor instead.

func (*ArchiveTraceResponse) ProtoMessage 

func (*ArchiveTraceResponse) ProtoMessage()

func (*ArchiveTraceResponse) ProtoReflect 

func (x *ArchiveTraceResponse) ProtoReflect() protoreflect.Message

func (*ArchiveTraceResponse) Reset 

func (x *ArchiveTraceResponse) Reset()

func (*ArchiveTraceResponse) String 

func (x *ArchiveTraceResponse) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCollectorServiceClient 

func NewCollectorServiceClient(cc grpc.ClientConnInterface) CollectorServiceClient

type CollectorServiceServer 

type CollectorServiceServer interface {
	PostSpans(context.Context, *PostSpansRequest) (*PostSpansResponse, error)
	// contains filtered or unexported methods
}

CollectorServiceServer is the server API for CollectorService service. All implementations must embed UnimplementedCollectorServiceServer for forward compatibility

type FindTracesRequest 

type FindTracesRequest struct {
	Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*FindTracesRequest) Descriptor deprecated 

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

Deprecated: Use FindTracesRequest.ProtoReflect.Descriptor instead.

func (*FindTracesRequest) GetQuery 

func (x *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) ProtoMessage 

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) ProtoReflect 

func (x *FindTracesRequest) ProtoReflect() protoreflect.Message

func (*FindTracesRequest) Reset 

func (x *FindTracesRequest) Reset()

func (*FindTracesRequest) String 

func (x *FindTracesRequest) String() string

type GetDependenciesRequest 

type GetDependenciesRequest struct {
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDependenciesRequest) Descriptor deprecated 

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

Deprecated: Use GetDependenciesRequest.ProtoReflect.Descriptor instead.

func (*GetDependenciesRequest) GetEndTime 

func (x *GetDependenciesRequest) GetEndTime() *timestamppb.Timestamp

func (*GetDependenciesRequest) GetStartTime 

func (x *GetDependenciesRequest) GetStartTime() *timestamppb.Timestamp

func (*GetDependenciesRequest) ProtoMessage 

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) ProtoReflect 

func (x *GetDependenciesRequest) ProtoReflect() protoreflect.Message

func (*GetDependenciesRequest) Reset 

func (x *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) String 

func (x *GetDependenciesRequest) String() string

type GetDependenciesResponse 

type GetDependenciesResponse struct {
	Dependencies []*model.DependencyLink `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDependenciesResponse) Descriptor deprecated 

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

Deprecated: Use GetDependenciesResponse.ProtoReflect.Descriptor instead.

func (*GetDependenciesResponse) GetDependencies 

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

func (*GetDependenciesResponse) ProtoMessage 

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) ProtoReflect 

func (x *GetDependenciesResponse) ProtoReflect() protoreflect.Message

func (*GetDependenciesResponse) Reset 

func (x *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) String 

func (x *GetDependenciesResponse) String() string

type GetOperationsRequest 

type GetOperationsRequest struct {
	Service  string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	SpanKind string `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationsRequest) Descriptor deprecated 

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

Deprecated: Use GetOperationsRequest.ProtoReflect.Descriptor instead.

func (*GetOperationsRequest) GetService 

func (x *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind 

func (x *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) ProtoMessage 

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) ProtoReflect 

func (x *GetOperationsRequest) ProtoReflect() protoreflect.Message

func (*GetOperationsRequest) Reset 

func (x *GetOperationsRequest) Reset()

func (*GetOperationsRequest) String 

func (x *GetOperationsRequest) String() string

type GetOperationsResponse 

type GetOperationsResponse struct {
	OperationNames []string     `protobuf:"bytes,1,rep,name=operationNames,proto3" json:"operationNames,omitempty"` //deprecated
	Operations     []*Operation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationsResponse) Descriptor deprecated 

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

Deprecated: Use GetOperationsResponse.ProtoReflect.Descriptor instead.

func (*GetOperationsResponse) GetOperationNames 

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

func (*GetOperationsResponse) GetOperations 

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

func (*GetOperationsResponse) ProtoMessage 

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) ProtoReflect 

func (x *GetOperationsResponse) ProtoReflect() protoreflect.Message

func (*GetOperationsResponse) Reset 

func (x *GetOperationsResponse) Reset()

func (*GetOperationsResponse) String 

func (x *GetOperationsResponse) String() string

type GetServicesRequest 

type GetServicesRequest struct {
	// contains filtered or unexported fields
}

func (*GetServicesRequest) Descriptor deprecated 

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

Deprecated: Use GetServicesRequest.ProtoReflect.Descriptor instead.

func (*GetServicesRequest) ProtoMessage 

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) ProtoReflect 

func (x *GetServicesRequest) ProtoReflect() protoreflect.Message

func (*GetServicesRequest) Reset 

func (x *GetServicesRequest) Reset()

func (*GetServicesRequest) String 

func (x *GetServicesRequest) String() string

type GetServicesResponse 

type GetServicesResponse struct {
	Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServicesResponse) Descriptor deprecated 

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

Deprecated: Use GetServicesResponse.ProtoReflect.Descriptor instead.

func (*GetServicesResponse) GetServices 

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

func (*GetServicesResponse) ProtoMessage 

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) ProtoReflect 

func (x *GetServicesResponse) ProtoReflect() protoreflect.Message

func (*GetServicesResponse) Reset 

func (x *GetServicesResponse) Reset()

func (*GetServicesResponse) String 

func (x *GetServicesResponse) String() string

type GetTraceRequest 

type GetTraceRequest struct {
	TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTraceRequest) Descriptor deprecated 

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

Deprecated: Use GetTraceRequest.ProtoReflect.Descriptor instead.

func (*GetTraceRequest) GetTraceId 

func (x *GetTraceRequest) GetTraceId() []byte

func (*GetTraceRequest) ProtoMessage 

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) ProtoReflect 

func (x *GetTraceRequest) ProtoReflect() protoreflect.Message

func (*GetTraceRequest) Reset 

func (x *GetTraceRequest) Reset()

func (*GetTraceRequest) String 

func (x *GetTraceRequest) String() string

type Operation 

type Operation struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SpanKind string `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	// contains filtered or unexported fields
}

func (*Operation) Descriptor deprecated 

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

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetName 

func (x *Operation) GetName() string

func (*Operation) GetSpanKind 

func (x *Operation) GetSpanKind() string

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect 

func (x *Operation) ProtoReflect() protoreflect.Message

func (*Operation) Reset 

func (x *Operation) Reset()

func (*Operation) String 

func (x *Operation) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*OperationSamplingStrategy) Descriptor deprecated 

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

Deprecated: Use OperationSamplingStrategy.ProtoReflect.Descriptor instead.

func (*OperationSamplingStrategy) GetOperation 

func (x *OperationSamplingStrategy) GetOperation() string

func (*OperationSamplingStrategy) GetProbabilisticSampling 

func (x *OperationSamplingStrategy) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*OperationSamplingStrategy) ProtoMessage 

func (*OperationSamplingStrategy) ProtoMessage()

func (*OperationSamplingStrategy) ProtoReflect 

func (x *OperationSamplingStrategy) ProtoReflect() protoreflect.Message

func (*OperationSamplingStrategy) Reset 

func (x *OperationSamplingStrategy) Reset()

func (*OperationSamplingStrategy) String 

func (x *OperationSamplingStrategy) String() string

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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use PerOperationSamplingStrategies.ProtoReflect.Descriptor instead.

func (*PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond 

func (x *PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetDefaultSamplingProbability 

func (x *PerOperationSamplingStrategies) GetDefaultSamplingProbability() float64

func (*PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond 

func (x *PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetPerOperationStrategies 

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

func (*PerOperationSamplingStrategies) ProtoMessage 

func (*PerOperationSamplingStrategies) ProtoMessage()

func (*PerOperationSamplingStrategies) ProtoReflect 

func (x *PerOperationSamplingStrategies) ProtoReflect() protoreflect.Message

func (*PerOperationSamplingStrategies) Reset 

func (x *PerOperationSamplingStrategies) Reset()

func (*PerOperationSamplingStrategies) String 

func (x *PerOperationSamplingStrategies) String() string

type PostSpansRequest 

type PostSpansRequest struct {
	Batch *model.Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*PostSpansRequest) Descriptor deprecated 

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

Deprecated: Use PostSpansRequest.ProtoReflect.Descriptor instead.

func (*PostSpansRequest) GetBatch 

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

func (*PostSpansRequest) ProtoMessage 

func (*PostSpansRequest) ProtoMessage()

func (*PostSpansRequest) ProtoReflect 

func (x *PostSpansRequest) ProtoReflect() protoreflect.Message

func (*PostSpansRequest) Reset 

func (x *PostSpansRequest) Reset()

func (*PostSpansRequest) String 

func (x *PostSpansRequest) String() string

type PostSpansResponse 

type PostSpansResponse struct {
	// contains filtered or unexported fields
}

func (*PostSpansResponse) Descriptor deprecated 

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

Deprecated: Use PostSpansResponse.ProtoReflect.Descriptor instead.

func (*PostSpansResponse) ProtoMessage 

func (*PostSpansResponse) ProtoMessage()

func (*PostSpansResponse) ProtoReflect 

func (x *PostSpansResponse) ProtoReflect() protoreflect.Message

func (*PostSpansResponse) Reset 

func (x *PostSpansResponse) Reset()

func (*PostSpansResponse) String 

func (x *PostSpansResponse) String() string

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"`
	// contains filtered or unexported fields
}

ProbabilisticSamplingStrategy samples traces with a fixed probability.

func (*ProbabilisticSamplingStrategy) Descriptor deprecated 

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

Deprecated: Use ProbabilisticSamplingStrategy.ProtoReflect.Descriptor instead.

func (*ProbabilisticSamplingStrategy) GetSamplingRate 

func (x *ProbabilisticSamplingStrategy) GetSamplingRate() float64

func (*ProbabilisticSamplingStrategy) ProtoMessage 

func (*ProbabilisticSamplingStrategy) ProtoMessage()

func (*ProbabilisticSamplingStrategy) ProtoReflect 

func (x *ProbabilisticSamplingStrategy) ProtoReflect() protoreflect.Message

func (*ProbabilisticSamplingStrategy) Reset 

func (x *ProbabilisticSamplingStrategy) Reset()

func (*ProbabilisticSamplingStrategy) String 

func (x *ProbabilisticSamplingStrategy) String() string

type QueryServiceClient 

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

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc.ClientConnInterface) QueryServiceClient

type QueryServiceServer 

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

QueryServiceServer is the server API for QueryService service. All implementations must embed UnimplementedQueryServiceServer for forward compatibility

type QueryService_FindTracesClient 

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

type QueryService_FindTracesServer 

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

type QueryService_GetTraceClient 

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

type QueryService_GetTraceServer 

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

type RateLimitingSamplingStrategy 

type RateLimitingSamplingStrategy struct {

	// TODO this field type should be changed to double, to support rates like 1 per minute.
	MaxTracesPerSecond int32 `protobuf:"varint,1,opt,name=maxTracesPerSecond,proto3" json:"maxTracesPerSecond,omitempty"`
	// contains filtered or unexported fields
}

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

func (*RateLimitingSamplingStrategy) Descriptor deprecated 

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

Deprecated: Use RateLimitingSamplingStrategy.ProtoReflect.Descriptor instead.

func (*RateLimitingSamplingStrategy) GetMaxTracesPerSecond 

func (x *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int32

func (*RateLimitingSamplingStrategy) ProtoMessage 

func (*RateLimitingSamplingStrategy) ProtoMessage()

func (*RateLimitingSamplingStrategy) ProtoReflect 

func (x *RateLimitingSamplingStrategy) ProtoReflect() protoreflect.Message

func (*RateLimitingSamplingStrategy) Reset 

func (x *RateLimitingSamplingStrategy) Reset()

func (*RateLimitingSamplingStrategy) String 

func (x *RateLimitingSamplingStrategy) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSamplingManagerClient 

func NewSamplingManagerClient(cc grpc.ClientConnInterface) SamplingManagerClient

type SamplingManagerServer 

type SamplingManagerServer interface {
	GetSamplingStrategy(context.Context, *SamplingStrategyParameters) (*SamplingStrategyResponse, error)
	// contains filtered or unexported methods
}

SamplingManagerServer is the server API for SamplingManager service. All implementations must embed UnimplementedSamplingManagerServer for forward compatibility

type SamplingStrategyParameters 

type SamplingStrategyParameters struct {

	// serviceName is a required argument.
	ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	// contains filtered or unexported fields
}

SamplingStrategyParameters defines request parameters for remote sampler.

func (*SamplingStrategyParameters) Descriptor deprecated 

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

Deprecated: Use SamplingStrategyParameters.ProtoReflect.Descriptor instead.

func (*SamplingStrategyParameters) GetServiceName 

func (x *SamplingStrategyParameters) GetServiceName() string

func (*SamplingStrategyParameters) ProtoMessage 

func (*SamplingStrategyParameters) ProtoMessage()

func (*SamplingStrategyParameters) ProtoReflect 

func (x *SamplingStrategyParameters) ProtoReflect() protoreflect.Message

func (*SamplingStrategyParameters) Reset 

func (x *SamplingStrategyParameters) Reset()

func (*SamplingStrategyParameters) String 

func (x *SamplingStrategyParameters) String() string

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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use SamplingStrategyResponse.ProtoReflect.Descriptor instead.

func (*SamplingStrategyResponse) GetOperationSampling 

func (x *SamplingStrategyResponse) GetOperationSampling() *PerOperationSamplingStrategies

func (*SamplingStrategyResponse) GetProbabilisticSampling 

func (x *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*SamplingStrategyResponse) GetRateLimitingSampling 

func (x *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy

func (*SamplingStrategyResponse) GetStrategyType 

func (x *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType

func (*SamplingStrategyResponse) ProtoMessage 

func (*SamplingStrategyResponse) ProtoMessage()

func (*SamplingStrategyResponse) ProtoReflect 

func (x *SamplingStrategyResponse) ProtoReflect() protoreflect.Message

func (*SamplingStrategyResponse) Reset 

func (x *SamplingStrategyResponse) Reset()

func (*SamplingStrategyResponse) String 

func (x *SamplingStrategyResponse) String() string

type SamplingStrategyType 

type SamplingStrategyType int32

See description of the SamplingStrategyResponse.strategyType field. 

const (
	SamplingStrategyType_PROBABILISTIC SamplingStrategyType = 0
	SamplingStrategyType_RATE_LIMITING SamplingStrategyType = 1
)

func (SamplingStrategyType) Descriptor 

func (SamplingStrategyType) Descriptor() protoreflect.EnumDescriptor

func (SamplingStrategyType) Enum 

func (x SamplingStrategyType) Enum() *SamplingStrategyType

func (SamplingStrategyType) EnumDescriptor deprecated 

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

Deprecated: Use SamplingStrategyType.Descriptor instead.

func (SamplingStrategyType) Number 

func (x SamplingStrategyType) Number() protoreflect.EnumNumber

func (SamplingStrategyType) String 

func (x SamplingStrategyType) String() string

func (SamplingStrategyType) Type 

func (SamplingStrategyType) Type() protoreflect.EnumType

type SpansResponseChunk 

type SpansResponseChunk struct {
	Spans []*model.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	// contains filtered or unexported fields
}

func (*SpansResponseChunk) Descriptor deprecated 

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

Deprecated: Use SpansResponseChunk.ProtoReflect.Descriptor instead.

func (*SpansResponseChunk) GetSpans 

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

func (*SpansResponseChunk) ProtoMessage 

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) ProtoReflect 

func (x *SpansResponseChunk) ProtoReflect() protoreflect.Message

func (*SpansResponseChunk) Reset 

func (x *SpansResponseChunk) Reset()

func (*SpansResponseChunk) String 

func (x *SpansResponseChunk) String() string

type TraceQueryParameters 

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

func (*TraceQueryParameters) Descriptor deprecated 

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

Deprecated: Use TraceQueryParameters.ProtoReflect.Descriptor instead.

func (*TraceQueryParameters) GetDurationMax 

func (x *TraceQueryParameters) GetDurationMax() *durationpb.Duration

func (*TraceQueryParameters) GetDurationMin 

func (x *TraceQueryParameters) GetDurationMin() *durationpb.Duration

func (*TraceQueryParameters) GetOperationName 

func (x *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetSearchDepth 

func (x *TraceQueryParameters) GetSearchDepth() int32

func (*TraceQueryParameters) GetServiceName 

func (x *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax 

func (x *TraceQueryParameters) GetStartTimeMax() *timestamppb.Timestamp

func (*TraceQueryParameters) GetStartTimeMin 

func (x *TraceQueryParameters) GetStartTimeMin() *timestamppb.Timestamp

func (*TraceQueryParameters) GetTags 

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

func (*TraceQueryParameters) ProtoMessage 

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) ProtoReflect 

func (x *TraceQueryParameters) ProtoReflect() protoreflect.Message

func (*TraceQueryParameters) Reset 

func (x *TraceQueryParameters) Reset()

func (*TraceQueryParameters) String 

func (x *TraceQueryParameters) String() string

type UnimplementedCollectorServiceServer 

type UnimplementedCollectorServiceServer struct {
}

UnimplementedCollectorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCollectorServiceServer) PostSpans 

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

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServiceServer) ArchiveTrace 

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

func (UnimplementedQueryServiceServer) FindTraces 

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

func (UnimplementedQueryServiceServer) GetDependencies 

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

func (UnimplementedQueryServiceServer) GetOperations 

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

func (UnimplementedQueryServiceServer) GetServices 

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

func (UnimplementedQueryServiceServer) GetTrace 

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

type UnimplementedSamplingManagerServer 

type UnimplementedSamplingManagerServer struct {
}

UnimplementedSamplingManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedSamplingManagerServer) GetSamplingStrategy 

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

type UnsafeCollectorServiceServer 

type UnsafeCollectorServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCollectorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CollectorServiceServer will result in compilation errors.

type UnsafeQueryServiceServer 

type UnsafeQueryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeQueryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServiceServer will result in compilation errors.

type UnsafeSamplingManagerServer 

type UnsafeSamplingManagerServer interface {
	// contains filtered or unexported methods
}

UnsafeSamplingManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SamplingManagerServer will result in compilation errors.

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.