tempopb

package module
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2024 License: Apache-2.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PushErrorReason_name = map[int32]string{
		0: "NO_ERROR",
		1: "MAX_LIVE_TRACES",
		2: "TRACE_TOO_LARGE",
		3: "UNKNOWN_ERROR",
	}
	PushErrorReason_value = map[string]int32{
		"NO_ERROR":        0,
		"MAX_LIVE_TRACES": 1,
		"TRACE_TOO_LARGE": 2,
		"UNKNOWN_ERROR":   3,
	}
)

Enum value maps for PushErrorReason.

View Source 
var (
	DedicatedColumn_Scope_name = map[int32]string{
		0: "SPAN",
		1: "RESOURCE",
	}
	DedicatedColumn_Scope_value = map[string]int32{
		"SPAN":     0,
		"RESOURCE": 1,
	}
)

Enum value maps for DedicatedColumn_Scope.

View Source 
var (
	DedicatedColumn_Type_name = map[int32]string{
		0: "STRING",
	}
	DedicatedColumn_Type_value = map[string]int32{
		"STRING": 0,
	}
)

Enum value maps for DedicatedColumn_Type.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_tempo_proto protoreflect.FileDescriptor
View Source 
var MetricsGenerator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.MetricsGenerator",
	HandlerType: (*MetricsGeneratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushSpans",
			Handler:    _MetricsGenerator_PushSpans_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _MetricsGenerator_GetMetrics_Handler,
		},
		{
			MethodName: "QueryRange",
			Handler:    _MetricsGenerator_QueryRange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tempo.proto",
}

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

View Source 
var Metrics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.Metrics",
	HandlerType: (*MetricsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SpanMetricsSummary",
			Handler:    _Metrics_SpanMetricsSummary_Handler,
		},
		{
			MethodName: "QueryRange",
			Handler:    _Metrics_QueryRange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tempo.proto",
}

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

View Source 
var Pusher_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.Pusher",
	HandlerType: (*PusherServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushBytes",
			Handler:    _Pusher_PushBytes_Handler,
		},
		{
			MethodName: "PushBytesV2",
			Handler:    _Pusher_PushBytesV2_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tempo.proto",
}

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

View Source 
var Querier_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.Querier",
	HandlerType: (*QuerierServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FindTraceByID",
			Handler:    _Querier_FindTraceByID_Handler,
		},
		{
			MethodName: "SearchRecent",
			Handler:    _Querier_SearchRecent_Handler,
		},
		{
			MethodName: "SearchBlock",
			Handler:    _Querier_SearchBlock_Handler,
		},
		{
			MethodName: "SearchTags",
			Handler:    _Querier_SearchTags_Handler,
		},
		{
			MethodName: "SearchTagsV2",
			Handler:    _Querier_SearchTagsV2_Handler,
		},
		{
			MethodName: "SearchTagValues",
			Handler:    _Querier_SearchTagValues_Handler,
		},
		{
			MethodName: "SearchTagValuesV2",
			Handler:    _Querier_SearchTagValuesV2_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tempo.proto",
}

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

View Source 
var StreamingQuerier_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.StreamingQuerier",
	HandlerType: (*StreamingQuerierServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Search",
			Handler:       _StreamingQuerier_Search_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "tempo.proto",
}

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

Functions

func RegisterMetricsGeneratorServer 

func RegisterMetricsGeneratorServer(s grpc.ServiceRegistrar, srv MetricsGeneratorServer)

func RegisterMetricsServer 

func RegisterMetricsServer(s grpc.ServiceRegistrar, srv MetricsServer)

func RegisterPusherServer 

func RegisterPusherServer(s grpc.ServiceRegistrar, srv PusherServer)

func RegisterQuerierServer 

func RegisterQuerierServer(s grpc.ServiceRegistrar, srv QuerierServer)

func RegisterStreamingQuerierServer 

func RegisterStreamingQuerierServer(s grpc.ServiceRegistrar, srv StreamingQuerierServer)

Types

type DedicatedColumn 

type DedicatedColumn struct {
	Scope DedicatedColumn_Scope `protobuf:"varint,3,opt,name=scope,proto3,enum=opentelemetry.DedicatedColumn_Scope" json:"scope,omitempty"`
	Name  string                `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type  DedicatedColumn_Type  `protobuf:"varint,1,opt,name=type,proto3,enum=opentelemetry.DedicatedColumn_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Configuration for a single dedicated attribute column.

func (*DedicatedColumn) CloneMessageVT added in v0.2.0 

func (m *DedicatedColumn) CloneMessageVT() proto.Message

func (*DedicatedColumn) CloneVT added in v0.2.0 

func (m *DedicatedColumn) CloneVT() *DedicatedColumn

func (*DedicatedColumn) Descriptor deprecated 

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

Deprecated: Use DedicatedColumn.ProtoReflect.Descriptor instead.

func (*DedicatedColumn) EqualMessageVT added in v0.2.0 

func (this *DedicatedColumn) EqualMessageVT(thatMsg proto.Message) bool

func (*DedicatedColumn) EqualVT added in v0.2.0 

func (this *DedicatedColumn) EqualVT(that *DedicatedColumn) bool

func (*DedicatedColumn) GetName 

func (x *DedicatedColumn) GetName() string

func (*DedicatedColumn) GetScope 

func (x *DedicatedColumn) GetScope() DedicatedColumn_Scope

func (*DedicatedColumn) GetType 

func (x *DedicatedColumn) GetType() DedicatedColumn_Type

func (*DedicatedColumn) MarshalToSizedBufferVT added in v0.2.0 

func (m *DedicatedColumn) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DedicatedColumn) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *DedicatedColumn) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*DedicatedColumn) MarshalToVT added in v0.2.0 

func (m *DedicatedColumn) MarshalToVT(dAtA []byte) (int, error)

func (*DedicatedColumn) MarshalToVTStrict added in v0.2.0 

func (m *DedicatedColumn) MarshalToVTStrict(dAtA []byte) (int, error)

func (*DedicatedColumn) MarshalVT added in v0.2.0 

func (m *DedicatedColumn) MarshalVT() (dAtA []byte, err error)

func (*DedicatedColumn) MarshalVTStrict added in v0.2.0 

func (m *DedicatedColumn) MarshalVTStrict() (dAtA []byte, err error)

func (*DedicatedColumn) ProtoMessage 

func (*DedicatedColumn) ProtoMessage()

func (*DedicatedColumn) ProtoReflect added in v0.2.0 

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

func (*DedicatedColumn) Reset 

func (x *DedicatedColumn) Reset()

func (*DedicatedColumn) SizeVT added in v0.2.0 

func (m *DedicatedColumn) SizeVT() (n int)

func (*DedicatedColumn) String 

func (x *DedicatedColumn) String() string

func (*DedicatedColumn) UnmarshalVT added in v0.2.0 

func (m *DedicatedColumn) UnmarshalVT(dAtA []byte) error

type DedicatedColumn_Scope 

type DedicatedColumn_Scope int32
const (
	DedicatedColumn_SPAN     DedicatedColumn_Scope = 0
	DedicatedColumn_RESOURCE DedicatedColumn_Scope = 1
)

func (DedicatedColumn_Scope) Descriptor added in v0.2.0 

func (DedicatedColumn_Scope) Descriptor() protoreflect.EnumDescriptor

func (DedicatedColumn_Scope) Enum added in v0.2.0 

func (x DedicatedColumn_Scope) Enum() *DedicatedColumn_Scope

func (DedicatedColumn_Scope) EnumDescriptor deprecated 

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

Deprecated: Use DedicatedColumn_Scope.Descriptor instead.

func (DedicatedColumn_Scope) Number added in v0.2.0 

func (x DedicatedColumn_Scope) Number() protoreflect.EnumNumber

func (DedicatedColumn_Scope) String 

func (x DedicatedColumn_Scope) String() string

func (DedicatedColumn_Scope) Type added in v0.2.0 

func (DedicatedColumn_Scope) Type() protoreflect.EnumType

type DedicatedColumn_Type 

type DedicatedColumn_Type int32
const (
	DedicatedColumn_STRING DedicatedColumn_Type = 0
)

func (DedicatedColumn_Type) Descriptor added in v0.2.0 

func (DedicatedColumn_Type) Descriptor() protoreflect.EnumDescriptor

func (DedicatedColumn_Type) Enum added in v0.2.0 

func (x DedicatedColumn_Type) Enum() *DedicatedColumn_Type

func (DedicatedColumn_Type) EnumDescriptor deprecated 

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

Deprecated: Use DedicatedColumn_Type.Descriptor instead.

func (DedicatedColumn_Type) Number added in v0.2.0 

func (x DedicatedColumn_Type) Number() protoreflect.EnumNumber

func (DedicatedColumn_Type) String 

func (x DedicatedColumn_Type) String() string

func (DedicatedColumn_Type) Type added in v0.2.0 

func (DedicatedColumn_Type) Type() protoreflect.EnumType

type KeyValue 

type KeyValue struct {
	Key   string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *TraceQLStatic `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValue) CloneMessageVT added in v0.2.0 

func (m *KeyValue) CloneMessageVT() proto.Message

func (*KeyValue) CloneVT added in v0.2.0 

func (m *KeyValue) CloneVT() *KeyValue

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) EqualMessageVT added in v0.2.0 

func (this *KeyValue) EqualMessageVT(thatMsg proto.Message) bool

func (*KeyValue) EqualVT added in v0.2.0 

func (this *KeyValue) EqualVT(that *KeyValue) bool

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (x *KeyValue) GetValue() *TraceQLStatic

func (*KeyValue) MarshalToSizedBufferVT added in v0.2.0 

func (m *KeyValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyValue) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *KeyValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*KeyValue) MarshalToVT added in v0.2.0 

func (m *KeyValue) MarshalToVT(dAtA []byte) (int, error)

func (*KeyValue) MarshalToVTStrict added in v0.2.0 

func (m *KeyValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*KeyValue) MarshalVT added in v0.2.0 

func (m *KeyValue) MarshalVT() (dAtA []byte, err error)

func (*KeyValue) MarshalVTStrict added in v0.2.0 

func (m *KeyValue) MarshalVTStrict() (dAtA []byte, err error)

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect added in v0.2.0 

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

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) SizeVT added in v0.2.0 

func (m *KeyValue) SizeVT() (n int)

func (*KeyValue) String 

func (x *KeyValue) String() string

func (*KeyValue) UnmarshalVT added in v0.2.0 

func (m *KeyValue) UnmarshalVT(dAtA []byte) error

type LinkSlice 

type LinkSlice struct {
	Links []*v11.Span_Link `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

this message exists for marshalling/unmarshalling convenience to/from parquet. in parquet we proto encode links to a column. unfortunately you can't encode a slice directly so we use this wrapper to generate the required marshalling/unmarshalling functions.

func (*LinkSlice) CloneMessageVT added in v0.2.0 

func (m *LinkSlice) CloneMessageVT() proto.Message

func (*LinkSlice) CloneVT added in v0.2.0 

func (m *LinkSlice) CloneVT() *LinkSlice

func (*LinkSlice) Descriptor deprecated 

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

Deprecated: Use LinkSlice.ProtoReflect.Descriptor instead.

func (*LinkSlice) EqualMessageVT added in v0.2.0 

func (this *LinkSlice) EqualMessageVT(thatMsg proto.Message) bool

func (*LinkSlice) EqualVT added in v0.2.0 

func (this *LinkSlice) EqualVT(that *LinkSlice) bool
func (x *LinkSlice) GetLinks() []*v11.Span_Link

func (*LinkSlice) MarshalToSizedBufferVT added in v0.2.0 

func (m *LinkSlice) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinkSlice) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *LinkSlice) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*LinkSlice) MarshalToVT added in v0.2.0 

func (m *LinkSlice) MarshalToVT(dAtA []byte) (int, error)

func (*LinkSlice) MarshalToVTStrict added in v0.2.0 

func (m *LinkSlice) MarshalToVTStrict(dAtA []byte) (int, error)

func (*LinkSlice) MarshalVT added in v0.2.0 

func (m *LinkSlice) MarshalVT() (dAtA []byte, err error)

func (*LinkSlice) MarshalVTStrict added in v0.2.0 

func (m *LinkSlice) MarshalVTStrict() (dAtA []byte, err error)

func (*LinkSlice) ProtoMessage 

func (*LinkSlice) ProtoMessage()

func (*LinkSlice) ProtoReflect added in v0.2.0 

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

func (*LinkSlice) Reset 

func (x *LinkSlice) Reset()

func (*LinkSlice) SizeVT added in v0.2.0 

func (m *LinkSlice) SizeVT() (n int)

func (*LinkSlice) String 

func (x *LinkSlice) String() string

func (*LinkSlice) UnmarshalVT added in v0.2.0 

func (m *LinkSlice) UnmarshalVT(dAtA []byte) error

type MetricsClient 

type MetricsClient interface {
	SpanMetricsSummary(ctx context.Context, in *SpanMetricsSummaryRequest, opts ...grpc.CallOption) (*SpanMetricsSummaryResponse, error)
	QueryRange(ctx context.Context, in *QueryRangeRequest, opts ...grpc.CallOption) (*QueryRangeResponse, error)
}

MetricsClient is the client API for Metrics service.

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

func NewMetricsClient 

func NewMetricsClient(cc grpc.ClientConnInterface) MetricsClient

type MetricsGeneratorClient 

type MetricsGeneratorClient interface {
	PushSpans(ctx context.Context, in *PushSpansRequest, opts ...grpc.CallOption) (*PushResponse, error)
	GetMetrics(ctx context.Context, in *SpanMetricsRequest, opts ...grpc.CallOption) (*SpanMetricsResponse, error)
	QueryRange(ctx context.Context, in *QueryRangeRequest, opts ...grpc.CallOption) (*QueryRangeResponse, error)
}

MetricsGeneratorClient is the client API for MetricsGenerator service.

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

func NewMetricsGeneratorClient 

func NewMetricsGeneratorClient(cc grpc.ClientConnInterface) MetricsGeneratorClient

type MetricsGeneratorServer 

type MetricsGeneratorServer interface {
	PushSpans(context.Context, *PushSpansRequest) (*PushResponse, error)
	GetMetrics(context.Context, *SpanMetricsRequest) (*SpanMetricsResponse, error)
	QueryRange(context.Context, *QueryRangeRequest) (*QueryRangeResponse, error)
	// contains filtered or unexported methods
}

MetricsGeneratorServer is the server API for MetricsGenerator service. All implementations must embed UnimplementedMetricsGeneratorServer for forward compatibility

type MetricsServer 

type MetricsServer interface {
	SpanMetricsSummary(context.Context, *SpanMetricsSummaryRequest) (*SpanMetricsSummaryResponse, error)
	QueryRange(context.Context, *QueryRangeRequest) (*QueryRangeResponse, error)
	// contains filtered or unexported methods
}

