OpenQuizz
Une application de gestion des contenus pédagogiques
_BulkWriteContext Class Reference
Inheritance diagram for _BulkWriteContext:
Collaboration diagram for _BulkWriteContext:

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
 

Detailed Description

A wrapper around SocketInfo for use with write splitting functions.

Constructor & Destructor Documentation

◆ __init__()

def __init__ (   self,
  database_name,
  command,
  sock_info,
  operation_id,
  listeners,
  session,
  op_type,
  codec 
)

Member Function Documentation

◆ check_keys()

def check_keys (   self)
Should we check keys for this operation type?

◆ execute()

def execute (   self,
  docs,
  client 
)

Reimplemented in _EncryptedBulkWriteContext.

◆ execute_unack()

def execute_unack (   self,
  docs,
  client 
)

Reimplemented in _EncryptedBulkWriteContext.

◆ legacy_bulk_insert()

def legacy_bulk_insert (   self,
  request_id,
  msg,
  max_doc_size,
  acknowledged,
  docs,
  compress 
)

◆ legacy_write()

def legacy_write (   self,
  request_id,
  msg,
  max_doc_size,
  acknowledged,
  docs 
)
A proxy for SocketInfo.legacy_write that handles event publishing.

◆ max_bson_size()

def max_bson_size (   self)
A proxy for SockInfo.max_bson_size.

◆ max_message_size()

def max_message_size (   self)
A proxy for SockInfo.max_message_size.

◆ max_split_size()

def max_split_size (   self)
The maximum size of a BSON command before batch splitting.

Reimplemented in _EncryptedBulkWriteContext.

◆ max_write_batch_size()

def max_write_batch_size (   self)
A proxy for SockInfo.max_write_batch_size.

◆ write_command()

def write_command (   self,
  request_id,
  msg,
  docs 
)
A proxy for SocketInfo.write_command that handles event publishing.

Field Documentation

◆ codec

codec

◆ command

command

◆ compress

compress

◆ db_name

db_name

◆ field

field

◆ listeners

listeners

◆ name

name

◆ op_id

op_id

◆ op_type

op_type

◆ publish

publish

◆ session

session

◆ sock_info

sock_info

◆ start_time

start_time

The documentation for this class was generated from the following file: