api_v2

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

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

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

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterCollectorServiceServer

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

func RegisterQueryServiceServer

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

func RegisterSamplingManagerServer

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

Types

type ArchiveTraceRequest

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

func (*ArchiveTraceRequest) Descriptor

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

func (*ArchiveTraceRequest) Marshal

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

func (*ArchiveTraceRequest) MarshalTo

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

func (*ArchiveTraceRequest) MarshalToSizedBuffer

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

func (*ArchiveTraceRequest) ProtoMessage

func (*ArchiveTraceRequest) ProtoMessage()

func (*ArchiveTraceRequest) Reset

func (m *ArchiveTraceRequest) Reset()

func (*ArchiveTraceRequest) Size

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

func (*ArchiveTraceRequest) String

func (m *ArchiveTraceRequest) String() string

func (*ArchiveTraceRequest) Unmarshal

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

func (*ArchiveTraceRequest) XXX_DiscardUnknown

func (m *ArchiveTraceRequest) XXX_DiscardUnknown()

func (*ArchiveTraceRequest) XXX_Marshal

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

func (*ArchiveTraceRequest) XXX_Merge

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

func (*ArchiveTraceRequest) XXX_Size

func (m *ArchiveTraceRequest) XXX_Size() int

func (*ArchiveTraceRequest) XXX_Unmarshal

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

type ArchiveTraceResponse

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

func (*ArchiveTraceResponse) Descriptor

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

func (*ArchiveTraceResponse) Marshal

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

func (*ArchiveTraceResponse) MarshalTo

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

func (*ArchiveTraceResponse) MarshalToSizedBuffer

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

func (*ArchiveTraceResponse) ProtoMessage

func (*ArchiveTraceResponse) ProtoMessage()

func (*ArchiveTraceResponse) Reset

func (m *ArchiveTraceResponse) Reset()

func (*ArchiveTraceResponse) Size

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

func (*ArchiveTraceResponse) String

func (m *ArchiveTraceResponse) String() string

func (*ArchiveTraceResponse) Unmarshal

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

func (*ArchiveTraceResponse) XXX_DiscardUnknown

func (m *ArchiveTraceResponse) XXX_DiscardUnknown()

func (*ArchiveTraceResponse) XXX_Marshal

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

func (*ArchiveTraceResponse) XXX_Merge

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

func (*ArchiveTraceResponse) XXX_Size

func (m *ArchiveTraceResponse) XXX_Size() int

func (*ArchiveTraceResponse) XXX_Unmarshal

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

type CollectorServiceClient

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

CollectorServiceClient is the client API for CollectorService service.

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

func NewCollectorServiceClient

func NewCollectorServiceClient(cc *grpc.ClientConn) CollectorServiceClient

type CollectorServiceServer

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

CollectorServiceServer is the server API for CollectorService service.

type FindTracesRequest

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

func (*FindTracesRequest) Descriptor

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

func (*FindTracesRequest) GetQuery

func (m *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) Marshal

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

func (*FindTracesRequest) MarshalTo

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

func (*FindTracesRequest) MarshalToSizedBuffer

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

func (*FindTracesRequest) ProtoMessage

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) Reset

func (m *FindTracesRequest) Reset()

func (*FindTracesRequest) Size

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

func (*FindTracesRequest) String

func (m *FindTracesRequest) String() string

func (*FindTracesRequest) Unmarshal

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

func (*FindTracesRequest) XXX_DiscardUnknown

func (m *FindTracesRequest) XXX_DiscardUnknown()

func (*FindTracesRequest) XXX_Marshal

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

func (*FindTracesRequest) XXX_Merge

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

func (*FindTracesRequest) XXX_Size

func (m *FindTracesRequest) XXX_Size() int

func (*FindTracesRequest) XXX_Unmarshal

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

type GetDependenciesRequest

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

func (*GetDependenciesRequest) Descriptor

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

func (*GetDependenciesRequest) GetEndTime

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

func (*GetDependenciesRequest) GetStartTime

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

func (*GetDependenciesRequest) Marshal

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

func (*GetDependenciesRequest) MarshalTo

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

func (*GetDependenciesRequest) MarshalToSizedBuffer

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

func (*GetDependenciesRequest) ProtoMessage

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) Reset

func (m *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) Size

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

func (*GetDependenciesRequest) String

func (m *GetDependenciesRequest) String() string

func (*GetDependenciesRequest) Unmarshal

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

func (*GetDependenciesRequest) XXX_DiscardUnknown

func (m *GetDependenciesRequest) XXX_DiscardUnknown()

func (*GetDependenciesRequest) XXX_Marshal

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

func (*GetDependenciesRequest) XXX_Merge

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

func (*GetDependenciesRequest) XXX_Size

func (m *GetDependenciesRequest) XXX_Size() int

func (*GetDependenciesRequest) XXX_Unmarshal

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

type GetDependenciesResponse

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

func (*GetDependenciesResponse) Descriptor

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

func (*GetDependenciesResponse) GetDependencies

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

func (*GetDependenciesResponse) Marshal

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

func (*GetDependenciesResponse) MarshalTo

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

func (*GetDependenciesResponse) MarshalToSizedBuffer

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

func (*GetDependenciesResponse) ProtoMessage

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) Reset

func (m *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) Size

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

func (*GetDependenciesResponse) String

func (m *GetDependenciesResponse) String() string

func (*GetDependenciesResponse) Unmarshal

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

func (*GetDependenciesResponse) XXX_DiscardUnknown

func (m *GetDependenciesResponse) XXX_DiscardUnknown()

func (*GetDependenciesResponse) XXX_Marshal

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

func (*GetDependenciesResponse) XXX_Merge

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

func (*GetDependenciesResponse) XXX_Size

func (m *GetDependenciesResponse) XXX_Size() int

func (*GetDependenciesResponse) XXX_Unmarshal

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

type GetOperationsRequest

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

func (*GetOperationsRequest) Descriptor

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

func (*GetOperationsRequest) GetService

func (m *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind

func (m *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) Marshal

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

func (*GetOperationsRequest) MarshalTo

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

func (*GetOperationsRequest) MarshalToSizedBuffer

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

func (*GetOperationsRequest) ProtoMessage

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) Reset

func (m *GetOperationsRequest) Reset()

func (*GetOperationsRequest) Size

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

func (*GetOperationsRequest) String

func (m *GetOperationsRequest) String() string

func (*GetOperationsRequest) Unmarshal

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

func (*GetOperationsRequest) XXX_DiscardUnknown

func (m *GetOperationsRequest) XXX_DiscardUnknown()

func (*GetOperationsRequest) XXX_Marshal

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

func (*GetOperationsRequest) XXX_Merge

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

func (*GetOperationsRequest) XXX_Size

func (m *GetOperationsRequest) XXX_Size() int

func (*GetOperationsRequest) XXX_Unmarshal

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

type GetOperationsResponse

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

func (*GetOperationsResponse) Descriptor

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

func (*GetOperationsResponse) GetOperationNames

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

func (*GetOperationsResponse) GetOperations

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

func (*GetOperationsResponse) Marshal

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

func (*GetOperationsResponse) MarshalTo

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

func (*GetOperationsResponse) MarshalToSizedBuffer

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

func (*GetOperationsResponse) ProtoMessage

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) Reset

func (m *GetOperationsResponse) Reset()

func (*GetOperationsResponse) Size

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

func (*GetOperationsResponse) String

func (m *GetOperationsResponse) String() string

func (*GetOperationsResponse) Unmarshal

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

func (*GetOperationsResponse) XXX_DiscardUnknown

func (m *GetOperationsResponse) XXX_DiscardUnknown()

func (*GetOperationsResponse) XXX_Marshal

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

func (*GetOperationsResponse) XXX_Merge

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

func (*GetOperationsResponse) XXX_Size

func (m *GetOperationsResponse) XXX_Size() int

func (*GetOperationsResponse) XXX_Unmarshal

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

type GetServicesRequest

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

func (*GetServicesRequest) Descriptor

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

func (*GetServicesRequest) Marshal

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

func (*GetServicesRequest) MarshalTo

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

func (*GetServicesRequest) MarshalToSizedBuffer

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

func (*GetServicesRequest) ProtoMessage

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) Reset

func (m *GetServicesRequest) Reset()

func (*GetServicesRequest) Size

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

func (*GetServicesRequest) String

func (m *GetServicesRequest) String() string

func (*GetServicesRequest) Unmarshal

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

func (*GetServicesRequest) XXX_DiscardUnknown

func (m *GetServicesRequest) XXX_DiscardUnknown()

func (*GetServicesRequest) XXX_Marshal

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

func (*GetServicesRequest) XXX_Merge

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

func (*GetServicesRequest) XXX_Size

func (m *GetServicesRequest) XXX_Size() int

func (*GetServicesRequest) XXX_Unmarshal

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

