tempopb

Aug 17, 2022

Changes in this version

type SearchBlockRequest

+ FooterSize uint32

+ Size_ uint64

+ func (m *SearchBlockRequest) GetFooterSize() uint32

+ func (m *SearchBlockRequest) GetSize_() uint64

type SearchMetrics

+ TotalBlockBytes uint64

+ func (m *SearchMetrics) GetTotalBlockBytes() uint64

Apr 28, 2022

Changes in this version

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

+ func ReuseByteSlices(buffs [][]byte)

+ type MetricsGeneratorClient interface

+ PushSpans func(ctx context.Context, in *PushSpansRequest, opts ...grpc.CallOption) (*PushResponse, error)

+ func NewMetricsGeneratorClient(cc *grpc.ClientConn) MetricsGeneratorClient

+ type MetricsGeneratorServer interface

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

+ type PushSpansRequest struct

+ Batches []*v1.ResourceSpans

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

+ func (*PushSpansRequest) ProtoMessage()

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

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

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

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

+ func (m *PushSpansRequest) Reset()

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

+ func (m *PushSpansRequest) String() string

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

+ func (m *PushSpansRequest) XXX_DiscardUnknown()

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

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

+ func (m *PushSpansRequest) XXX_Size() int

+ func (m *PushSpansRequest) XXX_Unmarshal(b []byte) error

type PusherClient

+ PushBytesV2 func(ctx context.Context, in *PushBytesRequest, opts ...grpc.CallOption) (*PushResponse, error)

type PusherServer

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

type SearchMetrics

+ SkippedTraces uint32

+ func (m *SearchMetrics) GetSkippedTraces() uint32

+ type UnimplementedMetricsGeneratorServer struct

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

type UnimplementedPusherServer

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

Jan 24, 2022

Changes in this version

type QuerierClient

+ SearchBlock func(ctx context.Context, in *SearchBlockRequest, opts ...grpc.CallOption) (*SearchResponse, error)

+ SearchRecent func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)

type QuerierServer

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

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

+ type SearchBlockRequest struct

+ BlockID string

+ DataEncoding string

+ Encoding string

+ IndexPageSize uint32

+ PagesToSearch uint32

+ SearchReq *SearchRequest

+ StartPage uint32

+ TotalRecords uint32

+ Version string

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

+ func (*SearchBlockRequest) ProtoMessage()

+ func (m *SearchBlockRequest) GetBlockID() string

+ func (m *SearchBlockRequest) GetDataEncoding() string

+ func (m *SearchBlockRequest) GetEncoding() string

+ func (m *SearchBlockRequest) GetIndexPageSize() uint32

+ func (m *SearchBlockRequest) GetPagesToSearch() uint32

+ func (m *SearchBlockRequest) GetSearchReq() *SearchRequest

+ func (m *SearchBlockRequest) GetStartPage() uint32

+ func (m *SearchBlockRequest) GetTotalRecords() uint32

+ func (m *SearchBlockRequest) GetVersion() string

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

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

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

+ func (m *SearchBlockRequest) Reset()

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

+ func (m *SearchBlockRequest) String() string

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

+ func (m *SearchBlockRequest) XXX_DiscardUnknown()

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

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

+ func (m *SearchBlockRequest) XXX_Size() int

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

type SearchRequest

+ End uint32

+ Start uint32

+ func (m *SearchRequest) GetEnd() uint32

+ func (m *SearchRequest) GetStart() uint32

type UnimplementedQuerierServer

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

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

Nov 5, 2021

Changes in this version

type PushBytesRequest

+ SearchData []PreallocBytes

type QuerierClient

+ Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)

+ SearchTagValues func(ctx context.Context, in *SearchTagValuesRequest, opts ...grpc.CallOption) (*SearchTagValuesResponse, error)

+ SearchTags func(ctx context.Context, in *SearchTagsRequest, opts ...grpc.CallOption) (*SearchTagsResponse, error)

type QuerierServer

+ Search func(context.Context, *SearchRequest) (*SearchResponse, error)

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

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

+ type SearchMetrics struct

+ InspectedBlocks uint32

+ InspectedBytes uint64

+ InspectedTraces uint32

+ SkippedBlocks uint32

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

+ func (*SearchMetrics) ProtoMessage()

+ func (m *SearchMetrics) GetInspectedBlocks() uint32

+ func (m *SearchMetrics) GetInspectedBytes() uint64

+ func (m *SearchMetrics) GetInspectedTraces() uint32

+ func (m *SearchMetrics) GetSkippedBlocks() uint32

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

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

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

+ func (m *SearchMetrics) Reset()

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

+ func (m *SearchMetrics) String() string

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

+ func (m *SearchMetrics) XXX_DiscardUnknown()

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

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

+ func (m *SearchMetrics) XXX_Size() int

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

+ type SearchRequest struct

+ Limit uint32

+ MaxDurationMs uint32

