mirror of
https://github.com/SigNoz/signoz.git
synced 2025-12-18 07:56:56 +00:00
85f04e4bae
* chore: update types 1. add partial bool to indicate if the value covers the partial interval 2. add optional unit if present (ex: duration_nano, metrics with units) 3. use pointers wherever necessary 4. add format options for request and remove redundant name in query envelope * chore: fix some gaps 1. make the range as [start, end) 2. provide the logs statement builder with the body column 3. skip the body filter on resource filter statement builder 4. remove unnecessary agg expr rewriter in metrics 5. add ability to skip full text in where clause visitor * chore: add API endpoint for new query range * chore: add bucket cache implementation * chore: add fingerprinting impl and add bucket cache to querier * chore: add provider factory
99 lines
2.1 KiB
Go
99 lines
2.1 KiB
Go
package querier
|
|
|
|
import (
|
|
"sync"
|
|
|
|
qbtypes "github.com/SigNoz/signoz/pkg/types/querybuildertypes/querybuildertypesv5"
|
|
)
|
|
|
|
// Pools for reducing allocations in hot paths
|
|
var (
|
|
// Pool for label slices
|
|
labelSlicePool = sync.Pool{
|
|
New: func() any {
|
|
s := make([]*qbtypes.Label, 0, 16)
|
|
return &s
|
|
},
|
|
}
|
|
|
|
// Pool for string slices used in label processing
|
|
stringSlicePool = sync.Pool{
|
|
New: func() any {
|
|
s := make([]string, 0, 16)
|
|
return &s
|
|
},
|
|
}
|
|
|
|
// Pool for time series value slices
|
|
valueSlicePool = sync.Pool{
|
|
New: func() any {
|
|
s := make([]*qbtypes.TimeSeriesValue, 0, 100)
|
|
return &s
|
|
},
|
|
}
|
|
|
|
// Pool for aggregation value maps
|
|
aggValueMapPool = sync.Pool{
|
|
New: func() any {
|
|
m := make(map[int]float64, 4)
|
|
return &m
|
|
},
|
|
}
|
|
)
|
|
|
|
// GetLabelSlice gets a label slice from the pool
|
|
func GetLabelSlice() []*qbtypes.Label {
|
|
sp := labelSlicePool.Get().(*[]*qbtypes.Label)
|
|
return *sp
|
|
}
|
|
|
|
// PutLabelSlice returns a label slice to the pool
|
|
func PutLabelSlice(s []*qbtypes.Label) {
|
|
s = s[:0] // Reset slice
|
|
labelSlicePool.Put(&s)
|
|
}
|
|
|
|
// GetStringSlice gets a string slice from the pool
|
|
func GetStringSlice() []string {
|
|
sp := stringSlicePool.Get().(*[]string)
|
|
return *sp
|
|
}
|
|
|
|
// PutStringSlice returns a string slice to the pool
|
|
func PutStringSlice(s []string) {
|
|
s = s[:0] // Reset slice
|
|
stringSlicePool.Put(&s)
|
|
}
|
|
|
|
// GetValueSlice gets a time series value slice from the pool
|
|
func GetValueSlice() []*qbtypes.TimeSeriesValue {
|
|
sp := valueSlicePool.Get().(*[]*qbtypes.TimeSeriesValue)
|
|
return *sp
|
|
}
|
|
|
|
// PutValueSlice returns a time series value slice to the pool
|
|
func PutValueSlice(s []*qbtypes.TimeSeriesValue) {
|
|
s = s[:0] // Reset slice
|
|
valueSlicePool.Put(&s)
|
|
}
|
|
|
|
// GetAggValueMap gets an aggregation value map from the pool
|
|
func GetAggValueMap() map[int]float64 {
|
|
mp := aggValueMapPool.Get().(*map[int]float64)
|
|
m := *mp
|
|
// Clear the map
|
|
for k := range m {
|
|
delete(m, k)
|
|
}
|
|
return m
|
|
}
|
|
|
|
// PutAggValueMap returns an aggregation value map to the pool
|
|
func PutAggValueMap(m map[int]float64) {
|
|
// Clear before returning to pool
|
|
for k := range m {
|
|
delete(m, k)
|
|
}
|
|
aggValueMapPool.Put(&m)
|
|
}
|