model

package
v1.86.2 Latest Latest
Warning

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

Go to latest
Published: Jun 25, 2024 License: Apache-2.0 Imports: 24 Imported by: 1

Documentation

Overview

nolint

nolint

nolint

Index

Constants

View Source
const (
	// StringType indicates the value is a unicode string
	StringType = ValueType_STRING
	// BoolType indicates the value is a Boolean encoded as int64 number 0 or 1
	BoolType = ValueType_BOOL
	// Int64Type indicates the value is an int64 number
	Int64Type = ValueType_INT64
	// Float64Type indicates the value is a float64 number stored as int64
	Float64Type = ValueType_FLOAT64
	// BinaryType indicates the value is binary blob stored as a byte array
	BinaryType = ValueType_BINARY
)

These constants are kept mostly for backwards compatibility.

View Source
const (
	// ChildOf span reference type describes a reference to a parent span
	// that depends on the response from the current (child) span
	ChildOf = SpanRefType_CHILD_OF

	// FollowsFrom span reference type describes a reference to a "parent" span
	// that does not depend on the response from the current (child) span
	FollowsFrom = SpanRefType_FOLLOWS_FROM
)

Variables

View Source
var (
	ValueType_name = map[int32]string{
		0: "STRING",
		1: "BOOL",
		2: "INT64",
		3: "FLOAT64",
		4: "BINARY",
	}
	ValueType_value = map[string]int32{
		"STRING":  0,
		"BOOL":    1,
		"INT64":   2,
		"FLOAT64": 3,
		"BINARY":  4,
	}
)

Enum value maps for ValueType.

View Source
var (
	SpanRefType_name = map[int32]string{
		0: "CHILD_OF",
		1: "FOLLOWS_FROM",
	}
	SpanRefType_value = map[string]int32{
		"CHILD_OF":     0,
		"FOLLOWS_FROM": 1,
	}
)

Enum value maps for SpanRefType.

View Source
var File_model_proto protoreflect.FileDescriptor
View Source
var File_query_proto protoreflect.FileDescriptor

Functions

func DurationAsMicroseconds

func DurationAsMicroseconds(d time.Duration) uint64

DurationAsMicroseconds converts time.Duration to microseconds, which is the format the Duration field is stored in the Span.

func EpochMicrosecondsAsTime

func EpochMicrosecondsAsTime(ts uint64) time.Time

EpochMicrosecondsAsTime converts microseconds since epoch to time.Time value.

func HashCode

func HashCode(o Hashable) (uint64, error)

HashCode calculates a FNV-1a hash code for a Hashable object.

func KeyValueCompare

func KeyValueCompare(this *KeyValue, that interface{}) int

func MicrosecondsAsDuration

func MicrosecondsAsDuration(v uint64) time.Duration

MicrosecondsAsDuration converts duration in microseconds to time.Duration value.

func RegisterQueryServiceServer

func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer)

func TimeAsEpochMicroseconds

func TimeAsEpochMicroseconds(t time.Time) uint64

TimeAsEpochMicroseconds converts time.Time to microseconds since epoch, which is the format the StartTime field is stored in the Span.

Types

type ArchiveTraceRequest

type ArchiveTraceRequest struct {
	TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveTraceRequest) Descriptor deprecated

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

Deprecated: Use ArchiveTraceRequest.ProtoReflect.Descriptor instead.

func (*ArchiveTraceRequest) GetTraceId

func (x *ArchiveTraceRequest) GetTraceId() []byte

func (*ArchiveTraceRequest) ProtoMessage

func (*ArchiveTraceRequest) ProtoMessage()

func (*ArchiveTraceRequest) ProtoReflect

func (x *ArchiveTraceRequest) ProtoReflect() protoreflect.Message

func (*ArchiveTraceRequest) Reset

func (x *ArchiveTraceRequest) Reset()

func (*ArchiveTraceRequest) String

func (x *ArchiveTraceRequest) String() string

type ArchiveTraceResponse

type ArchiveTraceResponse struct {
	// contains filtered or unexported fields
}

func (*ArchiveTraceResponse) Descriptor deprecated

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

Deprecated: Use ArchiveTraceResponse.ProtoReflect.Descriptor instead.

func (*ArchiveTraceResponse) ProtoMessage

func (*ArchiveTraceResponse) ProtoMessage()

func (*ArchiveTraceResponse) ProtoReflect

