Versions in this module Expand all Collapse all v0 v0.2.4 Apr 23, 2022 Changes in this version + var DefaultStatsDumpFrequencySeconds = 5 + func SetStatsDumpFrequency(seconds int) func(t *TransformStatsManager) + type MockStatsManager struct + func NewMockStatsManager() *MockStatsManager + func (s *MockStatsManager) AddStepWatcher(stepName string) *StepWatcher + func (s *MockStatsManager) StartDumping() + func (s *MockStatsManager) StopDumping() + type Stats struct + ElapsedTimeSec int + OutputBufferLen int + RowsPerSecondAvg int + RowsPerSecondDelta int + StatusEmoji string + StatusText string + StepName string + TotalRowsProcessed int + func (s Stats) String() string + type StatsFetcher interface + GetStats func() []Stats + type StepWatcher struct + func NewStepWatcher(log logger.Logger, stepName string) *StepWatcher + func (n *StepWatcher) CalculateStats() + func (n *StepWatcher) RenderStats() Stats + func (n *StepWatcher) StartWatching(rowCountPtr *int64, chanPtr *chan stream.Record) + func (n *StepWatcher) StopWatching() + type TransformStatsManager struct + func NewTransformStats(log logger.Logger, options ...func(t *TransformStatsManager)) *TransformStatsManager + func (t *TransformStatsManager) AddStepWatcher(stepName string) *StepWatcher + func (t *TransformStatsManager) GetStats() []Stats + func (t *TransformStatsManager) StartDumping() + func (t *TransformStatsManager) StopDumping()
Go to main page