MetricsServer is the server API for Metrics service. All implementations must embed UnimplementedMetricsServer for forward compatibility

type PushBytesRequest 

type PushBytesRequest struct {

	// pre-marshalled Traces. length must match ids
	Traces [][]byte `protobuf:"bytes,2,rep,name=traces,proto3" json:"traces,omitempty"`
	// trace ids. length must match traces
	Ids [][]byte `protobuf:"bytes,3,rep,name=ids,proto3" json:"ids,omitempty"`
	// search data, length must match traces
	SearchData [][]byte `protobuf:"bytes,4,rep,name=searchData,proto3" json:"searchData,omitempty"`
	// contains filtered or unexported fields
}

PushBytesRequest pushes slices of traces, ids and searchdata. Traces are encoded using the 

current BatchDecoder in ./pkg/model

func (*PushBytesRequest) CloneMessageVT added in v0.2.0 

func (m *PushBytesRequest) CloneMessageVT() proto.Message

func (*PushBytesRequest) CloneVT added in v0.2.0 

func (m *PushBytesRequest) CloneVT() *PushBytesRequest

func (*PushBytesRequest) Descriptor deprecated 

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

Deprecated: Use PushBytesRequest.ProtoReflect.Descriptor instead.

func (*PushBytesRequest) EqualMessageVT added in v0.2.0 

func (this *PushBytesRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*PushBytesRequest) EqualVT added in v0.2.0 

func (this *PushBytesRequest) EqualVT(that *PushBytesRequest) bool

func (*PushBytesRequest) GetIds added in v0.2.0 

func (x *PushBytesRequest) GetIds() [][]byte

func (*PushBytesRequest) GetSearchData added in v0.2.0 

func (x *PushBytesRequest) GetSearchData() [][]byte

func (*PushBytesRequest) GetTraces added in v0.2.0 

func (x *PushBytesRequest) GetTraces() [][]byte

func (*PushBytesRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *PushBytesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PushBytesRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *PushBytesRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*PushBytesRequest) MarshalToVT added in v0.2.0 

func (m *PushBytesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PushBytesRequest) MarshalToVTStrict added in v0.2.0 

func (m *PushBytesRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*PushBytesRequest) MarshalVT added in v0.2.0 

func (m *PushBytesRequest) MarshalVT() (dAtA []byte, err error)

func (*PushBytesRequest) MarshalVTStrict added in v0.2.0 

func (m *PushBytesRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*PushBytesRequest) ProtoMessage 

func (*PushBytesRequest) ProtoMessage()

func (*PushBytesRequest) ProtoReflect added in v0.2.0 

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

func (*PushBytesRequest) Reset 

func (x *PushBytesRequest) Reset()

func (*PushBytesRequest) SizeVT added in v0.2.0 

func (m *PushBytesRequest) SizeVT() (n int)

func (*PushBytesRequest) String 

func (x *PushBytesRequest) String() string

func (*PushBytesRequest) UnmarshalVT added in v0.2.0 

func (m *PushBytesRequest) UnmarshalVT(dAtA []byte) error

type PushErrorReason 

type PushErrorReason int32
const (
	PushErrorReason_NO_ERROR        PushErrorReason = 0
	PushErrorReason_MAX_LIVE_TRACES PushErrorReason = 1
	PushErrorReason_TRACE_TOO_LARGE PushErrorReason = 2
	PushErrorReason_UNKNOWN_ERROR   PushErrorReason = 3
)

func (PushErrorReason) Descriptor added in v0.2.0 

func (PushErrorReason) Descriptor() protoreflect.EnumDescriptor

func (PushErrorReason) Enum added in v0.2.0 

func (x PushErrorReason) Enum() *PushErrorReason

func (PushErrorReason) EnumDescriptor deprecated 

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

Deprecated: Use PushErrorReason.Descriptor instead.

func (PushErrorReason) Number added in v0.2.0 

func (x PushErrorReason) Number() protoreflect.EnumNumber

func (PushErrorReason) String 

func (x PushErrorReason) String() string

func (PushErrorReason) Type added in v0.2.0 

func (PushErrorReason) Type() protoreflect.EnumType

type PushResponse 

type PushResponse struct {
	ErrorsByTrace []PushErrorReason `protobuf:"varint,1,rep,packed,name=errorsByTrace,proto3,enum=opentelemetry.PushErrorReason" json:"errorsByTrace,omitempty"`
	// contains filtered or unexported fields
}

Write

func (*PushResponse) CloneMessageVT added in v0.2.0 

func (m *PushResponse) CloneMessageVT() proto.Message

func (*PushResponse) CloneVT added in v0.2.0 

func (m *PushResponse) CloneVT() *PushResponse

func (*PushResponse) Descriptor deprecated 

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

Deprecated: Use PushResponse.ProtoReflect.Descriptor instead.

func (*PushResponse) EqualMessageVT added in v0.2.0 

func (this *PushResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*PushResponse) EqualVT added in v0.2.0 

func (this *PushResponse) EqualVT(that *PushResponse) bool

func (*PushResponse) GetErrorsByTrace 

func (x *PushResponse) GetErrorsByTrace() []PushErrorReason

func (*PushResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *PushResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PushResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *PushResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*PushResponse) MarshalToVT added in v0.2.0 

func (m *PushResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PushResponse) MarshalToVTStrict added in v0.2.0 

func (m *PushResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*PushResponse) MarshalVT added in v0.2.0 

func (m *PushResponse) MarshalVT() (dAtA []byte, err error)

func (*PushResponse) MarshalVTStrict added in v0.2.0 

func (m *PushResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) ProtoReflect added in v0.2.0 

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

func (*PushResponse) Reset 

func (x *PushResponse) Reset()

func (*PushResponse) SizeVT added in v0.2.0 

func (m *PushResponse) SizeVT() (n int)

func (*PushResponse) String 

func (x *PushResponse) String() string

func (*PushResponse) UnmarshalVT added in v0.2.0 

func (m *PushResponse) UnmarshalVT(dAtA []byte) error

type PushSpansRequest 

type PushSpansRequest struct {

	// just send entire OTel spans for now
	Batches []*v11.ResourceSpans `protobuf:"bytes,1,rep,name=batches,proto3" json:"batches,omitempty"`
	// contains filtered or unexported fields
}

func (*PushSpansRequest) CloneMessageVT added in v0.2.0 

func (m *PushSpansRequest) CloneMessageVT() proto.Message

func (*PushSpansRequest) CloneVT added in v0.2.0 

func (m *PushSpansRequest) CloneVT() *PushSpansRequest

func (*PushSpansRequest) Descriptor deprecated 

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

Deprecated: Use PushSpansRequest.ProtoReflect.Descriptor instead.

func (*PushSpansRequest) EqualMessageVT added in v0.2.0 

func (this *PushSpansRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*PushSpansRequest) EqualVT added in v0.2.0 

func (this *PushSpansRequest) EqualVT(that *PushSpansRequest) bool

func (*PushSpansRequest) GetBatches 

func (x *PushSpansRequest) GetBatches() []*v11.ResourceSpans

func (*PushSpansRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *PushSpansRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PushSpansRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *PushSpansRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*PushSpansRequest) MarshalToVT added in v0.2.0 

func (m *PushSpansRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PushSpansRequest) MarshalToVTStrict added in v0.2.0 

func (m *PushSpansRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*PushSpansRequest) MarshalVT added in v0.2.0 

func (m *PushSpansRequest) MarshalVT() (dAtA []byte, err error)

func (*PushSpansRequest) MarshalVTStrict added in v0.2.0 

func (m *PushSpansRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*PushSpansRequest) ProtoMessage 

func (*PushSpansRequest) ProtoMessage()

func (*PushSpansRequest) ProtoReflect added in v0.2.0 

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

func (*PushSpansRequest) Reset 

func (x *PushSpansRequest) Reset()

func (*PushSpansRequest) SizeVT added in v0.2.0 

func (m *PushSpansRequest) SizeVT() (n int)

func (*PushSpansRequest) String 

func (x *PushSpansRequest) String() string

func (*PushSpansRequest) UnmarshalVT added in v0.2.0 

func (m *PushSpansRequest) UnmarshalVT(dAtA []byte) error

type PusherClient 

type PusherClient interface {
	// different versions of PushBytes expect the trace data to be pushed in
	// different formats
	PushBytes(ctx context.Context, in *PushBytesRequest, opts ...grpc.CallOption) (*PushResponse, error)
	PushBytesV2(ctx context.Context, in *PushBytesRequest, opts ...grpc.CallOption) (*PushResponse, error)
}

PusherClient is the client API for Pusher service.

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

func NewPusherClient 

func NewPusherClient(cc grpc.ClientConnInterface) PusherClient

type PusherServer 

type PusherServer interface {
	// different versions of PushBytes expect the trace data to be pushed in
	// different formats
	PushBytes(context.Context, *PushBytesRequest) (*PushResponse, error)
	PushBytesV2(context.Context, *PushBytesRequest) (*PushResponse, error)
	// contains filtered or unexported methods
}

PusherServer is the server API for Pusher service. All implementations must embed UnimplementedPusherServer for forward compatibility

type QuerierClient 

type QuerierClient interface {
	FindTraceByID(ctx context.Context, in *TraceByIDRequest, opts ...grpc.CallOption) (*TraceByIDResponse, error)
	SearchRecent(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	SearchBlock(ctx context.Context, in *SearchBlockRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	SearchTags(ctx context.Context, in *SearchTagsRequest, opts ...grpc.CallOption) (*SearchTagsResponse, error)
	SearchTagsV2(ctx context.Context, in *SearchTagsRequest, opts ...grpc.CallOption) (*SearchTagsV2Response, error)
	SearchTagValues(ctx context.Context, in *SearchTagValuesRequest, opts ...grpc.CallOption) (*SearchTagValuesResponse, error)
	SearchTagValuesV2(ctx context.Context, in *SearchTagValuesRequest, opts ...grpc.CallOption) (*SearchTagValuesV2Response, error)
}

QuerierClient is the client API for Querier service.

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

func NewQuerierClient 

func NewQuerierClient(cc grpc.ClientConnInterface) QuerierClient

type QuerierServer 

type QuerierServer interface {
	FindTraceByID(context.Context, *TraceByIDRequest) (*TraceByIDResponse, error)
	SearchRecent(context.Context, *SearchRequest) (*SearchResponse, error)
	SearchBlock(context.Context, *SearchBlockRequest) (*SearchResponse, error)
	SearchTags(context.Context, *SearchTagsRequest) (*SearchTagsResponse, error)
	SearchTagsV2(context.Context, *SearchTagsRequest) (*SearchTagsV2Response, error)
	SearchTagValues(context.Context, *SearchTagValuesRequest) (*SearchTagValuesResponse, error)
	SearchTagValuesV2(context.Context, *SearchTagValuesRequest) (*SearchTagValuesV2Response, error)
	// contains filtered or unexported methods
}

QuerierServer is the server API for Querier service. All implementations must embed UnimplementedQuerierServer for forward compatibility

type QueryRangeRequest 

type QueryRangeRequest struct {
	Query      string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Start      uint64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End        uint64 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	Step       uint64 `protobuf:"varint,4,opt,name=step,proto3" json:"step,omitempty"`
	ShardID    uint32 `protobuf:"varint,5,opt,name=shardID,proto3" json:"shardID,omitempty"`
	ShardCount uint32 `protobuf:"varint,6,opt,name=shardCount,proto3" json:"shardCount,omitempty"`
	QueryMode  string `protobuf:"bytes,7,opt,name=queryMode,proto3" json:"queryMode,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRangeRequest) CloneMessageVT added in v0.2.0 

func (m *QueryRangeRequest) CloneMessageVT() proto.Message

func (*QueryRangeRequest) CloneVT added in v0.2.0 

func (m *QueryRangeRequest) CloneVT() *QueryRangeRequest

func (*QueryRangeRequest) Descriptor deprecated 

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

Deprecated: Use QueryRangeRequest.ProtoReflect.Descriptor instead.

func (*QueryRangeRequest) EqualMessageVT added in v0.2.0 

func (this *QueryRangeRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*QueryRangeRequest) EqualVT added in v0.2.0 

func (this *QueryRangeRequest) EqualVT(that *QueryRangeRequest) bool

func (*QueryRangeRequest) GetEnd 

func (x *QueryRangeRequest) GetEnd() uint64

func (*QueryRangeRequest) GetQuery 

func (x *QueryRangeRequest) GetQuery() string

func (*QueryRangeRequest) GetQueryMode 

func (x *QueryRangeRequest) GetQueryMode() string

func (*QueryRangeRequest) GetShardCount 

func (x *QueryRangeRequest) GetShardCount() uint32

func (*QueryRangeRequest) GetShardID 

func (x *QueryRangeRequest) GetShardID() uint32

func (*QueryRangeRequest) GetStart 

func (x *QueryRangeRequest) GetStart() uint64

func (*QueryRangeRequest) GetStep 

func (x *QueryRangeRequest) GetStep() uint64

func (*QueryRangeRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *QueryRangeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRangeRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *QueryRangeRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*QueryRangeRequest) MarshalToVT added in v0.2.0 

func (m *QueryRangeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRangeRequest) MarshalToVTStrict added in v0.2.0 

func (m *QueryRangeRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*QueryRangeRequest) MarshalVT added in v0.2.0 

func (m *QueryRangeRequest) MarshalVT() (dAtA []byte, err error)

func (*QueryRangeRequest) MarshalVTStrict added in v0.2.0 

func (m *QueryRangeRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*QueryRangeRequest) ProtoMessage 

func (*QueryRangeRequest) ProtoMessage()

func (*QueryRangeRequest) ProtoReflect added in v0.2.0 

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

func (*QueryRangeRequest) Reset 

func (x *QueryRangeRequest) Reset()

func (*QueryRangeRequest) SizeVT added in v0.2.0 

func (m *QueryRangeRequest) SizeVT() (n int)

func (*QueryRangeRequest) String 

func (x *QueryRangeRequest) String() string

func (*QueryRangeRequest) UnmarshalVT added in v0.2.0 

func (m *QueryRangeRequest) UnmarshalVT(dAtA []byte) error

type QueryRangeResponse 

type QueryRangeResponse struct {
	Series  []*TimeSeries  `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	Metrics *SearchMetrics `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRangeResponse) CloneMessageVT added in v0.2.0 

func (m *QueryRangeResponse) CloneMessageVT() proto.Message

func (*QueryRangeResponse) CloneVT added in v0.2.0 

func (m *QueryRangeResponse) CloneVT() *QueryRangeResponse

func (*QueryRangeResponse) Descriptor deprecated 

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

Deprecated: Use QueryRangeResponse.ProtoReflect.Descriptor instead.

func (*QueryRangeResponse) EqualMessageVT added in v0.2.0 

func (this *QueryRangeResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*QueryRangeResponse) EqualVT added in v0.2.0 

func (this *QueryRangeResponse) EqualVT(that *QueryRangeResponse) bool

func (*QueryRangeResponse) GetMetrics 

func (x *QueryRangeResponse) GetMetrics() *SearchMetrics

func (*QueryRangeResponse) GetSeries 

func (x *QueryRangeResponse) GetSeries() []*TimeSeries

func (*QueryRangeResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *QueryRangeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRangeResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *QueryRangeResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*QueryRangeResponse) MarshalToVT added in v0.2.0 

func (m *QueryRangeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRangeResponse) MarshalToVTStrict added in v0.2.0 

func (m *QueryRangeResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*QueryRangeResponse) MarshalVT added in v0.2.0 

func (m *QueryRangeResponse) MarshalVT() (dAtA []byte, err error)

func (*QueryRangeResponse) MarshalVTStrict added in v0.2.0 

func (m *QueryRangeResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*QueryRangeResponse) ProtoMessage 

func (*QueryRangeResponse) ProtoMessage()

func (*QueryRangeResponse) ProtoReflect added in v0.2.0 

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

func (*QueryRangeResponse) Reset 

func (x *QueryRangeResponse) Reset()

func (*QueryRangeResponse) SizeVT added in v0.2.0 

func (m *QueryRangeResponse) SizeVT() (n int)

func (*QueryRangeResponse) String 

func (x *QueryRangeResponse) String() string

func (*QueryRangeResponse) UnmarshalVT added in v0.2.0 

func (m *QueryRangeResponse) UnmarshalVT(dAtA []byte) error

type RawHistogram 

type RawHistogram struct {
	Bucket uint64 `protobuf:"varint,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Count  uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*RawHistogram) CloneMessageVT added in v0.2.0 

func (m *RawHistogram) CloneMessageVT() proto.Message

func (*RawHistogram) CloneVT added in v0.2.0 

func (m *RawHistogram) CloneVT() *RawHistogram

func (*RawHistogram) Descriptor deprecated 

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

Deprecated: Use RawHistogram.ProtoReflect.Descriptor instead.

func (*RawHistogram) EqualMessageVT added in v0.2.0 

func (this *RawHistogram) EqualMessageVT(thatMsg proto.Message) bool

func (*RawHistogram) EqualVT added in v0.2.0 

func (this *RawHistogram) EqualVT(that *RawHistogram) bool

func (*RawHistogram) GetBucket 

func (x *RawHistogram) GetBucket() uint64

func (*RawHistogram) GetCount 

func (x *RawHistogram) GetCount() uint64

func (*RawHistogram) MarshalToSizedBufferVT added in v0.2.0 

func (m *RawHistogram) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RawHistogram) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *RawHistogram) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*RawHistogram) MarshalToVT added in v0.2.0 

