tempopb

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2022 License: AGPL-3.0 Imports: 12 Imported by: 5

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

Functions

func RegisterMetricsGeneratorServer added in v1.4.0 

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

func RegisterPusherServer 

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

func RegisterQuerierServer 

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

func ReuseByteSlices added in v1.4.0 

func ReuseByteSlices(buffs [][]byte)

ReuseByteSlices puts the byte slice back into bytePool for reuse.

func SliceFromBytePool added in v1.0.0 

func SliceFromBytePool(size int) []byte

SliceFromBytePool gets a slice from the byte pool

Types

type MetricsGeneratorClient added in v1.4.0 

type MetricsGeneratorClient interface {
	PushSpans(ctx context.Context, in *PushSpansRequest, opts ...grpc.CallOption) (*PushResponse, 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 added in v1.4.0 

func NewMetricsGeneratorClient(cc *grpc.ClientConn) MetricsGeneratorClient

type MetricsGeneratorServer added in v1.4.0 

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

MetricsGeneratorServer is the server API for MetricsGenerator service.

type PreallocBytes added in v1.0.0 

type PreallocBytes struct {
	Slice []byte
}

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

func (*PreallocBytes) MarshalTo added in v1.0.0 

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

MarshalTo implements proto.Marshaller. returned int is not used

func (*PreallocBytes) Size added in v1.0.0 

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

Size implements proto.Sizer.

func (*PreallocBytes) Unmarshal added in v1.0.0 

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

Unmarshal implements proto.Message.

type PushBytesRequest added in v0.5.0 

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 added in v0.5.0 

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

func (*PushBytesRequest) Marshal added in v0.5.0 

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

func (*PushBytesRequest) MarshalTo added in v0.5.0 

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

func (*PushBytesRequest) MarshalToSizedBuffer added in v0.5.0 

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

func (*PushBytesRequest) ProtoMessage added in v0.5.0 

func (*PushBytesRequest) ProtoMessage()

func (*PushBytesRequest) Reset added in v0.5.0 

func (m *PushBytesRequest) Reset()

func (*PushBytesRequest) Size added in v0.5.0 

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

func (*PushBytesRequest) String added in v0.5.0 

func (m *PushBytesRequest) String() string

func (*PushBytesRequest) Unmarshal added in v0.5.0 

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

func (*PushBytesRequest) XXX_DiscardUnknown added in v0.5.0 

func (m *PushBytesRequest) XXX_DiscardUnknown()

func (*PushBytesRequest) XXX_Marshal added in v0.5.0 

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

func (*PushBytesRequest) XXX_Merge added in v0.5.0 

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

func (*PushBytesRequest) XXX_Size added in v0.5.0 

func (m *PushBytesRequest) XXX_Size() int

func (*PushBytesRequest) XXX_Unmarshal added in v0.5.0 

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 added in v1.4.0 

type PushSpansRequest struct {
	// just send entire OTel spans for now
	Batches []*v1.ResourceSpans `protobuf:"bytes,1,rep,name=batches,proto3" json:"batches,omitempty"`
}

func (*PushSpansRequest) Descriptor added in v1.4.0 

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

func (*PushSpansRequest) GetBatches added in v1.4.0 

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

func (*PushSpansRequest) Marshal added in v1.4.0 

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

func (*PushSpansRequest) MarshalTo added in v1.4.0 

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

func (*PushSpansRequest) MarshalToSizedBuffer added in v1.4.0 

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

func (*PushSpansRequest) ProtoMessage added in v1.4.0 

func (*PushSpansRequest) ProtoMessage()

func (*PushSpansRequest) Reset added in v1.4.0 

func (m *PushSpansRequest) Reset()

func (*PushSpansRequest) Size added in v1.4.0 

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

func (*PushSpansRequest) String added in v1.4.0 

func (m *PushSpansRequest) String() string

func (*PushSpansRequest) Unmarshal added in v1.4.0 

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

func (*PushSpansRequest) XXX_DiscardUnknown added in v1.4.0 

func (m *PushSpansRequest) XXX_DiscardUnknown()

func (*PushSpansRequest) XXX_Marshal added in v1.4.0 

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

func (*PushSpansRequest) XXX_Merge added in v1.4.0 

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

func (*PushSpansRequest) XXX_Size added in v1.4.0 

func (m *PushSpansRequest) XXX_Size() int

func (*PushSpansRequest) XXX_Unmarshal added in v1.4.0 

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)
	SearchTagValues(ctx context.Context, in *SearchTagValuesRequest, opts ...grpc.CallOption) (*SearchTagValuesResponse, 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 

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)
	SearchTagValues(context.Context, *SearchTagValuesRequest) (*SearchTagValuesResponse, error)
}

QuerierServer is the server API for Querier service.

type SearchBlockRequest added in v1.3.0 

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

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

func (*SearchBlockRequest) Descriptor added in v1.3.0 

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

func (*SearchBlockRequest) GetBlockID added in v1.3.0 

func (m *SearchBlockRequest) GetBlockID() string

func (*SearchBlockRequest) GetDataEncoding added in v1.3.0 

func (m *SearchBlockRequest) GetDataEncoding() string

func (*SearchBlockRequest) GetEncoding added in v1.3.0 

func (m *SearchBlockRequest) GetEncoding() string

func (*SearchBlockRequest) GetFooterSize added in v1.5.0 

func (m *SearchBlockRequest) GetFooterSize() uint32

func (*SearchBlockRequest) GetIndexPageSize added in v1.3.0 

func (m *SearchBlockRequest) GetIndexPageSize() uint32

func (*SearchBlockRequest) GetPagesToSearch added in v1.3.0 

func (m *SearchBlockRequest) GetPagesToSearch() uint32

func (*SearchBlockRequest) GetSearchReq added in v1.3.0 

func (m *SearchBlockRequest) GetSearchReq() *SearchRequest

func (*SearchBlockRequest) GetSize_ added in v1.5.0 

func (m *SearchBlockRequest) GetSize_() uint64

func (*SearchBlockRequest) GetStartPage added in v1.3.0 

func (m *SearchBlockRequest) GetStartPage() uint32

func (*SearchBlockRequest) GetTotalRecords added in v1.3.0 

func (m *SearchBlockRequest) GetTotalRecords() uint32

func (*SearchBlockRequest) GetVersion added in v1.3.0 

func (m *SearchBlockRequest) GetVersion() string

func (*SearchBlockRequest) Marshal added in v1.3.0 

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

func (*SearchBlockRequest) MarshalTo added in v1.3.0 

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

func (*SearchBlockRequest) MarshalToSizedBuffer added in v1.3.0 

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

func (*SearchBlockRequest) ProtoMessage added in v1.3.0 

func (*SearchBlockRequest) ProtoMessage()

func (*SearchBlockRequest) Reset added in v1.3.0 

func (m *SearchBlockRequest) Reset()

func (*SearchBlockRequest) Size added in v1.3.0 

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

func (*SearchBlockRequest) String added in v1.3.0 

func (m *SearchBlockRequest) String() string

func (*SearchBlockRequest) Unmarshal added in v1.3.0 

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

func (*SearchBlockRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *SearchBlockRequest) XXX_DiscardUnknown()

func (*SearchBlockRequest) XXX_Marshal added in v1.3.0 

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

func (*SearchBlockRequest) XXX_Merge added in v1.3.0 

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

func (*SearchBlockRequest) XXX_Size added in v1.3.0 

func (m *SearchBlockRequest) XXX_Size() int

func (*SearchBlockRequest) XXX_Unmarshal added in v1.3.0 

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

type SearchMetrics added in v1.2.0 

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"`
	InspectedBlocks uint32 `protobuf:"varint,3,opt,name=inspectedBlocks,proto3" json:"inspectedBlocks,omitempty"`
	SkippedBlocks   uint32 `protobuf:"varint,4,opt,name=skippedBlocks,proto3" json:"skippedBlocks,omitempty"`
	SkippedTraces   uint32 `protobuf:"varint,5,opt,name=skippedTraces,proto3" json:"skippedTraces,omitempty"`
	TotalBlockBytes uint64 `protobuf:"varint,6,opt,name=totalBlockBytes,proto3" json:"totalBlockBytes,omitempty"`
}

func (*SearchMetrics) Descriptor added in v1.2.0 

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

func (*SearchMetrics) GetInspectedBlocks added in v1.2.0 

func (m *SearchMetrics) GetInspectedBlocks() uint32

