mirror of
https://github.com/hanzoai/o11y.git
synced 2026-10-15 12:58:33 +00:00
zeekay
b36a8788a5
Full rebrand of the SigNoz observability platform: - Go module: github.com/SigNoz/signoz → github.com/hanzoai/o11y - Frontend: @signozhq/* → @hanzo/o11y-*, posthog-js → @hanzo/insights - Docker: signoz/* → ghcr.io/hanzoai/o11y* - ClickHouse → Hanzo Datastore (hanzoai/datastore) - Env vars: SIGNOZ_* → HANZO_* - DB tables: signoz_* → o11y_* - All branding, URLs, docs updated - 2172 files changed
75 lines
2.1 KiB
Go
75 lines
2.1 KiB
Go
package logs
|
|
|
|
import (
|
|
"fmt"
|
|
"regexp"
|
|
|
|
"github.com/hanzoai/o11y/pkg/query-service/constants"
|
|
"github.com/hanzoai/o11y/pkg/query-service/model"
|
|
v3 "github.com/hanzoai/o11y/pkg/query-service/model/v3"
|
|
)
|
|
|
|
func ValidateUpdateFieldPayload(field *model.UpdateField) error {
|
|
if field.Name == "" {
|
|
return fmt.Errorf("name cannot be empty")
|
|
}
|
|
if field.Type == "" {
|
|
return fmt.Errorf("type cannot be empty")
|
|
}
|
|
if field.DataType == "" {
|
|
return fmt.Errorf("dataType cannot be empty")
|
|
}
|
|
|
|
matched, err := regexp.MatchString(fmt.Sprintf("^(%s|%s|%s)$", constants.Static, constants.Attributes, constants.Resources), field.Type)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !matched {
|
|
return fmt.Errorf("type %s not supported", field.Type)
|
|
}
|
|
|
|
if field.IndexType != "" {
|
|
matched, err := regexp.MatchString(`^(minmax|set\([0-9]\)|bloom_filter\((0?.?[0-9]+|1)\)|tokenbf_v1\([0-9]+,[0-9]+,[0-9]+\)|ngrambf_v1\([0-9]+,[0-9]+,[0-9]+,[0-9]+\))$`, field.IndexType)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !matched {
|
|
return fmt.Errorf("index type %s not supported", field.IndexType)
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func ValidateUpdateFieldPayloadV2(field *model.UpdateField) error {
|
|
if field.Name == "" {
|
|
return fmt.Errorf("name cannot be empty")
|
|
}
|
|
if field.Type == "" {
|
|
return fmt.Errorf("type cannot be empty")
|
|
}
|
|
if field.DataType == "" {
|
|
return fmt.Errorf("dataType cannot be empty")
|
|
}
|
|
|
|
// the logs api uses the old names i.e attributes and resources while traces use tag and attribute.
|
|
// update log api to use tag and attribute.
|
|
matched, err := regexp.MatchString(fmt.Sprintf("^(%s|%s)$", v3.AttributeKeyTypeTag, v3.AttributeKeyTypeResource), field.Type)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !matched {
|
|
return fmt.Errorf("type %s not supported", field.Type)
|
|
}
|
|
|
|
if field.IndexType != "" {
|
|
matched, err := regexp.MatchString(`^(minmax|set\([0-9]\)|bloom_filter\((0?.?[0-9]+|1)\)|tokenbf_v1\([0-9]+,[0-9]+,[0-9]+\)|ngrambf_v1\([0-9]+,[0-9]+,[0-9]+,[0-9]+\))$`, field.IndexType)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !matched {
|
|
return fmt.Errorf("index type %s not supported", field.IndexType)
|
|
}
|
|
}
|
|
return nil
|
|
}
|