features

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