pkg

type LightningPoller struct {
	SfUtils *pkg.SalesforceUtils
	// contains filtered or unexported fields
}

type Position struct {
	LastModifiedDate  *time.Time
	NextURL           string
	PreviousRecordIDs map[string]*time.Time
}

type QueryWithCallback struct {
	Query          func() string                       `json:"query" validate:"required"`
	PersistenceKey string                              `json:"persistenceKey"`
	Callback       func(result []byte, err error) bool `validate:"required"`
	DependsOn      []string
}

type RunConfig struct {
	Queries                            []QueryWithCallback `validate:"required"`
	StartupPositionOverrides           map[string]time.Time
	Ticker                             *time.Ticker
	PersistenceEnabled                 bool          `json:"persistence_enabled"`
	PersistencePath                    string        `json:"persistence_path"`
	LastModifiedDateCorrectionDuration time.Duration `json:"last_modified_date_correction_duration"`
	SkipDependencyCheck                bool          `json:"skip_dependency_check"`
}