|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.mongodb.DBTCPConnector
public class DBTCPConnector
Constructor Summary | |
---|---|
DBTCPConnector(Mongo m,
java.util.List<ServerAddress> all)
|
|
DBTCPConnector(Mongo m,
ServerAddress... all)
|
|
DBTCPConnector(Mongo m,
ServerAddress addr)
|
Method Summary | |
---|---|
com.mongodb.Response |
call(DB db,
DBCollection coll,
com.mongodb.OutMessage m)
does a read operation on the database |
com.mongodb.Response |
call(DB db,
DBCollection coll,
com.mongodb.OutMessage m,
ServerAddress hostNeeded)
does a read operation on the database |
com.mongodb.Response |
call(DB db,
DBCollection coll,
com.mongodb.OutMessage m,
ServerAddress hostNeeded,
int retries)
does a read operation on the database |
void |
close()
|
java.lang.String |
debugString()
|
ServerAddress |
getAddress()
|
java.util.List<ServerAddress> |
getAllAddress()
Gets the list of seed server addresses |
java.lang.String |
getConnectPoint()
|
DBPortPool |
getDBPortPool(ServerAddress addr)
Gets the DBPortPool associated with a ServerAddress. |
int |
getMaxBsonObjectSize()
Gets the maximum size for a BSON object supported by the current master server. |
ReplicaSetStatus |
getReplicaSetStatus()
|
java.util.List<ServerAddress> |
getServerAddressList()
Gets the list of server addresses currently seen by the connector. |
boolean |
isOpen()
returns true if the connector is in a usable state |
void |
requestDone()
End the current "request", if this thread is in one. |
void |
requestEnsureConnection()
Ensures that a connection exists for the "consistent request" |
void |
requestStart()
Start a "request". |
WriteResult |
say(DB db,
com.mongodb.OutMessage m,
WriteConcern concern)
does a write operation |
WriteResult |
say(DB db,
com.mongodb.OutMessage m,
WriteConcern concern,
ServerAddress hostNeeded)
does a write operation |
void |
start()
|
void |
updatePortPool(ServerAddress addr)
Assigns a new DBPortPool for a given ServerAddress. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DBTCPConnector(Mongo m, ServerAddress addr) throws MongoException
MongoException
public DBTCPConnector(Mongo m, ServerAddress... all) throws MongoException
MongoException
public DBTCPConnector(Mongo m, java.util.List<ServerAddress> all) throws MongoException
MongoException
Method Detail |
---|
public void start()
public void requestStart()
requestStart
in interface DBConnector
public void requestDone()
requestDone
in interface DBConnector
public void requestEnsureConnection()
DBConnector
requestEnsureConnection
in interface DBConnector
public WriteResult say(DB db, com.mongodb.OutMessage m, WriteConcern concern) throws MongoException
DBConnector
say
in interface DBConnector
db
- the databasem
- the request messageconcern
- the write concern
MongoException
public WriteResult say(DB db, com.mongodb.OutMessage m, WriteConcern concern, ServerAddress hostNeeded) throws MongoException
DBConnector
say
in interface DBConnector
db
- the databasem
- the request messageconcern
- the write concernhostNeeded
- specific server to connect to
MongoException
public com.mongodb.Response call(DB db, DBCollection coll, com.mongodb.OutMessage m) throws MongoException
DBConnector
call
in interface DBConnector
db
- the databasecoll
- the collectionm
- the request message
MongoException
public com.mongodb.Response call(DB db, DBCollection coll, com.mongodb.OutMessage m, ServerAddress hostNeeded) throws MongoException
DBConnector
call
in interface DBConnector
db
- the databasecoll
- the collectionm
- the request messagehostNeeded
- specific server to connect to
MongoException
public com.mongodb.Response call(DB db, DBCollection coll, com.mongodb.OutMessage m, ServerAddress hostNeeded, int retries) throws MongoException
DBConnector
call
in interface DBConnector
db
- the databasecoll
- the collectionm
- the request messagehostNeeded
- specific server to connect toretries
- number of retries in case of error
MongoException
public ServerAddress getAddress()
public java.util.List<ServerAddress> getAllAddress()
public java.util.List<ServerAddress> getServerAddressList()
public ReplicaSetStatus getReplicaSetStatus()
public java.lang.String getConnectPoint()
public java.lang.String debugString()
public void close()
public void updatePortPool(ServerAddress addr)
addr
- public DBPortPool getDBPortPool(ServerAddress addr)
addr
-
public boolean isOpen()
DBConnector
isOpen
in interface DBConnector
public int getMaxBsonObjectSize()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |