Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPMetricsFetcher ¶
type HTTPMetricsFetcher struct {
// contains filtered or unexported fields
}
func NewHTTPMetricsFetcher ¶
func NewHTTPMetricsFetcher(tokenGen tokenGenerator) (*HTTPMetricsFetcher, error)
func (HTTPMetricsFetcher) Fetch ¶
func (f HTTPMetricsFetcher) Fetch(ctx context.Context, queryName metricdatatypes.UMAExportQuery, date civil.Date) (io.ReadCloser, error)
type JSONPayload ¶
type JSONPayload struct {
R RField `json:"r,omitempty"`
}
type JobArguments ¶
type JobArguments struct {
// contains filtered or unexported fields
}
func NewJobArguments ¶
func NewJobArguments( queryName metricdatatypes.UMAExportQuery, day civil.Date, histogramName metricdatatypes.HistogramName) JobArguments
NewJobArguments constructor to create JobArguments, encapsulating essential workflow parameters.
type MetricFetecher ¶
type MetricFetecher interface {
Fetch(context.Context, metricdatatypes.UMAExportQuery, civil.Date) (io.ReadCloser, error)
}
type MetricParser ¶
type MetricParser interface {
Parse(context.Context, io.ReadCloser) (metricdatatypes.BucketDataMetrics, error)
}
type MetricStorer ¶
type MetricStorer interface {
HasCapstone(context.Context, civil.Date, metricdatatypes.HistogramName) (bool, error)
SaveCapstone(context.Context, civil.Date, metricdatatypes.HistogramName) error
SaveMetrics(context.Context, civil.Date, metricdatatypes.BucketDataMetrics) error
}
MetricStorer represents the behavior to the storage layer.
type RField ¶
type RField map[string]metricdatatypes.BucketDataMetric
type UMAExportJobProcessor ¶
type UMAExportJobProcessor struct {
// contains filtered or unexported fields
}
func NewUMAExportJobProcessor ¶
func NewUMAExportJobProcessor( metricStorer MetricStorer, metricFetcher MetricFetecher, metricParser MetricParser) UMAExportJobProcessor
NewUMAExportJobProcessor constructs a UMAExportJobProcessor.
func (UMAExportJobProcessor) Process ¶
func (p UMAExportJobProcessor) Process(ctx context.Context, job JobArguments) error
type XSSIMetricsParser ¶
type XSSIMetricsParser struct{}
func (XSSIMetricsParser) Parse ¶
func (p XSSIMetricsParser) Parse(ctx context.Context, data io.ReadCloser) (metricdatatypes.BucketDataMetrics, error)
Source Files
Click to show internal directories.
Click to hide internal directories.