Function make_stash_message

gunicorn/dirty/protocol.py:762–790

Build a stash operation message dict. Args: request_id: Unique request identifier (int or str) op: Stash operation code (STASH_OP_*) table: Table name key: Optional key for put/get/delete operations value: Optional value for put operation pat

(request_id, op: int, table: str,
                       key=None, value=None, pattern=None)

def make_stash_message(request_id, op: int, table: str,
                       key=None, value=None, pattern=None) -> dict:
    """
    Build a stash operation message dict.

    Args:
        request_id: Unique request identifier (int or str)
        op: Stash operation code (STASH_OP_*)
        table: Table name
        key: Optional key for put/get/delete operations
        value: Optional value for put operation
        pattern: Optional pattern for keys operation

    Returns:
        dict: Stash message dict
    """
    msg = {
        "type": DirtyProtocol.MSG_TYPE_STASH,
        "id": request_id,
        "op": op,
        "table": table,
    }
    if key is not None:
        msg["key"] = key
    if value is not None:
        msg["value"] = value
    if pattern is not None:
        msg["pattern"] = pattern
    return msg


def make_manage_message(request_id, op: int, count: int = 1) -> dict: