Files
76c2c85b97 [Generator] Add DRAIN span_name sanitizer (#6098)
* [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]>
2026-02-22 00:55:22 -08:00

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()
}
}