func (x *ArchiveTraceResponse) ProtoReflect() protoreflect.Message

func (*ArchiveTraceResponse) Reset

func (x *ArchiveTraceResponse) Reset()

func (*ArchiveTraceResponse) String

func (x *ArchiveTraceResponse) String() string

type Batch

type Batch struct {
	Spans   []*Span  `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	Process *Process `protobuf:"bytes,2,opt,name=process,proto3" json:"process,omitempty"`
	// contains filtered or unexported fields
}

Note that both Span and Batch may contain a Process. This is different from the Thrift model which was only used for transport, because Proto model is also used by the backend as the domain model, where once a batch is received it is split into individual spans which are all processed independently, and therefore they all need a Process. As far as on-the-wire semantics, both Batch and Spans in the same message may contain their own instances of Process, with span.Process taking priority over batch.Process.

func (*Batch) Descriptor deprecated

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

Deprecated: Use Batch.ProtoReflect.Descriptor instead.

func (*Batch) GetProcess

func (x *Batch) GetProcess() *Process

func (*Batch) GetSpans

func (x *Batch) GetSpans() []*Span

func (*Batch) ProtoMessage

func (*Batch) ProtoMessage()

func (*Batch) ProtoReflect

func (x *Batch) ProtoReflect() protoreflect.Message

func (*Batch) Reset

func (x *Batch) Reset()

func (*Batch) String

func (x *Batch) String() string
type DependencyLink struct {
	Parent    string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Child     string `protobuf:"bytes,2,opt,name=child,proto3" json:"child,omitempty"`
	CallCount uint64 `protobuf:"varint,3,opt,name=call_count,json=callCount,proto3" json:"call_count,omitempty"`
	Source    string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*DependencyLink) Descriptor deprecated

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

Deprecated: Use DependencyLink.ProtoReflect.Descriptor instead.

func (*DependencyLink) GetCallCount

func (x *DependencyLink) GetCallCount() uint64

func (*DependencyLink) GetChild

func (x *DependencyLink) GetChild() string

func (*DependencyLink) GetParent

func (x *DependencyLink) GetParent() string

func (*DependencyLink) GetSource

func (x *DependencyLink) GetSource() string

func (*DependencyLink) ProtoMessage

func (*DependencyLink) ProtoMessage()

func (*DependencyLink) ProtoReflect

func (x *DependencyLink) ProtoReflect() protoreflect.Message

func (*DependencyLink) Reset

func (x *DependencyLink) Reset()

func (*DependencyLink) String

func (x *DependencyLink) String() string

type FindTracesRequest

type FindTracesRequest struct {
	Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*FindTracesRequest) Descriptor deprecated

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

Deprecated: Use FindTracesRequest.ProtoReflect.Descriptor instead.

func (*FindTracesRequest) GetQuery

func (x *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) ProtoMessage

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) ProtoReflect

func (x *FindTracesRequest) ProtoReflect() protoreflect.Message

func (*FindTracesRequest) Reset

func (x *FindTracesRequest) Reset()

func (*FindTracesRequest) String

func (x *FindTracesRequest) String() string

type GetDependenciesRequest

type GetDependenciesRequest struct {
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDependenciesRequest) Descriptor deprecated

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

Deprecated: Use GetDependenciesRequest.ProtoReflect.Descriptor instead.

func (*GetDependenciesRequest) GetEndTime

func (x *GetDependenciesRequest) GetEndTime() *timestamppb.Timestamp

func (*GetDependenciesRequest) GetStartTime

func (x *GetDependenciesRequest) GetStartTime() *timestamppb.Timestamp

func (*GetDependenciesRequest) ProtoMessage

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) ProtoReflect

func (x *GetDependenciesRequest) ProtoReflect() protoreflect.Message

func (*GetDependenciesRequest) Reset

func (x *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) String

func (x *GetDependenciesRequest) String() string

type GetDependenciesResponse

type GetDependenciesResponse struct {
	Dependencies []*DependencyLink `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDependenciesResponse) Descriptor deprecated

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

Deprecated: Use GetDependenciesResponse.ProtoReflect.Descriptor instead.

func (*GetDependenciesResponse) GetDependencies

func (x *GetDependenciesResponse) GetDependencies() []*DependencyLink

func (*GetDependenciesResponse) ProtoMessage

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) ProtoReflect

func (x *GetDependenciesResponse) ProtoReflect() protoreflect.Message

