#include <oplogreader.h>
Public Member Functions | |
bool | awaitCapable () |
DBClientConnection * | conn () |
bool | connect (string hostname) |
BSONObj | findOne (const char *ns, const Query &q) |
BSONObj | getLastOp (const char *ns) |
bool | haveCursor () |
bool | more () |
bool | moreInCurrentBatch () |
BSONObj | next () |
BSONObj | nextSafe () |
OplogReader () | |
void | peek (vector< BSONObj > &v, int n) |
void | putBack (BSONObj op) |
void | query (const char *ns, const BSONObj &query) |
void | resetConnection () |
void | resetCursor () |
void | tailCheck () |
void | tailingQuery (const char *ns, const BSONObj &query) |
void | tailingQueryGTE (const char *ns, OpTime t) |
~OplogReader () | |
Private Attributes | |
auto_ptr< DBClientConnection > | _conn |
auto_ptr< DBClientCursor > | cursor |
Definition at line 14 of file oplogreader.h.
mongo::OplogReader::OplogReader | ( | ) | [inline] |
Definition at line 19 of file oplogreader.h.
mongo::OplogReader::~OplogReader | ( | ) | [inline] |
Definition at line 21 of file oplogreader.h.
bool mongo::OplogReader::awaitCapable | ( | ) | [inline] |
Definition at line 85 of file oplogreader.h.
DBClientConnection* mongo::OplogReader::conn | ( | ) | [inline] |
Definition at line 31 of file oplogreader.h.
bool mongo::OplogReader::connect | ( | string | hostname | ) |
Definition at line 32 of file oplogreader.h.
BSONObj mongo::OplogReader::getLastOp | ( | const char * | ns | ) | [inline] |
Definition at line 36 of file oplogreader.h.
bool mongo::OplogReader::haveCursor | ( | ) | [inline] |
Definition at line 50 of file oplogreader.h.
bool mongo::OplogReader::more | ( | ) | [inline] |
Definition at line 75 of file oplogreader.h.
bool mongo::OplogReader::moreInCurrentBatch | ( | ) | [inline] |
Definition at line 79 of file oplogreader.h.
BSONObj mongo::OplogReader::next | ( | ) | [inline] |
Definition at line 96 of file oplogreader.h.
BSONObj mongo::OplogReader::nextSafe | ( | ) | [inline] |
Definition at line 94 of file oplogreader.h.
void mongo::OplogReader::peek | ( | vector< BSONObj > & | v, | |
int | n | |||
) | [inline] |
Definition at line 89 of file oplogreader.h.
void mongo::OplogReader::putBack | ( | BSONObj | op | ) | [inline] |
Definition at line 100 of file oplogreader.h.
void mongo::OplogReader::query | ( | const char * | ns, | |
const BSONObj & | query | |||
) | [inline] |
Definition at line 52 of file oplogreader.h.
void mongo::OplogReader::resetConnection | ( | ) | [inline] |
Definition at line 27 of file oplogreader.h.
void mongo::OplogReader::resetCursor | ( | ) | [inline] |
Definition at line 24 of file oplogreader.h.
void mongo::OplogReader::tailCheck | ( | ) | [inline] |
Definition at line 43 of file oplogreader.h.
void mongo::OplogReader::tailingQuery | ( | const char * | ns, | |
const BSONObj & | query | |||
) | [inline] |
Definition at line 57 of file oplogreader.h.
void mongo::OplogReader::tailingQueryGTE | ( | const char * | ns, | |
OpTime | t | |||
) | [inline] |
Definition at line 67 of file oplogreader.h.
auto_ptr<DBClientConnection> mongo::OplogReader::_conn [private] |
Definition at line 15 of file oplogreader.h.
auto_ptr<DBClientCursor> mongo::OplogReader::cursor [private] |
Definition at line 16 of file oplogreader.h.