feat(output): add --stdout.iterations option

output/stdout.go

@@ -16,6 +16,7 @@ import (
 // Stdout outputter for Stdout
 type Stdout struct {
 	Base
+	Iterations int `help:"Inavtive on maximum iterations INT"`
 
 	close func() bool
 }
@@ -31,9 +32,14 @@ func (s *Stdout) Initialize(ctx context.Context) error {
 		return true
 	})
 
-	go func() {
+	go func(iter int) {
 		var cur *types.Data
 		s.write(<-s.r) // output first data immediately
+		iter--
+		if iter == 0 {
+			s.Close()
+			return
+		}
 		tick := time.NewTicker(time.Second * time.Duration(s.Interval))
 		for {
 			select {
@@ -43,6 +49,13 @@ func (s *Stdout) Initialize(ctx context.Context) error {
 				}
 				s.write(cur)
 				cur = nil // dismiss
+				if iter > 0 {
+					iter--
+					if iter == 0 {
+						tick.Stop()
+						s.Close()
+					}
+				}
 			case d, more := <-s.r:
 				if !more {
 					slog.Debug("Output channel has been closed", "outputter", s.Name())
@@ -51,7 +64,7 @@ func (s *Stdout) Initialize(ctx context.Context) error {
 				cur = d
 			}
 		}
-	}()
+	}(s.Iterations)
 	return nil
 }