metrics

type AttrFilter struct {
	org.TimeFilter
	App *bunapp.App

	ProjectID uint32
	Metric    []string

	AttrKey         []string
	Instrument      []string
	OtelLibraryName []string
	SearchInput     string
}

type AttrHandler struct {
	*bunapp.App
}

type AttrKeyItem struct {
	Value  string `json:"value"`
	Count  uint64 `json:"count"`
	Pinned bool   `json:"pinned"`
}

type AttrMap map[string]string

type AttrName struct {
	Canonical string
	Alts      []string
}

type AttrValueItem struct {
	Value string `json:"value"`
	Count uint64 `json:"count"`
}

type BaseGridItem struct {
	bun.BaseModel `bun:"grid_items,alias:g"`

	ID       uint64   `json:"id" bun:",pk,autoincrement"`
	DashID   uint64   `json:"dashId"`
	DashKind DashKind `json:"dashKind"`
	RowID    uint64   `json:"rowId" bun:",nullzero"`

	Title       string `json:"title"`
	Description string `json:"description" bun:",nullzero"`

	Width  int `json:"width"`
	Height int `json:"height"`
	XAxis  int `json:"xAxis"`
	YAxis  int `json:"yAxis"`

	Type   GridItemType   `json:"type"`
	Params bunutil.Params `json:"params"`

	CreatedAt time.Time `json:"createdAt" bun:",nullzero"`
	UpdatedAt time.Time `json:"updatedAt" bun:",nullzero"`
}

type BaseGridItemTpl struct {
	Title       string `yaml:"title"`
	Description string `yaml:"description,omitempty"`

	Width  int `yaml:"width,omitempty"`
	Height int `yaml:"height,omitempty"`
	XAxis  int `yaml:"x_axis,omitempty"`
	YAxis  int `yaml:"y_axis,omitempty"`

	Type GridItemType `yaml:"type"`
}

type BaseMonitorTpl struct {
	Name string `yaml:"name"`

	Type org.MonitorType `yaml:"type,omitempty"`

	NotifyEveryoneByEmail bool `yaml:"notify_everyone_by_email"`
}

type CHStorage struct {
	// contains filtered or unexported fields
}

type CHStorageConfig struct {
	ProjectID uint32
	MetricMap map[string]*Metric
	Search    []chquery.Token
	TableName string
}

type ChartGridItem struct {
	*BaseGridItem `bun:",inherit"`

	Params ChartGridItemParams `json:"params"`
}

type ChartGridItemParams struct {
	ChartKind ChartKind         `json:"chartKind"`
	Metrics   []mql.MetricAlias `json:"metrics"`
	Query     string            `json:"query"`
	// Use ColumnMap instead of MetricMap for compatibility with TableGridItem.
	ColumnMap     map[string]*MetricColumn    `json:"columnMap"`
	TimeseriesMap map[string]*TimeseriesStyle `json:"timeseriesMap"`
	Legend        *ChartLegend                `json:"legend"`
}

type ChartGridItemTpl struct {
	BaseGridItemTpl `yaml:",inline"`

	ChartKind ChartKind                   `yaml:"chart"`
	Metrics   []string                    `yaml:"metrics"`
	Query     []string                    `yaml:"query"`
	Columns   map[string]*MetricColumn    `yaml:"columns,omitempty"`
	Styles    map[string]*TimeseriesStyle `yaml:"styles,omitempty"`
	Legend    *ChartLegend                `yaml:"legend,omitempty"`
}

type ChartKind string

type ChartLegend struct {
	Type      LegendType      `json:"type" yaml:"type"`
	Placement LegendPlacement `json:"placement" yaml:"placement"`
	Values    []LegendValue   `json:"values" yaml:"values"`
}

type CloudwatchDatapoint struct {
	MetricStreamName string            `json:"metric_stream_name"`
	AccountID        string            `json:"account_id"`
	Region           string            `json:"region"`
	Namespace        string            `json:"namespace"`
	MetricName       string            `json:"metric_name"`
	Dimensions       map[string]string `json:"dimensions"`
	Timestamp        int64             `json:"timestamp"`
	Value            struct {
		Min   float64 `json:"min"`
		Max   float64 `json:"max"`
		Sum   float64 `json:"sum"`
		Count float64 `json:"count"`
	} `json:"value"`
	Unit string `json:"unit"`
}

type ColumnInfo struct {
	Name      string `json:"name"`
	Unit      string `json:"unit"`
	IsGroup   bool   `json:"isGroup"`
	TableFunc string `json:"tableFunc"`
}

type CumToDeltaConv struct {
	// contains filtered or unexported fields
}

type DashBuilder struct {
	// contains filtered or unexported fields
}

