metric

package

v0.1.1 Latest Latest Go to latest Published: Oct 20, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/odpf/predator

Links

Open Source Insights

Documentation ¶

Index ¶

func NewBasicMetricSpecGenerator(toleranceStore protocol.ToleranceStore, metadataStore protocol.MetadataStore) protocol.MetricSpecGenerator
type BasicMetricProfiler
- func NewBasicMetricProfiler(tableProfiler protocol.MetricProfiler, fieldProfiler protocol.MetricProfiler, ...) *BasicMetricProfiler
- func (m *BasicMetricProfiler) Profile(entry protocol.Entry, profile *job.Profile, metricSpecs []*metric.Spec) ([]*metric.Metric, error)
type BasicMetricSpecGenerator
- func (b *BasicMetricSpecGenerator) Generate(tableSpec *meta.TableSpec, tolerances []*protocol.Tolerance) ([]*metric.Spec, error)
- func (b *BasicMetricSpecGenerator) GenerateMetricSpec(urn string) ([]*metric.Spec, error)
type DefaultGenerator
- func NewDefaultGenerator(specGenerator protocol.MetricSpecGenerator, profiler protocol.MetricProfiler, ...) *DefaultGenerator
- func (m *DefaultGenerator) Generate(entry protocol.Entry, profile *job.Profile) ([]*metric.Metric, error)
type DefaultProfileStatisticGenerator
- func NewDefaultProfileStatisticGenerator(metadataStore protocol.MetadataStore, queryExecutor protocol.QueryExecutor, ...) *DefaultProfileStatisticGenerator
- func (d *DefaultProfileStatisticGenerator) Generate(profile *job.Profile) error
type MultistageGenerator
- func NewMultistageGenerator(generators []protocol.MetricGenerator, ...) *MultistageGenerator
- func (m *MultistageGenerator) Generate(entry protocol.Entry, profile *job.Profile) (metrics []*metric.Metric, err error)
type QualityMetricProfiler
- func NewQualityMetricProfiler(metricStore protocol.MetricStore, profileStore protocol.ProfileStore, ...) *QualityMetricProfiler
- func (m *QualityMetricProfiler) Profile(entry protocol.Entry, profile *job.Profile, metricSpecs []*metric.Spec) ([]*metric.Metric, error)
type QualityMetricSpecGenerator
- func NewQualityMetricSpecGenerator(metadataStore protocol.MetadataStore, toleranceStore protocol.ToleranceStore) *QualityMetricSpecGenerator
- func (q *QualityMetricSpecGenerator) Generate(tableSpec *meta.TableSpec, tolerances []*protocol.Tolerance) ([]*metric.Spec, error)
- func (q *QualityMetricSpecGenerator) GenerateMetricSpec(urn string) ([]*metric.Spec, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewBasicMetricSpecGenerator ¶

func NewBasicMetricSpecGenerator(toleranceStore protocol.ToleranceStore, metadataStore protocol.MetadataStore) protocol.MetricSpecGenerator

Types ¶

type BasicMetricProfiler ¶

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

BasicMetricProfiler to profile table and fiend metric concurrently

func NewBasicMetricProfiler ¶

func NewBasicMetricProfiler(tableProfiler protocol.MetricProfiler, fieldProfiler protocol.MetricProfiler, profileStore protocol.ProfileStore, statsClientBuilder stats.ClientBuilder) *BasicMetricProfiler

NewBasicMetricProfiler create BasicMetricProfiler

func (*BasicMetricProfiler) Profile ¶

func (m *BasicMetricProfiler) Profile(entry protocol.Entry, profile *job.Profile, metricSpecs []*metric.Spec) ([]*metric.Metric, error)

Profile to start generate basic metrics

type BasicMetricSpecGenerator ¶

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

func (*BasicMetricSpecGenerator) Generate ¶

func (b *BasicMetricSpecGenerator) Generate(tableSpec *meta.TableSpec, tolerances []*protocol.Tolerance) ([]*metric.Spec, error)

func (*BasicMetricSpecGenerator) GenerateMetricSpec ¶

func (b *BasicMetricSpecGenerator) GenerateMetricSpec(urn string) ([]*metric.Spec, error)

type DefaultGenerator ¶

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

DefaultGenerator is default metric generator

func NewDefaultGenerator ¶

func NewDefaultGenerator(specGenerator protocol.MetricSpecGenerator, profiler protocol.MetricProfiler, metricStore protocol.MetricStore) *DefaultGenerator

func (*DefaultGenerator) Generate ¶

func (m *DefaultGenerator) Generate(entry protocol.Entry, profile *job.Profile) ([]*metric.Metric, error)

Generate get metric specification, calculate metric and store

type DefaultProfileStatisticGenerator ¶

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

func NewDefaultProfileStatisticGenerator ¶

func NewDefaultProfileStatisticGenerator(metadataStore protocol.MetadataStore, queryExecutor protocol.QueryExecutor, profileStore protocol.ProfileStore) *DefaultProfileStatisticGenerator

NewDefaultProfileStatisticGenerator create DefaultProfileStatisticGenerator

func (*DefaultProfileStatisticGenerator) Generate ¶

func (d *DefaultProfileStatisticGenerator) Generate(profile *job.Profile) error

type MultistageGenerator ¶

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

MultistageGenerator metric generator that generate metric from multiple generators

func NewMultistageGenerator ¶

func NewMultistageGenerator(generators []protocol.MetricGenerator, profileStatGen protocol.ProfileStatisticGenerator) *MultistageGenerator

NewMultistageGenerator create protocol.MetricsGenerator

func (*MultistageGenerator) Generate ¶

func (m *MultistageGenerator) Generate(entry protocol.Entry, profile *job.Profile) (metrics []*metric.Metric, err error)

Generate generate metric from multiple generator

type QualityMetricProfiler ¶

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

QualityMetricProfiler to profile quality metrics

func NewQualityMetricProfiler ¶

func NewQualityMetricProfiler(metricStore protocol.MetricStore, profileStore protocol.ProfileStore, statsClientBuilder stats.ClientBuilder) *QualityMetricProfiler

NewQualityMetricProfiler create QualityMetricProfiler

func (*QualityMetricProfiler) Profile ¶

func (m *QualityMetricProfiler) Profile(entry protocol.Entry, profile *job.Profile, metricSpecs []*metric.Spec) ([]*metric.Metric, error)

CreateProfile to start generate quality metrics

type QualityMetricSpecGenerator ¶

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

func NewQualityMetricSpecGenerator ¶

func NewQualityMetricSpecGenerator(metadataStore protocol.MetadataStore, toleranceStore protocol.ToleranceStore) *QualityMetricSpecGenerator

func (*QualityMetricSpecGenerator) Generate ¶

func (q *QualityMetricSpecGenerator) Generate(tableSpec *meta.TableSpec, tolerances []*protocol.Tolerance) ([]*metric.Spec, error)

func (*QualityMetricSpecGenerator) GenerateMetricSpec ¶

func (q *QualityMetricSpecGenerator) GenerateMetricSpec(urn string) ([]*metric.Spec, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
common
field
mock
table

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL