output

type Writer ¶

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

Writer serialises task.Result values to a file in JSONL or CSV format. Send is non-blocking; results are dropped (with a warning) if the internal buffer is full. Close drains the buffer and flushes the file.

func New(cfg config.OutputConfig) (*Writer, error)

func (w *Writer) Close()

func (w *Writer) Send(r task.Result)