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 |