func (m *RawHistogram) MarshalToVT(dAtA []byte) (int, error)

func (*RawHistogram) MarshalToVTStrict added in v0.2.0 

func (m *RawHistogram) MarshalToVTStrict(dAtA []byte) (int, error)

func (*RawHistogram) MarshalVT added in v0.2.0 

func (m *RawHistogram) MarshalVT() (dAtA []byte, err error)

func (*RawHistogram) MarshalVTStrict added in v0.2.0 

func (m *RawHistogram) MarshalVTStrict() (dAtA []byte, err error)

func (*RawHistogram) ProtoMessage 

func (*RawHistogram) ProtoMessage()

func (*RawHistogram) ProtoReflect added in v0.2.0 

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

func (*RawHistogram) Reset 

func (x *RawHistogram) Reset()

func (*RawHistogram) SizeVT added in v0.2.0 

func (m *RawHistogram) SizeVT() (n int)

func (*RawHistogram) String 

func (x *RawHistogram) String() string

func (*RawHistogram) UnmarshalVT added in v0.2.0 

func (m *RawHistogram) UnmarshalVT(dAtA []byte) error

type Sample 

type Sample struct {

	// Fields order MUST match promql.FPoint so that we can cast types between them.
	TimestampMs int64   `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	Value       float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Sample) CloneMessageVT added in v0.2.0 

func (m *Sample) CloneMessageVT() proto.Message

func (*Sample) CloneVT added in v0.2.0 

func (m *Sample) CloneVT() *Sample

func (*Sample) Descriptor deprecated 

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

Deprecated: Use Sample.ProtoReflect.Descriptor instead.

func (*Sample) EqualMessageVT added in v0.2.0 

func (this *Sample) EqualMessageVT(thatMsg proto.Message) bool

func (*Sample) EqualVT added in v0.2.0 

func (this *Sample) EqualVT(that *Sample) bool

func (*Sample) GetTimestampMs 

func (x *Sample) GetTimestampMs() int64

func (*Sample) GetValue 

func (x *Sample) GetValue() float64

func (*Sample) MarshalToSizedBufferVT added in v0.2.0 

func (m *Sample) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Sample) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *Sample) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Sample) MarshalToVT added in v0.2.0 

func (m *Sample) MarshalToVT(dAtA []byte) (int, error)

func (*Sample) MarshalToVTStrict added in v0.2.0 

func (m *Sample) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Sample) MarshalVT added in v0.2.0 

func (m *Sample) MarshalVT() (dAtA []byte, err error)

func (*Sample) MarshalVTStrict added in v0.2.0 

func (m *Sample) MarshalVTStrict() (dAtA []byte, err error)

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) ProtoReflect added in v0.2.0 

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

func (*Sample) Reset 

func (x *Sample) Reset()

func (*Sample) SizeVT added in v0.2.0 

func (m *Sample) SizeVT() (n int)

func (*Sample) String 

func (x *Sample) String() string

func (*Sample) UnmarshalVT added in v0.2.0 

func (m *Sample) UnmarshalVT(dAtA []byte) error

type SearchBlockRequest 

type SearchBlockRequest struct {
	SearchReq        *SearchRequest     `protobuf:"bytes,1,opt,name=searchReq,proto3" json:"searchReq,omitempty"`
	BlockID          string             `protobuf:"bytes,2,opt,name=blockID,proto3" json:"blockID,omitempty"`
	StartPage        uint32             `protobuf:"varint,3,opt,name=startPage,proto3" json:"startPage,omitempty"`
	PagesToSearch    uint32             `protobuf:"varint,4,opt,name=pagesToSearch,proto3" json:"pagesToSearch,omitempty"`
	Encoding         string             `protobuf:"bytes,5,opt,name=encoding,proto3" json:"encoding,omitempty"`
	IndexPageSize    uint32             `protobuf:"varint,6,opt,name=indexPageSize,proto3" json:"indexPageSize,omitempty"`
	TotalRecords     uint32             `protobuf:"varint,7,opt,name=totalRecords,proto3" json:"totalRecords,omitempty"`
	DataEncoding     string             `protobuf:"bytes,8,opt,name=dataEncoding,proto3" json:"dataEncoding,omitempty"`
	Version          string             `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	Size             uint64             `protobuf:"varint,10,opt,name=size,proto3" json:"size,omitempty"`             // total size of data file
	FooterSize       uint32             `protobuf:"varint,11,opt,name=footerSize,proto3" json:"footerSize,omitempty"` // size of file footer (parquet)
	DedicatedColumns []*DedicatedColumn `protobuf:"bytes,12,rep,name=dedicatedColumns,proto3" json:"dedicatedColumns,omitempty"`
	// contains filtered or unexported fields
}

SearchBlockRequest takes SearchRequest parameters as well as all information necessary to search a block in the backend.

func (*SearchBlockRequest) CloneMessageVT added in v0.2.0 

func (m *SearchBlockRequest) CloneMessageVT() proto.Message

func (*SearchBlockRequest) CloneVT added in v0.2.0 

func (m *SearchBlockRequest) CloneVT() *SearchBlockRequest

func (*SearchBlockRequest) Descriptor deprecated 

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

Deprecated: Use SearchBlockRequest.ProtoReflect.Descriptor instead.

func (*SearchBlockRequest) EqualMessageVT added in v0.2.0 

func (this *SearchBlockRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchBlockRequest) EqualVT added in v0.2.0 

func (this *SearchBlockRequest) EqualVT(that *SearchBlockRequest) bool

func (*SearchBlockRequest) GetBlockID 

func (x *SearchBlockRequest) GetBlockID() string

func (*SearchBlockRequest) GetDataEncoding 

func (x *SearchBlockRequest) GetDataEncoding() string

func (*SearchBlockRequest) GetDedicatedColumns 

func (x *SearchBlockRequest) GetDedicatedColumns() []*DedicatedColumn

func (*SearchBlockRequest) GetEncoding 

func (x *SearchBlockRequest) GetEncoding() string

func (*SearchBlockRequest) GetFooterSize 

func (x *SearchBlockRequest) GetFooterSize() uint32

func (*SearchBlockRequest) GetIndexPageSize 

func (x *SearchBlockRequest) GetIndexPageSize() uint32

func (*SearchBlockRequest) GetPagesToSearch 

func (x *SearchBlockRequest) GetPagesToSearch() uint32

func (*SearchBlockRequest) GetSearchReq 

func (x *SearchBlockRequest) GetSearchReq() *SearchRequest

func (*SearchBlockRequest) GetSize added in v0.2.0 

func (x *SearchBlockRequest) GetSize() uint64

func (*SearchBlockRequest) GetStartPage 

func (x *SearchBlockRequest) GetStartPage() uint32

func (*SearchBlockRequest) GetTotalRecords 

func (x *SearchBlockRequest) GetTotalRecords() uint32

func (*SearchBlockRequest) GetVersion 

func (x *SearchBlockRequest) GetVersion() string

func (*SearchBlockRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchBlockRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchBlockRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchBlockRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchBlockRequest) MarshalToVT added in v0.2.0 

func (m *SearchBlockRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SearchBlockRequest) MarshalToVTStrict added in v0.2.0 

func (m *SearchBlockRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchBlockRequest) MarshalVT added in v0.2.0 

func (m *SearchBlockRequest) MarshalVT() (dAtA []byte, err error)

func (*SearchBlockRequest) MarshalVTStrict added in v0.2.0 

func (m *SearchBlockRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchBlockRequest) ProtoMessage 

func (*SearchBlockRequest) ProtoMessage()

func (*SearchBlockRequest) ProtoReflect added in v0.2.0 

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

func (*SearchBlockRequest) Reset 

func (x *SearchBlockRequest) Reset()

func (*SearchBlockRequest) SizeVT added in v0.2.0 

func (m *SearchBlockRequest) SizeVT() (n int)

func (*SearchBlockRequest) String 

func (x *SearchBlockRequest) String() string

func (*SearchBlockRequest) UnmarshalVT added in v0.2.0 

func (m *SearchBlockRequest) UnmarshalVT(dAtA []byte) error

type SearchMetrics 

type SearchMetrics struct {
	InspectedTraces uint32 `protobuf:"varint,1,opt,name=inspectedTraces,proto3" json:"inspectedTraces,omitempty"`
	InspectedBytes  uint64 `protobuf:"varint,2,opt,name=inspectedBytes,proto3" json:"inspectedBytes,omitempty"`
	TotalBlocks     uint32 `protobuf:"varint,3,opt,name=totalBlocks,proto3" json:"totalBlocks,omitempty"`
	CompletedJobs   uint32 `protobuf:"varint,4,opt,name=completedJobs,proto3" json:"completedJobs,omitempty"`
	TotalJobs       uint32 `protobuf:"varint,5,opt,name=totalJobs,proto3" json:"totalJobs,omitempty"`
	TotalBlockBytes uint64 `protobuf:"varint,6,opt,name=totalBlockBytes,proto3" json:"totalBlockBytes,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchMetrics) CloneMessageVT added in v0.2.0 

func (m *SearchMetrics) CloneMessageVT() proto.Message

func (*SearchMetrics) CloneVT added in v0.2.0 

func (m *SearchMetrics) CloneVT() *SearchMetrics

func (*SearchMetrics) Descriptor deprecated 

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

Deprecated: Use SearchMetrics.ProtoReflect.Descriptor instead.

func (*SearchMetrics) EqualMessageVT added in v0.2.0 

func (this *SearchMetrics) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchMetrics) EqualVT added in v0.2.0 

func (this *SearchMetrics) EqualVT(that *SearchMetrics) bool

func (*SearchMetrics) GetCompletedJobs 

func (x *SearchMetrics) GetCompletedJobs() uint32

func (*SearchMetrics) GetInspectedBytes 

func (x *SearchMetrics) GetInspectedBytes() uint64

func (*SearchMetrics) GetInspectedTraces 

func (x *SearchMetrics) GetInspectedTraces() uint32

func (*SearchMetrics) GetTotalBlockBytes 

func (x *SearchMetrics) GetTotalBlockBytes() uint64

func (*SearchMetrics) GetTotalBlocks 

func (x *SearchMetrics) GetTotalBlocks() uint32

func (*SearchMetrics) GetTotalJobs 

func (x *SearchMetrics) GetTotalJobs() uint32

func (*SearchMetrics) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchMetrics) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchMetrics) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchMetrics) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchMetrics) MarshalToVT added in v0.2.0 

func (m *SearchMetrics) MarshalToVT(dAtA []byte) (int, error)

func (*SearchMetrics) MarshalToVTStrict added in v0.2.0 

func (m *SearchMetrics) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchMetrics) MarshalVT added in v0.2.0 

func (m *SearchMetrics) MarshalVT() (dAtA []byte, err error)

func (*SearchMetrics) MarshalVTStrict added in v0.2.0 

func (m *SearchMetrics) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchMetrics) ProtoMessage 

func (*SearchMetrics) ProtoMessage()

func (*SearchMetrics) ProtoReflect added in v0.2.0 

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

func (*SearchMetrics) Reset 

func (x *SearchMetrics) Reset()

func (*SearchMetrics) SizeVT added in v0.2.0 

func (m *SearchMetrics) SizeVT() (n int)

func (*SearchMetrics) String 

func (x *SearchMetrics) String() string

func (*SearchMetrics) UnmarshalVT added in v0.2.0 

func (m *SearchMetrics) UnmarshalVT(dAtA []byte) error

type SearchRequest 

type SearchRequest struct {

	// case insensitive partial match
	Tags          map[string]string `` /* 149-byte string literal not displayed */
	MinDurationMs uint32            `protobuf:"varint,2,opt,name=MinDurationMs,proto3" json:"MinDurationMs,omitempty"`
	MaxDurationMs uint32            `protobuf:"varint,3,opt,name=MaxDurationMs,proto3" json:"MaxDurationMs,omitempty"`
	Limit         uint32            `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	Start         uint32            `protobuf:"varint,5,opt,name=start,proto3" json:"start,omitempty"`
	End           uint32            `protobuf:"varint,6,opt,name=end,proto3" json:"end,omitempty"`
	// TraceQL query
	Query           string `protobuf:"bytes,8,opt,name=Query,proto3" json:"Query,omitempty"`
	SpansPerSpanSet uint32 `protobuf:"varint,9,opt,name=SpansPerSpanSet,proto3" json:"SpansPerSpanSet,omitempty"`
	// contains filtered or unexported fields
}

