mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
* [Generator] Add DRAIN span_name sanitizer * Fix linter * Fix formatting * Update default manifest * Fix build error in update-fixtures * Remove bad test * Remove misleading comment * Add per-tenant override for drain mode * Do a machines job * Address PR feedback * Address PR review: rename drain_mode config and improve sanitizer - Rename `drain_mode` to `span_name_sanitization` across all config, legacy config, interfaces, and overrides for better user-facing clarity - Add explicit default value "disabled" in RegisterFlagsAndApplyDefaults - Add ValidateSpanNameSanitization function in validation/fields.go - Rename metrics to remove DRAIN reference: `drain_spans_compacted_total` -> `spans_sanitized_total` `post_drain_demand_estimate` -> `post_sanitization_demand_estimate` - Pass configured staleDuration to NewDrainSanitizer instead of hardcoded 15min, consistent with other registry components - Extract "span_name" magic string to labelSpanName constant - Update all tests with new names and signatures * Update manifest * Use empty string as disabled * Update CHANGELOG.md Co-authored-by: Suraj Nath <[email protected]> * Update manifest --------- Co-authored-by: Suraj Nath <[email protected]>
232 lines
4.1 KiB
Go
232 lines
4.1 KiB
Go
// Copyright (c) 2024 Alexey Mayshev and contributors. All rights reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package deque
|
|
|
|
import (
|
|
"iter"
|
|
|
|
"github.com/maypok86/otter/v2/internal/generated/node"
|
|
)
|
|
|
|
type Linked[K comparable, V any] struct {
|
|
head node.Node[K, V]
|
|
tail node.Node[K, V]
|
|
len int
|
|
isExp bool
|
|
}
|
|
|
|
func NewLinked[K comparable, V any](isExp bool) *Linked[K, V] {
|
|
return &Linked[K, V]{
|
|
isExp: isExp,
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) PushBack(n node.Node[K, V]) {
|
|
if d.IsEmpty() {
|
|
d.head = n
|
|
d.tail = n
|
|
} else {
|
|
d.setPrev(n, d.tail)
|
|
d.setNext(d.tail, n)
|
|
d.tail = n
|
|
}
|
|
|
|
d.len++
|
|
}
|
|
|
|
func (d *Linked[K, V]) UpdateNode(n, old node.Node[K, V]) {
|
|
oldNext := d.getNext(old)
|
|
if node.Equals(oldNext, nil) {
|
|
if node.Equals(d.tail, old) {
|
|
d.tail = n
|
|
}
|
|
} else {
|
|
d.setPrev(oldNext, n)
|
|
d.setNext(n, oldNext)
|
|
d.setNext(old, nil)
|
|
}
|
|
|
|
oldPrev := d.getPrev(old)
|
|
if node.Equals(oldPrev, nil) {
|
|
if node.Equals(d.head, old) {
|
|
d.head = n
|
|
}
|
|
} else {
|
|
d.setPrev(n, oldPrev)
|
|
d.setNext(oldPrev, n)
|
|
d.setPrev(old, nil)
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) PushFront(n node.Node[K, V]) {
|
|
if d.IsEmpty() {
|
|
d.head = n
|
|
d.tail = n
|
|
} else {
|
|
d.setNext(n, d.head)
|
|
d.setPrev(d.head, n)
|
|
d.head = n
|
|
}
|
|
|
|
d.len++
|
|
}
|
|
|
|
func (d *Linked[K, V]) PopFront() node.Node[K, V] {
|
|
if d.IsEmpty() {
|
|
return nil
|
|
}
|
|
|
|
result := d.head
|
|
d.Delete(result)
|
|
return result
|
|
}
|
|
|
|
/*
|
|
func (d *Linked[K, V]) PopBack() node.Node[K, V] {
|
|
if d.IsEmpty() {
|
|
return nil
|
|
}
|
|
|
|
result := d.tail
|
|
d.Delete(result)
|
|
return result
|
|
}
|
|
*/
|
|
|
|
func (d *Linked[K, V]) NotContains(n node.Node[K, V]) bool {
|
|
return !d.Contains(n)
|
|
}
|
|
|
|
func (d *Linked[K, V]) Contains(n node.Node[K, V]) bool {
|
|
return !node.Equals(d.getPrev(n), nil) || !node.Equals(d.getNext(n), nil) || node.Equals(d.head, n)
|
|
}
|
|
|
|
func (d *Linked[K, V]) MoveToBack(n node.Node[K, V]) {
|
|
if !node.Equals(n, d.tail) {
|
|
d.Delete(n)
|
|
d.PushBack(n)
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) MoveToFront(n node.Node[K, V]) {
|
|
if !node.Equals(n, d.head) {
|
|
d.Delete(n)
|
|
d.PushFront(n)
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) Delete(n node.Node[K, V]) {
|
|
next := d.getNext(n)
|
|
prev := d.getPrev(n)
|
|
|
|
if node.Equals(prev, nil) {
|
|
if node.Equals(next, nil) && !node.Equals(d.head, n) {
|
|
return
|
|
}
|
|
|
|
d.head = next
|
|
} else {
|
|
d.setNext(prev, next)
|
|
d.setPrev(n, nil)
|
|
}
|
|
|
|
if node.Equals(next, nil) {
|
|
d.tail = prev
|
|
} else {
|
|
d.setPrev(next, prev)
|
|
d.setNext(n, nil)
|
|
}
|
|
|
|
d.len--
|
|
}
|
|
|
|
func (d *Linked[K, V]) Clear() {
|
|
for !d.IsEmpty() {
|
|
d.PopFront()
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) Len() int {
|
|
return d.len
|
|
}
|
|
|
|
func (d *Linked[K, V]) IsEmpty() bool {
|
|
return d.Len() == 0
|
|
}
|
|
|
|
func (d *Linked[K, V]) Head() node.Node[K, V] {
|
|
return d.head
|
|
}
|
|
|
|
func (d *Linked[K, V]) Tail() node.Node[K, V] {
|
|
return d.tail
|
|
}
|
|
|
|
func (d *Linked[K, V]) All() iter.Seq[node.Node[K, V]] {
|
|
return func(yield func(node.Node[K, V]) bool) {
|
|
cursor := d.head
|
|
for !node.Equals(cursor, nil) {
|
|
if !yield(cursor) {
|
|
return
|
|
}
|
|
cursor = d.getNext(cursor)
|
|
}
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) Backward() iter.Seq[node.Node[K, V]] {
|
|
return func(yield func(node.Node[K, V]) bool) {
|
|
cursor := d.tail
|
|
for !node.Equals(cursor, nil) {
|
|
if !yield(cursor) {
|
|
return
|
|
}
|
|
cursor = d.getPrev(cursor)
|
|
}
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) setPrev(to, n node.Node[K, V]) {
|
|
if d.isExp {
|
|
to.SetPrevExp(n)
|
|
} else {
|
|
to.SetPrev(n)
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) setNext(to, n node.Node[K, V]) {
|
|
if d.isExp {
|
|
to.SetNextExp(n)
|
|
} else {
|
|
to.SetNext(n)
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) getNext(n node.Node[K, V]) node.Node[K, V] {
|
|
if d.isExp {
|
|
return n.NextExp()
|
|
} else {
|
|
return n.Next()
|
|
}
|
|
}
|
|
|
|
func (d *Linked[K, V]) getPrev(n node.Node[K, V]) node.Node[K, V] {
|
|
if d.isExp {
|
|
return n.PrevExp()
|
|
} else {
|
|
return n.Prev()
|
|
}
|
|
}
|