Skip to content

MockConfluentMessage

faststream.confluent.testing.MockConfluentMessage #

MockConfluentMessage(
    raw_msg: bytes,
    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 
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
def __init__(
    self,
    raw_msg: bytes,
    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 
246
247
def len(self) -> int:
    return len(self._raw_msg)

error #

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

headers #

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

key #

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

offset #

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

partition #

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

timestamp #

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

topic #

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

value #

value() -> bytes
Source code in faststream/confluent/testing.py 
270
271
def value(self) -> bytes:
    return self._raw_msg