SearchRequest takes no block parameters and implies a "recent traces" search

func (*SearchRequest) CloneMessageVT added in v0.2.0 

func (m *SearchRequest) CloneMessageVT() proto.Message

func (*SearchRequest) CloneVT added in v0.2.0 

func (m *SearchRequest) CloneVT() *SearchRequest

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) EqualMessageVT added in v0.2.0 

func (this *SearchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchRequest) EqualVT added in v0.2.0 

func (this *SearchRequest) EqualVT(that *SearchRequest) bool

func (*SearchRequest) GetEnd 

func (x *SearchRequest) GetEnd() uint32

func (*SearchRequest) GetLimit 

func (x *SearchRequest) GetLimit() uint32

func (*SearchRequest) GetMaxDurationMs 

func (x *SearchRequest) GetMaxDurationMs() uint32

func (*SearchRequest) GetMinDurationMs 

func (x *SearchRequest) GetMinDurationMs() uint32

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) GetSpansPerSpanSet 

func (x *SearchRequest) GetSpansPerSpanSet() uint32

func (*SearchRequest) GetStart 

func (x *SearchRequest) GetStart() uint32

func (*SearchRequest) GetTags 

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

func (*SearchRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchRequest) MarshalToVT added in v0.2.0 

func (m *SearchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SearchRequest) MarshalToVTStrict added in v0.2.0 

func (m *SearchRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchRequest) MarshalVT added in v0.2.0 

func (m *SearchRequest) MarshalVT() (dAtA []byte, err error)

func (*SearchRequest) MarshalVTStrict added in v0.2.0 

func (m *SearchRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect added in v0.2.0 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) SizeVT added in v0.2.0 

func (m *SearchRequest) SizeVT() (n int)

func (*SearchRequest) String 

func (x *SearchRequest) String() string

func (*SearchRequest) UnmarshalVT added in v0.2.0 

func (m *SearchRequest) UnmarshalVT(dAtA []byte) error

type SearchResponse 

type SearchResponse struct {
	Traces  []*TraceSearchMetadata `protobuf:"bytes,1,rep,name=traces,proto3" json:"traces,omitempty"`
	Metrics *SearchMetrics         `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse) CloneMessageVT added in v0.2.0 

func (m *SearchResponse) CloneMessageVT() proto.Message

func (*SearchResponse) CloneVT added in v0.2.0 

func (m *SearchResponse) CloneVT() *SearchResponse

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) EqualMessageVT added in v0.2.0 

func (this *SearchResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchResponse) EqualVT added in v0.2.0 

func (this *SearchResponse) EqualVT(that *SearchResponse) bool

func (*SearchResponse) GetMetrics 

func (x *SearchResponse) GetMetrics() *SearchMetrics

func (*SearchResponse) GetTraces 

func (x *SearchResponse) GetTraces() []*TraceSearchMetadata

func (*SearchResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchResponse) MarshalToVT added in v0.2.0 

func (m *SearchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SearchResponse) MarshalToVTStrict added in v0.2.0 

func (m *SearchResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchResponse) MarshalVT added in v0.2.0 

func (m *SearchResponse) MarshalVT() (dAtA []byte, err error)

func (*SearchResponse) MarshalVTStrict added in v0.2.0 

func (m *SearchResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect added in v0.2.0 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) SizeVT added in v0.2.0 

func (m *SearchResponse) SizeVT() (n int)

func (*SearchResponse) String 

func (x *SearchResponse) String() string

func (*SearchResponse) UnmarshalVT added in v0.2.0 

func (m *SearchResponse) UnmarshalVT(dAtA []byte) error

type SearchTagValuesRequest 

type SearchTagValuesRequest struct {
	TagName string `protobuf:"bytes,1,opt,name=tagName,proto3" json:"tagName,omitempty"`
	Query   string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // TraceQL query
	// contains filtered or unexported fields
}

func (*SearchTagValuesRequest) CloneMessageVT added in v0.2.0 

func (m *SearchTagValuesRequest) CloneMessageVT() proto.Message

func (*SearchTagValuesRequest) CloneVT added in v0.2.0 

func (m *SearchTagValuesRequest) CloneVT() *SearchTagValuesRequest

func (*SearchTagValuesRequest) Descriptor deprecated 

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

Deprecated: Use SearchTagValuesRequest.ProtoReflect.Descriptor instead.

func (*SearchTagValuesRequest) EqualMessageVT added in v0.2.0 

func (this *SearchTagValuesRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchTagValuesRequest) EqualVT added in v0.2.0 

func (this *SearchTagValuesRequest) EqualVT(that *SearchTagValuesRequest) bool

func (*SearchTagValuesRequest) GetQuery 

func (x *SearchTagValuesRequest) GetQuery() string

func (*SearchTagValuesRequest) GetTagName 

func (x *SearchTagValuesRequest) GetTagName() string

func (*SearchTagValuesRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchTagValuesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchTagValuesRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchTagValuesRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchTagValuesRequest) MarshalToVT added in v0.2.0 

func (m *SearchTagValuesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SearchTagValuesRequest) MarshalToVTStrict added in v0.2.0 

func (m *SearchTagValuesRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchTagValuesRequest) MarshalVT added in v0.2.0 

func (m *SearchTagValuesRequest) MarshalVT() (dAtA []byte, err error)

func (*SearchTagValuesRequest) MarshalVTStrict added in v0.2.0 

func (m *SearchTagValuesRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchTagValuesRequest) ProtoMessage 

func (*SearchTagValuesRequest) ProtoMessage()

func (*SearchTagValuesRequest) ProtoReflect added in v0.2.0 

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

func (*SearchTagValuesRequest) Reset 

func (x *SearchTagValuesRequest) Reset()

func (*SearchTagValuesRequest) SizeVT added in v0.2.0 

func (m *SearchTagValuesRequest) SizeVT() (n int)

func (*SearchTagValuesRequest) String 

func (x *SearchTagValuesRequest) String() string

func (*SearchTagValuesRequest) UnmarshalVT added in v0.2.0 

func (m *SearchTagValuesRequest) UnmarshalVT(dAtA []byte) error

type SearchTagValuesResponse 

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

func (*SearchTagValuesResponse) CloneMessageVT added in v0.2.0 

func (m *SearchTagValuesResponse) CloneMessageVT() proto.Message

func (*SearchTagValuesResponse) CloneVT added in v0.2.0 

func (m *SearchTagValuesResponse) CloneVT() *SearchTagValuesResponse

func (*SearchTagValuesResponse) Descriptor deprecated 

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

Deprecated: Use SearchTagValuesResponse.ProtoReflect.Descriptor instead.

func (*SearchTagValuesResponse) EqualMessageVT added in v0.2.0 

func (this *SearchTagValuesResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchTagValuesResponse) EqualVT added in v0.2.0 

func (this *SearchTagValuesResponse) EqualVT(that *SearchTagValuesResponse) bool

func (*SearchTagValuesResponse) GetTagValues 

func (x *SearchTagValuesResponse) GetTagValues() []string

func (*SearchTagValuesResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchTagValuesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchTagValuesResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchTagValuesResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchTagValuesResponse) MarshalToVT added in v0.2.0 

func (m *SearchTagValuesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SearchTagValuesResponse) MarshalToVTStrict added in v0.2.0 

func (m *SearchTagValuesResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchTagValuesResponse) MarshalVT added in v0.2.0 

func (m *SearchTagValuesResponse) MarshalVT() (dAtA []byte, err error)

func (*SearchTagValuesResponse) MarshalVTStrict added in v0.2.0 

func (m *SearchTagValuesResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchTagValuesResponse) ProtoMessage 

func (*SearchTagValuesResponse) ProtoMessage()

func (*SearchTagValuesResponse) ProtoReflect added in v0.2.0 

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

func (*SearchTagValuesResponse) Reset 

func (x *SearchTagValuesResponse) Reset()

func (*SearchTagValuesResponse) SizeVT added in v0.2.0 

func (m *SearchTagValuesResponse) SizeVT() (n int)

func (*SearchTagValuesResponse) String 

func (x *SearchTagValuesResponse) String() string

func (*SearchTagValuesResponse) UnmarshalVT added in v0.2.0 

func (m *SearchTagValuesResponse) UnmarshalVT(dAtA []byte) error

type SearchTagValuesV2Response 

type SearchTagValuesV2Response struct {
	TagValues []*TagValue `protobuf:"bytes,1,rep,name=tagValues,proto3" json:"tagValues,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagValuesV2Response) CloneMessageVT added in v0.2.0 

func (m *SearchTagValuesV2Response) CloneMessageVT() proto.Message

func (*SearchTagValuesV2Response) CloneVT added in v0.2.0 

func (m *SearchTagValuesV2Response) CloneVT() *SearchTagValuesV2Response

func (*SearchTagValuesV2Response) Descriptor deprecated 

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

Deprecated: Use SearchTagValuesV2Response.ProtoReflect.Descriptor instead.

func (*SearchTagValuesV2Response) EqualMessageVT added in v0.2.0 

func (this *SearchTagValuesV2Response) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchTagValuesV2Response) EqualVT added in v0.2.0 

func (this *SearchTagValuesV2Response) EqualVT(that *SearchTagValuesV2Response) bool

func (*SearchTagValuesV2Response) GetTagValues 

func (x *SearchTagValuesV2Response) GetTagValues() []*TagValue

func (*SearchTagValuesV2Response) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchTagValuesV2Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchTagValuesV2Response) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchTagValuesV2Response) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchTagValuesV2Response) MarshalToVT added in v0.2.0 

func (m *SearchTagValuesV2Response) MarshalToVT(dAtA []byte) (int, error)

func (*SearchTagValuesV2Response) MarshalToVTStrict added in v0.2.0 

func (m *SearchTagValuesV2Response) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchTagValuesV2Response) MarshalVT added in v0.2.0 

func (m *SearchTagValuesV2Response) MarshalVT() (dAtA []byte, err error)

func (*SearchTagValuesV2Response) MarshalVTStrict added in v0.2.0 

func (m *SearchTagValuesV2Response) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchTagValuesV2Response) ProtoMessage 

func (*SearchTagValuesV2Response) ProtoMessage()

func (*SearchTagValuesV2Response) ProtoReflect added in v0.2.0 

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

func (*SearchTagValuesV2Response) Reset 

func (x *SearchTagValuesV2Response) Reset()

func (*SearchTagValuesV2Response) SizeVT added in v0.2.0 

func (m *SearchTagValuesV2Response) SizeVT() (n int)

func (*SearchTagValuesV2Response) String 

func (x *SearchTagValuesV2Response) String() string

func (*SearchTagValuesV2Response) UnmarshalVT added in v0.2.0 

func (m *SearchTagValuesV2Response) UnmarshalVT(dAtA []byte) error

type SearchTagsRequest 

type SearchTagsRequest struct {
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagsRequest) CloneMessageVT added in v0.2.0 

func (m *SearchTagsRequest) CloneMessageVT() proto.Message

func (*SearchTagsRequest) CloneVT added in v0.2.0 

func (m *SearchTagsRequest) CloneVT() *SearchTagsRequest

func (*SearchTagsRequest) Descriptor deprecated 

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

Deprecated: Use SearchTagsRequest.ProtoReflect.Descriptor instead.

func (*SearchTagsRequest) EqualMessageVT added in v0.2.0 

func (this *SearchTagsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchTagsRequest) EqualVT added in v0.2.0 

func (this *SearchTagsRequest) EqualVT(that *SearchTagsRequest) bool

func (*SearchTagsRequest) GetScope 

func (x *SearchTagsRequest) GetScope() string

func (*SearchTagsRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchTagsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchTagsRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchTagsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchTagsRequest) MarshalToVT added in v0.2.0 

func (m *SearchTagsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SearchTagsRequest) MarshalToVTStrict added in v0.2.0 

func (m *SearchTagsRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchTagsRequest) MarshalVT added in v0.2.0 

func (m *SearchTagsRequest) MarshalVT() (dAtA []byte, err error)

func (*SearchTagsRequest) MarshalVTStrict added in v0.2.0 

func (m *SearchTagsRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchTagsRequest) ProtoMessage 

func (*SearchTagsRequest) ProtoMessage()

func (*SearchTagsRequest) ProtoReflect added in v0.2.0 

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

func (*SearchTagsRequest) Reset 

func (x *SearchTagsRequest) Reset()

func (*SearchTagsRequest) SizeVT added in v0.2.0 

func (m *SearchTagsRequest) SizeVT() (n int)

func (*SearchTagsRequest) String 

func (x *SearchTagsRequest) String() string

func (*SearchTagsRequest) UnmarshalVT added in v0.2.0 

func (m *SearchTagsRequest) UnmarshalVT(dAtA []byte) error

type SearchTagsResponse 

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

func (*SearchTagsResponse) CloneMessageVT added in v0.2.0 

func (m *SearchTagsResponse) CloneMessageVT() proto.Message

func (*SearchTagsResponse) CloneVT added in v0.2.0 

func (m *SearchTagsResponse) CloneVT() *SearchTagsResponse

func (*SearchTagsResponse) Descriptor deprecated 

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

Deprecated: Use SearchTagsResponse.ProtoReflect.Descriptor instead.

func (*SearchTagsResponse) EqualMessageVT added in v0.2.0 

func (this *SearchTagsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchTagsResponse) EqualVT added in v0.2.0 

func (this *SearchTagsResponse) EqualVT(that *SearchTagsResponse) bool

func (*SearchTagsResponse) GetTagNames 

func (x *SearchTagsResponse) GetTagNames() []string

func (*SearchTagsResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchTagsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchTagsResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchTagsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchTagsResponse) MarshalToVT added in v0.2.0 

func (m *SearchTagsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SearchTagsResponse) MarshalToVTStrict added in v0.2.0 

func (m *SearchTagsResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchTagsResponse) MarshalVT added in v0.2.0 

func (m *SearchTagsResponse) MarshalVT() (dAtA []byte, err error)

func (*SearchTagsResponse) MarshalVTStrict added in v0.2.0 

func (m *SearchTagsResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchTagsResponse) ProtoMessage 

func (*SearchTagsResponse) ProtoMessage()

func (*SearchTagsResponse) ProtoReflect added in v0.2.0 

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

func (*SearchTagsResponse) Reset 

func (x *SearchTagsResponse) Reset()

func (*SearchTagsResponse) SizeVT added in v0.2.0 

func (m *SearchTagsResponse) SizeVT() (n int)

func (*SearchTagsResponse) String 

func (x *SearchTagsResponse) String() string

func (*SearchTagsResponse) UnmarshalVT added in v0.2.0 

func (m *SearchTagsResponse) UnmarshalVT(dAtA []byte) error

type SearchTagsV2Response 

