Skip to content

MockConfluentMessage

faststream.confluent.testing.MockConfluentMessage #

MockConfluentMessage(
    raw_msg: bytes | None,
    topic: str,
    key: bytes | str,
    headers: list[tuple[str, bytes]],
    offset: int,
    partition: int,
    timestamp_type: int,
    timestamp_ms: int,
    error: str | None = None,
)
Source code in faststream/confluent/testing.py 
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
def __init__(
    self,
    raw_msg: bytes | None,
    topic: str,
    key: bytes | str,
    headers: list[tuple[str, bytes]],
    offset: int,
    partition: int,
    timestamp_type: int,
    timestamp_ms: int,
    error: str | None = None,
) -> None:
    self._raw_msg = raw_msg
    self._topic = topic

    if isinstance(key, str):
        self._key = key.encode()
    else:
        self._key = key

    self._headers = headers
    self._error = error
    self._offset = offset
    self._partition = partition
    self._timestamp = (timestamp_type, timestamp_ms)

len #

len() -> int
Source code in faststream/confluent/testing.py 
315
316
def len(self) -> int:
    return 0 if self._raw_msg is None else len(self._raw_msg)

error #

error() -> str | None
Source code in faststream/confluent/testing.py 
318
319
def error(self) -> str | None:
    return self._error

headers #

headers() -> list[tuple[str, bytes]]
Source code in faststream/confluent/testing.py 
321
322
def headers(self) -> list[tuple[str, bytes]]:
    return self._headers

key #

key() -> bytes
Source code in faststream/confluent/testing.py 
324
325
def key(self) -> bytes:
    return self._key

offset #

offset() -> int
Source code in faststream/confluent/testing.py 
327
328
def offset(self) -> int:
    return self._offset

partition #

partition() -> int
Source code in faststream/confluent/testing.py 
330
331
def partition(self) -> int:
    return self._partition

timestamp #

timestamp() -> tuple[int, int]
Source code in faststream/confluent/testing.py 
333
334
def timestamp(self) -> tuple[int, int]:
    return self._timestamp

topic #

topic() -> str
Source code in faststream/confluent/testing.py 
336
337
def topic(self) -> str:
    return self._topic

value #

value() -> bytes | None
Source code in faststream/confluent/testing.py 
339
340
def value(self) -> bytes | None:
    return self._raw_msg