tempopb

package
v1.83.0 Latest Latest
Warning

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

Go to latest
Published: Apr 15, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

README

=== tempopb

tempopb is the Grafana Tempo link:https://grafana.com/docs/tempo/latest/api_docs/#tempo-grpc-api[gRPC client]
Source code: https://github.com/grafana/tempo/tree/main/pkg/tempopb

Supports Tempo version 2.3.0.

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTempo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTempo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTempo = fmt.Errorf("proto: unexpected end of group")
)
View Source
var DedicatedColumn_Scope_name = map[int32]string{
	0: "SPAN",
	1: "RESOURCE",
}
View Source
var DedicatedColumn_Scope_value = map[string]int32{
	"SPAN":     0,
	"RESOURCE": 1,
}
View Source
var DedicatedColumn_Type_name = map[int32]string{
	0: "STRING",
}
View Source
var DedicatedColumn_Type_value = map[string]int32{
	"STRING": 0,
}

Functions

func RegisterMetricsGeneratorServer

func RegisterMetricsGeneratorServer(s *grpc.Server, srv MetricsGeneratorServer)

func RegisterMetricsServer

func RegisterMetricsServer(s *grpc.Server, srv MetricsServer)

func RegisterPusherServer

func RegisterPusherServer(s *grpc.Server, srv PusherServer)

func RegisterQuerierServer

func RegisterQuerierServer(s *grpc.Server, srv QuerierServer)

func RegisterStreamingQuerierServer

func RegisterStreamingQuerierServer(s *grpc.Server, srv StreamingQuerierServer)

func ReuseByteSlices

func ReuseByteSlices(buffs [][]byte)

ReuseByteSlices puts the byte slice back into bytePool for reuse.

Types

type DedicatedColumn

type DedicatedColumn struct {
	Scope DedicatedColumn_Scope `protobuf:"varint,3,opt,name=scope,proto3,enum=tempopb.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=tempopb.DedicatedColumn_Type" json:"type,omitempty"`
}

Configuration for a single dedicated attribute column.

func (*DedicatedColumn) Descriptor

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

func (*DedicatedColumn) GetName

func (m *DedicatedColumn) GetName() string

func (*DedicatedColumn) GetScope

func (m *DedicatedColumn) GetScope() DedicatedColumn_Scope

func (*DedicatedColumn) GetType

func (*DedicatedColumn) Marshal

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

func (*DedicatedColumn) MarshalTo

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

func (*DedicatedColumn) MarshalToSizedBuffer

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

func (*DedicatedColumn) ProtoMessage

func (*DedicatedColumn) ProtoMessage()

func (*DedicatedColumn) Reset

func (m *DedicatedColumn) Reset()

func (*DedicatedColumn) Size

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

func (*DedicatedColumn) String

func (m *DedicatedColumn) String() string

func (*DedicatedColumn) Unmarshal

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

func (*DedicatedColumn) XXX_DiscardUnknown

func (m *DedicatedColumn) XXX_DiscardUnknown()

func (*DedicatedColumn) XXX_Marshal

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

func (*DedicatedColumn) XXX_Merge

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

func (*DedicatedColumn) XXX_Size

func (m *DedicatedColumn) XXX_Size() int

func (*DedicatedColumn) XXX_Unmarshal

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

type DedicatedColumn_Scope

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

func (DedicatedColumn_Scope) EnumDescriptor

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

func (DedicatedColumn_Scope) String

func (x DedicatedColumn_Scope) String() string

type DedicatedColumn_Type

type DedicatedColumn_Type int32
const (
	DedicatedColumn_STRING DedicatedColumn_Type = 0
)

func (DedicatedColumn_Type) EnumDescriptor

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

func (DedicatedColumn_Type) String

func (x DedicatedColumn_Type) String() string

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"`
}

func (*KeyValue) Descriptor

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

func (*KeyValue) GetKey

func (m *KeyValue) GetKey() string

func (*KeyValue) GetValue

func (m *KeyValue) GetValue() *TraceQLStatic

func (*KeyValue) Marshal

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

func (*KeyValue) MarshalTo

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

func (*KeyValue) MarshalToSizedBuffer

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

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset

func (m *KeyValue) Reset()

func (*KeyValue) Size

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

func (*KeyValue) String

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal

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

func (*KeyValue) XXX_DiscardUnknown

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal

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

func (*KeyValue) XXX_Merge

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

func (*KeyValue) XXX_Size

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal

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

type LinkSlice

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

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

func (*LinkSlice) Descriptor() ([]byte, []int)
func (m *LinkSlice) GetLinks() []*v11.Span_Link

func (*LinkSlice) Marshal

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

func (*LinkSlice) MarshalTo

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

func (*LinkSlice) MarshalToSizedBuffer

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

func (*LinkSlice) ProtoMessage

func (*LinkSlice) ProtoMessage()

func (*LinkSlice) Reset

func (m *LinkSlice) Reset()

func (*LinkSlice) Size

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

func (*LinkSlice) String

func (m *LinkSlice) String() string

func (*LinkSlice) Unmarshal

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

func (*LinkSlice) XXX_DiscardUnknown

func (m *LinkSlice) XXX_DiscardUnknown()

func (*LinkSlice) XXX_Marshal

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

func (*LinkSlice) XXX_Merge

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

func (*LinkSlice) XXX_Size

func (m *LinkSlice) XXX_Size() int

func (*LinkSlice) XXX_Unmarshal

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

type MetricsClient

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

MetricsClient is the client API for Metrics service.

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

func NewMetricsClient

func NewMetricsClient(cc *grpc.ClientConn) 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)
}

MetricsGeneratorClient is the client API for MetricsGenerator service.

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

func NewMetricsGeneratorClient

func NewMetricsGeneratorClient(cc *grpc.ClientConn) MetricsGeneratorClient

type MetricsGeneratorServer

type MetricsGeneratorServer interface {
	PushSpans(context.Context, *PushSpansRequest) (*PushResponse, error)
	GetMetrics(context.Context, *SpanMetricsRequest) (*SpanMetricsResponse, error)
}

MetricsGeneratorServer is the server API for MetricsGenerator service.

type MetricsServer

type MetricsServer interface {
	SpanMetricsSummary(context.Context, *SpanMetricsSummaryRequest) (*SpanMetricsSummaryResponse, error)
}

MetricsServer is the server API for Metrics service.

type PreallocBytes

type PreallocBytes struct {
	Slice []byte
}

PreallocBytes is a (repeated bytes slices) which preallocs slices on Unmarshal.

