spaniter

Jul 3, 2026

Changes in this version

+ var ErrSequenceReused = errors.New("row iterator sequence reused")

type Option

+ func WithOnDrainError(f func(error)) Option

type RowIteratorResult

+ func (r RowIteratorResult) StatsCaptured() bool

Jun 27, 2026

Changes in this version

+ func PullRowIteratorSeq(rowIter *spanner.RowIterator, opts ...Option) (pull func() (*spanner.Row, error, bool), stop func())

type Option

+ func WithStatsEncoding(enc StatsEncoding) Option

type RowIteratorResult

+ func (r RowIteratorResult) ResultSet(rows []*structpb.ListValue) (*sppb.ResultSet, error)

+ func (r RowIteratorResult) StatsProto() (*sppb.ResultSetStats, error)

+ type StatsEncoding int

+ const StatsEncodingDMLExact

+ const StatsEncodingDefault

Jun 26, 2026

Changes in this version

type Stats

+ func (s Stats) HasResultSetStats() bool

+ func (s Stats) ResultSetStats() (*sppb.ResultSetStats, error)

+ func (s Stats) ResultSetStatsForDML() (*sppb.ResultSetStats, error)

Jun 25, 2026

Changes in this version

+ var ErrNilRow = errors.New("nil row")

+ var ErrNilRowIterator = errors.New("nil row iterator")

+ func RowIteratorSeq(rowIter *spanner.RowIterator, opts ...Option) iter.Seq2[*spanner.Row, error]

+ func Rows(rows ...*spanner.Row) iter.Seq2[*spanner.Row, error]

+ func SliceToRowSeq(rows []*spanner.Row) iter.Seq2[*spanner.Row, error]

+ type Option func(*config)

+ func WithDrainOnEarlyStop() Option

+ func WithOnMetadata(f func(*sppb.ResultSetMetadata)) Option

+ func WithOnStats(f func(Stats)) Option

+ func WithResult(result *RowIteratorResult) Option

+ type RowIteratorResult struct

+ Metadata *sppb.ResultSetMetadata

+ RowsRead int64

+ Stats Stats

+ func DrainRowIterator(rowIter *spanner.RowIterator, opts ...Option) (*RowIteratorResult, error)

+ type Stats struct

+ QueryPlan *sppb.QueryPlan

+ QueryStats map[string]any

+ RowCount int64