Struct StoryIndex

pub struct StoryIndex { /* private fields */ }

Implementations

impl StoryIndex

pub fn new(location: PersistLocation) -> Result<Self, PersistError>

pub fn shards(&self) -> ShardRange

pub fn with_scrapes<F: FnOnce(&ScrapeStore) -> T, T>(&self, f: F) -> T

Borrow the ScrapeStore for a period of time.

Trait Implementations

impl Storage for StoryIndex

fn most_recent_story(&self) -> Result<StoryDate, PersistError>

Returns the most recent story date.

fn shard_range(&self) -> Result<ShardRange, PersistError>

Returns the range of shards for this index.

fn story_count(&self) -> Result<StorageSummary, PersistError>

Count the docs in this index, breaking it out by index segment.

fn fetch_count( &self, query: StoryQuery, max: usize, ) -> Result<usize, PersistError>

Count the docs matching the query, at most max.

fn fetch_detail_one( &self, query: StoryQuery, ) -> Result<Option<HashMap<String, Vec<String>>>, PersistError>

Fetches the index-specific story details for a single story.

fn fetch<S: StoryScrapePayload>( &self, query: StoryQuery, max: usize, ) -> Result<Vec<Story<S>>, PersistError>

where Self: StorageFetch<S>,

Fetch a list of stories with the specified payload type.

fn fetch_one<S: StoryScrapePayload>( &self, query: StoryQuery, ) -> Result<Option<Story<S>>, PersistError>

where Self: StorageFetch<S>,

Fetch a single story with the specified payload type.

impl StorageFetch<Shard> for StoryIndex

fn fetch_type( &self, query: StoryQuery, max: usize, ) -> Result<Vec<Story<Shard>>, PersistError>

impl StorageFetch<TypedScrape> for StoryIndex

fn fetch_type( &self, query: StoryQuery, max: usize, ) -> Result<Vec<Story<TypedScrape>>, PersistError>

impl StorageWriter for StoryIndex

fn insert_scrapes<I: IntoIterator<Item = TypedScrape>>( &mut self, eval: &StoryEvaluator, scrapes: I, ) -> Result<Vec<ScrapePersistResult>, PersistError>

Inserts individual scrapes, assuming that there is no story overlap in the input scrapes. If there are matching scrapes in stories in the index, those stories are updated with the new scrapes.

fn insert_scrape_collections<I: IntoIterator<Item = ScrapeCollection>>( &mut self, eval: &StoryEvaluator, scrape_collections: I, ) -> Result<Vec<ScrapePersistResult>, PersistError>

Inserts a set of pre-existing scrape collections, assuming that these stories do not already exist in the index. This is the fastest way to populate an index.

fn reinsert_stories<I: IntoIterator<Item = StoryIdentifier>>( &mut self, eval: &StoryEvaluator, stories: I, ) -> Result<Vec<ScrapePersistResult>, PersistError>

Re-insert a set of stories, assuming that they are in the index. This must only be used with a story sourced from this index. Note that the