MongoFeedStore

Instance Constructors

new MongoFeedStore(feedName: String, title: Option[String] = None, feedEntriesCollectionName: Option[String] = None, feedInfoCollectionName: String, ser: (E) ⇒ DBObject, deser: (DBObject) ⇒ E, url: Url)(implicit context: MongoContext)

feedEntriesCollectionName
name of the entriesCollection that contains the feed entries
feedInfoCollectionName
name of the entriesCollection that contains the feed info of all the feeds
ser
function to serialize an element to a DBObject
deser
function to deserialize a DBObject to an element
url
the base Url
context
a implicit MongoContext implementation

Type Members

case class FeedEntry(sequenceNr: Long, entry: Entry[E]) extends Product with Serializable

Attributes
protected
Definition Classes
AbstractFeedStore

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def close(): Unit

This method is called when the be.wegenenverkeer.atomium.server.FeedService is stopped.
This method is called when the be.wegenenverkeer.atomium.server.FeedService is stopped.

Definition Classes
FeedStore
def dbObject2FeedEntry(dbo: DBObject): FeedEntry

Attributes
protected
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def feedEntry2DbObject(uuid: String, e: E): MongoDBObject

Attributes
protected
def feedEntry2DbObject(e: E): MongoDBObject

Attributes
protected
def feedLink(startId: Long, count: Int, forward: Boolean): Url

Creates a link to a feed page.
Creates a link to a feed page.
startId
the starting entry's id (non inclusive)
count
the number of entries in the page
forward
if true navigate to 'previous' elements in feed (towards head of feed) else navigate to 'next' elements in feed (towards last page of feed)
returns
the URL

Attributes
protected
Definition Classes
AbstractFeedStore
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def generateEntryID(): String

Attributes
protected
Definition Classes
AbstractFeedStore
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getFeed(start: Long, pageSize: Int, forward: Boolean)(implicit context: MongoContext): Option[Feed[E]]

Retrieves a page of the feed.
Retrieves a page of the feed.
start
the starting entry (exclusive), should not be returned in the feed page
pageSize
the number of entries
forward
if true navigate to 'previous' elements in feed (towards head of feed) else navigate to 'next' elements in feed (towards last page of feed)
returns
the feed page or None if the page is not found

Definition Classes
AbstractFeedStore → FeedStore
def getFeedEntries(start: Long, count: Int, ascending: Boolean)(implicit context: MongoContext): List[FeedEntry]

Retrieves entries with their sequence numbers from the feed
Retrieves entries with their sequence numbers from the feed
start
the starting entry (inclusive), MUST be returned in the entries
count
the number of entries to return
ascending
if true return entries with sequence numbers >= start in ascending order else return entries with sequence numbers <= start in descending order
returns
the corresponding entries sorted accordingly

Definition Classes
MongoFeedStore → AbstractFeedStore
def getHeadOfFeed(pageSize: Int)(implicit context: MongoContext): Option[Feed[E]]

Retrieves the head of the feed.
Retrieves the head of the feed. This is the first page containing the most recent entries
pageSize
the maximum number of feed entries to return. The page could contain less entries
returns
the head of the feed

Definition Classes
AbstractFeedStore → FeedStore
def getMostRecentFeedEntries(count: Int)(implicit context: MongoContext): List[FeedEntry]

retrieves the most recent entries from the feedstore sorted in descending order
retrieves the most recent entries from the feedstore sorted in descending order
count
the amount of recent entries to return
returns
a list containing tuples of a sequence number and its corresponding entry and sorted by descending sequence number

Definition Classes
MongoFeedStore → AbstractFeedStore
def getNextLink(id: Long, count: Int, next: Option[Long]): Option[Link]

Attributes
protected
Definition Classes
AbstractFeedStore
def getNextSequence: Long

Attributes
protected
def getNumberOfEntriesLowerThan(sequenceNr: Long, inclusive: Boolean = true)(implicit context: MongoContext): Long

sequenceNr
sequence number to match
inclusive
if true include the specified sequence number
returns
the number of entries in the feed with sequence number equal or lower than specified

Definition Classes
MongoFeedStore → AbstractFeedStore
def getPreviousLink(id: Long, count: Int, previous: Option[Long]): Option[Link]

Attributes
protected
Definition Classes
AbstractFeedStore
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def link(l: String, start: Long, pageSize: Int, forward: Boolean): Link

Attributes
protected
Definition Classes
AbstractFeedStore
def maxId(implicit context: MongoContext): Long

returns
the maximum sequence number used in this feed or minId if feed is empty

Definition Classes
MongoFeedStore → AbstractFeedStore
def minId(implicit context: MongoContext): Long

returns
one less than the minimum sequence number used in this feed

Definition Classes
MongoFeedStore → AbstractFeedStore
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def open(): Unit

This method is called when the be.wegenenverkeer.atomium.server.FeedService is started.
This method is called when the be.wegenenverkeer.atomium.server.FeedService is started. This can be used as a hook (to check consistency, for example)

Definition Classes
FeedStore
def push(uuid: String, entry: E)(implicit context: MongoContext): Unit

Definition Classes
MongoFeedStore → FeedStore
def push(entries: Iterable[E])(implicit context: MongoContext): Unit

push a list of entries to the feed
push a list of entries to the feed
entries
the entries to push to the feed

Definition Classes
MongoFeedStore → FeedStore
def push(entry: E)(implicit context: MongoContext): Unit

push a single entry to the feed
push a single entry to the feed
entry
the entry to push to the feed

Definition Classes
FeedStore
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: object MongoFeedStore | package mongo

class MongoFeedStore[E] extends AbstractFeedStore[E, MongoContext]

Instance Constructors

new MongoFeedStore(feedName: String, title: Option[String] = None, feedEntriesCollectionName: Option[String] = None, feedInfoCollectionName: String, ser: (E) ⇒ DBObject, deser: (DBObject) ⇒ E, url: Url)(implicit context: MongoContext)

Type Members

case class FeedEntry(sequenceNr: Long, entry: Entry[E]) extends Product with Serializable

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def close(): Unit

def dbObject2FeedEntry(dbo: DBObject): FeedEntry

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def feedEntry2DbObject(uuid: String, e: E): MongoDBObject

def feedEntry2DbObject(e: E): MongoDBObject

def feedLink(startId: Long, count: Int, forward: Boolean): Url

def finalize(): Unit

def generateEntryID(): String

final def getClass(): Class[_]

def getFeed(start: Long, pageSize: Int, forward: Boolean)(implicit context: MongoContext): Option[Feed[E]]

def getFeedEntries(start: Long, count: Int, ascending: Boolean)(implicit context: MongoContext): List[FeedEntry]

def getHeadOfFeed(pageSize: Int)(implicit context: MongoContext): Option[Feed[E]]

def getMostRecentFeedEntries(count: Int)(implicit context: MongoContext): List[FeedEntry]

def getNextLink(id: Long, count: Int, next: Option[Long]): Option[Link]

def getNextSequence: Long

def getNumberOfEntriesLowerThan(sequenceNr: Long, inclusive: Boolean = true)(implicit context: MongoContext): Long

def getPreviousLink(id: Long, count: Int, previous: Option[Long]): Option[Link]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def link(l: String, start: Long, pageSize: Int, forward: Boolean): Link

def maxId(implicit context: MongoContext): Long

def minId(implicit context: MongoContext): Long

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def open(): Unit

def push(uuid: String, entry: E)(implicit context: MongoContext): Unit

def push(entries: Iterable[E])(implicit context: MongoContext): Unit

def push(entry: E)(implicit context: MongoContext): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from AbstractFeedStore[E, MongoContext]

Inherited from FeedStore[E, MongoContext]

Inherited from AnyRef

Inherited from Any

Ungrouped