iterator

Jan 27, 2026

Changes in this version

+ type SimpleFetcher func(ctx context.Context, req Req, opts ...grpc.CallOption) (SimpleResponse[T], error)

+ type SimpleIterator struct

+ func NewSimpleIterator[Req any, T any](ctx context.Context, req Req, fetch SimpleFetcher[Req, T], ...) *SimpleIterator[Req, T]

+ func (it *SimpleIterator[Req, T]) Error() error

+ func (it *SimpleIterator[Req, T]) Next() bool

+ func (it *SimpleIterator[Req, T]) Take(size int64) ([]T, error)

+ func (it *SimpleIterator[Req, T]) TakeAll() ([]T, error)

+ func (it *SimpleIterator[Req, T]) Value() T

+ type SimpleResponse interface

+ Items func() []T

Jan 15, 2026

Changes in this version

+ type Iterator struct

+ func NewIterator[Req PageRequest, T any](ctx context.Context, req Req, fetch PageFetcher[Req, T], ...) *Iterator[Req, T]

+ func (it *Iterator[Req, T]) Error() error

+ func (it *Iterator[Req, T]) Next() bool

+ func (it *Iterator[Req, T]) NextPageToken() string

+ func (it *Iterator[Req, T]) Take(size int64) ([]T, error)

+ func (it *Iterator[Req, T]) TakeAll() ([]T, error)

+ func (it *Iterator[Req, T]) Value() T

+ type PageFetcher func(ctx context.Context, req Req, opts ...grpc.CallOption) (PageResponse[T], error)

+ type PageRequest interface

+ GetPageSize func() int64

+ GetPageToken func() string

+ SetPageSize func(int64)

+ SetPageToken func(string)

+ type PageResponse interface

+ GetNextPageToken func() string

+ Items func() []T