metrics

Documentation

Index

• func FreshnessLatency(writeLog []libqpu.WriteLogEntry) (float64, float64, float64, float64)
• func FreshnessVersions(queryLog []libqpu.QueryLogEntry, writeLog []libqpu.WriteLogEntry, ...) (float64, float64, float64, float64, error)
• type LatencyM
  • func NewLatencyM() LatencyM
  • func (m LatencyM) AddFromOp(logOp libqpu.LogOperation) (err error)
  • func (m LatencyM) AddFromTs(t0 time.Time) (err error)
  • func (m LatencyM) GetMetrics() (float64, float64, float64, float64)

Functions

func FreshnessLatency

func FreshnessLatency(writeLog []libqpu.WriteLogEntry) (float64, float64, float64, float64)

FreshnessLatency ...

func FreshnessVersions

func FreshnessVersions(queryLog []libqpu.QueryLogEntry, writeLog []libqpu.WriteLogEntry, putInCacheLog []libqpu.WriteLogEntry) (float64, float64, float64, float64, error)

FreshnessVersions ...

Types

type LatencyM

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

LatencyM ...

func NewLatencyM

func NewLatencyM() LatencyM

NewLatencyM ...

func (LatencyM) AddFromOp

func (m LatencyM) AddFromOp(logOp libqpu.LogOperation) (err error)

AddFromOp ...

func (LatencyM) AddFromTs

func (m LatencyM) AddFromTs(t0 time.Time) (err error)

AddFromTs ...

func (LatencyM) GetMetrics

func (m LatencyM) GetMetrics() (float64, float64, float64, float64)

GetMetrics ...