public class BackLogLoader
extends java.lang.Object
Modifier and Type | Field | Description |
---|---|---|
protected java.util.Map<java.lang.String,java.util.concurrent.atomic.AtomicInteger> |
counters |
|
protected DBConnector |
DB |
Constructor | Description |
---|---|
BackLogLoader(DBConnector newDB) |
Modifier and Type | Method | Description |
---|---|---|
void |
addBackLogEntry(java.lang.String channelName,
int subNameField,
java.lang.String entry) |
|
protected java.lang.Integer |
checkSetBacklogTableVersion(java.lang.Integer setVersion) |
|
void |
checkUpgradeBacklogTable(ChannelsLibrary channels) |
|
void |
delBackLogEntry(java.lang.String channelName,
long timeStamp) |
|
protected java.util.List<Quad<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Integer>> |
enumBackLogEntries(java.lang.String channelName,
int firstIndex,
int numToReturn) |
|
java.util.List<Triad<java.lang.String,java.lang.Integer,java.lang.Long>> |
getBackLogEntries(java.lang.String channelName,
int subNameField,
int newestToSkip,
int numToReturn) |
|
int |
getBackLogPageEnd(java.lang.String channelName,
int subNameField) |
|
protected int |
getCounter(java.lang.String channelName,
boolean bump) |
|
int |
getLowestBackLogIndex(java.lang.String channelName,
int subNameField,
long afterDate) |
|
java.util.List<Triad<java.lang.String,java.lang.Integer,java.lang.Long>> |
searchBackLogEntries(java.lang.String channelName,
int subNameField,
java.lang.String search,
int numToReturn) |
|
void |
trimBackLogEntries(java.lang.String[] channels,
int maxMessages,
long oldestTime) |
|
protected void |
updateBackLogEntry(java.lang.String channelName,
int index,
long date,
int subNameField,
java.lang.String entry) |
protected DBConnector DB
protected java.util.Map<java.lang.String,java.util.concurrent.atomic.AtomicInteger> counters
public BackLogLoader(DBConnector newDB)
protected int getCounter(java.lang.String channelName, boolean bump)
protected java.lang.Integer checkSetBacklogTableVersion(java.lang.Integer setVersion)
protected void updateBackLogEntry(java.lang.String channelName, int index, long date, int subNameField, java.lang.String entry)
public void addBackLogEntry(java.lang.String channelName, int subNameField, java.lang.String entry)
public void delBackLogEntry(java.lang.String channelName, long timeStamp)
protected java.util.List<Quad<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Integer>> enumBackLogEntries(java.lang.String channelName, int firstIndex, int numToReturn)
public int getBackLogPageEnd(java.lang.String channelName, int subNameField)
public java.util.List<Triad<java.lang.String,java.lang.Integer,java.lang.Long>> searchBackLogEntries(java.lang.String channelName, int subNameField, java.lang.String search, int numToReturn)
public int getLowestBackLogIndex(java.lang.String channelName, int subNameField, long afterDate)
public java.util.List<Triad<java.lang.String,java.lang.Integer,java.lang.Long>> getBackLogEntries(java.lang.String channelName, int subNameField, int newestToSkip, int numToReturn)
public void trimBackLogEntries(java.lang.String[] channels, int maxMessages, long oldestTime)
public void checkUpgradeBacklogTable(ChannelsLibrary channels)