+ MinDurationMs uint32

+ Tags map[string]string

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

+ func (*SearchRequest) ProtoMessage()

+ func (m *SearchRequest) GetLimit() uint32

+ func (m *SearchRequest) GetMaxDurationMs() uint32

+ func (m *SearchRequest) GetMinDurationMs() uint32

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

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

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

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

+ func (m *SearchRequest) Reset()

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

+ func (m *SearchRequest) String() string

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

+ func (m *SearchRequest) XXX_DiscardUnknown()

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

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

+ func (m *SearchRequest) XXX_Size() int

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

+ type SearchResponse struct

+ Metrics *SearchMetrics

+ Traces []*TraceSearchMetadata

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

+ func (*SearchResponse) ProtoMessage()

+ func (m *SearchResponse) GetMetrics() *SearchMetrics

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

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

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

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

+ func (m *SearchResponse) Reset()

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

+ func (m *SearchResponse) String() string

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

+ func (m *SearchResponse) XXX_DiscardUnknown()

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

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

+ func (m *SearchResponse) XXX_Size() int

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

+ type SearchTagValuesRequest struct

+ TagName string

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

+ func (*SearchTagValuesRequest) ProtoMessage()

+ func (m *SearchTagValuesRequest) GetTagName() string

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

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

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

+ func (m *SearchTagValuesRequest) Reset()

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

+ func (m *SearchTagValuesRequest) String() string

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

+ func (m *SearchTagValuesRequest) XXX_DiscardUnknown()

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

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

+ func (m *SearchTagValuesRequest) XXX_Size() int

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

+ type SearchTagValuesResponse struct

+ TagValues []string

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

+ func (*SearchTagValuesResponse) ProtoMessage()

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

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

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

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

+ func (m *SearchTagValuesResponse) Reset()

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

+ func (m *SearchTagValuesResponse) String() string

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

+ func (m *SearchTagValuesResponse) XXX_DiscardUnknown()

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

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

+ func (m *SearchTagValuesResponse) XXX_Size() int

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

+ type SearchTagsRequest struct

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

+ func (*SearchTagsRequest) ProtoMessage()

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

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

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

+ func (m *SearchTagsRequest) Reset()

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

+ func (m *SearchTagsRequest) String() string

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

+ func (m *SearchTagsRequest) XXX_DiscardUnknown()

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

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

+ func (m *SearchTagsRequest) XXX_Size() int

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

+ type SearchTagsResponse struct

+ TagNames []string

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

+ func (*SearchTagsResponse) ProtoMessage()

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

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

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

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

+ func (m *SearchTagsResponse) Reset()

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

+ func (m *SearchTagsResponse) String() string

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

+ func (m *SearchTagsResponse) XXX_DiscardUnknown()

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

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

+ func (m *SearchTagsResponse) XXX_Size() int

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

+ type TraceByIDMetrics struct

+ FailedBlocks uint32

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

+ func (*TraceByIDMetrics) ProtoMessage()

+ func (m *TraceByIDMetrics) GetFailedBlocks() uint32

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

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

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

+ func (m *TraceByIDMetrics) Reset()

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

+ func (m *TraceByIDMetrics) String() string

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

+ func (m *TraceByIDMetrics) XXX_DiscardUnknown()

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

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

+ func (m *TraceByIDMetrics) XXX_Size() int

+ func (m *TraceByIDMetrics) XXX_Unmarshal(b []byte) error

type TraceByIDResponse

+ Metrics *TraceByIDMetrics

+ func (m *TraceByIDResponse) GetMetrics() *TraceByIDMetrics

+ type TraceSearchMetadata struct

+ DurationMs uint32

+ RootServiceName string

+ RootTraceName string

+ StartTimeUnixNano uint64

+ TraceID string

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

+ func (*TraceSearchMetadata) ProtoMessage()

+ func (m *TraceSearchMetadata) GetDurationMs() uint32

+ func (m *TraceSearchMetadata) GetRootServiceName() string

+ func (m *TraceSearchMetadata) GetRootTraceName() string

+ func (m *TraceSearchMetadata) GetStartTimeUnixNano() uint64

+ func (m *TraceSearchMetadata) GetTraceID() string

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

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

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

+ func (m *TraceSearchMetadata) Reset()

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

+ func (m *TraceSearchMetadata) String() string

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

+ func (m *TraceSearchMetadata) XXX_DiscardUnknown()

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

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

+ func (m *TraceSearchMetadata) XXX_Size() int

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

type UnimplementedQuerierServer

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

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

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

Jun 7, 2021

Changes in this version

+ func ReuseTraceBytes(trace *TraceBytes)

+ func SliceFromBytePool(size int) []byte

+ type PreallocBytes struct

+ Slice []byte

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

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

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

type PushBytesRequest

+ Ids []PreallocBytes

+ Traces []PreallocBytes

+ type TraceBytes struct

+ Traces [][]byte

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

