metrics

Documentation

Index

• type Table
  • func NewTable(factory metrics.Factory, tableName string) *Table
  • func (t *Table) Emit(err error, latency time.Duration)
  • func (t *Table) Exec(query cassandra.UpdateQuery, logger *zap.Logger) error

Types

type Table

type Table struct {
	Attempts   metrics.Counter `metric:"attempts"`
	Inserts    metrics.Counter `metric:"inserts"`
	Errors     metrics.Counter `metric:"errors"`
	LatencyOk  metrics.Timer   `metric:"latency-ok"`
	LatencyErr metrics.Timer   `metric:"latency-err"`
}

Table is a collection of metrics about Cassandra write operations.

func NewTable

func NewTable(factory metrics.Factory, tableName string) *Table

NewTable takes a metrics scope and creates a table metrics struct

func (*Table) Emit

func (t *Table) Emit(err error, latency time.Duration)

Emit will record success or failure counts and latency metrics depending on the passed error.

func (*Table) Exec

func (t *Table) Exec(query cassandra.UpdateQuery, logger *zap.Logger) error

Exec executes an update query and reports metrics/logs about it.