this is a cursor that works over a set of servers can be used in serial/paralellel as controlled by sub classes More...
#include <parallel.h>
Public Member Functions | |
| ClusteredCursor (QueryMessage &q) | |
| ClusteredCursor (const string &ns, const BSONObj &q, int options=0, const BSONObj &fields=BSONObj()) | |
| void | init () |
| call before using | |
| virtual bool | more ()=0 |
| virtual BSONObj | next ()=0 |
| virtual string | type () const =0 |
| virtual BSONObj | explain () |
Static Public Member Functions | |
| static BSONObj | concatQuery (const BSONObj &query, const BSONObj &extraFilter) |
Protected Member Functions | |
| virtual void | _init ()=0 |
| auto_ptr< DBClientCursor > | query (const string &server, int num=0, BSONObj extraFilter=BSONObj(), int skipLeft=0, bool lazy=false) |
| BSONObj | explain (const string &server, BSONObj extraFilter=BSONObj()) |
| void | _checkCursor (DBClientCursor *cursor) |
| checks the cursor for any errors will throw an exceptionif an error is encountered | |
| virtual void | _explain (map< string, list< BSONObj > > &out)=0 |
Static Protected Member Functions | |
| static BSONObj | _concatFilter (const BSONObj &filter, const BSONObj &extraFilter) |
Protected Attributes | |
| string | _ns |
| BSONObj | _query |
| int | _options |
| BSONObj | _fields |
| int | _batchSize |
| bool | _didInit |
| bool | _done |
this is a cursor that works over a set of servers can be used in serial/paralellel as controlled by sub classes
1.6.3