metrics

Documentation

Index

• Constants
• func GetDailyUsageFromProm(ctx context.Context, api promv1.API, query string, start, end time.Time, ...) ([]*mgmtv1alpha1.DayResult, float64, error)
• func GetPromQueryFromMetric(metric mgmtv1alpha1.RangedMetricName, labels MetricLabels, timeWindow string) (string, error)
• func GetTotalUsageFromProm(ctx context.Context, api promv1.API, query string, dayEnd time.Time, ...) (float64, error)
• type MetricLabel
  • func NewEqLabel(key, value string) MetricLabel
  • func NewNotEqLabel(key, value string) MetricLabel
  • func (m *MetricLabel) ToBenthosMeta() string
  • func (m *MetricLabel) ToPromQueryString() string
• type MetricLabels
  • func (m MetricLabels) ToBenthosMeta() string
  • func (m MetricLabels) ToPromQueryString() string

Constants

const (
	AccountIdLabel     = "neosyncAccountId"
	JobIdLabel         = "neosyncJobId"
	TemporalWorkflowId = "temporalWorkflowId"
	TemporalRunId      = "temporalRunId"

	TableSchemaLabel    = "tableSchema"
	TableNameLabel      = "tableName"
	JobTypeLabel        = "jobType"
	IsUpdateConfigLabel = "isUpdateConfig"

	NeosyncDateLabel  = "date"
	NeosyncDateFormat = "2006-01-02"

	TemporalWorkflowIdEnvKey = "TEMPORAL_WORKFLOW_ID"
	TemporalRunIdEnvKey      = "TEMPORAL_ENV_ID"
	NeosyncDateEnvKey        = "NEOSYNC_DATE"
)

Functions

func GetDailyUsageFromProm

func GetDailyUsageFromProm(ctx context.Context, api promv1.API, query string, start, end time.Time, logger *slog.Logger) ([]*mgmtv1alpha1.DayResult, float64, error)

func GetPromQueryFromMetric

func GetPromQueryFromMetric(
	metric mgmtv1alpha1.RangedMetricName,
	labels MetricLabels,
	timeWindow string,
) (string, error)

func GetTotalUsageFromProm

func GetTotalUsageFromProm(ctx context.Context, api promv1.API, query string, dayEnd time.Time, logger *slog.Logger) (float64, error)

Types

type MetricLabel

type MetricLabel struct {
	Key   string
	Value string
	Sign  string
}

func NewEqLabel

func NewEqLabel(key, value string) MetricLabel

func NewNotEqLabel

func NewNotEqLabel(key, value string) MetricLabel

note: this has only been tested with prometheus and using it with benthos is not currently supported

func (*MetricLabel) ToBenthosMeta

func (m *MetricLabel) ToBenthosMeta() string

func (*MetricLabel) ToPromQueryString

func (m *MetricLabel) ToPromQueryString() string

type MetricLabels

type MetricLabels []MetricLabel

func (MetricLabels) ToBenthosMeta

func (m MetricLabels) ToBenthosMeta() string

func (MetricLabels) ToPromQueryString

func (m MetricLabels) ToPromQueryString() string