metricsbatch

type BatchConfigWithRawMetrics struct {
	Metrics MetricsBatchRawConfig `yaml:"metrics"`
}

type MetricsBatchConfig struct {
	Enabled  bool                        `yaml:"enabled"`
	Requests []MetricsBatchRequestConfig `yaml:"requests"`
}

type MetricsBatchRawConfig struct {
	Enabled  bool  `yaml:"enabled"`
	Requests []any `yaml:"requests"`
}

type MetricsBatchRequestConfig struct {
	ID   string                          `yaml:"id"`
	Type string                          `yaml:"type"`
	Data []MetricsBatchRequestDataConfig `yaml:"data"`
}

type MetricsBatchRequestDataConfig struct {
	Key      string `yaml:"key"`
	JMESPath string `yaml:"jmesPath"`
	OnNil    string `yaml:"onNil"`
}

type MetricsFetcher interface {
	Fetch(ctx context.Context, ctr *app.Container, writer MetricsWriter) (<-chan TermType, error)
}

type MetricsFetcherFactory interface {
	Init(conf []byte) error
	FetcherFactory(ctx context.Context, ctr *app.Container) (MetricsFetcher, error)
}

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

type MetricsType string

type MetricsWriter func(
	ctx context.Context,
	ctr *app.Container,
	data executor.ResponseContent[any],
) error

type PrometheusMetricsBatchRequestConfig struct {
	ID       string                          `yaml:"id"`
	Type     string                          `yaml:"type"`
	URL      string                          `yaml:"url"`
	Query    string                          `yaml:"query"`
	Interval string                          `yaml:"interval"`
	Data     []MetricsBatchRequestDataConfig `yaml:"data"`
}

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

type TermType int