type GetServicesResponse

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

func (*GetServicesResponse) Descriptor

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

func (*GetServicesResponse) GetServices

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

func (*GetServicesResponse) Marshal

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

func (*GetServicesResponse) MarshalTo

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

func (*GetServicesResponse) MarshalToSizedBuffer

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

func (*GetServicesResponse) ProtoMessage

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) Reset

func (m *GetServicesResponse) Reset()

func (*GetServicesResponse) Size

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

func (*GetServicesResponse) String

func (m *GetServicesResponse) String() string

func (*GetServicesResponse) Unmarshal

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

func (*GetServicesResponse) XXX_DiscardUnknown

func (m *GetServicesResponse) XXX_DiscardUnknown()

func (*GetServicesResponse) XXX_Marshal

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

func (*GetServicesResponse) XXX_Merge

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

func (*GetServicesResponse) XXX_Size

func (m *GetServicesResponse) XXX_Size() int

func (*GetServicesResponse) XXX_Unmarshal

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

type GetTraceRequest

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

func (*GetTraceRequest) Descriptor

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

func (*GetTraceRequest) Marshal

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

func (*GetTraceRequest) MarshalTo

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

func (*GetTraceRequest) MarshalToSizedBuffer

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

func (*GetTraceRequest) ProtoMessage

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) Reset

func (m *GetTraceRequest) Reset()

func (*GetTraceRequest) Size

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

func (*GetTraceRequest) String

func (m *GetTraceRequest) String() string

func (*GetTraceRequest) Unmarshal

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

func (*GetTraceRequest) XXX_DiscardUnknown

func (m *GetTraceRequest) XXX_DiscardUnknown()

func (*GetTraceRequest) XXX_Marshal

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

func (*GetTraceRequest) XXX_Merge

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

func (*GetTraceRequest) XXX_Size

func (m *GetTraceRequest) XXX_Size() int

func (*GetTraceRequest) XXX_Unmarshal

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

type Operation

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

func (*Operation) Descriptor

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

func (*Operation) GetName

func (m *Operation) GetName() string

func (*Operation) GetSpanKind

func (m *Operation) GetSpanKind() string

func (*Operation) Marshal

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

func (*Operation) MarshalTo

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

func (*Operation) MarshalToSizedBuffer

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

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) Reset

func (m *Operation) Reset()

func (*Operation) Size

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

func (*Operation) String

func (m *Operation) String() string

func (*Operation) Unmarshal

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

func (*Operation) XXX_DiscardUnknown

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal

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

func (*Operation) XXX_Merge

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

func (*Operation) XXX_Size

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal

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

type OperationSamplingStrategy

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

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

func (*OperationSamplingStrategy) Descriptor

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

func (*OperationSamplingStrategy) GetOperation

func (m *OperationSamplingStrategy) GetOperation() string

func (*OperationSamplingStrategy) GetProbabilisticSampling

func (m *OperationSamplingStrategy) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*OperationSamplingStrategy) Marshal

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

func (*OperationSamplingStrategy) MarshalTo

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

func (*OperationSamplingStrategy) MarshalToSizedBuffer

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

func (*OperationSamplingStrategy) ProtoMessage

func (*OperationSamplingStrategy) ProtoMessage()

func (*OperationSamplingStrategy) Reset

func (m *OperationSamplingStrategy) Reset()

func (*OperationSamplingStrategy) Size

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

func (*OperationSamplingStrategy) String

func (m *OperationSamplingStrategy) String() string

func (*OperationSamplingStrategy) Unmarshal

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

func (*OperationSamplingStrategy) XXX_DiscardUnknown

func (m *OperationSamplingStrategy) XXX_DiscardUnknown()

func (*OperationSamplingStrategy) XXX_Marshal

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

func (*OperationSamplingStrategy) XXX_Merge

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

func (*OperationSamplingStrategy) XXX_Size

func (m *OperationSamplingStrategy) XXX_Size() int

func (*OperationSamplingStrategy) XXX_Unmarshal

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

type PerOperationSamplingStrategies

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

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

func (*PerOperationSamplingStrategies) Descriptor

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

