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 |