Method
xadd
(
self: SyncClientProtocol,
name: KeyT,
fields: Dict[FieldT, EncodableT],
id: StreamIdT = "*",
maxlen: int | None = None,
approximate: bool = True,
nomkstream: bool = False,
minid: StreamIdT | None = None,
limit: int | None = None,
ref_policy: Literal["KEEPREF", "DELREF", "ACKED"] | None = None,
idmpauto: str | None = None,
idmp: tuple[str, bytes] | None = None,
)
Source from the content-addressed store, hash-verified
| 6722 | |
| 6723 | @overload |
| 6724 | def xadd( |
| 6725 | self: SyncClientProtocol, |
| 6726 | name: KeyT, |
| 6727 | fields: Dict[FieldT, EncodableT], |
| 6728 | id: StreamIdT = "*", |
| 6729 | maxlen: int | None = None, |
| 6730 | approximate: bool = True, |
| 6731 | nomkstream: bool = False, |
| 6732 | minid: StreamIdT | None = None, |
| 6733 | limit: int | None = None, |
| 6734 | ref_policy: Literal["KEEPREF", "DELREF", "ACKED"] | None = None, |
| 6735 | idmpauto: str | None = None, |
| 6736 | idmp: tuple[str, bytes] | None = None, |
| 6737 | ) -> bytes | str: ... |
| 6738 | |
| 6739 | @overload |
| 6740 | def xadd( |