func (*GetDependenciesResponse) Reset

func (x *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) String

func (x *GetDependenciesResponse) String() string

type GetOperationsRequest

type GetOperationsRequest struct {
	Service  string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	SpanKind string `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationsRequest) Descriptor deprecated

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

Deprecated: Use GetOperationsRequest.ProtoReflect.Descriptor instead.

func (*GetOperationsRequest) GetService

func (x *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind

func (x *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) ProtoMessage

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) ProtoReflect

func (x *GetOperationsRequest) ProtoReflect() protoreflect.Message

func (*GetOperationsRequest) Reset

func (x *GetOperationsRequest) Reset()

func (*GetOperationsRequest) String

func (x *GetOperationsRequest) String() string

type GetOperationsResponse

type GetOperationsResponse struct {
	OperationNames []string     `protobuf:"bytes,1,rep,name=operationNames,proto3" json:"operationNames,omitempty"` //deprecated
	Operations     []*Operation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationsResponse) Descriptor deprecated

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

Deprecated: Use GetOperationsResponse.ProtoReflect.Descriptor instead.

func (*GetOperationsResponse) GetOperationNames

func (x *GetOperationsResponse) GetOperationNames() []string

func (*GetOperationsResponse) GetOperations

func (x *GetOperationsResponse) GetOperations() []*Operation

func (*GetOperationsResponse) ProtoMessage

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) ProtoReflect

func (x *GetOperationsResponse) ProtoReflect() protoreflect.Message

func (*GetOperationsResponse) Reset

func (x *GetOperationsResponse) Reset()

func (*GetOperationsResponse) String

func (x *GetOperationsResponse) String() string

type GetServicesRequest

type GetServicesRequest struct {
	// contains filtered or unexported fields
}

func (*GetServicesRequest) Descriptor deprecated

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

Deprecated: Use GetServicesRequest.ProtoReflect.Descriptor instead.

func (*GetServicesRequest) ProtoMessage

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) ProtoReflect

func (x *GetServicesRequest) ProtoReflect() protoreflect.Message

func (*GetServicesRequest) Reset

func (x *GetServicesRequest) Reset()

func (*GetServicesRequest) String

func (x *GetServicesRequest) String() string

type GetServicesResponse

type GetServicesResponse struct {
	Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServicesResponse) Descriptor deprecated

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

Deprecated: Use GetServicesResponse.ProtoReflect.Descriptor instead.

func (*GetServicesResponse) GetServices

func (x *GetServicesResponse) GetServices() []string

func (*GetServicesResponse) ProtoMessage

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) ProtoReflect

func (x *GetServicesResponse) ProtoReflect() protoreflect.Message

func (*GetServicesResponse) Reset

func (x *GetServicesResponse) Reset()

func (*GetServicesResponse) String

func (x *GetServicesResponse) String() string

type GetTraceRequest

type GetTraceRequest struct {
	TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTraceRequest) Descriptor deprecated

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

Deprecated: Use GetTraceRequest.ProtoReflect.Descriptor instead.

func (*GetTraceRequest) GetTraceId

func (x *GetTraceRequest) GetTraceId() []byte

func (*GetTraceRequest) ProtoMessage

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) ProtoReflect

func (x *GetTraceRequest) ProtoReflect() protoreflect.Message

func (*GetTraceRequest) Reset

func (x *GetTraceRequest) Reset()

func (*GetTraceRequest) String

func (x *GetTraceRequest) String() string

type Hashable

type Hashable interface {
	Hash(w io.Writer) error
}

Hashable interface is for type that can participate in a hash computation by writing their data into io.Writer, which is usually an instance of hash.Hash.

type KeyValue

type KeyValue struct {
	Key      string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	VType    ValueType `protobuf:"varint,2,opt,name=v_type,json=vType,proto3,enum=jaeger.api_v2.ValueType" json:"v_type,omitempty"`
	VStr     string    `protobuf:"bytes,3,opt,name=v_str,json=vStr,proto3" json:"v_str,omitempty"`
	VBool    bool      `protobuf:"varint,4,opt,name=v_bool,json=vBool,proto3" json:"v_bool,omitempty"`
	VInt64   int64     `protobuf:"varint,5,opt,name=v_int64,json=vInt64,proto3" json:"v_int64,omitempty"`
	VFloat64 float64   `protobuf:"fixed64,6,opt,name=v_float64,json=vFloat64,proto3" json:"v_float64,omitempty"`
	VBinary  []byte    `protobuf:"bytes,7,opt,name=v_binary,json=vBinary,proto3" json:"v_binary,omitempty"`
	// contains filtered or unexported fields
}

func Binary

func Binary(key string, value []byte) KeyValue

Binary creates a Binary-typed KeyValue

func Bool

func Bool(key string, value bool) KeyValue

Bool creates a Bool-typed KeyValue

func Float64

func Float64(key string, value float64) KeyValue

Float64 creates a Float64-typed KeyValue

func Int64

func Int64(key string, value int64) KeyValue

Int64 creates a Int64-typed KeyValue

func String

func String(key string, value string) KeyValue

String creates a String-typed KeyValue

func (*KeyValue) AsString

func (kv *KeyValue) AsString() string

AsString returns a string representation of the value.

func (*KeyValue) AsStringLossy

func (kv *KeyValue) AsStringLossy() string

AsStringLossy returns a potentially lossy string representation of the value.

func (*KeyValue) Binary

func (kv *KeyValue) Binary() []byte

Binary returns the blob ([]byte) value stored in this KeyValue or nil if it stores a different type. The caller must check VType before using this method.

func (*KeyValue) Bool

func (kv *KeyValue) Bool() bool

Bool returns the Boolean value stored in this KeyValue or false if it stores a different type. The caller must check VType before using this method.

func (*KeyValue) Descriptor deprecated

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) Equal

func (this *KeyValue) Equal(that interface{}) bool

func (*KeyValue) Float64

func (kv *KeyValue) Float64() float64

Float64 returns the Float64 value stored in this KeyValue or 0 if it stores a different type. The caller must check VType before using this method.

func (*KeyValue) GetKey

func (x *KeyValue) GetKey() string

func (*KeyValue) GetVBinary

func (x *KeyValue) GetVBinary() []byte

func (*KeyValue) GetVBool

func (x *KeyValue) GetVBool() bool

func (*KeyValue) GetVFloat64

func (x *KeyValue) GetVFloat64() float64

func (*KeyValue) GetVInt64

func (x *KeyValue) GetVInt64() int64

func (*KeyValue) GetVStr

func (x *KeyValue) GetVStr() string

func (*KeyValue) GetVType

func (x *KeyValue) GetVType() ValueType

func (KeyValue) Hash

func (kv KeyValue) Hash(w io.Writer) error

Hash implements Hash from Hashable.

func (*KeyValue) Int64

func (kv *KeyValue) Int64() int64

Int64 returns the Int64 value stored in this KeyValue or 0 if it stores a different type. The caller must check VType before using this method.

func (*KeyValue) IsLess

func (kv *KeyValue) IsLess(two *KeyValue) bool

IsLess compares KeyValue object with another KeyValue. The order is based first on the keys, then on type, and finally on the value.

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect

func (x *KeyValue) ProtoReflect() protoreflect.Message

func (*KeyValue) Reset

func (x *KeyValue) Reset()

func (*KeyValue) String

func (x *KeyValue) String() string

func (*KeyValue) Value

func (kv *KeyValue) Value() interface{}

Value returns typed values stored in KeyValue as interface{}.

type KeyValues

type KeyValues []*KeyValue

KeyValues is a type alias that exposes convenience functions like Sort, FindByKey.

func (KeyValues) Equal

func (kvs KeyValues) Equal(other KeyValues) bool

Equal compares KeyValues with another list. Both lists must be already sorted.

func (KeyValues) FindByKey

func (kvs KeyValues) FindByKey(key string) (*KeyValue, bool)

FindByKey scans the list of key-values searching for the first one with the given key. Returns found tag and a boolean flag indicating if the search was successful.

func (KeyValues) Hash

func (kvs KeyValues) Hash(w io.Writer) error

Hash implements Hash from Hashable.

func (KeyValues) Len

func (kvs KeyValues) Len() int

func (KeyValues) Less

func (kvs KeyValues) Less(i, j int) bool

func (KeyValues) Sort

func (kvs KeyValues) Sort()

Sort does in-place sorting of KeyValues, then by value type, then by value.

func (KeyValues) Swap

func (kvs KeyValues) Swap(i, j int)

type Log

type Log struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Fields    []*KeyValue            `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetFields

func (x *Log) GetFields() []*KeyValue

func (*Log) GetTimestamp

func (x *Log) GetTimestamp() *timestamppb.Timestamp

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) ProtoReflect