type DashFilter struct {
	ProjectID uint32 `urlstruct:"-"`

	org.OrderByMixin

	Q      string
	Pinned bool
}

type DashHandler struct {
	*bunapp.App
}

type DashKind string

type DashSyncer struct {
	// contains filtered or unexported fields
}

type DashTableTpl struct {
	If      []MetricMatcher         `yaml:"if,omitempty"`
	Metrics []string                `yaml:"metrics"`
	Query   []string                `yaml:"query"`
	Columns map[string]*TableColumn `yaml:"columns,omitempty"`
}

type Dashboard struct {
	bun.BaseModel `bun:"dashboards,alias:d"`

	ID         uint64 `json:"id" bun:",pk,autoincrement"`
	ProjectID  uint32 `json:"projectId"`
	TemplateID string `json:"templateId" bun:",nullzero"`

	Name   string `json:"name"`
	Pinned bool   `json:"pinned"`

	MinInterval       unixtime.Millis `json:"minInterval"`
	TimeOffset        unixtime.Millis `json:"timeOffset"`
	TooltipsConnected bool            `json:"tooltipsConnected"`

	GridQuery    string `json:"gridQuery" bun:",nullzero"`
	GridMaxWidth int    `json:"gridMaxWidth" bun:",nullzero"`

	TableMetrics   []mql.MetricAlias       `json:"tableMetrics" bun:",type:jsonb,nullzero"`
	TableQuery     string                  `json:"tableQuery" bun:",nullzero"`
	TableGrouping  []string                `json:"tableGrouping" bun:",type:jsonb,nullzero"`
	TableColumnMap map[string]*TableColumn `json:"tableColumnMap" bun:",type:jsonb,nullzero"`

	CreatedAt time.Time `json:"createdAt" bun:",nullzero"`
	UpdatedAt time.Time `json:"updatedAt" bun:",nullzero"`
}

type DashboardIn struct {
	Name         string          `json:"name"`
	MinInterval  unixtime.Millis `json:"minInterval"`
	TimeOffset   unixtime.Millis `json:"timeOffset"`
	GridMaxWidth int             `json:"gridMaxWidth"`
}

type DashboardTpl struct {
	Schema string `yaml:"schema"`

	ID   string          `yaml:"id"`
	If   []MetricMatcher `yaml:"if,omitempty"`
	Name string          `yaml:"name"`

	MinInterval unixtime.Millis `yaml:"min_interval,omitempty"`
	TimeOffset  unixtime.Millis `yaml:"time_offset,omitempty"`
	GridQuery   string          `yaml:"grid_query,omitempty"`

	TableGridItems []*GridItemTpl `yaml:"table_grid_items,omitempty"`
	Table          []DashTableTpl `yaml:"table"`

	IncludeGridRows []string            `yaml:"include_grid_rows,omitempty"`
	GridRows        []*GridRowTpl       `yaml:"grid_rows"`
	Monitors        []*MetricMonitorTpl `yaml:"monitors,omitempty"`
}

type Datapoint struct {
	ch.CHModel `ch:"datapoint_minutes,insert:datapoint_minutes_buffer,alias:m"`

	ProjectID   uint32
	Metric      string     `ch:"metric,lc"`
	Description string     `ch:"-"`
	Unit        string     `ch:"-"`
	Instrument  Instrument `ch:",lc"`

	Time      time.Time `ch:"type:DateTime"`
	AttrsHash uint64

	Min       float64
	Max       float64
	Sum       float64
	Count     uint64
	Gauge     float64
	Histogram map[bfloat16.T]uint64 `ch:"type:AggregateFunction(quantilesBFloat16(0.5), Float32)"`

	Attrs        AttrMap  `ch:"-"`
	StringKeys   []string `ch:"type:Array(LowCardinality(String))"`
	StringValues []string

	OtelLibraryName    string `ch:",lc"`
	OtelLibraryVersion string `ch:",lc"`

	StartTimeUnixNano uint64 `ch:"-"`
	CumPoint          any    `ch:"-"`
}

type DatapointKey struct {
	ProjectID         uint32
	Metric            string
	AttrsHash         uint64
	StartTimeUnixNano uint64
}

type DatapointProcessor struct {
	*bunapp.App
	// contains filtered or unexported fields
}

type DatapointValue struct {
	Key   DatapointKey
	Point any
	Time  time.Time
}

type ErrorMonitorTpl struct {
	BaseMonitorTpl `yaml:",inline"`

	NotifyOnNewErrors       bool              `yaml:"notify_on_new_errors"`
	NotifyOnRecurringErrors bool              `yaml:"notify_on_recurring_errors"`
	Matchers                []org.AttrMatcher `yaml:"matchers"`
}

