Versions in this module Expand all Collapse all v0 v0.3.0 Sep 27, 2022 Changes in this version + const ActivityTypeIDChangeDataValue + const ActivityTypeIDNewLead + const MaximumHoursGap + var ErrDone = errors.New("no more records in iterator") + type CDCIterator struct + func NewCDCIterator(ctx context.Context, client *marketoclient.Client, pollingPeriod time.Duration, ...) (*CDCIterator, error) + func (c *CDCIterator) GetChangedLeadsIDs(ctx context.Context, token string) ([]int, map[int]int, error) + func (c *CDCIterator) GetDeletedLeadsIDs(ctx context.Context, token string) ([]int, error) + func (c *CDCIterator) HasNext(ctx context.Context) bool + func (c *CDCIterator) Next(ctx context.Context) (sdk.Record, error) + func (c *CDCIterator) Stop() + type CombinedIterator struct + func NewCombinedIterator(ctx context.Context, endpoint string, pollingPeriod time.Duration, ...) (*CombinedIterator, error) + func (c *CombinedIterator) HasNext(ctx context.Context) bool + func (c *CombinedIterator) Next(ctx context.Context) (sdk.Record, error) + func (c *CombinedIterator) Stop() + type Record struct + type SnapshotIterator struct + func NewSnapshotIterator(ctx context.Context, endpoint string, fields []string, ...) (*SnapshotIterator, error) + func (s *SnapshotIterator) HasNext(ctx context.Context) bool + func (s *SnapshotIterator) Next(ctx context.Context) (sdk.Record, error)
Go to main page