func (x *Log) ProtoReflect() protoreflect.Message

func (*Log) Reset

func (x *Log) Reset()

func (*Log) String

func (x *Log) String() string

type Operation

type Operation struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SpanKind string `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	// contains filtered or unexported fields
}

func (*Operation) Descriptor deprecated

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

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetName

func (x *Operation) GetName() string

func (*Operation) GetSpanKind

func (x *Operation) GetSpanKind() string

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect

func (x *Operation) ProtoReflect() protoreflect.Message

func (*Operation) Reset

func (x *Operation) Reset()

func (*Operation) String

func (x *Operation) String() string

type Process

type Process struct {
	ServiceName string      `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Tags        []*KeyValue `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func NewProcess

func NewProcess(serviceName string, tags []*KeyValue) *Process

NewProcess creates a new Process for given serviceName and tags. The tags are sorted in place and kept in the same array/slice, in order to store the Process in a canonical form that is relied upon by the Equal and Hash functions.

func (*Process) Descriptor deprecated

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) Equal

func (p *Process) Equal(other *Process) bool

Equal compares Process object with another Process.

func (*Process) GetServiceName

func (x *Process) GetServiceName() string

func (*Process) GetTags

func (x *Process) GetTags() []*KeyValue

func (*Process) Hash

func (p *Process) Hash(w io.Writer) (err error)

Hash implements Hash from Hashable.

func (*Process) ProtoMessage

func (*Process) ProtoMessage()

func (*Process) ProtoReflect

func (x *Process) ProtoReflect() protoreflect.Message

func (*Process) Reset

func (x *Process) Reset()

func (*Process) String

func (x *Process) String() string

type QueryServiceClient

QueryServiceClient is the client API for QueryService service.

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

type QueryServiceServer

QueryServiceServer is the server API for QueryService service.

type QueryService_FindTracesClient

type QueryService_FindTracesClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type QueryService_FindTracesServer

type QueryService_FindTracesServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type QueryService_GetTraceClient

type QueryService_GetTraceClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type QueryService_GetTraceServer

type QueryService_GetTraceServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type Services added in v1.79.0

type Services struct {
	Data []string `json:"data"`
}

type Span

type Span struct {
	TraceId       []byte                 `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId        []byte                 `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	OperationName string                 `protobuf:"bytes,3,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	References    []*SpanRef             `protobuf:"bytes,4,rep,name=references,proto3" json:"references,omitempty"`
	Flags         uint32                 `protobuf:"varint,5,opt,name=flags,proto3" json:"flags,omitempty"`
	StartTime     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	Duration      *durationpb.Duration   `protobuf:"bytes,7,opt,name=duration,proto3" json:"duration,omitempty"`
	Tags          []*KeyValue            `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	Logs          []*Log                 `protobuf:"bytes,9,rep,name=logs,proto3" json:"logs,omitempty"`
	Process       *Process               `protobuf:"bytes,10,opt,name=process,proto3" json:"process,omitempty"`
	ProcessId     string                 `protobuf:"bytes,11,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Warnings      []string               `protobuf:"bytes,12,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*Span) Descriptor deprecated

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

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetDuration

func (x *Span) GetDuration() *durationpb.Duration

func (*Span) GetFlags

func (x *Span) GetFlags() uint32

func (*Span) GetLogs

func (x *Span) GetLogs() []*Log

func (*Span) GetOperationName

func (x *Span) GetOperationName() string

func (*Span) GetProcess

func (x *Span) GetProcess() *Process

func (*Span) GetProcessId

func (x *Span) GetProcessId() string

func (*Span) GetReferences

func (x *Span) GetReferences() []*SpanRef

func (*Span) GetSpanId

func (x *Span) GetSpanId() []byte

func (*Span) GetStartTime

func (x *Span) GetStartTime() *timestamppb.Timestamp

func (*Span) GetTags

func (x *Span) GetTags() []*KeyValue

func (*Span) GetTraceId

func (x *Span) GetTraceId() []byte

func (*Span) GetWarnings

func (x *Span) GetWarnings() []string

func (*Span) ProtoMessage

func (*Span) ProtoMessage()

func (*Span) ProtoReflect

func (x *Span) ProtoReflect() protoreflect.Message

func (*Span) Reset

func (x *Span) Reset()

func (*Span) String

func (x *Span) String() string

type SpanID

type SpanID uint64

SpanID is a random 64bit identifier for a span

func NewSpanID

