mirror of
https://github.com/hanzoai/o11y.git
synced 2026-10-15 12:58:33 +00:00
zeekay
b9f9cdf918
Re-sync the entire SigNoz-derived Go tree to a clean fork of latest SigNoz main (upstream 3e6339019), eliminating the version-skew that broke `go build ./...` (mixed-era packages, ~14 imported-but-absent packages, partial signoz->o11y / clickhouse->datastore rebrands, self-import cycle, duplicate package decls). - pkg/ + cmd/ wholesale replaced with latest SigNoz; imports rewritten github.com/SigNoz/signoz/ -> github.com/hanzoai/o11y/. - Adopt SigNoz's CURRENT structure (resourcefilter->telemetryresourcefilter, integrationtypes->cloudintegrationtypes, roletypes/grammar/times folded in upstream); old paths dropped. - Fork deps repathed to hanzoai + bumped: signoz-otel-collector v0.144.6, clickhouse-go-mock v0.14.1, govaluate v0.1.0; expr-lang/expr => hanzoai/expr v1.17.8 (replace). go.mod reconciled from latest SigNoz; go.sum re-tidied. - ee/ + cmd/enterprise stripped — o11y stays MIT-only; community edition imports no ee packages. - Preserved o11y additions: module path github.com/hanzoai/o11y, mount.go (cloud.Register/zip mount adapter, HIP-0106), NOTICE + LICENSE (SigNoz §4c attribution retained; upstream pkg files are headerless per SigNoz convention). - Reverted o11y cosmetic renames (o11y*/datastore*) and experimental originals (authz/iamauthz, billing, zapreceiver, zapmetricreceiver) to SigNoz canonical to kill the skew; snapshots retained in git history for re-layering. go build ./... = exit 0. go vet clean except benign "unreachable code" in generated ANTLR parser files (inherited from upstream).
127 lines
4.2 KiB
Go
127 lines
4.2 KiB
Go
package implinframonitoring
|
|
|
|
import (
|
|
"context"
|
|
"slices"
|
|
|
|
"github.com/hanzoai/o11y/pkg/types/inframonitoringtypes"
|
|
qbtypes "github.com/hanzoai/o11y/pkg/types/querybuildertypes/querybuildertypesv5"
|
|
"github.com/hanzoai/o11y/pkg/valuer"
|
|
)
|
|
|
|
// buildNamespaceRecords assembles the page records. Pod phase counts come from
|
|
// phaseCounts in both modes; every row is a group of pods, so there's no
|
|
// per-row "current phase" concept (unlike pods/nodes list mode).
|
|
func buildNamespaceRecords(
|
|
resp *qbtypes.QueryRangeResponse,
|
|
pageGroups []map[string]string,
|
|
groupBy []qbtypes.GroupByKey,
|
|
metadataMap map[string]map[string]string,
|
|
phaseCounts map[string]podPhaseCounts,
|
|
) []inframonitoringtypes.NamespaceRecord {
|
|
metricsMap := parseFullQueryResponse(resp, groupBy)
|
|
|
|
records := make([]inframonitoringtypes.NamespaceRecord, 0, len(pageGroups))
|
|
for _, labels := range pageGroups {
|
|
compositeKey := compositeKeyFromLabels(labels, groupBy)
|
|
namespaceName := labels[inframonitoringtypes.NamespaceNameAttrKey]
|
|
|
|
record := inframonitoringtypes.NamespaceRecord{ // initialize with default values
|
|
NamespaceName: namespaceName,
|
|
NamespaceCPU: -1,
|
|
NamespaceMemory: -1,
|
|
Meta: map[string]string{},
|
|
}
|
|
|
|
if metrics, ok := metricsMap[compositeKey]; ok {
|
|
if v, exists := metrics["A"]; exists {
|
|
record.NamespaceCPU = v
|
|
}
|
|
if v, exists := metrics["D"]; exists {
|
|
record.NamespaceMemory = v
|
|
}
|
|
}
|
|
|
|
if phaseCountsForGroup, ok := phaseCounts[compositeKey]; ok {
|
|
record.PodCountsByPhase = inframonitoringtypes.PodCountsByPhase{
|
|
Pending: phaseCountsForGroup.Pending,
|
|
Running: phaseCountsForGroup.Running,
|
|
Succeeded: phaseCountsForGroup.Succeeded,
|
|
Failed: phaseCountsForGroup.Failed,
|
|
Unknown: phaseCountsForGroup.Unknown,
|
|
}
|
|
}
|
|
|
|
if attrs, ok := metadataMap[compositeKey]; ok {
|
|
for k, v := range attrs {
|
|
record.Meta[k] = v
|
|
}
|
|
}
|
|
|
|
records = append(records, record)
|
|
}
|
|
return records
|
|
}
|
|
|
|
func (m *module) getTopNamespaceGroups(
|
|
ctx context.Context,
|
|
orgID valuer.UUID,
|
|
req *inframonitoringtypes.PostableNamespaces,
|
|
metadataMap map[string]map[string]string,
|
|
) ([]map[string]string, error) {
|
|
orderByKey := req.OrderBy.Key.Name
|
|
if orderByKey == inframonitoringtypes.NamespaceNameAttrKey {
|
|
return inframonitoringtypes.PaginateMetadataByName(metadataMap, req.GroupBy, req.OrderBy.Direction, req.Offset, req.Limit, inframonitoringtypes.NamespaceNameAttrKey), nil
|
|
}
|
|
queryNamesForOrderBy := orderByToNamespacesQueryNames[orderByKey]
|
|
rankingQueryName := queryNamesForOrderBy[len(queryNamesForOrderBy)-1]
|
|
|
|
topReq := &qbtypes.QueryRangeRequest{
|
|
Start: uint64(req.Start),
|
|
End: uint64(req.End),
|
|
RequestType: qbtypes.RequestTypeScalar,
|
|
CompositeQuery: qbtypes.CompositeQuery{
|
|
Queries: make([]qbtypes.QueryEnvelope, 0, len(queryNamesForOrderBy)),
|
|
},
|
|
}
|
|
|
|
for _, envelope := range m.newNamespacesTableListQuery().CompositeQuery.Queries {
|
|
if !slices.Contains(queryNamesForOrderBy, envelope.GetQueryName()) {
|
|
continue
|
|
}
|
|
copied := envelope
|
|
if copied.Type == qbtypes.QueryTypeBuilder {
|
|
existingExpr := ""
|
|
if f := copied.GetFilter(); f != nil {
|
|
existingExpr = f.Expression
|
|
}
|
|
reqFilterExpr := ""
|
|
if req.Filter != nil {
|
|
reqFilterExpr = req.Filter.Expression
|
|
}
|
|
merged := mergeFilterExpressions(existingExpr, reqFilterExpr)
|
|
copied.SetFilter(&qbtypes.Filter{Expression: merged})
|
|
copied.SetGroupBy(req.GroupBy)
|
|
}
|
|
topReq.CompositeQuery.Queries = append(topReq.CompositeQuery.Queries, copied)
|
|
}
|
|
|
|
resp, err := m.querier.QueryRange(ctx, orgID, topReq)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
allMetricGroups := parseAndSortGroups(resp, rankingQueryName, req.GroupBy, req.OrderBy.Direction)
|
|
return paginateWithBackfill(allMetricGroups, metadataMap, req.GroupBy, req.Offset, req.Limit), nil
|
|
}
|
|
|
|
func (m *module) getNamespacesTableMetadata(ctx context.Context, orgID valuer.UUID, req *inframonitoringtypes.PostableNamespaces) (map[string]map[string]string, error) {
|
|
var nonGroupByAttrs []string
|
|
for _, key := range namespaceAttrKeysForMetadata {
|
|
if !isKeyInGroupByAttrs(req.GroupBy, key) {
|
|
nonGroupByAttrs = append(nonGroupByAttrs, key)
|
|
}
|
|
}
|
|
return m.getMetadata(ctx, orgID, namespacesTableMetricNamesList, req.GroupBy, nonGroupByAttrs, req.Filter, req.Start, req.End)
|
|
}
|