func (*SearchMetrics) GetInspectedBytes added in v1.2.0 

func (m *SearchMetrics) GetInspectedBytes() uint64

func (*SearchMetrics) GetInspectedTraces added in v1.2.0 

func (m *SearchMetrics) GetInspectedTraces() uint32

func (*SearchMetrics) GetSkippedBlocks added in v1.2.0 

func (m *SearchMetrics) GetSkippedBlocks() uint32

func (*SearchMetrics) GetSkippedTraces added in v1.4.0 

func (m *SearchMetrics) GetSkippedTraces() uint32

func (*SearchMetrics) GetTotalBlockBytes added in v1.5.0 

func (m *SearchMetrics) GetTotalBlockBytes() uint64

func (*SearchMetrics) Marshal added in v1.2.0 

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

func (*SearchMetrics) MarshalTo added in v1.2.0 

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

func (*SearchMetrics) MarshalToSizedBuffer added in v1.2.0 

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

func (*SearchMetrics) ProtoMessage added in v1.2.0 

func (*SearchMetrics) ProtoMessage()

func (*SearchMetrics) Reset added in v1.2.0 

func (m *SearchMetrics) Reset()

func (*SearchMetrics) Size added in v1.2.0 

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

func (*SearchMetrics) String added in v1.2.0 

func (m *SearchMetrics) String() string

func (*SearchMetrics) Unmarshal added in v1.2.0 

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

func (*SearchMetrics) XXX_DiscardUnknown added in v1.2.0 

func (m *SearchMetrics) XXX_DiscardUnknown()

func (*SearchMetrics) XXX_Marshal added in v1.2.0 

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

func (*SearchMetrics) XXX_Merge added in v1.2.0 

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

func (*SearchMetrics) XXX_Size added in v1.2.0 

func (m *SearchMetrics) XXX_Size() int

func (*SearchMetrics) XXX_Unmarshal added in v1.2.0 

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

type SearchRequest added in v1.2.0 

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

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

func (*SearchRequest) Descriptor added in v1.2.0 

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

func (*SearchRequest) GetEnd added in v1.3.0 

func (m *SearchRequest) GetEnd() uint32

func (*SearchRequest) GetLimit added in v1.2.0 

func (m *SearchRequest) GetLimit() uint32

func (*SearchRequest) GetMaxDurationMs added in v1.2.0 

func (m *SearchRequest) GetMaxDurationMs() uint32

func (*SearchRequest) GetMinDurationMs added in v1.2.0 

func (m *SearchRequest) GetMinDurationMs() uint32

func (*SearchRequest) GetStart added in v1.3.0 

func (m *SearchRequest) GetStart() uint32

func (*SearchRequest) GetTags added in v1.2.0 

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

func (*SearchRequest) Marshal added in v1.2.0 

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

func (*SearchRequest) MarshalTo added in v1.2.0 

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

func (*SearchRequest) MarshalToSizedBuffer added in v1.2.0 

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

func (*SearchRequest) ProtoMessage added in v1.2.0 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset added in v1.2.0 

func (m *SearchRequest) Reset()

func (*SearchRequest) Size added in v1.2.0 

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

func (*SearchRequest) String added in v1.2.0 

func (m *SearchRequest) String() string

func (*SearchRequest) Unmarshal added in v1.2.0 

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