func NewSpanID(v uint64) SpanID

NewSpanID creates a new SpanID from a 64bit unsigned int.

func SpanIDFromBytes

func SpanIDFromBytes(data []byte) (SpanID, error)

SpanIDFromBytes creates a SpandID from list of bytes

func SpanIDFromString

func SpanIDFromString(s string) (SpanID, error)

SpanIDFromString creates a SpanID from a hexadecimal string

func (SpanID) MarshalJSON

func (s SpanID) MarshalJSON() ([]byte, error)

MarshalJSON converts span id into a base64 string enclosed in quotes. Used by protobuf JSON serialization. Example: {1} => "AAAAAAAAAAE=".

func (SpanID) MarshalText

func (s SpanID) MarshalText() ([]byte, error)

MarshalText is called by encoding/json, which we do not want people to use.

func (*SpanID) MarshalTo

func (s *SpanID) MarshalTo(data []byte) (n int, err error)

MarshalTo converts span ID into a binary representation. Called by protobuf serialization.

func (*SpanID) Size

func (s *SpanID) Size() int

Size returns the size of this datum in protobuf. It is always 8 bytes.

func (SpanID) String

func (s SpanID) String() string

func (*SpanID) Unmarshal

func (s *SpanID) Unmarshal(data []byte) error

Unmarshal inflates span ID from a binary representation. Called by protobuf serialization.

func (*SpanID) UnmarshalJSON

func (s *SpanID) UnmarshalJSON(data []byte) error

UnmarshalJSON inflates span id from base64 string, possibly enclosed in quotes. User by protobuf JSON serialization.

There appears to be a bug in gogoproto, as this function is only called for numeric values. https://github.com/gogo/protobuf/issues/411#issuecomment-393856837

func (*SpanID) UnmarshalText

func (s *SpanID) UnmarshalText(text []byte) error

UnmarshalText is called by encoding/json, which we do not want people to use.

type SpanRef

type SpanRef struct {
	TraceId []byte      `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId  []byte      `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	RefType SpanRefType `protobuf:"varint,3,opt,name=ref_type,json=refType,proto3,enum=jaeger.api_v2.SpanRefType" json:"ref_type,omitempty"`
	// contains filtered or unexported fields
}

func MaybeAddParentSpanID

func MaybeAddParentSpanID(traceID TraceID, parentSpanID SpanID, refs []SpanRef) []SpanRef

MaybeAddParentSpanID adds non-zero parentSpanID to refs as a child-of reference. We no longer store ParentSpanID in the domain model, but the data in the database or other formats might still have these IDs without representing them in the References, so this converts parent IDs to canonical reference format.

func NewChildOfRef

func NewChildOfRef(traceID TraceID, spanID SpanID) SpanRef

NewChildOfRef creates a new child-of span reference.

func NewFollowsFromRef

func NewFollowsFromRef(traceID TraceID, spanID SpanID) SpanRef

NewFollowsFromRef creates a new follows-from span reference.

func (*SpanRef) Descriptor deprecated

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

Deprecated: Use SpanRef.ProtoReflect.Descriptor instead.

func (*SpanRef) GetRefType

func (x *SpanRef) GetRefType() SpanRefType

func (*SpanRef) GetSpanId

func (x *SpanRef) GetSpanId() []byte

func (*SpanRef) GetTraceId

func (x *SpanRef) GetTraceId() []byte

func (*SpanRef) ProtoMessage

func (*SpanRef) ProtoMessage()

func (*SpanRef) ProtoReflect

func (x *SpanRef) ProtoReflect() protoreflect.Message

func (*SpanRef) Reset

func (x *SpanRef) Reset()

func (*SpanRef) String

func (x *SpanRef) String() string

type SpanRefType

type SpanRefType int32
const (
	SpanRefType_CHILD_OF     SpanRefType = 0
	SpanRefType_FOLLOWS_FROM SpanRefType = 1
)

func (SpanRefType) Descriptor

func (SpanRefType) Enum

func (x SpanRefType) Enum() *SpanRefType

func (SpanRefType) EnumDescriptor deprecated

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

Deprecated: Use SpanRefType.Descriptor instead.

func (SpanRefType) Number

func (x SpanRefType) Number() protoreflect.EnumNumber

func (SpanRefType) String

