Versions in this module Expand all Collapse all v1 v1.8.0 Jul 11, 2017 Changes in this version + const EnvFeedThreshold v1.7.0 Jun 22, 2017 Changes in this version + var FeedThreshold = defaultFeedThreshold + func ReadFeedThresholdFromEnv() + func RetrieveLastFeed(db *sql.DB) (string, error) + func RetrieveNextFeed(db *sql.DB, feedId string) (sql.NullString, error) + func RetrievePreviousFeed(db *sql.DB, id string) (sql.NullString, error) + type AtomDataProcessor struct + func NewAtomDataProcessor(db *sql.DB) *AtomDataProcessor + func (adp *AtomDataProcessor) ProcessMessage(msg string) error + type TimestampedEvent struct + Timestamp time.Time + func RetrieveArchive(db *sql.DB, feedid string) ([]TimestampedEvent, error) + func RetrieveEvent(db *sql.DB, aggID string, version int) (TimestampedEvent, error) + func RetrieveRecent(db *sql.DB) ([]TimestampedEvent, error)
Go to main page