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


Public Member Functions | |
| def | __init__ (self, database_name, command, sock_info, operation_id, listeners, session, op_type, codec) |
| def | execute (self, docs, client) |
| def | execute_unack (self, docs, client) |
| def | check_keys (self) |
| def | max_bson_size (self) |
| def | max_message_size (self) |
| def | max_write_batch_size (self) |
| def | max_split_size (self) |
| def | legacy_bulk_insert (self, request_id, msg, max_doc_size, acknowledged, docs, compress) |
| def | legacy_write (self, request_id, msg, max_doc_size, acknowledged, docs) |
| def | write_command (self, request_id, msg, docs) |
Data Fields | |
| db_name | |
| command | |
| sock_info | |
| op_id | |
| listeners | |
| publish | |
| name | |
| field | |
| start_time | |
| session | |
| compress | |
| op_type | |
| codec | |
A wrapper around SocketInfo for use with write splitting functions.
| def __init__ | ( | self, | |
| database_name, | |||
| command, | |||
| sock_info, | |||
| operation_id, | |||
| listeners, | |||
| session, | |||
| op_type, | |||
| codec | |||
| ) |
| def check_keys | ( | self | ) |
Should we check keys for this operation type?
| def execute | ( | self, | |
| docs, | |||
| client | |||
| ) |
Reimplemented in _EncryptedBulkWriteContext.
| def execute_unack | ( | self, | |
| docs, | |||
| client | |||
| ) |
Reimplemented in _EncryptedBulkWriteContext.
| def legacy_bulk_insert | ( | self, | |
| request_id, | |||
| msg, | |||
| max_doc_size, | |||
| acknowledged, | |||
| docs, | |||
| compress | |||
| ) |
| def legacy_write | ( | self, | |
| request_id, | |||
| msg, | |||
| max_doc_size, | |||
| acknowledged, | |||
| docs | |||
| ) |
A proxy for SocketInfo.legacy_write that handles event publishing.
| def max_bson_size | ( | self | ) |
A proxy for SockInfo.max_bson_size.
| def max_message_size | ( | self | ) |
A proxy for SockInfo.max_message_size.
| def max_split_size | ( | self | ) |
The maximum size of a BSON command before batch splitting.
Reimplemented in _EncryptedBulkWriteContext.
| def max_write_batch_size | ( | self | ) |
A proxy for SockInfo.max_write_batch_size.
| def write_command | ( | self, | |
| request_id, | |||
| msg, | |||
| docs | |||
| ) |
A proxy for SocketInfo.write_command that handles event publishing.
| codec |
| command |
| compress |
| db_name |
| field |
| listeners |
| name |
| op_id |
| op_type |
| publish |
| session |
| sock_info |
| start_time |