record

type Array = []any

type ChannelStream struct {
	Ch chan RecordAndError
}

type CountingStream struct {
	Stream
	// contains filtered or unexported fields
}

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

type DiscardSink struct{}

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

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

type Object = map[string]any

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

type Record = any

type RecordAndError struct {
	Record
	Err error
}

type SingletonStream struct {
	Rec Record
	// contains filtered or unexported fields
}

type Sink interface {
	// Sink accepts a Record, with implementation-dependent effect. It is safe for concurrent use by multiple goroutines.
	Sink(rec Record) error
}

type SliceStream struct {
	Records []Record
	// contains filtered or unexported fields
}

type Stream interface {
	// Next returns the next Record in the stream, or io.EOF if end-of-stream, or other error if one occurred.
	// Next never returns both a Record and a non-nil error (as nil is indistinguishable from a real null Record).
	// Once Next returns io.EOF, every subsequent call will also return io.EOF.
	// Next is safe for concurrent use by multiple goroutines, although no guarantee of Record ordering is given under
	// concurrent access.
	Next() (Record, error)
}

type StringWriterSink struct {
	Writer io.StringWriter
	// contains filtered or unexported fields
}