Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

iterators

package

Go to main page

Versions in this module

v0

v0.1.1

Nov 6, 2023

v0.1.0

Nov 17, 2022

Changes in this version

+ type ChanIterator struct

+ func NewChanIterator(ctx context.Context, iterators []StructIterator[T], opts ...ChanIteratorOption) *ChanIterator[T]

+ func (d *ChanIterator[T]) Close() error

+ func (d *ChanIterator[T]) Collect() ([]T, error)

+ func (d *ChanIterator[T]) CollectPtr() ([]*T, error)

+ func (d *ChanIterator[T]) Item() (T, error)

+ func (d *ChanIterator[T]) Next() bool

+ type ChanIteratorOption func(*chanIteratorOptions)

+ func WithChanFanInBuffers(n int) ChanIteratorOption

+ func WithChanPreallocatedItems(n int) ChanIteratorOption

+ type Iterator interface

+ Close func() error

+ Next func() bool

+ type IteratorContext struct

+ Iterated int

+ func GetIteratorContext(ctx context.Context) *IteratorContext

+ type RowsIterator struct

+ func NewRowsIterator(rows R, opts ...RowsIteratorOption) *RowsIterator[R, T]

+ func (ri *RowsIterator[R, T]) Close() error

+ func (ri *RowsIterator[R, T]) Collect() ([]T, error)

+ func (ri *RowsIterator[R, T]) CollectPtr() ([]*T, error)

+ func (ri *RowsIterator[R, T]) Item() (T, error)

+ func (ri *RowsIterator[R, T]) Next() bool

+ type RowsIteratorOption func(*rowsIteratorOptions)

+ func WithRowsPreallocatedItems(n int) RowsIteratorOption

+ type ScannableIterator interface

+ StructScan func(interface{}) error

+ type SliceIterator struct

+ func NewSliceIterator(rows []T) *SliceIterator[T]

+ func (si *SliceIterator[T]) Close() error

+ func (si *SliceIterator[T]) Collect() ([]T, error)

+ func (si *SliceIterator[T]) CollectPtr() ([]*T, error)

+ func (si *SliceIterator[T]) Item() (T, error)

+ func (si *SliceIterator[T]) Next() bool

+ type SqlxIterator struct

+ func NewSqlxIterator(rows *sqlx.Rows, opts ...RowsIteratorOption) *SqlxIterator[T]

+ type StructIterator interface

+ Collect func() ([]T, error)

+ CollectPtr func() ([]*T, error)

+ Item func() (T, error)

+ type TransformIterator struct

+ func NewTransformIterator(ctx context.Context, iterator StructIterator[S], ...) *TransformIterator[S, T]

+ func (rt *TransformIterator[S, T]) Collect() ([]T, error)

+ func (rt *TransformIterator[S, T]) CollectPtr() ([]*T, error)

+ func (rt *TransformIterator[S, T]) Item() (T, error)

+ func (rt *TransformIterator[S, T]) Next() bool

+ type TransformerCtx func(context.Context, S) (T, error)

v0.0.1

Nov 15, 2022