tempopb

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2021 License: AGPL-3.0 Imports: 12 Imported by: 7

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 RegisterPusherServer 

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

func RegisterQuerierServer 

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

func ReuseTraceBytes added in v1.0.0 

func ReuseTraceBytes(trace *TraceBytes)

ReuseTraceBytes 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 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 PushRequests
	Requests []PreallocBytes `protobuf:"bytes,1,rep,name=requests,proto3,customtype=PreallocBytes" json:"requests"` // Deprecated: Do not use.
	// 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"`
}

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 PushRequest 

type PushRequest struct {
	Batch *v1.ResourceSpans `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
}

Write

func (*PushRequest) Descriptor 

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

func (*PushRequest) GetBatch 

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

func (*PushRequest) Marshal 

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

func (*PushRequest) MarshalTo 

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

func (*PushRequest) MarshalToSizedBuffer 

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

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset 

func (m *PushRequest) Reset()

func (*PushRequest) Size 

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

func (*PushRequest) String 

func (m *PushRequest) String() string

func (*PushRequest) Unmarshal 

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

func (*PushRequest) XXX_DiscardUnknown 

func (m *PushRequest) XXX_DiscardUnknown()

func (*PushRequest) XXX_Marshal 

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

func (*PushRequest) XXX_Merge 

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

func (*PushRequest) XXX_Size 

func (m *PushRequest) XXX_Size() int

func (*PushRequest) XXX_Unmarshal 

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

type PushResponse 

type PushResponse struct {
}

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 PusherClient 

type PusherClient interface {
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
	PushBytes(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 {
	Push(context.Context, *PushRequest) (*PushResponse, error)
	PushBytes(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)
}

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

QuerierServer is the server API for Querier service.

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

func (*TraceByIDResponse) Descriptor 

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

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 UnimplementedPusherServer 

type UnimplementedPusherServer struct {
}

UnimplementedPusherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPusherServer) Push 

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

func (*UnimplementedPusherServer) PushBytes added in v0.5.0 

func (*UnimplementedPusherServer) PushBytes(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)

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.