Versions in this module Expand all Collapse all v1 v1.1.0 Dec 17, 2020 v1.0.0 May 7, 2020 Changes in this version + func Print() chan struct + func PrintLimited(limit int) chan struct + func Process(processor func(dataPoint)) chan struct + func ProcessLimited(limit int, processor func(dataPoint)) chan struct + func RemovePendingOp(id OpID, status bool) error + func Sample(timestamp time.Time, duration time.Duration, targetID string, op SampleOp, ...) + type OpID int + func InsertPendingOp(timestamp time.Time, targetID string, op SampleOp, size int) OpID + type SampleOp int + const OpNone + const OpPing + const OpRead + const OpWrite + func (op SampleOp) String() string