func (x SpanRefType) String() string

func (SpanRefType) Type

type SpansResponseChunk

type SpansResponseChunk struct {
	Spans []*Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	// contains filtered or unexported fields
}

func (*SpansResponseChunk) Descriptor deprecated

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

Deprecated: Use SpansResponseChunk.ProtoReflect.Descriptor instead.

func (*SpansResponseChunk) GetSpans

func (x *SpansResponseChunk) GetSpans() []*Span

func (*SpansResponseChunk) ProtoMessage

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) ProtoReflect

func (x *SpansResponseChunk) ProtoReflect() protoreflect.Message

func (*SpansResponseChunk) Reset

func (x *SpansResponseChunk) Reset()

func (*SpansResponseChunk) String

func (x *SpansResponseChunk) String() string

type StructuredError added in v1.84.0

type StructuredError struct {
	Code    int    `json:"code,omitempty"`
	Msg     string `json:"msg"`
	TraceID string `json:"traceID,omitempty"`
}

type Trace

type Trace struct {
	Spans      []*Span                 `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	ProcessMap []*Trace_ProcessMapping `protobuf:"bytes,2,rep,name=process_map,json=processMap,proto3" json:"process_map,omitempty"`
	Warnings   []string                `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*Trace) Descriptor deprecated

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

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) GetProcessMap

func (x *Trace) GetProcessMap() []*Trace_ProcessMapping

func (*Trace) GetSpans

func (x *Trace) GetSpans() []*Span

func (*Trace) GetWarnings

func (x *Trace) GetWarnings() []string

func (*Trace) ProtoMessage

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect

func (x *Trace) ProtoReflect() protoreflect.Message

func (*Trace) Reset

func (x *Trace) Reset()

func (*Trace) String

func (x *Trace) String() string

type TraceID

type TraceID struct {
	Low  uint64 `json:"lo"`
	High uint64 `json:"hi"`
}

TraceID is a random 128bit identifier for a trace

func NewTraceID

func NewTraceID(high, low uint64) TraceID

NewTraceID creates a new TraceID from two 64bit unsigned ints.

func TraceIDFromBytes

func TraceIDFromBytes(data []byte) (TraceID, error)

TraceIDFromBytes creates a TraceID from list of bytes

func TraceIDFromString

func TraceIDFromString(s string) (TraceID, error)

TraceIDFromString creates a TraceID from a hexadecimal string

func (TraceID) MarshalJSON

func (t TraceID) MarshalJSON() ([]byte, error)

MarshalJSON converts trace id into a base64 string enclosed in quotes. Used by protobuf JSON serialization. Example: {high:2, low:1} => "AAAAAAAAAAIAAAAAAAAAAQ==".

func (TraceID) MarshalText

func (t TraceID) MarshalText() ([]byte, error)

MarshalText is called by encoding/json, which we do not want people to use.

func (*TraceID) MarshalTo

func (t *TraceID) MarshalTo(data []byte) (n int, err error)

MarshalTo converts trace ID into a binary representation. Called by protobuf serialization.

func (*TraceID) Size

func (t *TraceID) Size() int

Size returns the size of this datum in protobuf. It is always 16 bytes.

func (TraceID) String

func (t TraceID) String() string

func (*TraceID) Unmarshal

func (t *TraceID) Unmarshal(data []byte) error

Unmarshal inflates this trace ID from binary representation. Called by protobuf serialization.

func (*TraceID) UnmarshalJSON

func (t *TraceID) UnmarshalJSON(data []byte) error

UnmarshalJSON inflates trace id from base64 string, possibly enclosed in quotes. User by protobuf JSON serialization.

func (*TraceID) UnmarshalText

func (t *TraceID) UnmarshalText(text []byte) error

UnmarshalText is called by encoding/json, which we do not want people to use.

type TraceQueryParameters