func (*PreallocBytes) MarshalTo

func (r *PreallocBytes) MarshalTo(dAtA []byte) (int, error)

MarshalTo implements proto.Marshaller. returned int is not used

func (*PreallocBytes) Size

func (r *PreallocBytes) Size() (n int)

Size implements proto.Sizer.

func (*PreallocBytes) Unmarshal

func (r *PreallocBytes) Unmarshal(dAtA []byte) error

Unmarshal implements proto.Message.

type PushBytesRequest

type PushBytesRequest struct {
	// pre-marshalled Traces. length must match ids
	Traces []PreallocBytes `protobuf:"bytes,2,rep,name=traces,proto3,customtype=PreallocBytes" json:"traces"`
	// trace ids. length must match traces
	Ids []PreallocBytes `protobuf:"bytes,3,rep,name=ids,proto3,customtype=PreallocBytes" json:"ids"`
	// search data, length must match traces
	SearchData []PreallocBytes `protobuf:"bytes,4,rep,name=searchData,proto3,customtype=PreallocBytes" json:"searchData"`
}

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

current BatchDecoder in ./pkg/model

func (*PushBytesRequest) Descriptor

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

func (*PushBytesRequest) Marshal

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

func (*PushBytesRequest) MarshalTo

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

func (*PushBytesRequest) MarshalToSizedBuffer

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

func (*PushBytesRequest) ProtoMessage

func (*PushBytesRequest) ProtoMessage()

func (*PushBytesRequest) Reset

func (m *PushBytesRequest) Reset()

func (*PushBytesRequest) Size

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

func (*PushBytesRequest) String

func (m *PushBytesRequest) String() string

func (*PushBytesRequest) Unmarshal

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

func (*PushBytesRequest) XXX_DiscardUnknown

func (m *PushBytesRequest) XXX_DiscardUnknown()

func (*PushBytesRequest) XXX_Marshal

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

func (*PushBytesRequest) XXX_Merge

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

func (*PushBytesRequest) XXX_Size

func (m *PushBytesRequest) XXX_Size() int

func (*PushBytesRequest) XXX_Unmarshal

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

type PushResponse

type PushResponse struct {
}

Write

func (*PushResponse) Descriptor

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

func (*PushResponse) Marshal

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

func (*PushResponse) MarshalTo

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

func (*PushResponse) MarshalToSizedBuffer

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

func (*PushResponse) ProtoMessage

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset

func (m *PushResponse) Reset()

func (*PushResponse) Size

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

func (*PushResponse) String

func (m *PushResponse) String() string

func (*PushResponse) Unmarshal

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

func (*PushResponse) XXX_DiscardUnknown

func (m *PushResponse) XXX_DiscardUnknown()

func (*PushResponse) XXX_Marshal

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

func (*PushResponse) XXX_Merge

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

func (*PushResponse) XXX_Size

func (m *PushResponse) XXX_Size() int

func (*PushResponse) XXX_Unmarshal

func (m *PushResponse) XXX_Unmarshal(b []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"`
}

func (*PushSpansRequest) Descriptor

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

func (*PushSpansRequest) GetBatches

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

func (*PushSpansRequest) Marshal

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

func (*PushSpansRequest) MarshalTo

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

func (*PushSpansRequest) MarshalToSizedBuffer

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

func (*PushSpansRequest) ProtoMessage

func (*PushSpansRequest) ProtoMessage()

func (*PushSpansRequest) Reset

func (m *PushSpansRequest) Reset()

func (*PushSpansRequest) Size

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

func (*PushSpansRequest) String

func (m *PushSpansRequest) String() string

func (*PushSpansRequest) Unmarshal

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

func (*PushSpansRequest) XXX_DiscardUnknown

func (m *PushSpansRequest) XXX_DiscardUnknown()

func (*PushSpansRequest) XXX_Marshal

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

func (*PushSpansRequest) XXX_Merge

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

func (*PushSpansRequest) XXX_Size

func (m *PushSpansRequest) XXX_Size() int

func (*PushSpansRequest) XXX_Unmarshal

func (m *PushSpansRequest) XXX_Unmarshal(b []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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPusherClient

func NewPusherClient(cc *grpc.ClientConn) 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)
}

PusherServer is the server API for Pusher service.

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQuerierClient

func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

type QuerierServer

QuerierServer is the server API for Querier service.

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"`
}

func (*RawHistogram) Descriptor

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

func (*RawHistogram) GetBucket

func (m *RawHistogram) GetBucket() uint64

func (*RawHistogram) GetCount

func (m *RawHistogram) GetCount() uint64

func (*RawHistogram) Marshal

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

func (*RawHistogram) MarshalTo

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

func (*RawHistogram) MarshalToSizedBuffer

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

func (*RawHistogram) ProtoMessage

func (*RawHistogram) ProtoMessage()

func (*RawHistogram) Reset

func (m *RawHistogram) Reset()

func (*RawHistogram) Size

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

func (*RawHistogram) String

func (m *RawHistogram) String() string

func (*RawHistogram) Unmarshal

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

func (*RawHistogram) XXX_DiscardUnknown

func (m *RawHistogram) XXX_DiscardUnknown()

func (*RawHistogram) XXX_Marshal

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

func (*RawHistogram) XXX_Merge

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

func (*RawHistogram) XXX_Size

func (m *RawHistogram) XXX_Size() int

func (*RawHistogram) XXX_Unmarshal

func (m *RawHistogram) XXX_Unmarshal(b []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"`
	FooterSize       uint32             `protobuf:"varint,11,opt,name=footerSize,proto3" json:"footerSize,omitempty"`
	DedicatedColumns []*DedicatedColumn `protobuf:"bytes,12,rep,name=dedicatedColumns,proto3" json:"dedicatedColumns,omitempty"`
}

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

func (*SearchBlockRequest) Descriptor

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

func (*SearchBlockRequest) GetBlockID

func (m *SearchBlockRequest) GetBlockID() string

func (*SearchBlockRequest) GetDataEncoding

func (m *SearchBlockRequest) GetDataEncoding() string

func (*SearchBlockRequest) GetDedicatedColumns

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

func (*SearchBlockRequest) GetEncoding

func (m *SearchBlockRequest) GetEncoding() string

func (*SearchBlockRequest) GetFooterSize

func (m *SearchBlockRequest) GetFooterSize() uint32

func (*SearchBlockRequest) GetIndexPageSize

func (m *SearchBlockRequest) GetIndexPageSize() uint32

func (*SearchBlockRequest) GetPagesToSearch

func (m *SearchBlockRequest) GetPagesToSearch() uint32

