public class NewsPool
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private static java.util.Set<java.lang.String> |
categories |
private static java.lang.String[] |
category |
private static java.lang.String |
CATEGORY_BLACKLIST_ADD
a private blacklist entry was added
|
private static java.lang.String |
CATEGORY_BLACKLIST_DELETE
a private blacklist entry was deleted
|
private static java.lang.String |
CATEGORY_BLACKLIST_VOTE_ADD
a vote and comment on a private blacklist add
|
private static java.lang.String |
CATEGORY_BLACKLIST_VOTE_DEL
a vote and comment on a private blacklist delete
|
static java.lang.String |
CATEGORY_BLOG_ADD
a blog entry was added
|
private static java.lang.String |
CATEGORY_BLOG_DEL
a blog page das deleted
|
static java.lang.String |
CATEGORY_BOOKMARK_ADD
a bookmark was added/created
|
private static java.lang.String |
CATEGORY_BOOKMARK_DEL
a bookmark was deleted
|
private static java.lang.String |
CATEGORY_BOOKMARK_MOVE
a bookmark was moved
|
private static java.lang.String |
CATEGORY_BOOKMARK_VOTE_ADD
a vote and comment on a bookmark add
|
private static java.lang.String |
CATEGORY_BOOKMARK_VOTE_DEL
a vote and comment on a bookmark delete
|
private static java.lang.String |
CATEGORY_BOOKMARK_VOTE_MOVE
a vote and comment on a bookmark move
|
private static java.lang.String |
CATEGORY_CRAWL_COMMENT
a comment on a crawl with remote indexing
|
static java.lang.String |
CATEGORY_CRAWL_START
a crawl with remote indexing was started
|
private static java.lang.String |
CATEGORY_CRAWL_STOP
a crawl with remote indexing was stopped
|
private static java.lang.String |
CATEGORY_FILESHARE_ADD
a file was added to the file share
|
private static java.lang.String |
CATEGORY_FILESHARE_COMMENT
a comment to a file share entry
|
private static java.lang.String |
CATEGORY_FILESHARE_DEL
a file was added to the file share
|
static java.lang.String |
CATEGORY_PROFILE_BROADCAST
a peer starts up and renews its profile broadcast; used to implement supporter page
|
static java.lang.String |
CATEGORY_PROFILE_UPDATE
a profile entry was updated (implemented)
|
private static java.lang.String |
CATEGORY_PROFILE_VOTE_BAD
a peer has done something bad (i.e.
|
private static java.lang.String |
CATEGORY_PROFILE_VOTE_GOOD
a peer has done something good (i.e.
|
static java.lang.String |
CATEGORY_SURFTIPP_ADD
a surf tipp was added
|
static java.lang.String |
CATEGORY_SURFTIPP_VOTE_ADD
a vote and comment on a surf tipp
|
private static java.lang.String |
CATEGORY_WIKI_DEL
a wiki page das deleted
|
static java.lang.String |
CATEGORY_WIKI_UPDATE
a wiki page was updated
|
static int |
INCOMING_DB |
private NewsQueue |
incomingNews |
private int |
maxDistribution |
private static long |
MILLISECONDS_PER_DAY |
private static long |
MILLISECONDS_PER_HOUR |
private NewsDB |
newsDB |
static int |
OUTGOING_DB |
private NewsQueue |
outgoingNews |
static int |
PROCESSED_DB |
private NewsQueue |
processedNews |
static int |
PUBLISHED_DB |
private NewsQueue |
publishedNews |
Constructor and Description |
---|
NewsPool(java.io.File yacyDBPath,
boolean useTailCache,
boolean exceed134217727) |
Modifier and Type | Method and Description |
---|---|
int |
automaticProcess(SeedDB seedDB) |
private static boolean |
automaticProcessP(SeedDB seedDB,
NewsDB.Record record) |
void |
clear(int dbKey) |
void |
close() |
void |
enqueueIncomingNews(NewsDB.Record record) |
NewsDB.Record |
getByID(int dbKey,
java.lang.String id) |
NewsDB.Record |
getByOriginator(int dbKey,
java.lang.String category,
java.lang.String originatorHash) |
NewsDB.Record |
getSpecific(int dbKey,
java.lang.String category,
java.lang.String key,
java.lang.String value) |
void |
moveOff(int dbKey,
java.lang.String id) |
private boolean |
moveOff(NewsQueue fromqueue,
NewsQueue toqueue,
java.lang.String id) |
void |
moveOffAll(int dbKey) |
private static int |
moveOffAll(NewsQueue fromqueue,
NewsQueue toqueue) |
NewsDB.Record |
myPublication() |
NewsDB.Record |
parseExternal(java.lang.String external) |
private void |
publishMyNews(NewsDB.Record record) |
void |
publishMyNews(Seed mySeed,
java.lang.String category,
java.util.Map<java.lang.String,java.lang.String> attributes) |
void |
publishMyNews(Seed mySeed,
java.lang.String category,
java.util.Properties attributes) |
java.util.Iterator<NewsDB.Record> |
recordIterator(int dbKey) |
int |
size(int dbKey) |
private NewsQueue |
switchQueue(int dbKey) |
public static final int INCOMING_DB
public static final int PROCESSED_DB
public static final int OUTGOING_DB
public static final int PUBLISHED_DB
public static final java.lang.String CATEGORY_PROFILE_UPDATE
public static final java.lang.String CATEGORY_PROFILE_BROADCAST
private static final java.lang.String CATEGORY_PROFILE_VOTE_GOOD
private static final java.lang.String CATEGORY_PROFILE_VOTE_BAD
public static final java.lang.String CATEGORY_CRAWL_START
private static final java.lang.String CATEGORY_CRAWL_STOP
private static final java.lang.String CATEGORY_CRAWL_COMMENT
private static final java.lang.String CATEGORY_BLACKLIST_ADD
private static final java.lang.String CATEGORY_BLACKLIST_VOTE_ADD
private static final java.lang.String CATEGORY_BLACKLIST_DELETE
private static final java.lang.String CATEGORY_BLACKLIST_VOTE_DEL
private static final java.lang.String CATEGORY_FILESHARE_ADD
private static final java.lang.String CATEGORY_FILESHARE_DEL
private static final java.lang.String CATEGORY_FILESHARE_COMMENT
public static final java.lang.String CATEGORY_BOOKMARK_ADD
private static final java.lang.String CATEGORY_BOOKMARK_VOTE_ADD
private static final java.lang.String CATEGORY_BOOKMARK_MOVE
private static final java.lang.String CATEGORY_BOOKMARK_VOTE_MOVE
private static final java.lang.String CATEGORY_BOOKMARK_DEL
private static final java.lang.String CATEGORY_BOOKMARK_VOTE_DEL
public static final java.lang.String CATEGORY_SURFTIPP_ADD
public static final java.lang.String CATEGORY_SURFTIPP_VOTE_ADD
public static final java.lang.String CATEGORY_WIKI_UPDATE
private static final java.lang.String CATEGORY_WIKI_DEL
public static final java.lang.String CATEGORY_BLOG_ADD
private static final java.lang.String CATEGORY_BLOG_DEL
private static final java.lang.String[] category
private static final java.util.Set<java.lang.String> categories
private static final long MILLISECONDS_PER_HOUR
private static final long MILLISECONDS_PER_DAY
private final NewsDB newsDB
private final NewsQueue outgoingNews
private final NewsQueue publishedNews
private final NewsQueue incomingNews
private final NewsQueue processedNews
private final int maxDistribution
public NewsPool(java.io.File yacyDBPath, boolean useTailCache, boolean exceed134217727)
public void close()
public java.util.Iterator<NewsDB.Record> recordIterator(int dbKey)
public NewsDB.Record parseExternal(java.lang.String external)
public void publishMyNews(Seed mySeed, java.lang.String category, java.util.Map<java.lang.String,java.lang.String> attributes)
public void publishMyNews(Seed mySeed, java.lang.String category, java.util.Properties attributes)
private void publishMyNews(NewsDB.Record record)
public NewsDB.Record myPublication() throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
public void enqueueIncomingNews(NewsDB.Record record) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
public int size(int dbKey)
public int automaticProcess(SeedDB seedDB) throws java.io.IOException, java.lang.InterruptedException, SpaceExceededException
java.io.IOException
java.lang.InterruptedException
SpaceExceededException
private static boolean automaticProcessP(SeedDB seedDB, NewsDB.Record record)
public NewsDB.Record getSpecific(int dbKey, java.lang.String category, java.lang.String key, java.lang.String value)
public NewsDB.Record getByOriginator(int dbKey, java.lang.String category, java.lang.String originatorHash)
public NewsDB.Record getByID(int dbKey, java.lang.String id)
private NewsQueue switchQueue(int dbKey)
public void clear(int dbKey)
public void moveOff(int dbKey, java.lang.String id) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
private boolean moveOff(NewsQueue fromqueue, NewsQueue toqueue, java.lang.String id) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
public void moveOffAll(int dbKey) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException
private static int moveOffAll(NewsQueue fromqueue, NewsQueue toqueue) throws java.io.IOException, SpaceExceededException
java.io.IOException
SpaceExceededException