etlmetrics

Documentation

Overview

Package itermetrics contains utils to debug and measure iterators.

Index

• func WithInterval(d time.Duration) metricOptions
• type Iter
  • func DebugCount(it Iter, prefix string) Iter
• type Metrics
  • func New(opts ...metricOptions) *Metrics
  • func (m *Metrics) Count(it Iter, name string) Iter
  • func (m *Metrics) Done()
  • func (m *Metrics) Start()

Functions

func WithInterval

func WithInterval(d time.Duration) metricOptions

Types

type Iter

type Iter = etl.Iter

Iter alias of iter.Iter

func DebugCount

func DebugCount(it Iter, prefix string) Iter

DebugCount prints the number of elements fetched from the iterator.

type Metrics

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

func New

func New(opts ...metricOptions) *Metrics

func (*Metrics) Count

func (m *Metrics) Count(it Iter, name string) Iter

func (*Metrics) Done

func (m *Metrics) Done()

func (*Metrics) Start

func (m *Metrics) Start()