Versions in this module Expand all Collapse all v1 v1.4.1 Nov 8, 2024 Changes in this version + type LightningPoller struct + SfUtils *pkg.SalesforceUtils + func NewLightningPoller(queries []QueryWithCallback, sfConfig pkg.Config, startFrom *time.Time, ...) (*LightningPoller, error) + func (p *LightningPoller) Run() + type Position struct + LastModifiedDate *time.Time + NextURL string + PreviousRecordIDs map[string]*time.Time + type QueryWithCallback struct + Callback func(result []byte, err error) bool + DependsOn []string + PersistenceKey string + Query func() string + type RunConfig struct + LastModifiedDateCorrectionDuration time.Duration + PersistenceEnabled bool + PersistencePath string + Queries []QueryWithCallback + SkipDependencyCheck bool + StartupPositionOverrides map[string]time.Time + Ticker *time.Ticker
Go to main page