type SearchTagsV2Response struct {
	Scopes []*SearchTagsV2Scope `protobuf:"bytes,1,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagsV2Response) CloneMessageVT added in v0.2.0 

func (m *SearchTagsV2Response) CloneMessageVT() proto.Message

func (*SearchTagsV2Response) CloneVT added in v0.2.0 

func (m *SearchTagsV2Response) CloneVT() *SearchTagsV2Response

func (*SearchTagsV2Response) Descriptor deprecated 

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

Deprecated: Use SearchTagsV2Response.ProtoReflect.Descriptor instead.

func (*SearchTagsV2Response) EqualMessageVT added in v0.2.0 

func (this *SearchTagsV2Response) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchTagsV2Response) EqualVT added in v0.2.0 

func (this *SearchTagsV2Response) EqualVT(that *SearchTagsV2Response) bool

func (*SearchTagsV2Response) GetScopes 

func (x *SearchTagsV2Response) GetScopes() []*SearchTagsV2Scope

func (*SearchTagsV2Response) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchTagsV2Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchTagsV2Response) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchTagsV2Response) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchTagsV2Response) MarshalToVT added in v0.2.0 

func (m *SearchTagsV2Response) MarshalToVT(dAtA []byte) (int, error)

func (*SearchTagsV2Response) MarshalToVTStrict added in v0.2.0 

func (m *SearchTagsV2Response) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchTagsV2Response) MarshalVT added in v0.2.0 

func (m *SearchTagsV2Response) MarshalVT() (dAtA []byte, err error)

func (*SearchTagsV2Response) MarshalVTStrict added in v0.2.0 

func (m *SearchTagsV2Response) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchTagsV2Response) ProtoMessage 

func (*SearchTagsV2Response) ProtoMessage()

func (*SearchTagsV2Response) ProtoReflect added in v0.2.0 

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

func (*SearchTagsV2Response) Reset 

func (x *SearchTagsV2Response) Reset()

func (*SearchTagsV2Response) SizeVT added in v0.2.0 

func (m *SearchTagsV2Response) SizeVT() (n int)

func (*SearchTagsV2Response) String 

func (x *SearchTagsV2Response) String() string

func (*SearchTagsV2Response) UnmarshalVT added in v0.2.0 

func (m *SearchTagsV2Response) UnmarshalVT(dAtA []byte) error

type SearchTagsV2Scope 

type SearchTagsV2Scope struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagsV2Scope) CloneMessageVT added in v0.2.0 

func (m *SearchTagsV2Scope) CloneMessageVT() proto.Message

func (*SearchTagsV2Scope) CloneVT added in v0.2.0 

func (m *SearchTagsV2Scope) CloneVT() *SearchTagsV2Scope

func (*SearchTagsV2Scope) Descriptor deprecated 

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

Deprecated: Use SearchTagsV2Scope.ProtoReflect.Descriptor instead.

func (*SearchTagsV2Scope) EqualMessageVT added in v0.2.0 

func (this *SearchTagsV2Scope) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchTagsV2Scope) EqualVT added in v0.2.0 

func (this *SearchTagsV2Scope) EqualVT(that *SearchTagsV2Scope) bool

func (*SearchTagsV2Scope) GetName 

func (x *SearchTagsV2Scope) GetName() string

func (*SearchTagsV2Scope) GetTags 

func (x *SearchTagsV2Scope) GetTags() []string

func (*SearchTagsV2Scope) MarshalToSizedBufferVT added in v0.2.0 

func (m *SearchTagsV2Scope) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchTagsV2Scope) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SearchTagsV2Scope) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchTagsV2Scope) MarshalToVT added in v0.2.0 

func (m *SearchTagsV2Scope) MarshalToVT(dAtA []byte) (int, error)

func (*SearchTagsV2Scope) MarshalToVTStrict added in v0.2.0 

func (m *SearchTagsV2Scope) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchTagsV2Scope) MarshalVT added in v0.2.0 

func (m *SearchTagsV2Scope) MarshalVT() (dAtA []byte, err error)

func (*SearchTagsV2Scope) MarshalVTStrict added in v0.2.0 

func (m *SearchTagsV2Scope) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchTagsV2Scope) ProtoMessage 

func (*SearchTagsV2Scope) ProtoMessage()

func (*SearchTagsV2Scope) ProtoReflect added in v0.2.0 

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

func (*SearchTagsV2Scope) Reset 

func (x *SearchTagsV2Scope) Reset()

func (*SearchTagsV2Scope) SizeVT added in v0.2.0 

func (m *SearchTagsV2Scope) SizeVT() (n int)

func (*SearchTagsV2Scope) String 

func (x *SearchTagsV2Scope) String() string

func (*SearchTagsV2Scope) UnmarshalVT added in v0.2.0 

func (m *SearchTagsV2Scope) UnmarshalVT(dAtA []byte) error

type Span 

type Span struct {
	SpanID            string         `protobuf:"bytes,1,opt,name=spanID,proto3" json:"spanID,omitempty"`
	Name              string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	StartTimeUnixNano uint64         `protobuf:"varint,3,opt,name=startTimeUnixNano,proto3" json:"startTimeUnixNano,omitempty"`
	DurationNanos     uint64         `protobuf:"varint,4,opt,name=durationNanos,proto3" json:"durationNanos,omitempty"`
	Attributes        []*v1.KeyValue `protobuf:"bytes,5,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*Span) CloneMessageVT added in v0.2.0 

func (m *Span) CloneMessageVT() proto.Message

func (*Span) CloneVT added in v0.2.0 

func (m *Span) CloneVT() *Span

func (*Span) Descriptor deprecated 

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

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) EqualMessageVT added in v0.2.0 

func (this *Span) EqualMessageVT(thatMsg proto.Message) bool

func (*Span) EqualVT added in v0.2.0 

func (this *Span) EqualVT(that *Span) bool

func (*Span) GetAttributes 

func (x *Span) GetAttributes() []*v1.KeyValue

func (*Span) GetDurationNanos 

func (x *Span) GetDurationNanos() uint64

func (*Span) GetName 

func (x *Span) GetName() string

func (*Span) GetSpanID 

func (x *Span) GetSpanID() string

func (*Span) GetStartTimeUnixNano 

func (x *Span) GetStartTimeUnixNano() uint64

func (*Span) MarshalToSizedBufferVT added in v0.2.0 

func (m *Span) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Span) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *Span) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Span) MarshalToVT added in v0.2.0 

func (m *Span) MarshalToVT(dAtA []byte) (int, error)

func (*Span) MarshalToVTStrict added in v0.2.0 

func (m *Span) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Span) MarshalVT added in v0.2.0 

func (m *Span) MarshalVT() (dAtA []byte, err error)

func (*Span) MarshalVTStrict added in v0.2.0 

func (m *Span) MarshalVTStrict() (dAtA []byte, err error)

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) ProtoReflect added in v0.2.0 

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

func (*Span) Reset 

func (x *Span) Reset()

func (*Span) SizeVT added in v0.2.0 

func (m *Span) SizeVT() (n int)

func (*Span) String 

func (x *Span) String() string

func (*Span) UnmarshalVT added in v0.2.0 

func (m *Span) UnmarshalVT(dAtA []byte) error

type SpanMetrics 

type SpanMetrics struct {
	LatencyHistogram []*RawHistogram `protobuf:"bytes,1,rep,name=latency_histogram,json=latencyHistogram,proto3" json:"latency_histogram,omitempty"`
	Series           []*KeyValue     `protobuf:"bytes,2,rep,name=series,proto3" json:"series,omitempty"`
	Errors           uint64          `protobuf:"varint,3,opt,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetrics) CloneMessageVT added in v0.2.0 

func (m *SpanMetrics) CloneMessageVT() proto.Message

func (*SpanMetrics) CloneVT added in v0.2.0 

func (m *SpanMetrics) CloneVT() *SpanMetrics

func (*SpanMetrics) Descriptor deprecated 

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

Deprecated: Use SpanMetrics.ProtoReflect.Descriptor instead.

func (*SpanMetrics) EqualMessageVT added in v0.2.0 

func (this *SpanMetrics) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetrics) EqualVT added in v0.2.0 

func (this *SpanMetrics) EqualVT(that *SpanMetrics) bool

func (*SpanMetrics) GetErrors 

func (x *SpanMetrics) GetErrors() uint64

func (*SpanMetrics) GetLatencyHistogram 

func (x *SpanMetrics) GetLatencyHistogram() []*RawHistogram

func (*SpanMetrics) GetSeries 

func (x *SpanMetrics) GetSeries() []*KeyValue

func (*SpanMetrics) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetrics) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetrics) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetrics) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetrics) MarshalToVT added in v0.2.0 

func (m *SpanMetrics) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetrics) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetrics) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetrics) MarshalVT added in v0.2.0 

func (m *SpanMetrics) MarshalVT() (dAtA []byte, err error)

func (*SpanMetrics) MarshalVTStrict added in v0.2.0 

func (m *SpanMetrics) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetrics) ProtoMessage 

func (*SpanMetrics) ProtoMessage()

func (*SpanMetrics) ProtoReflect added in v0.2.0 

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

func (*SpanMetrics) Reset 

func (x *SpanMetrics) Reset()

func (*SpanMetrics) SizeVT added in v0.2.0 

func (m *SpanMetrics) SizeVT() (n int)

func (*SpanMetrics) String 

func (x *SpanMetrics) String() string

func (*SpanMetrics) UnmarshalVT added in v0.2.0 

func (m *SpanMetrics) UnmarshalVT(dAtA []byte) error

type SpanMetricsData 

type SpanMetricsData struct {
	ResultType string               `protobuf:"bytes,1,opt,name=resultType,proto3" json:"resultType,omitempty"`
	Result     []*SpanMetricsResult `protobuf:"bytes,2,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsData) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsData) CloneMessageVT() proto.Message

func (*SpanMetricsData) CloneVT added in v0.2.0 

func (m *SpanMetricsData) CloneVT() *SpanMetricsData

func (*SpanMetricsData) Descriptor deprecated 

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

Deprecated: Use SpanMetricsData.ProtoReflect.Descriptor instead.

func (*SpanMetricsData) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsData) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsData) EqualVT added in v0.2.0 

func (this *SpanMetricsData) EqualVT(that *SpanMetricsData) bool

func (*SpanMetricsData) GetResult 

func (x *SpanMetricsData) GetResult() []*SpanMetricsResult

func (*SpanMetricsData) GetResultType 

func (x *SpanMetricsData) GetResultType() string

func (*SpanMetricsData) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsData) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsData) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsData) MarshalToVT added in v0.2.0 

func (m *SpanMetricsData) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsData) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsData) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsData) MarshalVT added in v0.2.0 

func (m *SpanMetricsData) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsData) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsData) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsData) ProtoMessage 

func (*SpanMetricsData) ProtoMessage()

func (*SpanMetricsData) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsData) Reset 

func (x *SpanMetricsData) Reset()

func (*SpanMetricsData) SizeVT added in v0.2.0 

func (m *SpanMetricsData) SizeVT() (n int)

func (*SpanMetricsData) String 

func (x *SpanMetricsData) String() string

func (*SpanMetricsData) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsData) UnmarshalVT(dAtA []byte) error

type SpanMetricsRequest 

type SpanMetricsRequest struct {
	Query   string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	GroupBy string `protobuf:"bytes,2,opt,name=groupBy,proto3" json:"groupBy,omitempty"`
	Limit   uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Start   uint32 `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	End     uint32 `protobuf:"varint,5,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsRequest) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsRequest) CloneMessageVT() proto.Message

func (*SpanMetricsRequest) CloneVT added in v0.2.0 

func (m *SpanMetricsRequest) CloneVT() *SpanMetricsRequest

func (*SpanMetricsRequest) Descriptor deprecated 

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

Deprecated: Use SpanMetricsRequest.ProtoReflect.Descriptor instead.

func (*SpanMetricsRequest) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsRequest) EqualVT added in v0.2.0 

func (this *SpanMetricsRequest) EqualVT(that *SpanMetricsRequest) bool

func (*SpanMetricsRequest) GetEnd 

func (x *SpanMetricsRequest) GetEnd() uint32

func (*SpanMetricsRequest) GetGroupBy 

func (x *SpanMetricsRequest) GetGroupBy() string

func (*SpanMetricsRequest) GetLimit 

func (x *SpanMetricsRequest) GetLimit() uint64

func (*SpanMetricsRequest) GetQuery 

func (x *SpanMetricsRequest) GetQuery() string

func (*SpanMetricsRequest) GetStart 

func (x *SpanMetricsRequest) GetStart() uint32

func (*SpanMetricsRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsRequest) MarshalToVT added in v0.2.0 

func (m *SpanMetricsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsRequest) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsRequest) MarshalVT added in v0.2.0 

func (m *SpanMetricsRequest) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsRequest) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsRequest) ProtoMessage 

func (*SpanMetricsRequest) ProtoMessage()

func (*SpanMetricsRequest) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsRequest) Reset 

func (x *SpanMetricsRequest) Reset()

func (*SpanMetricsRequest) SizeVT added in v0.2.0 

func (m *SpanMetricsRequest) SizeVT() (n int)

func (*SpanMetricsRequest) String 

func (x *SpanMetricsRequest) String() string

func (*SpanMetricsRequest) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsRequest) UnmarshalVT(dAtA []byte) error

type SpanMetricsResponse 

