Documentation ¶
Index ¶
- Variables
- func RegisterMetricsGeneratorServer(s *grpc.Server, srv MetricsGeneratorServer)
- func RegisterPusherServer(s *grpc.Server, srv PusherServer)
- func RegisterQuerierServer(s *grpc.Server, srv QuerierServer)
- func ReuseByteSlices(buffs [][]byte)
- func SliceFromBytePool(size int) []byte
- type MetricsGeneratorClient
- type MetricsGeneratorServer
- type PreallocBytes
- type PushBytesRequest
- func (*PushBytesRequest) Descriptor() ([]byte, []int)
- 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 (*PushBytesRequest) ProtoMessage()
- 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 PushResponse
- func (*PushResponse) Descriptor() ([]byte, []int)
- 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 (*PushResponse) ProtoMessage()
- 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 PushSpansRequest
- func (*PushSpansRequest) Descriptor() ([]byte, []int)
- 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 (*PushSpansRequest) ProtoMessage()
- 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
- type PusherServer
- type QuerierClient
- type QuerierServer
- type SearchBlockRequest
- func (*SearchBlockRequest) Descriptor() ([]byte, []int)
- func (m *SearchBlockRequest) GetBlockID() string
- func (m *SearchBlockRequest) GetDataEncoding() string
- func (m *SearchBlockRequest) GetEncoding() string
- func (m *SearchBlockRequest) GetFooterSize() uint32
- func (m *SearchBlockRequest) GetIndexPageSize() uint32
- func (m *SearchBlockRequest) GetPagesToSearch() uint32
- func (m *SearchBlockRequest) GetSearchReq() *SearchRequest
- func (m *SearchBlockRequest) GetSize_() uint64
- 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 (*SearchBlockRequest) ProtoMessage()
- 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 SearchMetrics
- func (*SearchMetrics) Descriptor() ([]byte, []int)
- func (m *SearchMetrics) GetInspectedBlocks() uint32
- func (m *SearchMetrics) GetInspectedBytes() uint64
- func (m *SearchMetrics) GetInspectedTraces() uint32
- func (m *SearchMetrics) GetSkippedBlocks() uint32
- func (m *SearchMetrics) GetSkippedTraces() uint32
- func (m *SearchMetrics) GetTotalBlockBytes() uint64
- 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 (*SearchMetrics) ProtoMessage()
- 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
- func (*SearchRequest) Descriptor() ([]byte, []int)
- func (m *SearchRequest) GetEnd() uint32
- func (m *SearchRequest) GetLimit() uint32
- func (m *SearchRequest) GetMaxDurationMs() uint32
- func (m *SearchRequest) GetMinDurationMs() uint32
- func (m *SearchRequest) GetStart() 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 (*SearchRequest) ProtoMessage()
- 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
- func (*SearchResponse) Descriptor() ([]byte, []int)
- 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 (*SearchResponse) ProtoMessage()
- 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
- func (*SearchTagValuesRequest) Descriptor() ([]byte, []int)
- 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 (*SearchTagValuesRequest) ProtoMessage()
- 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
- func (*SearchTagValuesResponse) Descriptor() ([]byte, []int)
- 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 (*SearchTagValuesResponse) ProtoMessage()
- 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
- func (*SearchTagsRequest) Descriptor() ([]byte, []int)
- 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 (*SearchTagsRequest) ProtoMessage()
- 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
- func (*SearchTagsResponse) Descriptor() ([]byte, []int)
- 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 (*SearchTagsResponse) ProtoMessage()
- 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 Trace
- func (*Trace) Descriptor() ([]byte, []int)
- 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 (*Trace) ProtoMessage()
- 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 TraceByIDMetrics
- func (*TraceByIDMetrics) Descriptor() ([]byte, []int)
- 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 (*TraceByIDMetrics) ProtoMessage()
- 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 TraceByIDRequest
- func (*TraceByIDRequest) Descriptor() ([]byte, []int)
- func (m *TraceByIDRequest) GetBlockEnd() string
- func (m *TraceByIDRequest) GetBlockStart() string
- func (m *TraceByIDRequest) GetQueryMode() string
- 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 (*TraceByIDRequest) ProtoMessage()
- 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
- func (*TraceByIDResponse) Descriptor() ([]byte, []int)
- func (m *TraceByIDResponse) GetMetrics() *TraceByIDMetrics
- 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 (*TraceByIDResponse) ProtoMessage()
- 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 TraceBytes
- func (*TraceBytes) Descriptor() ([]byte, []int)
- 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 (*TraceBytes) ProtoMessage()
- 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
- type TraceSearchMetadata
- func (*TraceSearchMetadata) Descriptor() ([]byte, []int)
- 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 (*TraceSearchMetadata) ProtoMessage()
- 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 UnimplementedMetricsGeneratorServer
- type UnimplementedPusherServer
- type UnimplementedQuerierServer
- func (*UnimplementedQuerierServer) FindTraceByID(ctx context.Context, req *TraceByIDRequest) (*TraceByIDResponse, error)
- func (*UnimplementedQuerierServer) SearchBlock(ctx context.Context, req *SearchBlockRequest) (*SearchResponse, error)
- func (*UnimplementedQuerierServer) SearchRecent(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)
Constants ¶
This section is empty.
Variables ¶
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
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) 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"` }
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) GetBatches ¶
func (m *Trace) GetBatches() []*v1.ResourceSpans
func (*Trace) ProtoMessage ¶
func (*Trace) ProtoMessage()
func (*Trace) XXX_DiscardUnknown ¶
func (m *Trace) XXX_DiscardUnknown()
func (*Trace) XXX_Marshal ¶
func (*Trace) XXX_Unmarshal ¶
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) 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)