func (*SearchBlockRequest) GetSearchReq

func (m *SearchBlockRequest) GetSearchReq() *SearchRequest

func (*SearchBlockRequest) GetSize_

func (m *SearchBlockRequest) GetSize_() uint64

func (*SearchBlockRequest) GetStartPage

func (m *SearchBlockRequest) GetStartPage() uint32

func (*SearchBlockRequest) GetTotalRecords

func (m *SearchBlockRequest) GetTotalRecords() uint32

func (*SearchBlockRequest) GetVersion

func (m *SearchBlockRequest) GetVersion() string

func (*SearchBlockRequest) Marshal

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

func (*SearchBlockRequest) MarshalTo

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

func (*SearchBlockRequest) MarshalToSizedBuffer

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

func (*SearchBlockRequest) ProtoMessage

func (*SearchBlockRequest) ProtoMessage()

func (*SearchBlockRequest) Reset

func (m *SearchBlockRequest) Reset()

func (*SearchBlockRequest) Size

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

func (*SearchBlockRequest) String

func (m *SearchBlockRequest) String() string

func (*SearchBlockRequest) Unmarshal

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

func (*SearchBlockRequest) XXX_DiscardUnknown

func (m *SearchBlockRequest) XXX_DiscardUnknown()

func (*SearchBlockRequest) XXX_Marshal

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

func (*SearchBlockRequest) XXX_Merge

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

func (*SearchBlockRequest) XXX_Size

func (m *SearchBlockRequest) XXX_Size() int

func (*SearchBlockRequest) XXX_Unmarshal

func (m *SearchBlockRequest) XXX_Unmarshal(b []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"`
}

func (*SearchMetrics) Descriptor

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

func (*SearchMetrics) GetCompletedJobs

func (m *SearchMetrics) GetCompletedJobs() uint32

func (*SearchMetrics) GetInspectedBytes

func (m *SearchMetrics) GetInspectedBytes() uint64

func (*SearchMetrics) GetInspectedTraces

func (m *SearchMetrics) GetInspectedTraces() uint32

func (*SearchMetrics) GetTotalBlockBytes

func (m *SearchMetrics) GetTotalBlockBytes() uint64

func (*SearchMetrics) GetTotalBlocks

func (m *SearchMetrics) GetTotalBlocks() uint32

func (*SearchMetrics) GetTotalJobs

func (m *SearchMetrics) GetTotalJobs() uint32

func (*SearchMetrics) Marshal

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

func (*SearchMetrics) MarshalTo

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

func (*SearchMetrics) MarshalToSizedBuffer

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

func (*SearchMetrics) ProtoMessage

func (*SearchMetrics) ProtoMessage()

func (*SearchMetrics) Reset

func (m *SearchMetrics) Reset()

func (*SearchMetrics) Size

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

func (*SearchMetrics) String

func (m *SearchMetrics) String() string

func (*SearchMetrics) Unmarshal

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

func (*SearchMetrics) XXX_DiscardUnknown

func (m *SearchMetrics) XXX_DiscardUnknown()

func (*SearchMetrics) XXX_Marshal

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

func (*SearchMetrics) XXX_Merge

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

func (*SearchMetrics) XXX_Size

func (m *SearchMetrics) XXX_Size() int

func (*SearchMetrics) XXX_Unmarshal

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

type SearchRequest