func (*SearchRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal added in v1.2.0 

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

func (*SearchRequest) XXX_Merge added in v1.2.0 

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

func (*SearchRequest) XXX_Size added in v1.2.0 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal added in v1.2.0 

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

type SearchResponse added in v1.2.0 

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 added in v1.2.0 

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

func (*SearchResponse) GetMetrics added in v1.2.0 

func (m *SearchResponse) GetMetrics() *SearchMetrics

func (*SearchResponse) GetTraces added in v1.2.0 

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

func (*SearchResponse) Marshal added in v1.2.0 

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

func (*SearchResponse) MarshalTo added in v1.2.0 

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

func (*SearchResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*SearchResponse) ProtoMessage added in v1.2.0 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset added in v1.2.0 

func (m *SearchResponse) Reset()

func (*SearchResponse) Size added in v1.2.0 

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

func (*SearchResponse) String added in v1.2.0 

func (m *SearchResponse) String() string

func (*SearchResponse) Unmarshal added in v1.2.0 

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

func (*SearchResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal added in v1.2.0 

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

func (*SearchResponse) XXX_Merge added in v1.2.0 

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

func (*SearchResponse) XXX_Size added in v1.2.0 

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal added in v1.2.0 

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

type SearchTagValuesRequest added in v1.2.0 

type SearchTagValuesRequest struct {
	TagName string `protobuf:"bytes,1,opt,name=tagName,proto3" json:"tagName,omitempty"`
}

func (*SearchTagValuesRequest) Descriptor added in v1.2.0 

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

func (*SearchTagValuesRequest) GetTagName added in v1.2.0 

func (m *SearchTagValuesRequest) GetTagName() string

func (*SearchTagValuesRequest) Marshal added in v1.2.0 

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

func (*SearchTagValuesRequest) MarshalTo added in v1.2.0 

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

func (*SearchTagValuesRequest) MarshalToSizedBuffer added in v1.2.0 

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

func (*SearchTagValuesRequest) ProtoMessage added in v1.2.0 

func (*SearchTagValuesRequest) ProtoMessage()

func (*SearchTagValuesRequest) Reset added in v1.2.0 

func (m *SearchTagValuesRequest) Reset()

func (*SearchTagValuesRequest) Size added in v1.2.0 

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

func (*SearchTagValuesRequest) String added in v1.2.0 

func (m *SearchTagValuesRequest) String() string

func (*SearchTagValuesRequest) Unmarshal added in v1.2.0 

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

func (*SearchTagValuesRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *SearchTagValuesRequest) XXX_DiscardUnknown()

func (*SearchTagValuesRequest) XXX_Marshal added in v1.2.0 

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

func (*SearchTagValuesRequest) XXX_Merge added in v1.2.0 

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

func (*SearchTagValuesRequest) XXX_Size added in v1.2.0 

func (m *SearchTagValuesRequest) XXX_Size() int

func (*SearchTagValuesRequest) XXX_Unmarshal added in v1.2.0 

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

type SearchTagValuesResponse added in v1.2.0 

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

func (*SearchTagValuesResponse) Descriptor added in v1.2.0 

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

func (*SearchTagValuesResponse) GetTagValues added in v1.2.0 

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

func (*SearchTagValuesResponse) Marshal added in v1.2.0 

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

func (*SearchTagValuesResponse) MarshalTo added in v1.2.0 

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

func (*SearchTagValuesResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*SearchTagValuesResponse) ProtoMessage added in v1.2.0 

func (*SearchTagValuesResponse) ProtoMessage()

func (*SearchTagValuesResponse) Reset added in v1.2.0 

func (m *SearchTagValuesResponse) Reset()

func (*SearchTagValuesResponse) Size added in v1.2.0 

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

func (*SearchTagValuesResponse) String added in v1.2.0 

func (m *SearchTagValuesResponse) String() string

func (*SearchTagValuesResponse) Unmarshal added in v1.2.0 

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

func (*SearchTagValuesResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *SearchTagValuesResponse) XXX_DiscardUnknown()

func (*SearchTagValuesResponse) XXX_Marshal added in v1.2.0 

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

func (*SearchTagValuesResponse) XXX_Merge added in v1.2.0 

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

func (*SearchTagValuesResponse) XXX_Size added in v1.2.0 

func (m *SearchTagValuesResponse) XXX_Size() int

func (*SearchTagValuesResponse) XXX_Unmarshal added in v1.2.0 

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

type SearchTagsRequest added in v1.2.0 

type SearchTagsRequest struct {
}

func (*SearchTagsRequest) Descriptor added in v1.2.0 

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

func (*SearchTagsRequest) Marshal added in v1.2.0 

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

func (*SearchTagsRequest) MarshalTo added in v1.2.0 

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

func (*SearchTagsRequest) MarshalToSizedBuffer added in v1.2.0 

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

func (*SearchTagsRequest) ProtoMessage added in v1.2.0 

func (*SearchTagsRequest) ProtoMessage()

func (*SearchTagsRequest) Reset added in v1.2.0 

func (m *SearchTagsRequest) Reset()

func (*SearchTagsRequest) Size added in v1.2.0 

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

func (*SearchTagsRequest) String added in v1.2.0 

func (m *SearchTagsRequest) String() string

func (*SearchTagsRequest) Unmarshal added in v1.2.0 

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

func (*SearchTagsRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *SearchTagsRequest) XXX_DiscardUnknown()

func (*SearchTagsRequest) XXX_Marshal added in v1.2.0 

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

func (*SearchTagsRequest) XXX_Merge added in v1.2.0 

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

func (*SearchTagsRequest) XXX_Size added in v1.2.0 

func (m *SearchTagsRequest) XXX_Size() int

func (*SearchTagsRequest) XXX_Unmarshal added in v1.2.0 

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

type SearchTagsResponse added in v1.2.0 

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

func (*SearchTagsResponse) Descriptor added in v1.2.0 

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

func (*SearchTagsResponse) GetTagNames added in v1.2.0 

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

func (*SearchTagsResponse) Marshal added in v1.2.0 

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

func (*SearchTagsResponse) MarshalTo added in v1.2.0 

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

func (*SearchTagsResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*SearchTagsResponse) ProtoMessage added in v1.2.0 

func (*SearchTagsResponse) ProtoMessage()

func (*SearchTagsResponse) Reset added in v1.2.0 

func (m *SearchTagsResponse) Reset()

func (*SearchTagsResponse) Size added in v1.2.0 

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

func (*SearchTagsResponse) String added in v1.2.0 

func (m *SearchTagsResponse) String() string

func (*SearchTagsResponse) Unmarshal added in v1.2.0 

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

func (*SearchTagsResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *SearchTagsResponse) XXX_DiscardUnknown()

func (*SearchTagsResponse) XXX_Marshal added in v1.2.0 

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

func (*SearchTagsResponse) XXX_Merge added in v1.2.0 

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

func (*SearchTagsResponse) XXX_Size added in v1.2.0 

func (m *SearchTagsResponse) XXX_Size() int

func (*SearchTagsResponse) XXX_Unmarshal added in v1.2.0 

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

type Trace 

type Trace struct {
	Batches []*v1.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() []*v1.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 added in v1.2.0 

type TraceByIDMetrics struct {
	FailedBlocks uint32 `protobuf:"varint,1,opt,name=failedBlocks,proto3" json:"failedBlocks,omitempty"`
}

func (*TraceByIDMetrics) Descriptor added in v1.2.0 

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

func (*TraceByIDMetrics) GetFailedBlocks added in v1.2.0 

func (m *TraceByIDMetrics) GetFailedBlocks() uint32

func (*TraceByIDMetrics) Marshal added in v1.2.0 

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

func (*TraceByIDMetrics) MarshalTo added in v1.2.0 

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

func (*TraceByIDMetrics) MarshalToSizedBuffer added in v1.2.0 

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

func (*TraceByIDMetrics) ProtoMessage added in v1.2.0 

func (*TraceByIDMetrics) ProtoMessage()

func (*TraceByIDMetrics) Reset added in v1.2.0 

func (m *TraceByIDMetrics) Reset()

func (*TraceByIDMetrics) Size added in v1.2.0 

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

func (*TraceByIDMetrics) String added in v1.2.0 

func (m *TraceByIDMetrics) String() string

func (*TraceByIDMetrics) Unmarshal added in v1.2.0 

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

func (*TraceByIDMetrics) XXX_DiscardUnknown added in v1.2.0 

func (m *TraceByIDMetrics) XXX_DiscardUnknown()

func (*TraceByIDMetrics) XXX_Marshal added in v1.2.0 

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

func (*TraceByIDMetrics) XXX_Merge added in v1.2.0 

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

func (*TraceByIDMetrics) XXX_Size added in v1.2.0 

func (m *TraceByIDMetrics) XXX_Size() int

func (*TraceByIDMetrics) XXX_Unmarshal added in v1.2.0 

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 added in v0.5.0 

func (m *TraceByIDRequest) GetBlockEnd() string

func (*TraceByIDRequest) GetBlockStart added in v0.5.0 

func (m *TraceByIDRequest) GetBlockStart() string

func (*TraceByIDRequest) GetQueryMode added in v0.7.0 

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 added in v1.2.0 

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 added in v1.0.0 

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

func (*TraceBytes) Descriptor added in v1.0.0 

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

func (*TraceBytes) GetTraces added in v1.0.0 

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

func (*TraceBytes) Marshal added in v1.0.0 

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

func (*TraceBytes) MarshalTo added in v1.0.0 

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

func (*TraceBytes) MarshalToSizedBuffer added in v1.0.0 

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

func (*TraceBytes) ProtoMessage added in v1.0.0 

func (*TraceBytes) ProtoMessage()

func (*TraceBytes) Reset added in v1.0.0 

func (m *TraceBytes) Reset()

func (*TraceBytes) Size added in v1.0.0 

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

func (*TraceBytes) String added in v1.0.0 

func (m *TraceBytes) String() string

func (*TraceBytes) Unmarshal added in v1.0.0 

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

func (*TraceBytes) XXX_DiscardUnknown added in v1.0.0 

func (m *TraceBytes) XXX_DiscardUnknown()

func (*TraceBytes) XXX_Marshal added in v1.0.0 

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

func (*TraceBytes) XXX_Merge added in v1.0.0 

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

func (*TraceBytes) XXX_Size added in v1.0.0 

func (m *TraceBytes) XXX_Size() int

func (*TraceBytes) XXX_Unmarshal added in v1.0.0 

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

type TraceSearchMetadata added in v1.2.0 

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

func (*TraceSearchMetadata) Descriptor added in v1.2.0 

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

func (*TraceSearchMetadata) GetDurationMs added in v1.2.0 

func (m *TraceSearchMetadata) GetDurationMs() uint32

func (*TraceSearchMetadata) GetRootServiceName added in v1.2.0 

func (m *TraceSearchMetadata) GetRootServiceName() string

func (*TraceSearchMetadata) GetRootTraceName added in v1.2.0 

func (m *TraceSearchMetadata) GetRootTraceName() string

func (*TraceSearchMetadata) GetStartTimeUnixNano added in v1.2.0 

func (m *TraceSearchMetadata) GetStartTimeUnixNano() uint64

func (*TraceSearchMetadata) GetTraceID added in v1.2.0 

func (m *TraceSearchMetadata) GetTraceID() string

func (*TraceSearchMetadata) Marshal added in v1.2.0 

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

func (*TraceSearchMetadata) MarshalTo added in v1.2.0 

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

func (*TraceSearchMetadata) MarshalToSizedBuffer added in v1.2.0 

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

func (*TraceSearchMetadata) ProtoMessage added in v1.2.0 

func (*TraceSearchMetadata) ProtoMessage()

func (*TraceSearchMetadata) Reset added in v1.2.0 

func (m *TraceSearchMetadata) Reset()

func (*TraceSearchMetadata) Size added in v1.2.0 

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

func (*TraceSearchMetadata) String added in v1.2.0 

func (m *TraceSearchMetadata) String() string

func (*TraceSearchMetadata) Unmarshal added in v1.2.0 

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

func (*TraceSearchMetadata) XXX_DiscardUnknown added in v1.2.0 

func (m *TraceSearchMetadata) XXX_DiscardUnknown()

func (*TraceSearchMetadata) XXX_Marshal added in v1.2.0 

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

func (*TraceSearchMetadata) XXX_Merge added in v1.2.0 

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

func (*TraceSearchMetadata) XXX_Size added in v1.2.0 

func (m *TraceSearchMetadata) XXX_Size() int

func (*TraceSearchMetadata) XXX_Unmarshal added in v1.2.0 

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

type UnimplementedMetricsGeneratorServer added in v1.4.0 

type UnimplementedMetricsGeneratorServer struct {
}

UnimplementedMetricsGeneratorServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsGeneratorServer) PushSpans added in v1.4.0 

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

type UnimplementedPusherServer 

type UnimplementedPusherServer struct {
}

UnimplementedPusherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPusherServer) PushBytes added in v0.5.0 

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

func (*UnimplementedPusherServer) PushBytesV2 added in v1.4.0 

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

type UnimplementedQuerierServer 

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) FindTraceByID 

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

func (*UnimplementedQuerierServer) SearchBlock added in v1.3.0 

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

func (*UnimplementedQuerierServer) SearchRecent added in v1.3.0 

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

func (*UnimplementedQuerierServer) SearchTagValues added in v1.2.0 

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

func (*UnimplementedQuerierServer) SearchTags added in v1.2.0 

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

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.