tracelimiter

type BlockingTracesLimiter ¶

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

BlockingTracesLimiter is a limiter that blocks when the number of traces exceeds the limit. It is used to limit the number of traces that are processed by the processor.

func NewBlockingTracesLimiter(numTraces uint64) *BlockingTracesLimiter

func (l *BlockingTracesLimiter) AcceptTrace(ctx context.Context, _ pcommon.TraceID, _ time.Time)

func (l *BlockingTracesLimiter) OnDeleteTrace()

type DropOldTracesLimiter ¶

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

func NewDropOldTracesLimiter(numTraces uint64, dropTrace func(id pcommon.TraceID, time time.Time)) *DropOldTracesLimiter

func (l *DropOldTracesLimiter) AcceptTrace(ctx context.Context, id pcommon.TraceID, time time.Time)

func (*DropOldTracesLimiter) OnDeleteTrace()