type SpanMetricsResponse struct {
	Estimated      bool           `protobuf:"varint,1,opt,name=estimated,proto3" json:"estimated,omitempty"`
	SpanCount      uint64         `protobuf:"varint,2,opt,name=spanCount,proto3" json:"spanCount,omitempty"`
	ErrorSpanCount uint64         `protobuf:"varint,3,opt,name=errorSpanCount,proto3" json:"errorSpanCount,omitempty"`
	Metrics        []*SpanMetrics `protobuf:"bytes,4,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsResponse) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsResponse) CloneMessageVT() proto.Message

func (*SpanMetricsResponse) CloneVT added in v0.2.0 

func (m *SpanMetricsResponse) CloneVT() *SpanMetricsResponse

func (*SpanMetricsResponse) Descriptor deprecated 

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

Deprecated: Use SpanMetricsResponse.ProtoReflect.Descriptor instead.

func (*SpanMetricsResponse) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsResponse) EqualVT added in v0.2.0 

func (this *SpanMetricsResponse) EqualVT(that *SpanMetricsResponse) bool

func (*SpanMetricsResponse) GetErrorSpanCount 

func (x *SpanMetricsResponse) GetErrorSpanCount() uint64

func (*SpanMetricsResponse) GetEstimated 

func (x *SpanMetricsResponse) GetEstimated() bool

func (*SpanMetricsResponse) GetMetrics 

func (x *SpanMetricsResponse) GetMetrics() []*SpanMetrics

func (*SpanMetricsResponse) GetSpanCount 

func (x *SpanMetricsResponse) GetSpanCount() uint64

func (*SpanMetricsResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsResponse) MarshalToVT added in v0.2.0 

func (m *SpanMetricsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsResponse) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsResponse) MarshalVT added in v0.2.0 

func (m *SpanMetricsResponse) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsResponse) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsResponse) ProtoMessage 

func (*SpanMetricsResponse) ProtoMessage()

func (*SpanMetricsResponse) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsResponse) Reset 

func (x *SpanMetricsResponse) Reset()

func (*SpanMetricsResponse) SizeVT added in v0.2.0 

func (m *SpanMetricsResponse) SizeVT() (n int)

func (*SpanMetricsResponse) String 

func (x *SpanMetricsResponse) String() string

func (*SpanMetricsResponse) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsResponse) UnmarshalVT(dAtA []byte) error

type SpanMetricsResult 

type SpanMetricsResult struct {
	LabelName  string                    `protobuf:"bytes,1,opt,name=labelName,proto3" json:"labelName,omitempty"` // if these are empty it is the primary trend
	LabelValue string                    `protobuf:"bytes,2,opt,name=labelValue,proto3" json:"labelValue,omitempty"`
	Ts         []*SpanMetricsResultPoint `protobuf:"bytes,3,rep,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsResult) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsResult) CloneMessageVT() proto.Message

func (*SpanMetricsResult) CloneVT added in v0.2.0 

func (m *SpanMetricsResult) CloneVT() *SpanMetricsResult

func (*SpanMetricsResult) Descriptor deprecated 

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

Deprecated: Use SpanMetricsResult.ProtoReflect.Descriptor instead.

func (*SpanMetricsResult) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsResult) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsResult) EqualVT added in v0.2.0 

func (this *SpanMetricsResult) EqualVT(that *SpanMetricsResult) bool

func (*SpanMetricsResult) GetLabelName 

func (x *SpanMetricsResult) GetLabelName() string

func (*SpanMetricsResult) GetLabelValue 

func (x *SpanMetricsResult) GetLabelValue() string

func (*SpanMetricsResult) GetTs 

func (x *SpanMetricsResult) GetTs() []*SpanMetricsResultPoint

func (*SpanMetricsResult) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsResult) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsResult) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsResult) MarshalToVT added in v0.2.0 

func (m *SpanMetricsResult) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsResult) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsResult) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsResult) MarshalVT added in v0.2.0 

func (m *SpanMetricsResult) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsResult) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsResult) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsResult) ProtoMessage 

func (*SpanMetricsResult) ProtoMessage()

func (*SpanMetricsResult) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsResult) Reset 

func (x *SpanMetricsResult) Reset()

func (*SpanMetricsResult) SizeVT added in v0.2.0 

func (m *SpanMetricsResult) SizeVT() (n int)

func (*SpanMetricsResult) String 

func (x *SpanMetricsResult) String() string

func (*SpanMetricsResult) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsResult) UnmarshalVT(dAtA []byte) error

type SpanMetricsResultPoint 

type SpanMetricsResultPoint struct {
	Time             uint32  `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Val              float64 `protobuf:"fixed64,2,opt,name=val,proto3" json:"val,omitempty"`
	ExemplarTraceID  []byte  `protobuf:"bytes,3,opt,name=exemplarTraceID,proto3" json:"exemplarTraceID,omitempty"`
	ExemplarDuration uint64  `protobuf:"varint,4,opt,name=exemplarDuration,proto3" json:"exemplarDuration,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsResultPoint) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsResultPoint) CloneMessageVT() proto.Message

func (*SpanMetricsResultPoint) CloneVT added in v0.2.0 

func (m *SpanMetricsResultPoint) CloneVT() *SpanMetricsResultPoint

func (*SpanMetricsResultPoint) Descriptor deprecated 

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

Deprecated: Use SpanMetricsResultPoint.ProtoReflect.Descriptor instead.

func (*SpanMetricsResultPoint) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsResultPoint) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsResultPoint) EqualVT added in v0.2.0 

func (this *SpanMetricsResultPoint) EqualVT(that *SpanMetricsResultPoint) bool

func (*SpanMetricsResultPoint) GetExemplarDuration 

func (x *SpanMetricsResultPoint) GetExemplarDuration() uint64

func (*SpanMetricsResultPoint) GetExemplarTraceID 

func (x *SpanMetricsResultPoint) GetExemplarTraceID() []byte

func (*SpanMetricsResultPoint) GetTime 

func (x *SpanMetricsResultPoint) GetTime() uint32

func (*SpanMetricsResultPoint) GetVal 

func (x *SpanMetricsResultPoint) GetVal() float64

func (*SpanMetricsResultPoint) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsResultPoint) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsResultPoint) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsResultPoint) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsResultPoint) MarshalToVT added in v0.2.0 

func (m *SpanMetricsResultPoint) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsResultPoint) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsResultPoint) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsResultPoint) MarshalVT added in v0.2.0 

func (m *SpanMetricsResultPoint) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsResultPoint) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsResultPoint) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsResultPoint) ProtoMessage 

func (*SpanMetricsResultPoint) ProtoMessage()

func (*SpanMetricsResultPoint) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsResultPoint) Reset 

func (x *SpanMetricsResultPoint) Reset()

func (*SpanMetricsResultPoint) SizeVT added in v0.2.0 

func (m *SpanMetricsResultPoint) SizeVT() (n int)

func (*SpanMetricsResultPoint) String 

func (x *SpanMetricsResultPoint) String() string

func (*SpanMetricsResultPoint) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsResultPoint) UnmarshalVT(dAtA []byte) error

type SpanMetricsSummary 

type SpanMetricsSummary struct {
	SpanCount      uint64      `protobuf:"varint,1,opt,name=spanCount,proto3" json:"spanCount,omitempty"`
	ErrorSpanCount uint64      `protobuf:"varint,2,opt,name=errorSpanCount,proto3" json:"errorSpanCount,omitempty"`
	Series         []*KeyValue `protobuf:"bytes,3,rep,name=series,proto3" json:"series,omitempty"`
	P99            uint64      `protobuf:"varint,4,opt,name=p99,proto3" json:"p99,omitempty"`
	P95            uint64      `protobuf:"varint,5,opt,name=p95,proto3" json:"p95,omitempty"`
	P90            uint64      `protobuf:"varint,6,opt,name=p90,proto3" json:"p90,omitempty"`
	P50            uint64      `protobuf:"varint,7,opt,name=p50,proto3" json:"p50,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsSummary) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsSummary) CloneMessageVT() proto.Message

func (*SpanMetricsSummary) CloneVT added in v0.2.0 

func (m *SpanMetricsSummary) CloneVT() *SpanMetricsSummary

func (*SpanMetricsSummary) Descriptor deprecated 

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

Deprecated: Use SpanMetricsSummary.ProtoReflect.Descriptor instead.

func (*SpanMetricsSummary) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsSummary) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsSummary) EqualVT added in v0.2.0 

func (this *SpanMetricsSummary) EqualVT(that *SpanMetricsSummary) bool

func (*SpanMetricsSummary) GetErrorSpanCount 

func (x *SpanMetricsSummary) GetErrorSpanCount() uint64

func (*SpanMetricsSummary) GetP50 

func (x *SpanMetricsSummary) GetP50() uint64

func (*SpanMetricsSummary) GetP90 

func (x *SpanMetricsSummary) GetP90() uint64

func (*SpanMetricsSummary) GetP95 

func (x *SpanMetricsSummary) GetP95() uint64

func (*SpanMetricsSummary) GetP99 

func (x *SpanMetricsSummary) GetP99() uint64

func (*SpanMetricsSummary) GetSeries 

func (x *SpanMetricsSummary) GetSeries() []*KeyValue

func (*SpanMetricsSummary) GetSpanCount 

func (x *SpanMetricsSummary) GetSpanCount() uint64

func (*SpanMetricsSummary) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsSummary) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsSummary) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsSummary) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsSummary) MarshalToVT added in v0.2.0 

func (m *SpanMetricsSummary) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsSummary) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsSummary) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsSummary) MarshalVT added in v0.2.0 

func (m *SpanMetricsSummary) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsSummary) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsSummary) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsSummary) ProtoMessage 

func (*SpanMetricsSummary) ProtoMessage()

func (*SpanMetricsSummary) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsSummary) Reset 

func (x *SpanMetricsSummary) Reset()

func (*SpanMetricsSummary) SizeVT added in v0.2.0 

func (m *SpanMetricsSummary) SizeVT() (n int)

func (*SpanMetricsSummary) String 

func (x *SpanMetricsSummary) String() string

func (*SpanMetricsSummary) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsSummary) UnmarshalVT(dAtA []byte) error

type SpanMetricsSummaryRequest 

type SpanMetricsSummaryRequest struct {
	Query   string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	GroupBy string `protobuf:"bytes,2,opt,name=groupBy,proto3" json:"groupBy,omitempty"`
	Limit   uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Start   uint32 `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	End     uint32 `protobuf:"varint,5,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsSummaryRequest) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsSummaryRequest) CloneMessageVT() proto.Message

func (*SpanMetricsSummaryRequest) CloneVT added in v0.2.0 

func (m *SpanMetricsSummaryRequest) CloneVT() *SpanMetricsSummaryRequest

func (*SpanMetricsSummaryRequest) Descriptor deprecated 

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

Deprecated: Use SpanMetricsSummaryRequest.ProtoReflect.Descriptor instead.

func (*SpanMetricsSummaryRequest) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsSummaryRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsSummaryRequest) EqualVT added in v0.2.0 

func (this *SpanMetricsSummaryRequest) EqualVT(that *SpanMetricsSummaryRequest) bool

func (*SpanMetricsSummaryRequest) GetEnd 

func (x *SpanMetricsSummaryRequest) GetEnd() uint32

func (*SpanMetricsSummaryRequest) GetGroupBy 

func (x *SpanMetricsSummaryRequest) GetGroupBy() string

func (*SpanMetricsSummaryRequest) GetLimit 

func (x *SpanMetricsSummaryRequest) GetLimit() uint64

func (*SpanMetricsSummaryRequest) GetQuery 

func (x *SpanMetricsSummaryRequest) GetQuery() string

func (*SpanMetricsSummaryRequest) GetStart 

func (x *SpanMetricsSummaryRequest) GetStart() uint32

func (*SpanMetricsSummaryRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsSummaryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsSummaryRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsSummaryRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsSummaryRequest) MarshalToVT added in v0.2.0 

func (m *SpanMetricsSummaryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsSummaryRequest) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsSummaryRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsSummaryRequest) MarshalVT added in v0.2.0 

func (m *SpanMetricsSummaryRequest) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsSummaryRequest) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsSummaryRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsSummaryRequest) ProtoMessage 

func (*SpanMetricsSummaryRequest) ProtoMessage()

func (*SpanMetricsSummaryRequest) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsSummaryRequest) Reset 

func (x *SpanMetricsSummaryRequest) Reset()

func (*SpanMetricsSummaryRequest) SizeVT added in v0.2.0 

func (m *SpanMetricsSummaryRequest) SizeVT() (n int)

func (*SpanMetricsSummaryRequest) String 

func (x *SpanMetricsSummaryRequest) String() string

func (*SpanMetricsSummaryRequest) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsSummaryRequest) UnmarshalVT(dAtA []byte) error

type SpanMetricsSummaryResponse 

type SpanMetricsSummaryResponse struct {
	Summaries []*SpanMetricsSummary `protobuf:"bytes,1,rep,name=summaries,proto3" json:"summaries,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanMetricsSummaryResponse) CloneMessageVT added in v0.2.0 

func (m *SpanMetricsSummaryResponse) CloneMessageVT() proto.Message

func (*SpanMetricsSummaryResponse) CloneVT added in v0.2.0 

func (m *SpanMetricsSummaryResponse) CloneVT() *SpanMetricsSummaryResponse

func (*SpanMetricsSummaryResponse) Descriptor deprecated 

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

Deprecated: Use SpanMetricsSummaryResponse.ProtoReflect.Descriptor instead.

func (*SpanMetricsSummaryResponse) EqualMessageVT added in v0.2.0 

func (this *SpanMetricsSummaryResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanMetricsSummaryResponse) EqualVT added in v0.2.0 

func (this *SpanMetricsSummaryResponse) EqualVT(that *SpanMetricsSummaryResponse) bool

func (*SpanMetricsSummaryResponse) GetSummaries 

func (x *SpanMetricsSummaryResponse) GetSummaries() []*SpanMetricsSummary

func (*SpanMetricsSummaryResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanMetricsSummaryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanMetricsSummaryResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanMetricsSummaryResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsSummaryResponse) MarshalToVT added in v0.2.0 

func (m *SpanMetricsSummaryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SpanMetricsSummaryResponse) MarshalToVTStrict added in v0.2.0 

func (m *SpanMetricsSummaryResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanMetricsSummaryResponse) MarshalVT added in v0.2.0 

func (m *SpanMetricsSummaryResponse) MarshalVT() (dAtA []byte, err error)

func (*SpanMetricsSummaryResponse) MarshalVTStrict added in v0.2.0 

func (m *SpanMetricsSummaryResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanMetricsSummaryResponse) ProtoMessage 

func (*SpanMetricsSummaryResponse) ProtoMessage()

func (*SpanMetricsSummaryResponse) ProtoReflect added in v0.2.0 

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

func (*SpanMetricsSummaryResponse) Reset 

func (x *SpanMetricsSummaryResponse) Reset()

func (*SpanMetricsSummaryResponse) SizeVT added in v0.2.0 

func (m *SpanMetricsSummaryResponse) SizeVT() (n int)

func (*SpanMetricsSummaryResponse) String 

func (x *SpanMetricsSummaryResponse) String() string

func (*SpanMetricsSummaryResponse) UnmarshalVT added in v0.2.0 

func (m *SpanMetricsSummaryResponse) UnmarshalVT(dAtA []byte) error

type SpanSet 

type SpanSet struct {
	Spans      []*Span        `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	Matched    uint32         `protobuf:"varint,2,opt,name=matched,proto3" json:"matched,omitempty"`
	Attributes []*v1.KeyValue `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanSet) CloneMessageVT added in v0.2.0 

func (m *SpanSet) CloneMessageVT() proto.Message

func (*SpanSet) CloneVT added in v0.2.0 

func (m *SpanSet) CloneVT() *SpanSet

func (*SpanSet) Descriptor deprecated 

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

Deprecated: Use SpanSet.ProtoReflect.Descriptor instead.

func (*SpanSet) EqualMessageVT added in v0.2.0 

func (this *SpanSet) EqualMessageVT(thatMsg proto.Message) bool

func (*SpanSet) EqualVT added in v0.2.0 

func (this *SpanSet) EqualVT(that *SpanSet) bool

func (*SpanSet) GetAttributes 

func (x *SpanSet) GetAttributes() []*v1.KeyValue

func (*SpanSet) GetMatched 

func (x *SpanSet) GetMatched() uint32

func (*SpanSet) GetSpans 

func (x *SpanSet) GetSpans() []*Span

func (*SpanSet) MarshalToSizedBufferVT added in v0.2.0 

func (m *SpanSet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanSet) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *SpanSet) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SpanSet) MarshalToVT added in v0.2.0 

