features

Jul 18, 2025

Changes in this version

+ var ErrKeySet = errors.New(`the option "Key" is invalid when using pagination`)

+ var ErrNoMoreResults = errors.New("no more results available")

+ var ErrNotImplemented = errors.New("not yet implemented")

+ type AllDocsPagerOptions interface

+ type DesignDocsPagerOptions interface

+ type FindPagerOptions interface

+ type Pager interface

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

+ GetAllWithContext func(context.Context) ([]T, error)

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

+ GetNextWithContext func(context.Context) ([]T, error)

+ HasNext func() bool

+ type PaginatedRow interface

+ type Pagination interface

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

+ Pages func() iter.Seq2[[]T, error]

+ PagesWithContext func(context.Context) iter.Seq2[[]T, error]

+ Rows func() iter.Seq2[T, error]

+ RowsWithContext func(context.Context) iter.Seq2[T, error]

+ func NewAllDocsPagination[O AllDocsPagerOptions](c *cloudantv1.CloudantV1, o O) Pagination[cloudantv1.DocsResultRow]

+ func NewDesignDocsPagination[O DesignDocsPagerOptions](c *cloudantv1.CloudantV1, o O) Pagination[cloudantv1.DocsResultRow]

+ func NewFindPagination[O FindPagerOptions](c *cloudantv1.CloudantV1, o O) Pagination[cloudantv1.Document]

+ func NewSearchPagination[O SearchPagerOptions](c *cloudantv1.CloudantV1, o O) Pagination[cloudantv1.SearchResultRow]

+ func NewViewPagination[O ViewPagerOptions](c *cloudantv1.CloudantV1, o O) Pagination[cloudantv1.ViewResultRow]

+ type SearchPagerOptions interface

+ type ViewPagerOptions interface

Aug 30, 2023

Changes in this version

+ const BatchSize

+ const LongpollTimeout

+ const StatusBadIO

+ const StatusBrokenJson

+ func ErrorText(err int) string

+ type ChangesFollower struct

+ func NewChangesFollower(c *cloudantv1.CloudantV1, o *cloudantv1.PostChangesOptions) (*ChangesFollower, error)

+ func NewChangesFollowerWithContext(ctx context.Context, c *cloudantv1.CloudantV1, ...) (*ChangesFollower, error)

+ func (cf *ChangesFollower) SetErrorTolerance(d time.Duration) error

+ func (cf *ChangesFollower) Start() (<-chan ChangesItem, error)

+ func (cf *ChangesFollower) StartOneOff() (<-chan ChangesItem, error)

+ func (cf *ChangesFollower) Stop()

+ type ChangesItem struct

+ func (ci ChangesItem) Item() (cloudantv1.ChangesResultItem, error)

+ type MockChangesGenerator struct

+ func NewMockChangesGenerator(batches int, errs []int) *MockChangesGenerator

+ func (mg *MockChangesGenerator) Next() (statusCode int, data []byte)

+ type MockDbInfoGenerator struct

+ func NewDbInfoGenerator(docCount, docSize int) *MockDbInfoGenerator

+ func (mg *MockDbInfoGenerator) Next() (statusCode int, data []byte)

+ type MockErrorGenerator struct

+ func NewMockErrorGenerator(err int) *MockErrorGenerator

+ func (mg *MockErrorGenerator) Next() (statusCode int, data []byte)

+ type MockGenerator interface

+ Next func() (statusCode int, data []byte)

+ type MockServer struct

+ func NewMockErrorServer(err int) *MockServer

+ func NewMockServer(batches int, errs []int) *MockServer

+ func (ms *MockServer) CallNumber() int

+ func (ms *MockServer) Limit() int

+ func (ms *MockServer) Start() *cloudantv1.CloudantV1

+ func (ms *MockServer) Stop()

+ func (ms *MockServer) WithDbInfo(docCount, docSize int) *MockServer

+ func (ms *MockServer) WithDbInfoError(err int) *MockServer

+ type Mode int

+ const Finite

+ const Listen

+ type TransientErrorSuppression int

+ const Always

+ const Never

+ const Timer