source

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

type Source interface {
	// Next returns the next record. It returns ErrDrained once the source
	// is exhausted, and any other error is a real failure. Returned records
	// must stay valid and unmodified across later Next calls, so a source
	// must not reuse buffers between records. The built-ins copy.
	Next(ctx context.Context) (domain.Record, error)
	// Close releases underlying resources. It is safe to call more than
	// once and concurrently with Next, and it must interrupt a blocked
	// Next. The engine closes a source to unwind a pending read.
	Close() error
}