func (m *SpanSet) MarshalToVT(dAtA []byte) (int, error)

func (*SpanSet) MarshalToVTStrict added in v0.2.0 

func (m *SpanSet) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SpanSet) MarshalVT added in v0.2.0 

func (m *SpanSet) MarshalVT() (dAtA []byte, err error)

func (*SpanSet) MarshalVTStrict added in v0.2.0 

func (m *SpanSet) MarshalVTStrict() (dAtA []byte, err error)

func (*SpanSet) ProtoMessage 

func (*SpanSet) ProtoMessage()

func (*SpanSet) ProtoReflect added in v0.2.0 

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

func (*SpanSet) Reset 

func (x *SpanSet) Reset()

func (*SpanSet) SizeVT added in v0.2.0 

func (m *SpanSet) SizeVT() (n int)

func (*SpanSet) String 

func (x *SpanSet) String() string

func (*SpanSet) UnmarshalVT added in v0.2.0 

func (m *SpanSet) UnmarshalVT(dAtA []byte) error

type StreamingQuerierClient 

type StreamingQuerierClient interface {
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (StreamingQuerier_SearchClient, error)
}

StreamingQuerierClient is the client API for StreamingQuerier service.

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

func NewStreamingQuerierClient 

func NewStreamingQuerierClient(cc grpc.ClientConnInterface) StreamingQuerierClient

type StreamingQuerierServer 

type StreamingQuerierServer interface {
	Search(*SearchRequest, StreamingQuerier_SearchServer) error
	// contains filtered or unexported methods
}

StreamingQuerierServer is the server API for StreamingQuerier service. All implementations must embed UnimplementedStreamingQuerierServer for forward compatibility

type StreamingQuerier_SearchClient 

type StreamingQuerier_SearchClient interface {
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type StreamingQuerier_SearchServer 

type StreamingQuerier_SearchServer interface {
	Send(*SearchResponse) error
	grpc.ServerStream
}

type TagValue 

type TagValue struct {
	Type  string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TagValue) CloneMessageVT added in v0.2.0 

func (m *TagValue) CloneMessageVT() proto.Message

func (*TagValue) CloneVT added in v0.2.0 

func (m *TagValue) CloneVT() *TagValue

func (*TagValue) Descriptor deprecated 

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

Deprecated: Use TagValue.ProtoReflect.Descriptor instead.

func (*TagValue) EqualMessageVT added in v0.2.0 

func (this *TagValue) EqualMessageVT(thatMsg proto.Message) bool

func (*TagValue) EqualVT added in v0.2.0 

func (this *TagValue) EqualVT(that *TagValue) bool

func (*TagValue) GetType 

func (x *TagValue) GetType() string

func (*TagValue) GetValue 

func (x *TagValue) GetValue() string

func (*TagValue) MarshalToSizedBufferVT added in v0.2.0 

func (m *TagValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TagValue) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TagValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TagValue) MarshalToVT added in v0.2.0 

func (m *TagValue) MarshalToVT(dAtA []byte) (int, error)

func (*TagValue) MarshalToVTStrict added in v0.2.0 

func (m *TagValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TagValue) MarshalVT added in v0.2.0 

func (m *TagValue) MarshalVT() (dAtA []byte, err error)

func (*TagValue) MarshalVTStrict added in v0.2.0 

func (m *TagValue) MarshalVTStrict() (dAtA []byte, err error)

func (*TagValue) ProtoMessage 

func (*TagValue) ProtoMessage()

func (*TagValue) ProtoReflect added in v0.2.0 

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

func (*TagValue) Reset 

func (x *TagValue) Reset()

func (*TagValue) SizeVT added in v0.2.0 

func (m *TagValue) SizeVT() (n int)

func (*TagValue) String 

func (x *TagValue) String() string

func (*TagValue) UnmarshalVT added in v0.2.0 

func (m *TagValue) UnmarshalVT(dAtA []byte) error

type TimeSeries 

type TimeSeries struct {
	Labels []*v1.KeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	// Sorted by time, oldest sample first.
	Samples    []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	PromLabels string    `protobuf:"bytes,3,opt,name=prom_labels,json=promLabels,proto3" json:"prom_labels,omitempty"`
	// contains filtered or unexported fields
}

https : // github.com/grafana/mimir/blob/main/pkg/mimirpb/mimir.proto#L53

func (*TimeSeries) CloneMessageVT added in v0.2.0 

func (m *TimeSeries) CloneMessageVT() proto.Message

func (*TimeSeries) CloneVT added in v0.2.0 

func (m *TimeSeries) CloneVT() *TimeSeries

func (*TimeSeries) Descriptor deprecated 

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

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) EqualMessageVT added in v0.2.0 

func (this *TimeSeries) EqualMessageVT(thatMsg proto.Message) bool

func (*TimeSeries) EqualVT added in v0.2.0 

func (this *TimeSeries) EqualVT(that *TimeSeries) bool

func (*TimeSeries) GetLabels 

func (x *TimeSeries) GetLabels() []*v1.KeyValue

func (*TimeSeries) GetPromLabels 

func (x *TimeSeries) GetPromLabels() string

func (*TimeSeries) GetSamples 

func (x *TimeSeries) GetSamples() []*Sample

func (*TimeSeries) MarshalToSizedBufferVT added in v0.2.0 

func (m *TimeSeries) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TimeSeries) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TimeSeries) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TimeSeries) MarshalToVT added in v0.2.0 

func (m *TimeSeries) MarshalToVT(dAtA []byte) (int, error)

func (*TimeSeries) MarshalToVTStrict added in v0.2.0 

func (m *TimeSeries) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TimeSeries) MarshalVT added in v0.2.0 

func (m *TimeSeries) MarshalVT() (dAtA []byte, err error)

func (*TimeSeries) MarshalVTStrict added in v0.2.0 

func (m *TimeSeries) MarshalVTStrict() (dAtA []byte, err error)

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) ProtoReflect added in v0.2.0 

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

func (*TimeSeries) Reset 

func (x *TimeSeries) Reset()

func (*TimeSeries) SizeVT added in v0.2.0 

func (m *TimeSeries) SizeVT() (n int)

func (*TimeSeries) String 

func (x *TimeSeries) String() string

func (*TimeSeries) UnmarshalVT added in v0.2.0 

func (m *TimeSeries) UnmarshalVT(dAtA []byte) error

type Trace 

type Trace struct {
	Batches []*v11.ResourceSpans `protobuf:"bytes,1,rep,name=batches,proto3" json:"batches,omitempty"`
	// contains filtered or unexported fields
}

func (*Trace) CloneMessageVT added in v0.2.0 

func (m *Trace) CloneMessageVT() proto.Message

func (*Trace) CloneVT added in v0.2.0 

func (m *Trace) CloneVT() *Trace

func (*Trace) Descriptor deprecated 

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

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) EqualMessageVT added in v0.2.0 

func (this *Trace) EqualMessageVT(thatMsg proto.Message) bool

func (*Trace) EqualVT added in v0.2.0 

func (this *Trace) EqualVT(that *Trace) bool

func (*Trace) GetBatches 

func (x *Trace) GetBatches() []*v11.ResourceSpans

func (*Trace) MarshalToSizedBufferVT added in v0.2.0 

func (m *Trace) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Trace) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *Trace) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Trace) MarshalToVT added in v0.2.0 

func (m *Trace) MarshalToVT(dAtA []byte) (int, error)

func (*Trace) MarshalToVTStrict added in v0.2.0 

func (m *Trace) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Trace) MarshalVT added in v0.2.0 

func (m *Trace) MarshalVT() (dAtA []byte, err error)

func (*Trace) MarshalVTStrict added in v0.2.0 

func (m *Trace) MarshalVTStrict() (dAtA []byte, err error)

func (*Trace) ProtoMessage 

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect added in v0.2.0 

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

func (*Trace) Reset 

func (x *Trace) Reset()

func (*Trace) SizeVT added in v0.2.0 

func (m *Trace) SizeVT() (n int)

func (*Trace) String 

func (x *Trace) String() string

func (*Trace) UnmarshalVT added in v0.2.0 

func (m *Trace) UnmarshalVT(dAtA []byte) error

type TraceByIDMetrics 

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

func (*TraceByIDMetrics) CloneMessageVT added in v0.2.0 

func (m *TraceByIDMetrics) CloneMessageVT() proto.Message

func (*TraceByIDMetrics) CloneVT added in v0.2.0 

func (m *TraceByIDMetrics) CloneVT() *TraceByIDMetrics

func (*TraceByIDMetrics) Descriptor deprecated 

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

Deprecated: Use TraceByIDMetrics.ProtoReflect.Descriptor instead.

func (*TraceByIDMetrics) EqualMessageVT added in v0.2.0 

func (this *TraceByIDMetrics) EqualMessageVT(thatMsg proto.Message) bool

func (*TraceByIDMetrics) EqualVT added in v0.2.0 

func (this *TraceByIDMetrics) EqualVT(that *TraceByIDMetrics) bool

func (*TraceByIDMetrics) MarshalToSizedBufferVT added in v0.2.0 

func (m *TraceByIDMetrics) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TraceByIDMetrics) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TraceByIDMetrics) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TraceByIDMetrics) MarshalToVT added in v0.2.0 

func (m *TraceByIDMetrics) MarshalToVT(dAtA []byte) (int, error)

func (*TraceByIDMetrics) MarshalToVTStrict added in v0.2.0 

func (m *TraceByIDMetrics) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TraceByIDMetrics) MarshalVT added in v0.2.0 

func (m *TraceByIDMetrics) MarshalVT() (dAtA []byte, err error)

func (*TraceByIDMetrics) MarshalVTStrict added in v0.2.0 

func (m *TraceByIDMetrics) MarshalVTStrict() (dAtA []byte, err error)

func (*TraceByIDMetrics) ProtoMessage 

func (*TraceByIDMetrics) ProtoMessage()

func (*TraceByIDMetrics) ProtoReflect added in v0.2.0 

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

func (*TraceByIDMetrics) Reset 

func (x *TraceByIDMetrics) Reset()

func (*TraceByIDMetrics) SizeVT added in v0.2.0 

func (m *TraceByIDMetrics) SizeVT() (n int)

func (*TraceByIDMetrics) String 

func (x *TraceByIDMetrics) String() string

func (*TraceByIDMetrics) UnmarshalVT added in v0.2.0 

func (m *TraceByIDMetrics) UnmarshalVT(dAtA []byte) error

type TraceByIDRequest 

type TraceByIDRequest struct {
	TraceID    []byte `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	BlockStart string `protobuf:"bytes,2,opt,name=blockStart,proto3" json:"blockStart,omitempty"`
	BlockEnd   string `protobuf:"bytes,3,opt,name=blockEnd,proto3" json:"blockEnd,omitempty"`
	QueryMode  string `protobuf:"bytes,5,opt,name=queryMode,proto3" json:"queryMode,omitempty"`
	// contains filtered or unexported fields
}

Read

func (*TraceByIDRequest) CloneMessageVT added in v0.2.0 

func (m *TraceByIDRequest) CloneMessageVT() proto.Message

func (*TraceByIDRequest) CloneVT added in v0.2.0 

func (m *TraceByIDRequest) CloneVT() *TraceByIDRequest

func (*TraceByIDRequest) Descriptor deprecated 

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

Deprecated: Use TraceByIDRequest.ProtoReflect.Descriptor instead.

func (*TraceByIDRequest) EqualMessageVT added in v0.2.0 

func (this *TraceByIDRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*TraceByIDRequest) EqualVT added in v0.2.0 

func (this *TraceByIDRequest) EqualVT(that *TraceByIDRequest) bool

func (*TraceByIDRequest) GetBlockEnd 

func (x *TraceByIDRequest) GetBlockEnd() string

func (*TraceByIDRequest) GetBlockStart 

func (x *TraceByIDRequest) GetBlockStart() string

func (*TraceByIDRequest) GetQueryMode 

func (x *TraceByIDRequest) GetQueryMode() string

func (*TraceByIDRequest) GetTraceID 

func (x *TraceByIDRequest) GetTraceID() []byte

func (*TraceByIDRequest) MarshalToSizedBufferVT added in v0.2.0 

func (m *TraceByIDRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TraceByIDRequest) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TraceByIDRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TraceByIDRequest) MarshalToVT added in v0.2.0 

func (m *TraceByIDRequest) MarshalToVT(dAtA []byte) (int, error)

func (*TraceByIDRequest) MarshalToVTStrict added in v0.2.0 

func (m *TraceByIDRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TraceByIDRequest) MarshalVT added in v0.2.0 

func (m *TraceByIDRequest) MarshalVT() (dAtA []byte, err error)

func (*TraceByIDRequest) MarshalVTStrict added in v0.2.0 

func (m *TraceByIDRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*TraceByIDRequest) ProtoMessage 

func (*TraceByIDRequest) ProtoMessage()

func (*TraceByIDRequest) ProtoReflect added in v0.2.0 

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

func (*TraceByIDRequest) Reset 

func (x *TraceByIDRequest) Reset()

func (*TraceByIDRequest) SizeVT added in v0.2.0 

func (m *TraceByIDRequest) SizeVT() (n int)

func (*TraceByIDRequest) String 

func (x *TraceByIDRequest) String() string

func (*TraceByIDRequest) UnmarshalVT added in v0.2.0 

func (m *TraceByIDRequest) UnmarshalVT(dAtA []byte) error

type TraceByIDResponse 

type TraceByIDResponse struct {
	Trace   *Trace            `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"`
	Metrics *TraceByIDMetrics `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceByIDResponse) CloneMessageVT added in v0.2.0 

func (m *TraceByIDResponse) CloneMessageVT() proto.Message

func (*TraceByIDResponse) CloneVT added in v0.2.0 

func (m *TraceByIDResponse) CloneVT() *TraceByIDResponse

func (*TraceByIDResponse) Descriptor deprecated 

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

Deprecated: Use TraceByIDResponse.ProtoReflect.Descriptor instead.

func (*TraceByIDResponse) EqualMessageVT added in v0.2.0 

func (this *TraceByIDResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*TraceByIDResponse) EqualVT added in v0.2.0 

func (this *TraceByIDResponse) EqualVT(that *TraceByIDResponse) bool

func (*TraceByIDResponse) GetMetrics 

func (x *TraceByIDResponse) GetMetrics() *TraceByIDMetrics

func (*TraceByIDResponse) GetTrace 

func (x *TraceByIDResponse) GetTrace() *Trace

func (*TraceByIDResponse) MarshalToSizedBufferVT added in v0.2.0 

func (m *TraceByIDResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TraceByIDResponse) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TraceByIDResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TraceByIDResponse) MarshalToVT added in v0.2.0 

func (m *TraceByIDResponse) MarshalToVT(dAtA []byte) (int, error)

func (*TraceByIDResponse) MarshalToVTStrict added in v0.2.0 

func (m *TraceByIDResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TraceByIDResponse) MarshalVT added in v0.2.0 

func (m *TraceByIDResponse) MarshalVT() (dAtA []byte, err error)

func (*TraceByIDResponse) MarshalVTStrict added in v0.2.0 

func (m *TraceByIDResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*TraceByIDResponse) ProtoMessage 

func (*TraceByIDResponse) ProtoMessage()

func (*TraceByIDResponse) ProtoReflect added in v0.2.0 

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

func (*TraceByIDResponse) Reset 

func (x *TraceByIDResponse) Reset()

func (*TraceByIDResponse) SizeVT added in v0.2.0 

func (m *TraceByIDResponse) SizeVT() (n int)

func (*TraceByIDResponse) String 

func (x *TraceByIDResponse) String() string

func (*TraceByIDResponse) UnmarshalVT added in v0.2.0 

func (m *TraceByIDResponse) UnmarshalVT(dAtA []byte) error

type TraceBytes 

type TraceBytes struct {

	// pre-marshalled Traces
	Traces [][]byte `protobuf:"bytes,1,rep,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceBytes) CloneMessageVT added in v0.2.0 

func (m *TraceBytes) CloneMessageVT() proto.Message

func (*TraceBytes) CloneVT added in v0.2.0 

func (m *TraceBytes) CloneVT() *TraceBytes

func (*TraceBytes) Descriptor deprecated 

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

Deprecated: Use TraceBytes.ProtoReflect.Descriptor instead.

func (*TraceBytes) EqualMessageVT added in v0.2.0 

func (this *TraceBytes) EqualMessageVT(thatMsg proto.Message) bool

func (*TraceBytes) EqualVT added in v0.2.0 

func (this *TraceBytes) EqualVT(that *TraceBytes) bool

func (*TraceBytes) GetTraces 

func (x *TraceBytes) GetTraces() [][]byte

func (*TraceBytes) MarshalToSizedBufferVT added in v0.2.0 

func (m *TraceBytes) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TraceBytes) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TraceBytes) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TraceBytes) MarshalToVT added in v0.2.0 

