api_v2

package
v0.0.0-...-be244c0 Latest Latest
Warning

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

Go to latest
Published: Sep 10, 2020 License: Apache-2.0 Imports: 14 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")
)
View Source
var (
	ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthSampling = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSampling   = fmt.Errorf("proto: integer overflow")
)
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 `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3,customtype=github.com/m8rge/m-jaeger/model.TraceID" json:"trace_id"`
	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) 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) 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) 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) 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) 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) 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) 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) 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) 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 `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3,customtype=github.com/m8rge/m-jaeger/model.TraceID" json:"trace_id"`
	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) 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) 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:"-"`
}

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) 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       float64                      `protobuf:"fixed64,1,opt,name=defaultSamplingProbability,proto3" json:"defaultSamplingProbability,omitempty"`
	DefaultLowerBoundTracesPerSecond float64                      `protobuf:"fixed64,2,opt,name=defaultLowerBoundTracesPerSecond,proto3" json:"defaultLowerBoundTracesPerSecond,omitempty"`
	PerOperationStrategies           []*OperationSamplingStrategy `protobuf:"bytes,3,rep,name=perOperationStrategies,proto3" json:"perOperationStrategies,omitempty"`
	DefaultUpperBoundTracesPerSecond float64                      `protobuf:"fixed64,4,opt,name=defaultUpperBoundTracesPerSecond,proto3" json:"defaultUpperBoundTracesPerSecond,omitempty"`
	XXX_NoUnkeyedLiteral             struct{}                     `json:"-"`
	XXX_unrecognized                 []byte                       `json:"-"`
	XXX_sizecache                    int32                        `json:"-"`
}

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) 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) 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) 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) 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         float64  `protobuf:"fixed64,1,opt,name=samplingRate,proto3" json:"samplingRate,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) 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 {
	MaxTracesPerSecond   int32    `protobuf:"varint,1,opt,name=maxTracesPerSecond,proto3" json:"maxTracesPerSecond,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) 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          string   `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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) 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
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) 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) 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

Jump to

Keyboard shortcuts

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