metrics

type Accessor interface {
	// In the future this should be a cursor or generator
	// pull everything into memory for right now for simplicity
	TableAccesses(ctx context.Context, conf *conf.LastUpdateConf) ([]TableAccess, error)
}

type ColumnChecker struct {
}

type Columns interface {
	Columns(ctx context.Context) ([]TableColumn, error)
}

type CompareChecker struct {
	Metrics    statsd.ClientInterface
	StaticConf *conf.StaticConf
	// contains filtered or unexported fields
}

type Comparison struct {
	Results []ComparisonResult
}

type ComparisonResult struct {
	Name   string
	First  Result
	Second Result
}

type FreshnessChecker struct {
	Metrics    statsd.ClientInterface
	StaticConf *conf.StaticConf
	Fr         Freshnesser
}

type Freshnesser interface {
	Freshness(ctx context.Context, conf *conf.FreshnessConf) ([]TableFreshness, error)
}

type LastAccessor struct {
	Metrics    statsd.ClientInterface
	StaticConf *conf.StaticConf
	Accessor   Accessor
	// contains filtered or unexported fields
}

type Result struct {
	Key  string
	Name string
	DB   string
	Rows int
}

type SQLContext struct {
	Env map[string]string
}

type TableAccess struct {
	Schema     string
	Table      string
	LastInsert time.Time
	Rows       int
}

type TableColumn struct {
	Database string
	Schema   string
	Table    string
	Column   string
	Type     string
	Length   int
}

type TableFreshness struct {
	Database   string
	Schema     string
	Table      string
	LastRecord time.Time
	Column     string
	Tags       []string
}