func (m *TraceBytes) MarshalToVT(dAtA []byte) (int, error)

func (*TraceBytes) MarshalToVTStrict added in v0.2.0 

func (m *TraceBytes) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TraceBytes) MarshalVT added in v0.2.0 

func (m *TraceBytes) MarshalVT() (dAtA []byte, err error)

func (*TraceBytes) MarshalVTStrict added in v0.2.0 

func (m *TraceBytes) MarshalVTStrict() (dAtA []byte, err error)

func (*TraceBytes) ProtoMessage 

func (*TraceBytes) ProtoMessage()

func (*TraceBytes) ProtoReflect added in v0.2.0 

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

func (*TraceBytes) Reset 

func (x *TraceBytes) Reset()

func (*TraceBytes) SizeVT added in v0.2.0 

func (m *TraceBytes) SizeVT() (n int)

func (*TraceBytes) String 

func (x *TraceBytes) String() string

func (*TraceBytes) UnmarshalVT added in v0.2.0 

func (m *TraceBytes) UnmarshalVT(dAtA []byte) error

type TraceQLStatic 

type TraceQLStatic struct {
	Type   int32   `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	N      int64   `protobuf:"varint,2,opt,name=n,proto3" json:"n,omitempty"`
	F      float64 `protobuf:"fixed64,3,opt,name=f,proto3" json:"f,omitempty"`
	S      string  `protobuf:"bytes,4,opt,name=s,proto3" json:"s,omitempty"`
	B      bool    `protobuf:"varint,5,opt,name=b,proto3" json:"b,omitempty"`
	D      uint64  `protobuf:"varint,6,opt,name=d,proto3" json:"d,omitempty"`
	Status int32   `protobuf:"varint,7,opt,name=status,proto3" json:"status,omitempty"`
	Kind   int32   `protobuf:"varint,8,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceQLStatic) CloneMessageVT added in v0.2.0 

func (m *TraceQLStatic) CloneMessageVT() proto.Message

func (*TraceQLStatic) CloneVT added in v0.2.0 

func (m *TraceQLStatic) CloneVT() *TraceQLStatic

func (*TraceQLStatic) Descriptor deprecated 

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

Deprecated: Use TraceQLStatic.ProtoReflect.Descriptor instead.

func (*TraceQLStatic) EqualMessageVT added in v0.2.0 

func (this *TraceQLStatic) EqualMessageVT(thatMsg proto.Message) bool

func (*TraceQLStatic) EqualVT added in v0.2.0 

func (this *TraceQLStatic) EqualVT(that *TraceQLStatic) bool

func (*TraceQLStatic) GetB 

func (x *TraceQLStatic) GetB() bool

func (*TraceQLStatic) GetD 

func (x *TraceQLStatic) GetD() uint64

func (*TraceQLStatic) GetF 

func (x *TraceQLStatic) GetF() float64

func (*TraceQLStatic) GetKind 

func (x *TraceQLStatic) GetKind() int32

func (*TraceQLStatic) GetN 

func (x *TraceQLStatic) GetN() int64

func (*TraceQLStatic) GetS 

func (x *TraceQLStatic) GetS() string

func (*TraceQLStatic) GetStatus 

func (x *TraceQLStatic) GetStatus() int32

func (*TraceQLStatic) GetType 

func (x *TraceQLStatic) GetType() int32

func (*TraceQLStatic) MarshalToSizedBufferVT added in v0.2.0 

func (m *TraceQLStatic) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TraceQLStatic) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TraceQLStatic) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TraceQLStatic) MarshalToVT added in v0.2.0 

func (m *TraceQLStatic) MarshalToVT(dAtA []byte) (int, error)

func (*TraceQLStatic) MarshalToVTStrict added in v0.2.0 

func (m *TraceQLStatic) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TraceQLStatic) MarshalVT added in v0.2.0 

func (m *TraceQLStatic) MarshalVT() (dAtA []byte, err error)

func (*TraceQLStatic) MarshalVTStrict added in v0.2.0 

func (m *TraceQLStatic) MarshalVTStrict() (dAtA []byte, err error)

func (*TraceQLStatic) ProtoMessage 

func (*TraceQLStatic) ProtoMessage()

func (*TraceQLStatic) ProtoReflect added in v0.2.0 

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

func (*TraceQLStatic) Reset 

func (x *TraceQLStatic) Reset()

func (*TraceQLStatic) SizeVT added in v0.2.0 

func (m *TraceQLStatic) SizeVT() (n int)

func (*TraceQLStatic) String 

func (x *TraceQLStatic) String() string

func (*TraceQLStatic) UnmarshalVT added in v0.2.0 

func (m *TraceQLStatic) UnmarshalVT(dAtA []byte) error

type TraceSearchMetadata 

type TraceSearchMetadata struct {
	TraceID           string     `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	RootServiceName   string     `protobuf:"bytes,2,opt,name=rootServiceName,proto3" json:"rootServiceName,omitempty"`
	RootTraceName     string     `protobuf:"bytes,3,opt,name=rootTraceName,proto3" json:"rootTraceName,omitempty"`
	StartTimeUnixNano uint64     `protobuf:"varint,4,opt,name=startTimeUnixNano,proto3" json:"startTimeUnixNano,omitempty"`
	DurationMs        uint32     `protobuf:"varint,5,opt,name=durationMs,proto3" json:"durationMs,omitempty"`
	SpanSet           *SpanSet   `protobuf:"bytes,6,opt,name=spanSet,proto3" json:"spanSet,omitempty"` // deprecated. use SpanSets field below
	SpanSets          []*SpanSet `protobuf:"bytes,7,rep,name=spanSets,proto3" json:"spanSets,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceSearchMetadata) CloneMessageVT added in v0.2.0 

func (m *TraceSearchMetadata) CloneMessageVT() proto.Message

func (*TraceSearchMetadata) CloneVT added in v0.2.0 

func (m *TraceSearchMetadata) CloneVT() *TraceSearchMetadata

func (*TraceSearchMetadata) Descriptor deprecated 

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

Deprecated: Use TraceSearchMetadata.ProtoReflect.Descriptor instead.

func (*TraceSearchMetadata) EqualMessageVT added in v0.2.0 

func (this *TraceSearchMetadata) EqualMessageVT(thatMsg proto.Message) bool

func (*TraceSearchMetadata) EqualVT added in v0.2.0 

func (this *TraceSearchMetadata) EqualVT(that *TraceSearchMetadata) bool

func (*TraceSearchMetadata) GetDurationMs 

func (x *TraceSearchMetadata) GetDurationMs() uint32

func (*TraceSearchMetadata) GetRootServiceName 

func (x *TraceSearchMetadata) GetRootServiceName() string

func (*TraceSearchMetadata) GetRootTraceName 

func (x *TraceSearchMetadata) GetRootTraceName() string

func (*TraceSearchMetadata) GetSpanSet 

func (x *TraceSearchMetadata) GetSpanSet() *SpanSet

func (*TraceSearchMetadata) GetSpanSets 

func (x *TraceSearchMetadata) GetSpanSets() []*SpanSet

func (*TraceSearchMetadata) GetStartTimeUnixNano 

func (x *TraceSearchMetadata) GetStartTimeUnixNano() uint64

func (*TraceSearchMetadata) GetTraceID 

func (x *TraceSearchMetadata) GetTraceID() string

func (*TraceSearchMetadata) MarshalToSizedBufferVT added in v0.2.0 

func (m *TraceSearchMetadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TraceSearchMetadata) MarshalToSizedBufferVTStrict added in v0.2.0 

func (m *TraceSearchMetadata) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*TraceSearchMetadata) MarshalToVT added in v0.2.0 

func (m *TraceSearchMetadata) MarshalToVT(dAtA []byte) (int, error)

func (*TraceSearchMetadata) MarshalToVTStrict added in v0.2.0 

func (m *TraceSearchMetadata) MarshalToVTStrict(dAtA []byte) (int, error)

func (*TraceSearchMetadata) MarshalVT added in v0.2.0 

func (m *TraceSearchMetadata) MarshalVT() (dAtA []byte, err error)

func (*TraceSearchMetadata) MarshalVTStrict added in v0.2.0 

func (m *TraceSearchMetadata) MarshalVTStrict() (dAtA []byte, err error)

func (*TraceSearchMetadata) ProtoMessage 

func (*TraceSearchMetadata) ProtoMessage()

func (*TraceSearchMetadata) ProtoReflect added in v0.2.0 

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

func (*TraceSearchMetadata) Reset 

func (x *TraceSearchMetadata) Reset()

func (*TraceSearchMetadata) SizeVT added in v0.2.0 

func (m *TraceSearchMetadata) SizeVT() (n int)

func (*TraceSearchMetadata) String 

func (x *TraceSearchMetadata) String() string

func (*TraceSearchMetadata) UnmarshalVT added in v0.2.0 

func (m *TraceSearchMetadata) UnmarshalVT(dAtA []byte) error

type UnimplementedMetricsGeneratorServer 

type UnimplementedMetricsGeneratorServer struct {
}

UnimplementedMetricsGeneratorServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsGeneratorServer) GetMetrics 

func (UnimplementedMetricsGeneratorServer) GetMetrics(context.Context, *SpanMetricsRequest) (*SpanMetricsResponse, error)

func (UnimplementedMetricsGeneratorServer) PushSpans 

func (UnimplementedMetricsGeneratorServer) PushSpans(context.Context, *PushSpansRequest) (*PushResponse, error)

func (UnimplementedMetricsGeneratorServer) QueryRange 

func (UnimplementedMetricsGeneratorServer) QueryRange(context.Context, *QueryRangeRequest) (*QueryRangeResponse, error)

type UnimplementedMetricsServer 

type UnimplementedMetricsServer struct {
}

UnimplementedMetricsServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsServer) QueryRange 

func (UnimplementedMetricsServer) QueryRange(context.Context, *QueryRangeRequest) (*QueryRangeResponse, error)

func (UnimplementedMetricsServer) SpanMetricsSummary 

func (UnimplementedMetricsServer) SpanMetricsSummary(context.Context, *SpanMetricsSummaryRequest) (*SpanMetricsSummaryResponse, error)

type UnimplementedPusherServer 

type UnimplementedPusherServer struct {
}

UnimplementedPusherServer must be embedded to have forward compatible implementations.

func (UnimplementedPusherServer) PushBytes 

func (UnimplementedPusherServer) PushBytes(context.Context, *PushBytesRequest) (*PushResponse, error)

func (UnimplementedPusherServer) PushBytesV2 

func (UnimplementedPusherServer) PushBytesV2(context.Context, *PushBytesRequest) (*PushResponse, error)

type UnimplementedQuerierServer 

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer must be embedded to have forward compatible implementations.

func (UnimplementedQuerierServer) FindTraceByID 

func (UnimplementedQuerierServer) FindTraceByID(context.Context, *TraceByIDRequest) (*TraceByIDResponse, error)

func (UnimplementedQuerierServer) SearchBlock 

func (UnimplementedQuerierServer) SearchBlock(context.Context, *SearchBlockRequest) (*SearchResponse, error)

func (UnimplementedQuerierServer) SearchRecent 

func (UnimplementedQuerierServer) SearchRecent(context.Context, *SearchRequest) (*SearchResponse, error)

func (UnimplementedQuerierServer) SearchTagValues 

func (UnimplementedQuerierServer) SearchTagValues(context.Context, *SearchTagValuesRequest) (*SearchTagValuesResponse, error)

func (UnimplementedQuerierServer) SearchTagValuesV2 

func (UnimplementedQuerierServer) SearchTagValuesV2(context.Context, *SearchTagValuesRequest) (*SearchTagValuesV2Response, error)

func (UnimplementedQuerierServer) SearchTags 

func (UnimplementedQuerierServer) SearchTags(context.Context, *SearchTagsRequest) (*SearchTagsResponse, error)

func (UnimplementedQuerierServer) SearchTagsV2 

func (UnimplementedQuerierServer) SearchTagsV2(context.Context, *SearchTagsRequest) (*SearchTagsV2Response, error)

type UnimplementedStreamingQuerierServer 

type UnimplementedStreamingQuerierServer struct {
}

UnimplementedStreamingQuerierServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamingQuerierServer) Search 

func (UnimplementedStreamingQuerierServer) Search(*SearchRequest, StreamingQuerier_SearchServer) error

type UnsafeMetricsGeneratorServer added in v0.2.0 

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

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

type UnsafeMetricsServer added in v0.2.0 

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

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

type UnsafePusherServer added in v0.2.0 

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

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

type UnsafeQuerierServer added in v0.2.0 

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

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

type UnsafeStreamingQuerierServer added in v0.2.0 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.