Versions in this module Expand all Collapse all v1 v1.0.0 Jan 5, 2017 Changes in this version + var FeedThreshold = defaultFeedThreshold + func NewESAtomPubProcessor() orapub.EventProcessor + 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 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