metrics

Documentation

Index

• type Accessor
• type ColumnChecker
• type Columns
• type CompareChecker
  • func NewCompareChecker(ms statsd.ClientInterface, sc *conf.StaticConf, primaryDB *sql.DB) (*CompareChecker, error)
  • func (cc *CompareChecker) Emit(cr ComparisonResult) error
  • func (cc *CompareChecker) ExecuteComp(ctx context.Context, comp conf.ComparisonSQLStatement) (map[string]Result, error)
  • func (cc *CompareChecker) Run(ctx context.Context) error
• type Comparison
• type ComparisonResult
  • func (cr ComparisonResult) Key() string
  • func (cr ComparisonResult) RatioFirstToSecond() float64
  • func (cr ComparisonResult) TargetName() string
• type FreshnessChecker
  • func NewFreshnessChecker(ms statsd.ClientInterface, sc *conf.StaticConf, fr Freshnesser) (*FreshnessChecker, error)
  • func (fc *FreshnessChecker) Emit(tf TableFreshness) (bool, error)
  • func (fc *FreshnessChecker) EmitAll(tfs []TableFreshness) error
  • func (fc *FreshnessChecker) Run(ctx context.Context) error
• type Freshnesser
• type LastAccessor
  • func NewLastAccessor(ms statsd.ClientInterface, sc *conf.StaticConf, accessor Accessor) (*LastAccessor, error)
  • func (l *LastAccessor) Emit(ta TableAccess, sm map[string]struct{}) (bool, error)
  • func (l *LastAccessor) EmitAll(tas []TableAccess) error
  • func (l *LastAccessor) QueryAccesses(ctx context.Context) error
• type Result
• type SQLContext
• type TableAccess
• type TableColumn
• type TableFreshness

Types

type Accessor

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

type ColumnChecker struct {
}

type Columns

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

type CompareChecker

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

func NewCompareChecker

func NewCompareChecker(ms statsd.ClientInterface, sc *conf.StaticConf, primaryDB *sql.DB) (*CompareChecker, error)

NewCompareChecker builds a compare checker and initializes all underlying resources.

func (*CompareChecker) Emit

func (cc *CompareChecker) Emit(cr ComparisonResult) error

func (*CompareChecker) ExecuteComp

func (cc *CompareChecker) ExecuteComp(ctx context.Context, comp conf.ComparisonSQLStatement) (map[string]Result, error)

func (*CompareChecker) Run

func (cc *CompareChecker) Run(ctx context.Context) error

type Comparison

type Comparison struct {
	Results []ComparisonResult
}

type ComparisonResult

type ComparisonResult struct {
	Name   string
	First  Result
	Second Result
}

func (ComparisonResult) Key

func (cr ComparisonResult) Key() string

func (ComparisonResult) RatioFirstToSecond

func (cr ComparisonResult) RatioFirstToSecond() float64

func (ComparisonResult) TargetName

func (cr ComparisonResult) TargetName() string

type FreshnessChecker

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

func NewFreshnessChecker

func NewFreshnessChecker(ms statsd.ClientInterface, sc *conf.StaticConf, fr Freshnesser) (*FreshnessChecker, error)

func (*FreshnessChecker) Emit

func (fc *FreshnessChecker) Emit(tf TableFreshness) (bool, error)

func (*FreshnessChecker) EmitAll

func (fc *FreshnessChecker) EmitAll(tfs []TableFreshness) error

func (*FreshnessChecker) Run

func (fc *FreshnessChecker) Run(ctx context.Context) error

type Freshnesser

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

type LastAccessor

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

func NewLastAccessor

func NewLastAccessor(ms statsd.ClientInterface, sc *conf.StaticConf, accessor Accessor) (*LastAccessor, error)

func (*LastAccessor) Emit

func (l *LastAccessor) Emit(ta TableAccess, sm map[string]struct{}) (bool, error)

func (*LastAccessor) EmitAll

func (l *LastAccessor) EmitAll(tas []TableAccess) error

func (*LastAccessor) QueryAccesses

func (l *LastAccessor) QueryAccesses(ctx context.Context) error

type Result

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

type SQLContext

type SQLContext struct {
	Env map[string]string
}

type TableAccess

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

type TableColumn

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

type TableFreshness

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