Versions in this module Expand all Collapse all v1 v1.66.0 Feb 6, 2025 Changes in this version + const DurationIndex + const OperationIndex + const ServiceIndex + var DefaultIndexFilter = func(_ *Span, _ int) bool + var DefaultTagFilter = tagFilterImpl + var ErrTraceIDWrongLength = errors.New("TraceID is not a 128bit integer") + func ToDomain(dbSpan *Span) (*model.Span, error) + type ChainedTagFilter []TagFilter + func NewChainedTagFilter(filters ...TagFilter) ChainedTagFilter + func (tf ChainedTagFilter) FilterLogFields(span *model.Span, logFields model.KeyValues) model.KeyValues + func (tf ChainedTagFilter) FilterProcessTags(span *model.Span, processTags model.KeyValues) model.KeyValues + func (tf ChainedTagFilter) FilterTags(span *model.Span, tags model.KeyValues) model.KeyValues + type ExactMatchTagFilter struct + func NewBlacklistFilter(tags []string) ExactMatchTagFilter + func NewWhitelistFilter(tags []string) ExactMatchTagFilter + func (tf ExactMatchTagFilter) FilterLogFields(_ *model.Span, logFields model.KeyValues) model.KeyValues + func (tf ExactMatchTagFilter) FilterProcessTags(_ *model.Span, processTags model.KeyValues) model.KeyValues + func (tf ExactMatchTagFilter) FilterTags(_ *model.Span, tags model.KeyValues) model.KeyValues + type IndexFilter func(span *Span, index int) bool + type KeyValue struct + Key string + ValueBinary []byte + ValueBool bool + ValueFloat64 float64 + ValueInt64 int64 + ValueString string + ValueType string + func (t *KeyValue) MarshalUDT(name string, info gocql.TypeInfo) ([]byte, error) + func (t *KeyValue) UnmarshalUDT(name string, info gocql.TypeInfo, data []byte) error + type Log struct + Fields []KeyValue + Timestamp int64 + func (l *Log) MarshalUDT(name string, info gocql.TypeInfo) ([]byte, error) + func (l *Log) UnmarshalUDT(name string, info gocql.TypeInfo, data []byte) error + type Operation struct + OperationName string + ServiceName string + SpanKind string + type Process struct + ServiceName string + Tags []KeyValue + func (p *Process) MarshalUDT(name string, info gocql.TypeInfo) ([]byte, error) + func (p *Process) UnmarshalUDT(name string, info gocql.TypeInfo, data []byte) error + type Span struct + Duration int64 + Flags int32 + Logs []Log + OperationName string + ParentID int64 + Process Process + Refs []SpanRef + ServiceName string + SpanHash int64 + SpanID int64 + StartTime int64 + Tags []KeyValue + TraceID TraceID + func FromDomain(span *model.Span) *Span + type SpanRef struct + RefType string + SpanID int64 + TraceID TraceID + func (s *SpanRef) MarshalUDT(name string, info gocql.TypeInfo) ([]byte, error) + func (s *SpanRef) UnmarshalUDT(name string, info gocql.TypeInfo, data []byte) error + type TagFilter interface + FilterLogFields func(span *model.Span, logFields model.KeyValues) model.KeyValues + FilterProcessTags func(span *model.Span, processTags model.KeyValues) model.KeyValues + FilterTags func(span *model.Span, tags model.KeyValues) model.KeyValues + type TagFilterDropAll struct + func NewTagFilterDropAll(dropTags bool, dropProcessTags bool, dropLogs bool) *TagFilterDropAll + func (f *TagFilterDropAll) FilterLogFields(_ *model.Span, logFields model.KeyValues) model.KeyValues + func (f *TagFilterDropAll) FilterProcessTags(_ *model.Span, processTags model.KeyValues) model.KeyValues + func (f *TagFilterDropAll) FilterTags(_ *model.Span, tags model.KeyValues) model.KeyValues + type TagInsertion struct + ServiceName string + TagKey string + TagValue string + func GetAllUniqueTags(span *model.Span, tagFilter TagFilter) []TagInsertion + func (t TagInsertion) String() string + type TraceID [16]byte + func TraceIDFromDomain(traceID model.TraceID) TraceID + func (dbTraceID TraceID) String() string + func (dbTraceID TraceID) ToDomain() model.TraceID + func (t *TraceID) UnmarshalCQL(_ gocql.TypeInfo, data []byte) error + func (t TraceID) MarshalCQL(gocql.TypeInfo) ([]byte, error) + type UniqueTraceIDs map[TraceID]struct + func IntersectTraceIDs(uniqueTraceIdsList []UniqueTraceIDs) UniqueTraceIDs + func UniqueTraceIDsFromList(traceIDs []TraceID) UniqueTraceIDs + func (u UniqueTraceIDs) Add(traceID TraceID)
Go to main page