type SearchRequest struct {
	// case insensitive partial match
	Tags          map[string]string `` /* 139-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"`
}

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

func (*SearchRequest) Descriptor

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

func (*SearchRequest) GetEnd

func (m *SearchRequest) GetEnd() uint32

func (*SearchRequest) GetLimit

func (m *SearchRequest) GetLimit() uint32

func (*SearchRequest) GetMaxDurationMs

func (m *SearchRequest) GetMaxDurationMs() uint32

func (*SearchRequest) GetMinDurationMs

func (m *SearchRequest) GetMinDurationMs() uint32

func (*SearchRequest) GetQuery

func (m *SearchRequest) GetQuery() string

func (*SearchRequest) GetSpansPerSpanSet

func (m *SearchRequest) GetSpansPerSpanSet() uint32

func (*SearchRequest) GetStart

func (m *SearchRequest) GetStart() uint32

func (*SearchRequest) GetTags

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

func (*SearchRequest) Marshal

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

func (*SearchRequest) MarshalTo

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

func (*SearchRequest) MarshalToSizedBuffer

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

func (*SearchRequest) ProtoMessage

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset

func (m *SearchRequest) Reset()

func (*SearchRequest) Size

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

func (*SearchRequest) String

func (m *SearchRequest) String() string

func (*SearchRequest) Unmarshal

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

func (*SearchRequest) XXX_DiscardUnknown

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal

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

func (*SearchRequest) XXX_Merge

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

func (*SearchRequest) XXX_Size

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal

func (m *SearchRequest) XXX_Unmarshal(b []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"`
}

func (*SearchResponse) Descriptor

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

func (*SearchResponse) GetMetrics

func (m *SearchResponse) GetMetrics() *SearchMetrics

func (*SearchResponse) GetTraces

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

func (*SearchResponse) Marshal

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

func (*SearchResponse) MarshalTo

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

func (*SearchResponse) MarshalToSizedBuffer

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

func (*SearchResponse) ProtoMessage

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset

func (m *SearchResponse) Reset()

func (*SearchResponse) Size

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

func (*SearchResponse) String

func (m *SearchResponse) String() string

func (*SearchResponse) Unmarshal

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

func (*SearchResponse) XXX_DiscardUnknown

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal

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

func (*SearchResponse) XXX_Merge

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

func (*SearchResponse) XXX_Size

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal

func (m *SearchResponse) XXX_Unmarshal(b []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"`
}

func (*SearchTagValuesRequest) Descriptor

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

func (*SearchTagValuesRequest) GetQuery

func (m *SearchTagValuesRequest) GetQuery() string

func (*SearchTagValuesRequest) GetTagName

func (m *SearchTagValuesRequest) GetTagName() string

func (*SearchTagValuesRequest) Marshal

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

func (*SearchTagValuesRequest) MarshalTo

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

func (*SearchTagValuesRequest) MarshalToSizedBuffer

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

func (*SearchTagValuesRequest) ProtoMessage

func (*SearchTagValuesRequest) ProtoMessage()

func (*SearchTagValuesRequest) Reset

func (m *SearchTagValuesRequest) Reset()

func (*SearchTagValuesRequest) Size

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

func (*SearchTagValuesRequest) String

func (m *SearchTagValuesRequest) String() string

func (*SearchTagValuesRequest) Unmarshal

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

func (*SearchTagValuesRequest) XXX_DiscardUnknown

func (m *SearchTagValuesRequest) XXX_DiscardUnknown()

func (*SearchTagValuesRequest) XXX_Marshal

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

func (*SearchTagValuesRequest) XXX_Merge

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

func (*SearchTagValuesRequest) XXX_Size

func (m *SearchTagValuesRequest) XXX_Size() int

func (*SearchTagValuesRequest) XXX_Unmarshal

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

type SearchTagValuesResponse

type SearchTagValuesResponse struct {
	TagValues []string `protobuf:"bytes,1,rep,name=tagValues,proto3" json:"tagValues,omitempty"`
}

func (*SearchTagValuesResponse) Descriptor

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

func (*SearchTagValuesResponse) GetTagValues

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

func (*SearchTagValuesResponse) Marshal

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

func (*SearchTagValuesResponse) MarshalTo

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

func (*SearchTagValuesResponse) MarshalToSizedBuffer

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

func (*SearchTagValuesResponse) ProtoMessage

func (*SearchTagValuesResponse) ProtoMessage()

func (*SearchTagValuesResponse) Reset

func (m *SearchTagValuesResponse) Reset()

func (*SearchTagValuesResponse) Size

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

func (*SearchTagValuesResponse) String

func (m *SearchTagValuesResponse) String() string

func (*SearchTagValuesResponse) Unmarshal

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

func (*SearchTagValuesResponse) XXX_DiscardUnknown

func (m *SearchTagValuesResponse) XXX_DiscardUnknown()

func (*SearchTagValuesResponse) XXX_Marshal

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

func (*SearchTagValuesResponse) XXX_Merge

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

func (*SearchTagValuesResponse) XXX_Size

func (m *SearchTagValuesResponse) XXX_Size() int

func (*SearchTagValuesResponse) XXX_Unmarshal

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

type SearchTagValuesV2Response

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

func (*SearchTagValuesV2Response) Descriptor

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

func (*SearchTagValuesV2Response) GetTagValues

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

func (*SearchTagValuesV2Response) Marshal

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

func (*SearchTagValuesV2Response) MarshalTo

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

func (*SearchTagValuesV2Response) MarshalToSizedBuffer

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

func (*SearchTagValuesV2Response) ProtoMessage

func (*SearchTagValuesV2Response) ProtoMessage()

func (*SearchTagValuesV2Response) Reset

func (m *SearchTagValuesV2Response) Reset()

func (*SearchTagValuesV2Response) Size

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

func (*SearchTagValuesV2Response) String

func (m *SearchTagValuesV2Response) String() string

func (*SearchTagValuesV2Response) Unmarshal

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

func (*SearchTagValuesV2Response) XXX_DiscardUnknown

func (m *SearchTagValuesV2Response) XXX_DiscardUnknown()

func (*SearchTagValuesV2Response) XXX_Marshal

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

func (*SearchTagValuesV2Response) XXX_Merge

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

func (*SearchTagValuesV2Response) XXX_Size

func (m *SearchTagValuesV2Response) XXX_Size() int

func (*SearchTagValuesV2Response) XXX_Unmarshal

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

type SearchTagsRequest

type SearchTagsRequest struct {
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
}

func (*SearchTagsRequest) Descriptor

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

func (*SearchTagsRequest) GetScope

func (m *SearchTagsRequest) GetScope() string

func (*SearchTagsRequest) Marshal

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

func (*SearchTagsRequest) MarshalTo

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

func (*SearchTagsRequest) MarshalToSizedBuffer

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

func (*SearchTagsRequest) ProtoMessage

func (*SearchTagsRequest) ProtoMessage()

func (*SearchTagsRequest) Reset

func (m *SearchTagsRequest) Reset()

func (*SearchTagsRequest) Size

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

func (*SearchTagsRequest) String

func (m *SearchTagsRequest) String() string

func (*SearchTagsRequest) Unmarshal

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

func (*SearchTagsRequest) XXX_DiscardUnknown

func (m *SearchTagsRequest) XXX_DiscardUnknown()

func (*SearchTagsRequest) XXX_Marshal

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

func (*SearchTagsRequest) XXX_Merge

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

func (*SearchTagsRequest) XXX_Size

func (m *SearchTagsRequest) XXX_Size() int

func (*SearchTagsRequest) XXX_Unmarshal

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

type SearchTagsResponse

type SearchTagsResponse struct {
	TagNames []string `protobuf:"bytes,1,rep,name=tagNames,proto3" json:"tagNames,omitempty"`
}

func (*SearchTagsResponse) Descriptor

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

func (*SearchTagsResponse) GetTagNames

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

func (*SearchTagsResponse) Marshal

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

func (*SearchTagsResponse) MarshalTo

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

func (*SearchTagsResponse) MarshalToSizedBuffer

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

func (*SearchTagsResponse) ProtoMessage

func (*SearchTagsResponse) ProtoMessage()

func (*SearchTagsResponse) Reset

func (m *SearchTagsResponse) Reset()

func (*SearchTagsResponse) Size

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

func (*SearchTagsResponse) String

func (m *SearchTagsResponse) String() string

func (*SearchTagsResponse) Unmarshal

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

func (*SearchTagsResponse) XXX_DiscardUnknown

func (m *SearchTagsResponse) XXX_DiscardUnknown()

func (*SearchTagsResponse) XXX_Marshal

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

func (*SearchTagsResponse) XXX_Merge

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

func (*SearchTagsResponse) XXX_Size

func (m *SearchTagsResponse) XXX_Size() int

func (*SearchTagsResponse) XXX_Unmarshal

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

type SearchTagsV2Response

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

func (*SearchTagsV2Response) Descriptor

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

func (*SearchTagsV2Response) GetScopes

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

func (*SearchTagsV2Response) Marshal

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

func (*SearchTagsV2Response) MarshalTo

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

func (*SearchTagsV2Response) MarshalToSizedBuffer

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

func (*SearchTagsV2Response) ProtoMessage

func (*SearchTagsV2Response) ProtoMessage()

func (*SearchTagsV2Response) Reset

func (m *SearchTagsV2Response) Reset()

func (*SearchTagsV2Response) Size

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

func (*SearchTagsV2Response) String

func (m *SearchTagsV2Response) String() string

func (*SearchTagsV2Response) Unmarshal

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

func (*SearchTagsV2Response) XXX_DiscardUnknown

func (m *SearchTagsV2Response) XXX_DiscardUnknown()

func (*SearchTagsV2Response) XXX_Marshal

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

func (*SearchTagsV2Response) XXX_Merge

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

func (*SearchTagsV2Response) XXX_Size

func (m *SearchTagsV2Response) XXX_Size() int

func (*SearchTagsV2Response) XXX_Unmarshal

func (m *SearchTagsV2Response) XXX_Unmarshal(b []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"`
}

func (*SearchTagsV2Scope) Descriptor

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

func (*SearchTagsV2Scope) GetName

func (m *SearchTagsV2Scope) GetName() string

func (*SearchTagsV2Scope) GetTags

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

func (*SearchTagsV2Scope) Marshal

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

func (*SearchTagsV2Scope) MarshalTo

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

func (*SearchTagsV2Scope) MarshalToSizedBuffer

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

func (*SearchTagsV2Scope) ProtoMessage

func (*SearchTagsV2Scope) ProtoMessage()

func (*SearchTagsV2Scope) Reset

func (m *SearchTagsV2Scope) Reset()

func (*SearchTagsV2Scope) Size

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

func (*SearchTagsV2Scope) String

func (m *SearchTagsV2Scope) String() string

func (*SearchTagsV2Scope) Unmarshal

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

func (*SearchTagsV2Scope) XXX_DiscardUnknown

func (m *SearchTagsV2Scope) XXX_DiscardUnknown()

func (*SearchTagsV2Scope) XXX_Marshal

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

func (*SearchTagsV2Scope) XXX_Merge

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

func (*SearchTagsV2Scope) XXX_Size

func (m *SearchTagsV2Scope) XXX_Size() int

func (*SearchTagsV2Scope) XXX_Unmarshal

func (m *SearchTagsV2Scope) XXX_Unmarshal(b []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"`
}

func (*Span) Descriptor

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

func (*Span) GetAttributes

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

func (*Span) GetDurationNanos

func (m *Span) GetDurationNanos() uint64

func (*Span) GetName

func (m *Span) GetName() string

func (*Span) GetSpanID

func (m *Span) GetSpanID() string

func (*Span) GetStartTimeUnixNano

func (m *Span) GetStartTimeUnixNano() uint64

func (*Span) Marshal

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

func (*Span) MarshalTo

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

func (*Span) MarshalToSizedBuffer

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

func (*Span) ProtoMessage

func (*Span) ProtoMessage()

func (*Span) Reset

func (m *Span) Reset()

func (*Span) Size

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

func (*Span) String

func (m *Span) String() string

func (*Span) Unmarshal

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

func (*Span) XXX_DiscardUnknown

func (m *Span) XXX_DiscardUnknown()

func (*Span) XXX_Marshal

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

func (*Span) XXX_Merge

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

func (*Span) XXX_Size

func (m *Span) XXX_Size() int

func (*Span) XXX_Unmarshal

func (m *Span) XXX_Unmarshal(b []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"`
}

func (*SpanMetrics) Descriptor

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

func (*SpanMetrics) GetErrors

func (m *SpanMetrics) GetErrors() uint64

func (*SpanMetrics) GetLatencyHistogram

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

func (*SpanMetrics) GetSeries

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

func (*SpanMetrics) Marshal

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

func (*SpanMetrics) MarshalTo

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

func (*SpanMetrics) MarshalToSizedBuffer

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

func (*SpanMetrics) ProtoMessage

func (*SpanMetrics) ProtoMessage()

func (*SpanMetrics) Reset

func (m *SpanMetrics) Reset()

func (*SpanMetrics) Size

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

func (*SpanMetrics) String

func (m *SpanMetrics) String() string

func (*SpanMetrics) Unmarshal

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

func (*SpanMetrics) XXX_DiscardUnknown

func (m *SpanMetrics) XXX_DiscardUnknown()

func (*SpanMetrics) XXX_Marshal

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

func (*SpanMetrics) XXX_Merge

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

func (*SpanMetrics) XXX_Size

func (m *SpanMetrics) XXX_Size() int

func (*SpanMetrics) XXX_Unmarshal

func (m *SpanMetrics) XXX_Unmarshal(b []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"`
}

func (*SpanMetricsRequest) Descriptor

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

func (*SpanMetricsRequest) GetEnd

func (m *SpanMetricsRequest) GetEnd() uint32

func (*SpanMetricsRequest) GetGroupBy

func (m *SpanMetricsRequest) GetGroupBy() string

func (*SpanMetricsRequest) GetLimit

func (m *SpanMetricsRequest) GetLimit() uint64

func (*SpanMetricsRequest) GetQuery

func (m *SpanMetricsRequest) GetQuery() string

func (*SpanMetricsRequest) GetStart

func (m *SpanMetricsRequest) GetStart() uint32

func (*SpanMetricsRequest) Marshal

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

func (*SpanMetricsRequest) MarshalTo

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

func (*SpanMetricsRequest) MarshalToSizedBuffer

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

func (*SpanMetricsRequest) ProtoMessage

func (*SpanMetricsRequest) ProtoMessage()

func (*SpanMetricsRequest) Reset

func (m *SpanMetricsRequest) Reset()

func (*SpanMetricsRequest) Size

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

func (*SpanMetricsRequest) String

func (m *SpanMetricsRequest) String() string

func (*SpanMetricsRequest) Unmarshal

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

func (*SpanMetricsRequest) XXX_DiscardUnknown

func (m *SpanMetricsRequest) XXX_DiscardUnknown()

func (*SpanMetricsRequest) XXX_Marshal

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

func (*SpanMetricsRequest) XXX_Merge

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

func (*SpanMetricsRequest) XXX_Size

func (m *SpanMetricsRequest) XXX_Size() int

func (*SpanMetricsRequest) XXX_Unmarshal

func (m *SpanMetricsRequest) XXX_Unmarshal(b []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"`
}

func (*SpanMetricsResponse) Descriptor

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

func (*SpanMetricsResponse) GetErrorSpanCount

func (m *SpanMetricsResponse) GetErrorSpanCount() uint64

func (*SpanMetricsResponse) GetEstimated

func (m *SpanMetricsResponse) GetEstimated() bool

func (*SpanMetricsResponse) GetMetrics

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

func (*SpanMetricsResponse) GetSpanCount

func (m *SpanMetricsResponse) GetSpanCount() uint64

func (*SpanMetricsResponse) Marshal

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

func (*SpanMetricsResponse) MarshalTo

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

func (*SpanMetricsResponse) MarshalToSizedBuffer

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

func (*SpanMetricsResponse) ProtoMessage

func (*SpanMetricsResponse) ProtoMessage()

func (*SpanMetricsResponse) Reset

func (m *SpanMetricsResponse) Reset()

func (*SpanMetricsResponse) Size

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

func (*SpanMetricsResponse) String

func (m *SpanMetricsResponse) String() string

func (*SpanMetricsResponse) Unmarshal

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

func (*SpanMetricsResponse) XXX_DiscardUnknown

func (m *SpanMetricsResponse) XXX_DiscardUnknown()

func (*SpanMetricsResponse) XXX_Marshal

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

func (*SpanMetricsResponse) XXX_Merge

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

func (*SpanMetricsResponse) XXX_Size

func (m *SpanMetricsResponse) XXX_Size() int

func (*SpanMetricsResponse) XXX_Unmarshal

func (m *SpanMetricsResponse) XXX_Unmarshal(b []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"`
}

func (*SpanMetricsSummary) Descriptor

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

func (*SpanMetricsSummary) GetErrorSpanCount

func (m *SpanMetricsSummary) GetErrorSpanCount() uint64

func (*SpanMetricsSummary) GetP50

func (m *SpanMetricsSummary) GetP50() uint64

func (*SpanMetricsSummary) GetP90

func (m *SpanMetricsSummary) GetP90() uint64

func (*SpanMetricsSummary) GetP95

func (m *SpanMetricsSummary) GetP95() uint64

func (*SpanMetricsSummary) GetP99

func (m *SpanMetricsSummary) GetP99() uint64

func (*SpanMetricsSummary) GetSeries

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

func (*SpanMetricsSummary) GetSpanCount

func (m *SpanMetricsSummary) GetSpanCount() uint64

func (*SpanMetricsSummary) Marshal

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

func (*SpanMetricsSummary) MarshalTo

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

func (*SpanMetricsSummary) MarshalToSizedBuffer

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

func (*SpanMetricsSummary) ProtoMessage

func (*SpanMetricsSummary) ProtoMessage()

func (*SpanMetricsSummary) Reset

func (m *SpanMetricsSummary) Reset()

func (*SpanMetricsSummary) Size

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

func (*SpanMetricsSummary) String

func (m *SpanMetricsSummary) String() string

func (*SpanMetricsSummary) Unmarshal

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

func (*SpanMetricsSummary) XXX_DiscardUnknown

func (m *SpanMetricsSummary) XXX_DiscardUnknown()

func (*SpanMetricsSummary) XXX_Marshal

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

func (*SpanMetricsSummary) XXX_Merge

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

func (*SpanMetricsSummary) XXX_Size

func (m *SpanMetricsSummary) XXX_Size() int

func (*SpanMetricsSummary) XXX_Unmarshal

func (m *SpanMetricsSummary) XXX_Unmarshal(b []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"`
}

func (*SpanMetricsSummaryRequest) Descriptor

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

func (*SpanMetricsSummaryRequest) GetEnd

func (m *SpanMetricsSummaryRequest) GetEnd() uint32

func (*SpanMetricsSummaryRequest) GetGroupBy

func (m *SpanMetricsSummaryRequest) GetGroupBy() string

func (*SpanMetricsSummaryRequest) GetLimit

func (m *SpanMetricsSummaryRequest) GetLimit() uint64

func (*SpanMetricsSummaryRequest) GetQuery

func (m *SpanMetricsSummaryRequest) GetQuery() string

func (*SpanMetricsSummaryRequest) GetStart

func (m *SpanMetricsSummaryRequest) GetStart() uint32

func (*SpanMetricsSummaryRequest) Marshal

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

func (*SpanMetricsSummaryRequest) MarshalTo

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

func (*SpanMetricsSummaryRequest) MarshalToSizedBuffer

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

func (*SpanMetricsSummaryRequest) ProtoMessage

func (*SpanMetricsSummaryRequest) ProtoMessage()

func (*SpanMetricsSummaryRequest) Reset

func (m *SpanMetricsSummaryRequest) Reset()

func (*SpanMetricsSummaryRequest) Size

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

func (*SpanMetricsSummaryRequest) String

func (m *SpanMetricsSummaryRequest) String() string

func (*SpanMetricsSummaryRequest) Unmarshal

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

func (*SpanMetricsSummaryRequest) XXX_DiscardUnknown

func (m *SpanMetricsSummaryRequest) XXX_DiscardUnknown()

func (*SpanMetricsSummaryRequest) XXX_Marshal

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

func (*SpanMetricsSummaryRequest) XXX_Merge

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

func (*SpanMetricsSummaryRequest) XXX_Size

func (m *SpanMetricsSummaryRequest) XXX_Size() int

func (*SpanMetricsSummaryRequest) XXX_Unmarshal

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

type SpanMetricsSummaryResponse

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

func (*SpanMetricsSummaryResponse) Descriptor

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

func (*SpanMetricsSummaryResponse) GetSummaries

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

func (*SpanMetricsSummaryResponse) Marshal

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

func (*SpanMetricsSummaryResponse) MarshalTo

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

func (*SpanMetricsSummaryResponse) MarshalToSizedBuffer

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

func (*SpanMetricsSummaryResponse) ProtoMessage

func (*SpanMetricsSummaryResponse) ProtoMessage()

func (*SpanMetricsSummaryResponse) Reset

func (m *SpanMetricsSummaryResponse) Reset()

func (*SpanMetricsSummaryResponse) Size

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

func (*SpanMetricsSummaryResponse) String

func (m *SpanMetricsSummaryResponse) String() string

func (*SpanMetricsSummaryResponse) Unmarshal

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

func (*SpanMetricsSummaryResponse) XXX_DiscardUnknown

func (m *SpanMetricsSummaryResponse) XXX_DiscardUnknown()

func (*SpanMetricsSummaryResponse) XXX_Marshal

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

func (*SpanMetricsSummaryResponse) XXX_Merge

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

func (*SpanMetricsSummaryResponse) XXX_Size

func (m *SpanMetricsSummaryResponse) XXX_Size() int

func (*SpanMetricsSummaryResponse) XXX_Unmarshal

func (m *SpanMetricsSummaryResponse) XXX_Unmarshal(b []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"`
}

func (*SpanSet) Descriptor

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

func (*SpanSet) GetAttributes

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

func (*SpanSet) GetMatched

func (m *SpanSet) GetMatched() uint32

func (*SpanSet) GetSpans

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

func (*SpanSet) Marshal

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

func (*SpanSet) MarshalTo

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

func (*SpanSet) MarshalToSizedBuffer

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

func (*SpanSet) ProtoMessage

func (*SpanSet) ProtoMessage()

func (*SpanSet) Reset

func (m *SpanSet) Reset()

func (*SpanSet) Size

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

func (*SpanSet) String

func (m *SpanSet) String() string

func (*SpanSet) Unmarshal

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

func (*SpanSet) XXX_DiscardUnknown

func (m *SpanSet) XXX_DiscardUnknown()

func (*SpanSet) XXX_Marshal

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

func (*SpanSet) XXX_Merge

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

func (*SpanSet) XXX_Size

func (m *SpanSet) XXX_Size() int

func (*SpanSet) XXX_Unmarshal

func (m *SpanSet) XXX_Unmarshal(b []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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStreamingQuerierClient

func NewStreamingQuerierClient(cc *grpc.ClientConn) StreamingQuerierClient

type StreamingQuerierServer

type StreamingQuerierServer interface {
	Search(*SearchRequest, StreamingQuerier_SearchServer) error
}

StreamingQuerierServer is the server API for StreamingQuerier service.

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"`
}

func (*TagValue) Descriptor

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

func (*TagValue) GetType

func (m *TagValue) GetType() string

func (*TagValue) GetValue

func (m *TagValue) GetValue() string

func (*TagValue) Marshal

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

func (*TagValue) MarshalTo

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

func (*TagValue) MarshalToSizedBuffer

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

func (*TagValue) ProtoMessage

func (*TagValue) ProtoMessage()

func (*TagValue) Reset

func (m *TagValue) Reset()

func (*TagValue) Size

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

func (*TagValue) String

func (m *TagValue) String() string

func (*TagValue) Unmarshal

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

func (*TagValue) XXX_DiscardUnknown

func (m *TagValue) XXX_DiscardUnknown()

func (*TagValue) XXX_Marshal

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

func (*TagValue) XXX_Merge

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

func (*TagValue) XXX_Size

func (m *TagValue) XXX_Size() int

func (*TagValue) XXX_Unmarshal

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

type Trace

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

func (*Trace) Descriptor

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

func (*Trace) GetBatches

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

func (*Trace) Marshal

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

func (*Trace) MarshalTo

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

func (*Trace) MarshalToSizedBuffer

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

func (*Trace) ProtoMessage

func (*Trace) ProtoMessage()

func (*Trace) Reset

func (m *Trace) Reset()

func (*Trace) Size

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

func (*Trace) String

func (m *Trace) String() string

func (*Trace) Unmarshal

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

func (*Trace) XXX_DiscardUnknown

func (m *Trace) XXX_DiscardUnknown()

func (*Trace) XXX_Marshal

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

func (*Trace) XXX_Merge

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

func (*Trace) XXX_Size

func (m *Trace) XXX_Size() int

func (*Trace) XXX_Unmarshal

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

type TraceByIDMetrics

type TraceByIDMetrics struct {
}

func (*TraceByIDMetrics) Descriptor

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

func (*TraceByIDMetrics) Marshal

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

func (*TraceByIDMetrics) MarshalTo

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

func (*TraceByIDMetrics) MarshalToSizedBuffer

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

func (*TraceByIDMetrics) ProtoMessage

func (*TraceByIDMetrics) ProtoMessage()

func (*TraceByIDMetrics) Reset

func (m *TraceByIDMetrics) Reset()

func (*TraceByIDMetrics) Size

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

func (*TraceByIDMetrics) String

func (m *TraceByIDMetrics) String() string

func (*TraceByIDMetrics) Unmarshal

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

func (*TraceByIDMetrics) XXX_DiscardUnknown

func (m *TraceByIDMetrics) XXX_DiscardUnknown()

func (*TraceByIDMetrics) XXX_Marshal

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

func (*TraceByIDMetrics) XXX_Merge

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

func (*TraceByIDMetrics) XXX_Size

func (m *TraceByIDMetrics) XXX_Size() int

func (*TraceByIDMetrics) XXX_Unmarshal

func (m *TraceByIDMetrics) XXX_Unmarshal(b []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"`
}

Read

func (*TraceByIDRequest) Descriptor

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

func (*TraceByIDRequest) GetBlockEnd

func (m *TraceByIDRequest) GetBlockEnd() string

func (*TraceByIDRequest) GetBlockStart

func (m *TraceByIDRequest) GetBlockStart() string

func (*TraceByIDRequest) GetQueryMode

func (m *TraceByIDRequest) GetQueryMode() string

func (*TraceByIDRequest) GetTraceID

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

func (*TraceByIDRequest) Marshal

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

func (*TraceByIDRequest) MarshalTo

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

func (*TraceByIDRequest) MarshalToSizedBuffer

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

func (*TraceByIDRequest) ProtoMessage

func (*TraceByIDRequest) ProtoMessage()

func (*TraceByIDRequest) Reset

func (m *TraceByIDRequest) Reset()

func (*TraceByIDRequest) Size

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

func (*TraceByIDRequest) String

func (m *TraceByIDRequest) String() string

func (*TraceByIDRequest) Unmarshal

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

func (*TraceByIDRequest) XXX_DiscardUnknown

func (m *TraceByIDRequest) XXX_DiscardUnknown()

func (*TraceByIDRequest) XXX_Marshal

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

func (*TraceByIDRequest) XXX_Merge

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

func (*TraceByIDRequest) XXX_Size

func (m *TraceByIDRequest) XXX_Size() int

func (*TraceByIDRequest) XXX_Unmarshal

func (m *TraceByIDRequest) XXX_Unmarshal(b []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"`
}

func (*TraceByIDResponse) Descriptor

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

func (*TraceByIDResponse) GetMetrics

func (m *TraceByIDResponse) GetMetrics() *TraceByIDMetrics

func (*TraceByIDResponse) GetTrace

func (m *TraceByIDResponse) GetTrace() *Trace

func (*TraceByIDResponse) Marshal

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

func (*TraceByIDResponse) MarshalTo

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

func (*TraceByIDResponse) MarshalToSizedBuffer

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

func (*TraceByIDResponse) ProtoMessage

func (*TraceByIDResponse) ProtoMessage()

func (*TraceByIDResponse) Reset

func (m *TraceByIDResponse) Reset()

func (*TraceByIDResponse) Size

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

func (*TraceByIDResponse) String

func (m *TraceByIDResponse) String() string

func (*TraceByIDResponse) Unmarshal

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

func (*TraceByIDResponse) XXX_DiscardUnknown

func (m *TraceByIDResponse) XXX_DiscardUnknown()

func (*TraceByIDResponse) XXX_Marshal

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

func (*TraceByIDResponse) XXX_Merge

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

func (*TraceByIDResponse) XXX_Size

func (m *TraceByIDResponse) XXX_Size() int

func (*TraceByIDResponse) XXX_Unmarshal

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

type TraceBytes

type TraceBytes struct {
	// pre-marshalled Traces
	Traces [][]byte `protobuf:"bytes,1,rep,name=traces,proto3" json:"traces,omitempty"`
}

func (*TraceBytes) Descriptor

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

func (*TraceBytes) GetTraces

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

func (*TraceBytes) Marshal

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

func (*TraceBytes) MarshalTo

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

func (*TraceBytes) MarshalToSizedBuffer

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

func (*TraceBytes) ProtoMessage

func (*TraceBytes) ProtoMessage()

func (*TraceBytes) Reset

func (m *TraceBytes) Reset()

func (*TraceBytes) Size

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

func (*TraceBytes) String

func (m *TraceBytes) String() string

func (*TraceBytes) Unmarshal

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

func (*TraceBytes) XXX_DiscardUnknown

func (m *TraceBytes) XXX_DiscardUnknown()

func (*TraceBytes) XXX_Marshal

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

func (*TraceBytes) XXX_Merge

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

func (*TraceBytes) XXX_Size

func (m *TraceBytes) XXX_Size() int

func (*TraceBytes) XXX_Unmarshal

func (m *TraceBytes) XXX_Unmarshal(b []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"`
}

func (*TraceQLStatic) Descriptor

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

func (*TraceQLStatic) GetB

func (m *TraceQLStatic) GetB() bool

func (*TraceQLStatic) GetD

func (m *TraceQLStatic) GetD() uint64

func (*TraceQLStatic) GetF

func (m *TraceQLStatic) GetF() float64

func (*TraceQLStatic) GetKind

func (m *TraceQLStatic) GetKind() int32

func (*TraceQLStatic) GetN

func (m *TraceQLStatic) GetN() int64

func (*TraceQLStatic) GetS

func (m *TraceQLStatic) GetS() string

func (*TraceQLStatic) GetStatus

func (m *TraceQLStatic) GetStatus() int32

func (*TraceQLStatic) GetType

func (m *TraceQLStatic) GetType() int32

func (*TraceQLStatic) Marshal

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

func (*TraceQLStatic) MarshalTo

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

func (*TraceQLStatic) MarshalToSizedBuffer

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

func (*TraceQLStatic) ProtoMessage

func (*TraceQLStatic) ProtoMessage()

func (*TraceQLStatic) Reset

func (m *TraceQLStatic) Reset()

func (*TraceQLStatic) Size

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

func (*TraceQLStatic) String

func (m *TraceQLStatic) String() string

func (*TraceQLStatic) Unmarshal

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

func (*TraceQLStatic) XXX_DiscardUnknown

func (m *TraceQLStatic) XXX_DiscardUnknown()

func (*TraceQLStatic) XXX_Marshal

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

func (*TraceQLStatic) XXX_Merge

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

func (*TraceQLStatic) XXX_Size

func (m *TraceQLStatic) XXX_Size() int

func (*TraceQLStatic) XXX_Unmarshal

func (m *TraceQLStatic) XXX_Unmarshal(b []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"`
	SpanSets          []*SpanSet `protobuf:"bytes,7,rep,name=spanSets,proto3" json:"spanSets,omitempty"`
}

func (*TraceSearchMetadata) Descriptor

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

func (*TraceSearchMetadata) GetDurationMs

func (m *TraceSearchMetadata) GetDurationMs() uint32

func (*TraceSearchMetadata) GetRootServiceName

func (m *TraceSearchMetadata) GetRootServiceName() string

func (*TraceSearchMetadata) GetRootTraceName

func (m *TraceSearchMetadata) GetRootTraceName() string

func (*TraceSearchMetadata) GetSpanSet

func (m *TraceSearchMetadata) GetSpanSet() *SpanSet

func (*TraceSearchMetadata) GetSpanSets

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

func (*TraceSearchMetadata) GetStartTimeUnixNano

func (m *TraceSearchMetadata) GetStartTimeUnixNano() uint64

func (*TraceSearchMetadata) GetTraceID

func (m *TraceSearchMetadata) GetTraceID() string

func (*TraceSearchMetadata) Marshal

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

func (*TraceSearchMetadata) MarshalTo

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

func (*TraceSearchMetadata) MarshalToSizedBuffer

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

func (*TraceSearchMetadata) ProtoMessage

func (*TraceSearchMetadata) ProtoMessage()

func (*TraceSearchMetadata) Reset

func (m *TraceSearchMetadata) Reset()

func (*TraceSearchMetadata) Size

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

func (*TraceSearchMetadata) String

func (m *TraceSearchMetadata) String() string

func (*TraceSearchMetadata) Unmarshal

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

func (*TraceSearchMetadata) XXX_DiscardUnknown

func (m *TraceSearchMetadata) XXX_DiscardUnknown()

func (*TraceSearchMetadata) XXX_Marshal

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

func (*TraceSearchMetadata) XXX_Merge

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

func (*TraceSearchMetadata) XXX_Size

func (m *TraceSearchMetadata) XXX_Size() int

func (*TraceSearchMetadata) XXX_Unmarshal

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

type UnimplementedMetricsGeneratorServer

type UnimplementedMetricsGeneratorServer struct {
}

UnimplementedMetricsGeneratorServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsGeneratorServer) GetMetrics

func (*UnimplementedMetricsGeneratorServer) PushSpans

type UnimplementedMetricsServer

type UnimplementedMetricsServer struct {
}

UnimplementedMetricsServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsServer) SpanMetricsSummary

type UnimplementedPusherServer

type UnimplementedPusherServer struct {
}

UnimplementedPusherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPusherServer) PushBytes

func (*UnimplementedPusherServer) PushBytesV2

type UnimplementedQuerierServer

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) FindTraceByID

func (*UnimplementedQuerierServer) SearchBlock

func (*UnimplementedQuerierServer) SearchRecent

func (*UnimplementedQuerierServer) SearchTagValues

func (*UnimplementedQuerierServer) SearchTagValuesV2

func (*UnimplementedQuerierServer) SearchTags

func (*UnimplementedQuerierServer) SearchTagsV2

type UnimplementedStreamingQuerierServer

type UnimplementedStreamingQuerierServer struct {
}

UnimplementedStreamingQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamingQuerierServer) Search

Directories

Path Synopsis
common
v1
resource
v1
trace
v1

Jump to

Keyboard shortcuts

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