func (*PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond

func (m *PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetDefaultSamplingProbability

func (m *PerOperationSamplingStrategies) GetDefaultSamplingProbability() float64

func (*PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond

func (m *PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetPerOperationStrategies

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

func (*PerOperationSamplingStrategies) Marshal

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

func (*PerOperationSamplingStrategies) MarshalTo

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

func (*PerOperationSamplingStrategies) MarshalToSizedBuffer

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

func (*PerOperationSamplingStrategies) ProtoMessage

func (*PerOperationSamplingStrategies) ProtoMessage()

func (*PerOperationSamplingStrategies) Reset

func (m *PerOperationSamplingStrategies) Reset()

func (*PerOperationSamplingStrategies) Size

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

func (*PerOperationSamplingStrategies) String

func (*PerOperationSamplingStrategies) Unmarshal

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

func (*PerOperationSamplingStrategies) XXX_DiscardUnknown

func (m *PerOperationSamplingStrategies) XXX_DiscardUnknown()

func (*PerOperationSamplingStrategies) XXX_Marshal

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

func (*PerOperationSamplingStrategies) XXX_Merge

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

func (*PerOperationSamplingStrategies) XXX_Size

func (m *PerOperationSamplingStrategies) XXX_Size() int

func (*PerOperationSamplingStrategies) XXX_Unmarshal

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

type PostSpansRequest

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

func (*PostSpansRequest) Descriptor

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

func (*PostSpansRequest) Free

func (m *PostSpansRequest) Free()

func (*PostSpansRequest) GetBatch

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

func (*PostSpansRequest) Marshal

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

func (*PostSpansRequest) MarshalTo

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

func (*PostSpansRequest) MarshalToSizedBuffer

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

func (*PostSpansRequest) ProtoMessage

func (*PostSpansRequest) ProtoMessage()

func (*PostSpansRequest) Reset

func (m *PostSpansRequest) Reset()

func (*PostSpansRequest) Size

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

func (*PostSpansRequest) String

func (m *PostSpansRequest) String() string

func (*PostSpansRequest) Unmarshal

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

func (*PostSpansRequest) XXX_DiscardUnknown

func (m *PostSpansRequest) XXX_DiscardUnknown()

func (*PostSpansRequest) XXX_Marshal

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

func (*PostSpansRequest) XXX_Merge

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

func (*PostSpansRequest) XXX_Size

func (m *PostSpansRequest) XXX_Size() int

func (*PostSpansRequest) XXX_Unmarshal

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

type PostSpansResponse

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

func (*PostSpansResponse) Descriptor

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

func (*PostSpansResponse) Marshal

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

func (*PostSpansResponse) MarshalTo

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

func (*PostSpansResponse) MarshalToSizedBuffer

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

func (*PostSpansResponse) ProtoMessage

func (*PostSpansResponse) ProtoMessage()

func (*PostSpansResponse) Reset

func (m *PostSpansResponse) Reset()

func (*PostSpansResponse) Size

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

func (*PostSpansResponse) String

func (m *PostSpansResponse) String() string

func (*PostSpansResponse) Unmarshal

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

func (*PostSpansResponse) XXX_DiscardUnknown

func (m *PostSpansResponse) XXX_DiscardUnknown()

func (*PostSpansResponse) XXX_Marshal

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

func (*PostSpansResponse) XXX_Merge

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

func (*PostSpansResponse) XXX_Size

func (m *PostSpansResponse) XXX_Size() int

func (*PostSpansResponse) XXX_Unmarshal

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

type ProbabilisticSamplingStrategy

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

ProbabilisticSamplingStrategy samples traces with a fixed probability.

func (*ProbabilisticSamplingStrategy) Descriptor

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

func (*ProbabilisticSamplingStrategy) GetSamplingRate

func (m *ProbabilisticSamplingStrategy) GetSamplingRate() float64

func (*ProbabilisticSamplingStrategy) Marshal

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

func (*ProbabilisticSamplingStrategy) MarshalTo

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

func (*ProbabilisticSamplingStrategy) MarshalToSizedBuffer

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

func (*ProbabilisticSamplingStrategy) ProtoMessage

func (*ProbabilisticSamplingStrategy) ProtoMessage()

func (*ProbabilisticSamplingStrategy) Reset

func (m *ProbabilisticSamplingStrategy) Reset()

func (*ProbabilisticSamplingStrategy) Size

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

func (*ProbabilisticSamplingStrategy) String

func (*ProbabilisticSamplingStrategy) Unmarshal

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

func (*ProbabilisticSamplingStrategy) XXX_DiscardUnknown

func (m *ProbabilisticSamplingStrategy) XXX_DiscardUnknown()

func (*ProbabilisticSamplingStrategy) XXX_Marshal

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

func (*ProbabilisticSamplingStrategy) XXX_Merge

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

func (*ProbabilisticSamplingStrategy) XXX_Size

func (m *ProbabilisticSamplingStrategy) XXX_Size() int

func (*ProbabilisticSamplingStrategy) XXX_Unmarshal

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

type QueryServiceClient

QueryServiceClient is the client API for QueryService service.

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

func NewQueryServiceClient

func NewQueryServiceClient(cc *grpc.ClientConn) QueryServiceClient

type QueryServiceServer

QueryServiceServer is the server API for QueryService service.

type QueryService_FindTracesClient

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

type QueryService_FindTracesServer

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

type QueryService_GetTraceClient

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

type QueryService_GetTraceServer

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

type RateLimitingSamplingStrategy

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

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

func (*RateLimitingSamplingStrategy) Descriptor

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

func (*RateLimitingSamplingStrategy) GetMaxTracesPerSecond

func (m *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int32

func (*RateLimitingSamplingStrategy) Marshal

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

func (*RateLimitingSamplingStrategy) MarshalTo

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

func (*RateLimitingSamplingStrategy) MarshalToSizedBuffer

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

func (*RateLimitingSamplingStrategy) ProtoMessage

func (*RateLimitingSamplingStrategy) ProtoMessage()

func (*RateLimitingSamplingStrategy) Reset

func (m *RateLimitingSamplingStrategy) Reset()

func (*RateLimitingSamplingStrategy) Size

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

func (*RateLimitingSamplingStrategy) String

func (*RateLimitingSamplingStrategy) Unmarshal

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

func (*RateLimitingSamplingStrategy) XXX_DiscardUnknown

func (m *RateLimitingSamplingStrategy) XXX_DiscardUnknown()

func (*RateLimitingSamplingStrategy) XXX_Marshal

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

func (*RateLimitingSamplingStrategy) XXX_Merge

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

func (*RateLimitingSamplingStrategy) XXX_Size

func (m *RateLimitingSamplingStrategy) XXX_Size() int

func (*RateLimitingSamplingStrategy) XXX_Unmarshal

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

type SamplingManagerClient

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

SamplingManagerClient is the client API for SamplingManager service.

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

func NewSamplingManagerClient

func NewSamplingManagerClient(cc *grpc.ClientConn) SamplingManagerClient

type SamplingManagerServer

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

SamplingManagerServer is the server API for SamplingManager service.

type SamplingStrategyParameters

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

SamplingStrategyParameters defines request parameters for remote sampler.

func (*SamplingStrategyParameters) Descriptor

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

func (*SamplingStrategyParameters) GetServiceName

func (m *SamplingStrategyParameters) GetServiceName() string

func (*SamplingStrategyParameters) Marshal

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

func (*SamplingStrategyParameters) MarshalTo

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

func (*SamplingStrategyParameters) MarshalToSizedBuffer

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

func (*SamplingStrategyParameters) ProtoMessage

func (*SamplingStrategyParameters) ProtoMessage()

func (*SamplingStrategyParameters) Reset

func (m *SamplingStrategyParameters) Reset()

func (*SamplingStrategyParameters) Size

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

func (*SamplingStrategyParameters) String

func (m *SamplingStrategyParameters) String() string

func (*SamplingStrategyParameters) Unmarshal

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

func (*SamplingStrategyParameters) XXX_DiscardUnknown

func (m *SamplingStrategyParameters) XXX_DiscardUnknown()

func (*SamplingStrategyParameters) XXX_Marshal

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

func (*SamplingStrategyParameters) XXX_Merge

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

func (*SamplingStrategyParameters) XXX_Size

func (m *SamplingStrategyParameters) XXX_Size() int

func (*SamplingStrategyParameters) XXX_Unmarshal

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

type SamplingStrategyResponse

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

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

func (*SamplingStrategyResponse) Descriptor

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

func (*SamplingStrategyResponse) GetOperationSampling

func (m *SamplingStrategyResponse) GetOperationSampling() *PerOperationSamplingStrategies

func (*SamplingStrategyResponse) GetProbabilisticSampling

func (m *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*SamplingStrategyResponse) GetRateLimitingSampling

func (m *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy

func (*SamplingStrategyResponse) GetStrategyType

func (m *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType

func (*SamplingStrategyResponse) Marshal

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

func (*SamplingStrategyResponse) MarshalTo

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

func (*SamplingStrategyResponse) MarshalToSizedBuffer

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

func (*SamplingStrategyResponse) ProtoMessage

func (*SamplingStrategyResponse) ProtoMessage()

func (*SamplingStrategyResponse) Reset

func (m *SamplingStrategyResponse) Reset()

func (*SamplingStrategyResponse) Size

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

func (*SamplingStrategyResponse) String

func (m *SamplingStrategyResponse) String() string

func (*SamplingStrategyResponse) Unmarshal

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

func (*SamplingStrategyResponse) XXX_DiscardUnknown

func (m *SamplingStrategyResponse) XXX_DiscardUnknown()

func (*SamplingStrategyResponse) XXX_Marshal

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

func (*SamplingStrategyResponse) XXX_Merge

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

func (*SamplingStrategyResponse) XXX_Size

func (m *SamplingStrategyResponse) XXX_Size() int

func (*SamplingStrategyResponse) XXX_Unmarshal

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

type SamplingStrategyType

type SamplingStrategyType int32

See description of the SamplingStrategyResponse.strategyType field.

const (
	SamplingStrategyType_PROBABILISTIC SamplingStrategyType = 0
	SamplingStrategyType_RATE_LIMITING SamplingStrategyType = 1
)

func (SamplingStrategyType) EnumDescriptor

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

func (SamplingStrategyType) String

func (x SamplingStrategyType) String() string

type SpansResponseChunk

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

func (*SpansResponseChunk) Descriptor

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

func (*SpansResponseChunk) GetSpans

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

func (*SpansResponseChunk) Marshal

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

func (*SpansResponseChunk) MarshalTo

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

func (*SpansResponseChunk) MarshalToSizedBuffer

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

func (*SpansResponseChunk) ProtoMessage

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) Reset

func (m *SpansResponseChunk) Reset()

func (*SpansResponseChunk) Size

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

func (*SpansResponseChunk) String

func (m *SpansResponseChunk) String() string

func (*SpansResponseChunk) Unmarshal

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

func (*SpansResponseChunk) XXX_DiscardUnknown

func (m *SpansResponseChunk) XXX_DiscardUnknown()

func (*SpansResponseChunk) XXX_Marshal

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

func (*SpansResponseChunk) XXX_Merge

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

func (*SpansResponseChunk) XXX_Size

func (m *SpansResponseChunk) XXX_Size() int

func (*SpansResponseChunk) XXX_Unmarshal

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

type TraceQueryParameters

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

func (*TraceQueryParameters) Descriptor

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

func (*TraceQueryParameters) GetDurationMax

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

func (*TraceQueryParameters) GetDurationMin

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

func (*TraceQueryParameters) GetOperationName

func (m *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetSearchDepth

func (m *TraceQueryParameters) GetSearchDepth() int32

func (*TraceQueryParameters) GetServiceName

func (m *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax

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

func (*TraceQueryParameters) GetStartTimeMin

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

func (*TraceQueryParameters) GetTags

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

func (*TraceQueryParameters) Marshal

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

func (*TraceQueryParameters) MarshalTo

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

func (*TraceQueryParameters) MarshalToSizedBuffer

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

func (*TraceQueryParameters) ProtoMessage

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) Reset

func (m *TraceQueryParameters) Reset()

func (*TraceQueryParameters) Size

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

func (*TraceQueryParameters) String

func (m *TraceQueryParameters) String() string

func (*TraceQueryParameters) Unmarshal

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

func (*TraceQueryParameters) XXX_DiscardUnknown

func (m *TraceQueryParameters) XXX_DiscardUnknown()

func (*TraceQueryParameters) XXX_Marshal

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

func (*TraceQueryParameters) XXX_Merge

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

func (*TraceQueryParameters) XXX_Size

func (m *TraceQueryParameters) XXX_Size() int

func (*TraceQueryParameters) XXX_Unmarshal

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

type UnimplementedCollectorServiceServer

type UnimplementedCollectorServiceServer struct {
}

UnimplementedCollectorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCollectorServiceServer) PostSpans

type UnimplementedQueryServiceServer

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) ArchiveTrace

func (*UnimplementedQueryServiceServer) FindTraces

func (*UnimplementedQueryServiceServer) GetDependencies

func (*UnimplementedQueryServiceServer) GetOperations

func (*UnimplementedQueryServiceServer) GetServices

func (*UnimplementedQueryServiceServer) GetTrace

type UnimplementedSamplingManagerServer

type UnimplementedSamplingManagerServer struct {
}

UnimplementedSamplingManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSamplingManagerServer) GetSamplingStrategy

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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