type TraceQueryParameters struct {
	ServiceName   string                 `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	OperationName string                 `protobuf:"bytes,2,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	Tags          map[string]string      `` /* 149-byte string literal not displayed */
	StartTimeMin  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3" json:"start_time_min,omitempty"`
	StartTimeMax  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3" json:"start_time_max,omitempty"`
	DurationMin   *durationpb.Duration   `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3" json:"duration_min,omitempty"`
	DurationMax   *durationpb.Duration   `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3" json:"duration_max,omitempty"`
	SearchDepth   int32                  `protobuf:"varint,8,opt,name=search_depth,json=searchDepth,proto3" json:"search_depth,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceQueryParameters) Descriptor deprecated

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

Deprecated: Use TraceQueryParameters.ProtoReflect.Descriptor instead.

func (*TraceQueryParameters) GetDurationMax

func (x *TraceQueryParameters) GetDurationMax() *durationpb.Duration

func (*TraceQueryParameters) GetDurationMin

func (x *TraceQueryParameters) GetDurationMin() *durationpb.Duration

func (*TraceQueryParameters) GetOperationName

func (x *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetSearchDepth

func (x *TraceQueryParameters) GetSearchDepth() int32

func (*TraceQueryParameters) GetServiceName

func (x *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax

func (x *TraceQueryParameters) GetStartTimeMax() *timestamppb.Timestamp

func (*TraceQueryParameters) GetStartTimeMin

func (x *TraceQueryParameters) GetStartTimeMin() *timestamppb.Timestamp

func (*TraceQueryParameters) GetTags

func (x *TraceQueryParameters) GetTags() map[string]string

func (*TraceQueryParameters) ProtoMessage

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) ProtoReflect

func (x *TraceQueryParameters) ProtoReflect() protoreflect.Message

func (*TraceQueryParameters) Reset

func (x *TraceQueryParameters) Reset()

func (*TraceQueryParameters) String

func (x *TraceQueryParameters) String() string

type Trace_ProcessMapping

type Trace_ProcessMapping struct {
	ProcessId string   `protobuf:"bytes,1,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Process   *Process `protobuf:"bytes,2,opt,name=process,proto3" json:"process,omitempty"`
	// contains filtered or unexported fields
}

func (*Trace_ProcessMapping) Descriptor deprecated

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

Deprecated: Use Trace_ProcessMapping.ProtoReflect.Descriptor instead.

func (*Trace_ProcessMapping) GetProcess

func (x *Trace_ProcessMapping) GetProcess() *Process

func (*Trace_ProcessMapping) GetProcessId

func (x *Trace_ProcessMapping) GetProcessId() string

func (*Trace_ProcessMapping) ProtoMessage

func (*Trace_ProcessMapping) ProtoMessage()

func (*Trace_ProcessMapping) ProtoReflect

func (x *Trace_ProcessMapping) ProtoReflect() protoreflect.Message

func (*Trace_ProcessMapping) Reset

func (x *Trace_ProcessMapping) Reset()

func (*Trace_ProcessMapping) String

func (x *Trace_ProcessMapping) String() string

type TracingResponse

type TracingResponse struct {
	Data               []jaegerModels.Trace `json:"data"`
	Errors             []StructuredError    `json:"errors"`
	FromAllClusters    bool                 `json:"fromAllClusters"`
	TracingServiceName string               `json:"tracingServiceName"`
}

type TracingServices

type TracingServices struct {
	Data []string `json:"data"`
}

type TracingSingleTrace

type TracingSingleTrace struct {
	Data   jaegerModels.Trace `json:"data"`
	Errors []StructuredError  `json:"errors"`
}

type TracingSpan

type TracingSpan struct {
	jaegerModels.Span
	TraceSize int `json:"traceSize"`
}

type UnimplementedQueryServiceServer

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) ArchiveTrace

func (*UnimplementedQueryServiceServer) FindTraces

func (*UnimplementedQueryServiceServer) GetDependencies

func (*UnimplementedQueryServiceServer) GetOperations

func (*UnimplementedQueryServiceServer) GetServices

func (*UnimplementedQueryServiceServer) GetTrace

type ValueType

type ValueType int32
const (
	ValueType_STRING  ValueType = 0
	ValueType_BOOL    ValueType = 1
	ValueType_INT64   ValueType = 2
	ValueType_FLOAT64 ValueType = 3
	ValueType_BINARY  ValueType = 4
)

func (ValueType) Descriptor

func (ValueType) Descriptor() protoreflect.EnumDescriptor

func (ValueType) Enum

func (x ValueType) Enum() *ValueType

func (ValueType) EnumDescriptor deprecated

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

Deprecated: Use ValueType.Descriptor instead.

func (ValueType) Number

func (x ValueType) Number() protoreflect.EnumNumber

func (ValueType) String

func (x ValueType) String() string

func (ValueType) Type

Directories

Path Synopsis
converter
json
nolint
nolint

Jump to

Keyboard shortcuts

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