+ func (*TraceBytes) ProtoMessage()

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

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

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

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

+ func (m *TraceBytes) Reset()

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

+ func (m *TraceBytes) String() string

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

+ func (m *TraceBytes) XXX_DiscardUnknown()

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

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

+ func (m *TraceBytes) XXX_Size() int

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

Apr 21, 2021

Changes in this version

type TraceByIDRequest

+ QueryMode string

+ func (m *TraceByIDRequest) GetQueryMode() string

Jan 15, 2021

Changes in this version

+ type PushBytesRequest struct

+ Requests [][]byte

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

+ func (*PushBytesRequest) ProtoMessage()

+ func (m *PushBytesRequest) GetRequests() [][]byte

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

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

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

+ func (m *PushBytesRequest) Reset()

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

+ func (m *PushBytesRequest) String() string

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

+ func (m *PushBytesRequest) XXX_DiscardUnknown()

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

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

+ func (m *PushBytesRequest) XXX_Size() int

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

type PusherClient

+ PushBytes func(ctx context.Context, in *PushBytesRequest, opts ...grpc.CallOption) (*PushResponse, error)

type PusherServer

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

type TraceByIDRequest

+ BlockEnd string

+ BlockStart string

+ QueryIngesters bool

+ func (m *TraceByIDRequest) GetBlockEnd() string

+ func (m *TraceByIDRequest) GetBlockStart() string

+ func (m *TraceByIDRequest) GetQueryIngesters() bool

type UnimplementedPusherServer

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

Oct 23, 2020

Changes in this version

+ var ErrIntOverflowTempo = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTempo = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupTempo = fmt.Errorf("proto: unexpected end of group")

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

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

+ type PushRequest struct

+ Batch *v1.ResourceSpans

+ func (*PushRequest) Descriptor() ([]byte, []int)

+ func (*PushRequest) ProtoMessage()

+ func (m *PushRequest) GetBatch() *v1.ResourceSpans

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

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

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

+ func (m *PushRequest) Reset()

+ func (m *PushRequest) Size() (n int)

+ func (m *PushRequest) String() string

+ func (m *PushRequest) Unmarshal(dAtA []byte) error

+ func (m *PushRequest) XXX_DiscardUnknown()

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

+ func (m *PushRequest) XXX_Merge(src proto.Message)

+ func (m *PushRequest) XXX_Size() int

+ func (m *PushRequest) XXX_Unmarshal(b []byte) error

+ type PushResponse struct

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

+ func (*PushResponse) ProtoMessage()

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

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

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

+ func (m *PushResponse) Reset()

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

+ func (m *PushResponse) String() string

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

+ func (m *PushResponse) XXX_DiscardUnknown()

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

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

+ func (m *PushResponse) XXX_Size() int

+ func (m *PushResponse) XXX_Unmarshal(b []byte) error

+ type PusherClient interface

+ Push func(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)

+ func NewPusherClient(cc *grpc.ClientConn) PusherClient

+ type PusherServer interface

+ Push func(context.Context, *PushRequest) (*PushResponse, error)

+ type QuerierClient interface

+ FindTraceByID func(ctx context.Context, in *TraceByIDRequest, opts ...grpc.CallOption) (*TraceByIDResponse, error)

+ func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

+ type QuerierServer interface

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

+ type Trace struct

+ Batches []*v1.ResourceSpans

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

+ func (*Trace) ProtoMessage()

+ func (m *Trace) GetBatches() []*v1.ResourceSpans

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

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

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

+ func (m *Trace) Reset()

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

+ func (m *Trace) String() string

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

+ func (m *Trace) XXX_DiscardUnknown()

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

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

+ func (m *Trace) XXX_Size() int

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

+ type TraceByIDRequest struct

+ TraceID []byte

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

+ func (*TraceByIDRequest) ProtoMessage()

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

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

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

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

+ func (m *TraceByIDRequest) Reset()

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

+ func (m *TraceByIDRequest) String() string

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

+ func (m *TraceByIDRequest) XXX_DiscardUnknown()

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

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

+ func (m *TraceByIDRequest) XXX_Size() int

+ func (m *TraceByIDRequest) XXX_Unmarshal(b []byte) error

+ type TraceByIDResponse struct

+ Trace *Trace

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

+ func (*TraceByIDResponse) ProtoMessage()

+ func (m *TraceByIDResponse) GetTrace() *Trace

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

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

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

+ func (m *TraceByIDResponse) Reset()

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

+ func (m *TraceByIDResponse) String() string

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

+ func (m *TraceByIDResponse) XXX_DiscardUnknown()

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

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

+ func (m *TraceByIDResponse) XXX_Size() int

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

+ type UnimplementedPusherServer struct

+ func (*UnimplementedPusherServer) Push(ctx context.Context, req *PushRequest) (*PushResponse, error)

+ type UnimplementedQuerierServer struct

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