observability_utils.go

package server

import (
	runtimev1 "github.com/rilldata/rill/proto/gen/rill/runtime/v1"
	"google.golang.org/protobuf/types/known/timestamppb"
)

func safeTimeStr(t *timestamppb.Timestamp) string {
	if t == nil {
		return ""
	}
	return t.AsTime().String()
}

func filterCount(m *runtimev1.Expression) int {
	if m == nil {
		return 0
	}
	c := 0
	switch e := m.Expression.(type) {
	case *runtimev1.Expression_Ident:
		c++
	case *runtimev1.Expression_Cond:
		for _, expr := range e.Cond.Exprs {
			c += filterCount(expr)
		}
	}
	return c
}

func marshalInlineMeasure(ms []*runtimev1.InlineMeasure) []string {
	if len(ms) == 0 {
		return make([]string, 0)
	}

	names := make([]string, len(ms))
	for i := 0; i < len(ms); i++ {
		names[i] = ms[i].Name
	}
	return nil
}

func marshalMetricsViewAggregationDimension(ms []*runtimev1.MetricsViewAggregationDimension) []string {
	if len(ms) == 0 {
		return make([]string, 0)
	}

	names := make([]string, len(ms))
	for i := 0; i < len(ms); i++ {
		names[i] = ms[i].Name
	}
	return nil
}

func marshalMetricsViewAggregationMeasures(ms []*runtimev1.MetricsViewAggregationMeasure) []string {
	if len(ms) == 0 {
		return make([]string, 0)
	}

	names := make([]string, len(ms))
	for i := 0; i < len(ms); i++ {
		names[i] = ms[i].Name
	}
	return nil
}

func marshalMetricsViewAggregationSort(ms []*runtimev1.MetricsViewAggregationSort) []string {
	if len(ms) == 0 {
		return make([]string, 0)
	}

	names := make([]string, len(ms))
	for i := 0; i < len(ms); i++ {
		names[i] = ms[i].Name
	}
	return nil
}

func marshalMetricsViewComparisonSort(ms []*runtimev1.MetricsViewComparisonSort) []string {
	if len(ms) == 0 {
		return make([]string, 0)
	}

	names := make([]string, len(ms))
	for i := 0; i < len(ms); i++ {
		names[i] = ms[i].Name
	}
	return nil
}

func marshalMetricsViewSort(ms []*runtimev1.MetricsViewSort) []string {
	if len(ms) == 0 {
		return make([]string, 0)
	}

	names := make([]string, len(ms))
	for i := 0; i < len(ms); i++ {
		names[i] = ms[i].Name
	}
	return nil
}

func marshalColumnTimeSeriesRequestBasicMeasure(m []*runtimev1.ColumnTimeSeriesRequest_BasicMeasure) []string {
	if len(m) == 0 {
		return make([]string, 0)
	}
	ids := make([]string, len(m))
	for i := 0; i < len(m); i++ {
		ids[i] = m[i].Id
	}
	return ids
}