merge

Documentation

Index

• type ListFunc
• type MergeTree
• type Merger
  • func (merger *Merger[M]) AddTraces(trees []TraceWithMetadata[M]) (_affected sets.Set[objKey], _err error)
  • func (merger *Merger[M]) FollowLinks(ctx context.Context, linkSelector tfconfig.LinkSelector, ...) error
  • func (merger *Merger[M]) MergeTraces() ([]*MergeTree[M], error)
• type RawTree
  • func (tr RawTree) FromThumbnail(self *RawTree, tt *jaegerbackend.TraceThumbnail)
  • func (tr RawTree) GetMetadata() struct{}
  • func (tr RawTree) GetSpans() *tftree.SpanTree
• type TargetLink
• type TraceWithMetadata

Types

type ListFunc

type ListFunc[M any] func(
	ctx context.Context,
	key objKey,
	startTime, endTime time.Time,
	limit int,
) ([]TraceWithMetadata[M], error)

type MergeTree

type MergeTree[M any] struct {
	Metadata []M

	Tree *tftree.SpanTree
}

type Merger

type Merger[M any] struct {
	// contains filtered or unexported fields
}

func (*Merger[M]) AddTraces

func (merger *Merger[M]) AddTraces(trees []TraceWithMetadata[M]) (_affected sets.Set[objKey], _err error)

func (*Merger[M]) FollowLinks

func (merger *Merger[M]) FollowLinks(
	ctx context.Context,
	linkSelector tfconfig.LinkSelector,
	startTime, endTime time.Time,
	lister ListFunc[M],
	concurrency int,
	limit int32,
	limitIsGlobal bool,
) error

func (*Merger[M]) MergeTraces

func (merger *Merger[M]) MergeTraces() ([]*MergeTree[M], error)

type RawTree

type RawTree struct {
	Tree *tftree.SpanTree
}

func (RawTree) FromThumbnail

func (tr RawTree) FromThumbnail(self *RawTree, tt *jaegerbackend.TraceThumbnail)

func (RawTree) GetMetadata

func (tr RawTree) GetMetadata() struct{}

func (RawTree) GetSpans

func (tr RawTree) GetSpans() *tftree.SpanTree

type TargetLink

type TargetLink struct {
	Key   objKey
	Role  zconstants.LinkRoleValue
	Class string
}

type TraceWithMetadata

type TraceWithMetadata[M any] struct {
	Tree     *tftree.SpanTree
	Metadata M
}