iterator

package

v2.39.0 Latest Latest Go to latest Published: Jan 15, 2026 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Iterator[Req PageRequest, T any] struct {
	// contains filtered or unexported fields
}

func NewIterator[Req PageRequest, T any](
	ctx context.Context,
	req Req,
	fetch PageFetcher[Req, T],
	opts ...grpc.CallOption,
) *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[Req PageRequest, T any] func(
	ctx context.Context,
	req Req,
	opts ...grpc.CallOption,
) (PageResponse[T], error)

type PageRequest interface {
	GetPageSize() int64
	SetPageSize(int64)
	GetPageToken() string
	SetPageToken(string)
}

type PageResponse[T any] interface {
	Items() []T
	GetNextPageToken() string
}