|
OpenQuizz
Une application de gestion des contenus pédagogiques
|


Public Member Functions | |
| def | __init__ (self, sock, pool, address, id) |
| def | ismaster (self, all_credentials=None) |
| def | command (self, dbname, spec, slave_ok=False, read_preference=ReadPreference.PRIMARY, codec_options=DEFAULT_CODEC_OPTIONS, check=True, allowable_errors=None, check_keys=False, read_concern=None, write_concern=None, parse_write_concern_error=False, collation=None, session=None, client=None, retryable_write=False, publish_events=True, user_fields=None, exhaust_allowed=False) |
| def | send_message (self, message, max_doc_size) |
| def | receive_message (self, request_id) |
| def | legacy_write (self, request_id, msg, max_doc_size, with_last_error) |
| def | write_command (self, request_id, msg) |
| def | check_auth (self, all_credentials) |
| def | authenticate (self, credentials) |
| def | validate_session (self, client, session) |
| def | close_socket (self, reason) |
| def | socket_closed (self) |
| def | send_cluster_time (self, command, session, client) |
| def | update_last_checkin_time (self) |
| def | update_is_writable (self, is_writable) |
| def | idle_time_seconds (self) |
| def | __eq__ (self, other) |
| def | __ne__ (self, other) |
| def | __hash__ (self) |
| def | __repr__ (self) |
Store a socket with some metadata. :Parameters: - `sock`: a raw socket object - `pool`: a Pool instance - `address`: the server's (host, port) - `id`: the id of this socket in it's pool
| def __init__ | ( | self, | |
| sock, | |||
| pool, | |||
| address, | |||
| id | |||
| ) |
| def __eq__ | ( | self, | |
| other | |||
| ) |
| def __hash__ | ( | self | ) |
| def __ne__ | ( | self, | |
| other | |||
| ) |
| def __repr__ | ( | self | ) |
| def authenticate | ( | self, | |
| credentials | |||
| ) |
Log in to the server and store these credentials in `authset`. Can raise ConnectionFailure or OperationFailure. :Parameters: - `credentials`: A MongoCredential.
| def check_auth | ( | self, | |
| all_credentials | |||
| ) |
Update this socket's authentication. Log in or out to bring this socket's credentials up to date with those provided. Can raise ConnectionFailure or OperationFailure. :Parameters: - `all_credentials`: dict, maps auth source to MongoCredential.
| def close_socket | ( | self, | |
| reason | |||
| ) |
Close this connection with a reason.
| def command | ( | self, | |
| dbname, | |||
| spec, | |||
slave_ok = False, |
|||
read_preference = ReadPreference.PRIMARY, |
|||
codec_options = DEFAULT_CODEC_OPTIONS, |
|||
check = True, |
|||
allowable_errors = None, |
|||
check_keys = False, |
|||
read_concern = None, |
|||
write_concern = None, |
|||
parse_write_concern_error = False, |
|||
collation = None, |
|||
session = None, |
|||
client = None, |
|||
retryable_write = False, |
|||
publish_events = True, |
|||
user_fields = None, |
|||
exhaust_allowed = False |
|||
| ) |
Execute a command or raise an error.
:Parameters:
- `dbname`: name of the database on which to run the command
- `spec`: a command document as a dict, SON, or mapping object
- `slave_ok`: whether to set the SlaveOkay wire protocol bit
- `read_preference`: a read preference
- `codec_options`: a CodecOptions instance
- `check`: raise OperationFailure if there are errors
- `allowable_errors`: errors to ignore if `check` is True
- `check_keys`: if True, check `spec` for invalid keys
- `read_concern`: The read concern for this command.
- `write_concern`: The write concern for this command.
- `parse_write_concern_error`: Whether to parse the
``writeConcernError`` field in the command response.
- `collation`: The collation for this command.
- `session`: optional ClientSession instance.
- `client`: optional MongoClient for gossipping $clusterTime.
- `retryable_write`: True if this command is a retryable write.
- `publish_events`: Should we publish events for this command?
- `user_fields` (optional): Response fields that should be decoded
using the TypeDecoders from codec_options, passed to
bson._decode_all_selective.
| def idle_time_seconds | ( | self | ) |
Seconds since this socket was last checked into its pool.
| def ismaster | ( | self, | |
all_credentials = None |
|||
| ) |
| def legacy_write | ( | self, | |
| request_id, | |||
| msg, | |||
| max_doc_size, | |||
| with_last_error | |||
| ) |
Send OP_INSERT, etc., optionally returning response as a dict.
Can raise ConnectionFailure or OperationFailure.
:Parameters:
- `request_id`: an int.
- `msg`: bytes, an OP_INSERT, OP_UPDATE, or OP_DELETE message,
perhaps with a getlasterror command appended.
- `max_doc_size`: size in bytes of the largest document in `msg`.
- `with_last_error`: True if a getlasterror command is appended.
| def receive_message | ( | self, | |
| request_id | |||
| ) |
Receive a raw BSON message or raise ConnectionFailure. If any exception is raised, the socket is closed.
| def send_cluster_time | ( | self, | |
| command, | |||
| session, | |||
| client | |||
| ) |
Add cluster time for MongoDB >= 3.6.
| def send_message | ( | self, | |
| message, | |||
| max_doc_size | |||
| ) |
Send a raw BSON message or raise ConnectionFailure. If a network exception is raised, the socket is closed.
| def socket_closed | ( | self | ) |
Return True if we know socket has been closed, False otherwise.
| def update_is_writable | ( | self, | |
| is_writable | |||
| ) |
| def update_last_checkin_time | ( | self | ) |
| def validate_session | ( | self, | |
| client, | |||
| session | |||
| ) |
Validate this session before use with client. Raises error if this session is logged in as a different user or the client is not the one that created the session.
| def write_command | ( | self, | |
| request_id, | |||
| msg | |||
| ) |
Send "insert" etc. command, returning response as a dict. Can raise ConnectionFailure or OperationFailure. :Parameters: - `request_id`: an int. - `msg`: bytes, the command message.
| address |
| auth_ctx |
| authset |
| cancel_context |
| closed |
| compression_context |
| compression_settings |
| enabled_for_cmap |
| generation |
| id |
| is_mongos |
| is_writable |
| last_checkin_time |
| listeners |
| max_bson_size |
| max_message_size |
| max_wire_version |
| max_write_batch_size |
| more_to_come |
| negotiated_mechanisms |
| op_msg_enabled |
| opts |
| performed_handshake |
| ready |
| sock |
| socket_checker |
| supports_sessions |