type ExpHistogramPoint struct {
	Sum       float64
	Count     uint64
	Histogram map[bfloat16.T]uint64
}

type GaugeColumn struct {
	Unit    string `json:"unit" yaml:"unit,omitempty"`
	AggFunc string `json:"aggFunc" yaml:"agg_func,omitempty"`
}

type GaugeGridItem struct {
	*BaseGridItem `bun:",inherit"`

	Params GaugeGridItemParams `json:"params"`
}

type GaugeGridItemParams struct {
	Metrics   []mql.MetricAlias       `json:"metrics"`
	Query     string                  `json:"query"`
	ColumnMap map[string]*GaugeColumn `json:"columnMap" bun:",nullzero"`

	Template      string         `json:"template" bun:",nullzero"`
	ValueMappings []ValueMapping `json:"valueMappings" bun:",nullzero"`
}

type GaugeGridItemTpl struct {
	BaseGridItemTpl `yaml:",inline"`

	Metrics []string                `yaml:"metrics"`
	Query   []string                `yaml:"query"`
	Columns map[string]*GaugeColumn `yaml:"columns,omitempty"`

	Template      string         `yaml:"template,omitempty"`
	ValueMappings []ValueMapping `yaml:"value_mappings,omitempty"`
}

type GridItem interface {
	Base() *BaseGridItem
	Validate() error
	Metrics() []string
}

type GridItemHandler struct {
	*bunapp.App
}

type GridItemIn struct {
	DashKind DashKind `json:"dashKind"`

	Title       string `json:"title"`
	Description string `json:"description"`

	Width  int `json:"width"`
	Height int `json:"height"`

	Type   GridItemType    `json:"type"`
	Params json.RawMessage `json:"params"`
}

type GridItemPos struct {
	ID     uint64 `json:"id"`
	Width  int32  `json:"width"`
	Height int32  `json:"height"`
	XAxis  int32  `json:"xAxis"`
	YAxis  int32  `json:"yAxis"`
}

type GridItemTpl struct {
	Value any
}

type GridItemType string

type GridRow struct {
	bun.BaseModel `bun:"grid_rows,alias:r"`

	ID     uint64 `json:"id" bun:",pk,autoincrement"`
	DashID uint64 `json:"dashId"`

	Title       string `json:"title"`
	Description string `json:"description" bun:",nullzero"`
	Expanded    bool   `json:"expanded"`
	Index       int    `json:"index"`

	Items []GridItem `json:"items" bun:"-"`

	CreatedAt time.Time `json:"createdAt" bun:",nullzero"`
	UpdatedAt time.Time `json:"updatedAt" bun:",nullzero"`
}

type GridRowHandler struct {
	*bunapp.App
}

type GridRowIn struct {
	Title       string `json:"title"`
	Description string `json:"description" bun:",nullzero"`
	Expanded    bool   `json:"expanded"`
}

type GridRowTpl struct {
	Title string         `yaml:"title"`
	Items []*GridItemTpl `yaml:"items"`
}

type HeatmapGridItem struct {
	*BaseGridItem `bun:",inherit"`

	Params HeatmapGridItemParams `json:"params"`
}

type HeatmapGridItemParams struct {
	Metric string `json:"metric"`
	Unit   string `json:"unit"`
	Query  string `json:"query"`
}

type HeatmapGridItemTpl struct {
	BaseGridItemTpl `yaml:",inline"`

	Metric string   `yaml:"metric"`
	Unit   string   `yaml:"unit,omitempty"`
	Query  []string `yaml:"query"`
}

type HistogramPoint struct {
	Sum          float64
	Count        uint64
	Bounds       []float64
	BucketCounts []uint64
}

type Instrument string

type KinesisEvent struct {
	RequestID string               `json:"requestId"`
	Records   []KinesisEventRecord `json:"records"`
}

type KinesisEventRecord struct {
	Data []byte `json:"data"`
}

type KinesisHandler struct {
	*bunapp.App
	// contains filtered or unexported fields
}

type LegendPlacement string

type LegendType string

type LegendValue string

type MappingOp string

type Metric struct {
	bun.BaseModel `bun:"metrics,alias:m"`

	ID        uint64 `json:"id,string" bun:",pk,autoincrement"`
	ProjectID uint32 `json:"projectId"`

	Name        string     `json:"name"`
	Description string     `json:"description"`
	Instrument  Instrument `json:"instrument"`
	Unit        string     `json:"unit" bun:",nullzero"`

	AttrKeys           []string `json:"attrKeys" bun:",array"`
	OtelLibraryName    string   `json:"otelLibraryName" bun:",nullzero"`
	OtelLibraryVersion string   `json:"otelLibraryVersion" bun:",nullzero"`

	CreatedAt time.Time `json:"createdAt" bun:",nullzero"`
	UpdatedAt time.Time `json:"updatedAt" bun:",nullzero"`

	// Payload
	NumTimeseries uint64 `json:"numTimeseries" bun:",scanonly"`
}

type MetricColumn struct {
	Unit  string `json:"unit" yaml:"unit,omitempty"`
	Color string `json:"color" yaml:"color,omitempty"`
}

type MetricFilter struct {
	org.TimeFilter

	ProjectID uint32

	AttrKey         []string
	Instrument      []string
	OtelLibraryName []string
	SearchInput     string

	Query string
}

type MetricHandler struct {
	*bunapp.App
}

type MetricKey struct {
	ProjectID uint32
	Metric    string
}

type MetricMatcher struct {
	Metric          string `yaml:"metric"`
	Instrumentation string `yaml:"instrumentation"`
	State           string `yaml:"state"`
}

type MetricMonitorTpl struct {
	BaseMonitorTpl `yaml:",inline"`

	Metrics    []string `yaml:"metrics"`
	Query      []string `yaml:"query"`
	Column     string   `yaml:"column"`
	ColumnUnit string   `yaml:"column_unit,omitempty"`

	MinAllowedValue bunutil.NullFloat64 `yaml:"min_allowed_value,omitempty"`
	MaxAllowedValue bunutil.NullFloat64 `yaml:"max_allowed_value,omitempty"`

	CheckNumPoint int             `yaml:"check_num_point"`
	TimeOffset    unixtime.Millis `yaml:"time_offset,omitempty"`
}

type MetricsServiceServer struct {
	collectormetricspb.UnimplementedMetricsServiceServer

	*bunapp.App
	// contains filtered or unexported fields
}

type Middleware struct {
	*org.Middleware
	App *bunapp.App
}

type MonitorTpl struct {
	Value any // *MetricMonitorTpl | *ErrorMonitorTpl
}

type NumberPoint struct {
	Int    int64
	Double float64
}

type PromDatapoint struct {
	Metric       string
	Value        float64
	StringKeys   []string
	StringValues []string
	Time         time.Time
}

type PrometheusHandler struct {
	*bunapp.App
	// contains filtered or unexported fields
}

type QueryFilter struct {
	org.TimeFilter
	org.OrderByMixin
	urlstruct.Pager

	Project *org.Project `urlstruct:"-"`

	Metric []string
	Alias  []string
	Query  string

	Search string

	TableAgg map[string]string
	// contains filtered or unexported fields
}

type QueryHandler struct {
	*bunapp.App
}

type TableColumn struct {
	MetricColumn `yaml:",inline"`

	AggFunc           string `json:"aggFunc" yaml:"agg_func,omitempty"`
	SparklineDisabled bool   `json:"sparklineDisabled" yaml:"sparkline_disabled,omitempty"`
}

type TableGridItem struct {
	*BaseGridItem `bun:",inherit"`

	Params TableGridItemParams `json:"params"`
}

type TableGridItemParams struct {
	Metrics      []mql.MetricAlias        `json:"metrics"`
	Query        string                   `json:"query"`
	ColumnMap    map[string]*MetricColumn `json:"columnMap"`
	ItemsPerPage int                      `json:"itemsPerPage"`
	DenseTable   bool                     `json:"denseTable"`
}

type TableGridItemTpl struct {
	BaseGridItemTpl `yaml:",inline"`

	Metrics []string                 `yaml:"metrics"`
	Query   []string                 `yaml:"query"`
	Columns map[string]*MetricColumn `yaml:"columns,omitempty"`
}

type Timeseries struct {
	ID     uint64    `json:"id"`
	Name   string    `json:"name"`
	Metric string    `json:"metric"`
	Unit   string    `json:"unit"`
	Attrs  mql.Attrs `json:"attrs"`
	Value  []float64 `json:"value"`
}

type TimeseriesStyle struct {
	Color      string  `json:"color" yaml:"color"`
	Opacity    int32   `json:"opacity" yaml:"opacity"`
	LineWidth  float32 `json:"lineWidth" yaml:"line_width"`
	Symbol     string  `json:"symbol" yaml:"symbol"`
	SymbolSize int32   `json:"symbolSize" yaml:"symbol_size"`
}

type ValueMapping struct {
	Op    MappingOp   `json:"op" yaml:"op"`
	Value json.Number `json:"value" yaml:"value"`
	Text  string      `json:"text" yaml:"text"`
	Color string      `json:"color" yaml:"color"`
}