o `šjใ@sXddlmZmZmZGdd„deƒZGdd„deƒZGdd„deƒZGdd „d eƒZd S) ้)ฺABCฺabstractmethodฺabstractpropertyc@s|eZdZdZedd„ƒZedd„ƒZedd„ƒZedd „ƒZed d „ƒZ ed d „ƒZ edd„ƒZ e dd„ƒZ edd„ƒZdS)ฺ ABCRecordฉcC๓dS)z) Number of total bytes in record Nrฉฺselfrr๚N/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/record/abc.pyฺ size_in_bytes๓zABCRecord.size_in_bytescCr)z# Absolute offset of record Nrrrrr ฺoffset r zABCRecord.offsetcCr)z Epoch milliseconds Nrrrrr ฺ timestampr zABCRecord.timestampcCr)z* CREATE_TIME(0) or APPEND_TIME(1) Nrrrrr ฺtimestamp_typer zABCRecord.timestamp_typecCr)z Bytes key or None Nrrrrr ฺkeyr z ABCRecord.keycCr)z Bytes value or None Nrrrrr ฺvalue r zABCRecord.valuecCr)z Prior to v2 format CRC was contained in every message. This will be the checksum for v0 and v1 and None for v2 and above. Nrrrrr ฺchecksum%r zABCRecord.checksumcCr)zP Return True if v0/v1 record matches checksum. noop/True for v2 records Nrrrrr ฺ validate_crc+r zABCRecord.validate_crccCr)zq If supported by version list of key-value tuples, or empty list if not supported by format. Nrrrrr ฺheaders0r zABCRecord.headersN)ฺ__name__ฺ __module__ฺ __qualname__ฺ __slots__rr r rrrrrrrrrrrr rs(        rc@s6eZdZdZed dd„ƒZedd„ƒZedd„ƒZdS) ฺABCRecordBatchBuilderrNcCr)aพ Writes record to internal buffer. Arguments: offset (int): Relative offset of record, starting from 0 timestamp (int or None): Timestamp in milliseconds since beginning of the epoch (midnight Jan 1, 1970 (UTC)). If omitted, will be set to current time. key (bytes or None): Key of the record value (bytes or None): Value of the record headers (List[Tuple[str, bytes]]): Headers of the record. Header keys can not be ``None``. Returns: (bytes, int): Checksum of the written record (or None for v2 and above) and size of the written record. Nrฉr r rrrrrrr ฺappend:r zABCRecordBatchBuilder.appendcCr)zถ Return the expected size change on buffer (uncompressed) if we add this message. This will account for varint size changes and give a reliable size. Nrrrrr r Mr z#ABCRecordBatchBuilder.size_in_bytescCr)zส Close for append, compress if needed, write size and header and return a ready to send buffer object. Return: bytearray: finished batch, ready to send. Nrrrrr ฺbuildTr zABCRecordBatchBuilder.build)N)rrrrrrr rrrrr r7s  rc@sDeZdZdZdZedd„ƒZedd„ƒZedd„ƒZ ed d „ƒZ d S) ฺABCRecordBatchz_ For v2 encapsulates a RecordBatch, for v0/v1 a single (maybe compressed) message. rcCr)zd Return iterator over records (ABCRecord instances). Will decompress if needed. Nrrrrr ฺ__iter__dr zABCRecordBatch.__iter__cCr)z& Return base offset for batch Nrrrrr ฺ base_offsetjr zABCRecordBatch.base_offsetcCr)zB Return size of batch in bytes (includes header overhead) Nrrrrr r or zABCRecordBatch.size_in_bytescCr)z1 Return magic value (0, 1, 2) for batch. Nrrrrr ฺmagictr zABCRecordBatch.magicN) rrrฺ__doc__rrrrrr r rrrr r^s   rc@s@eZdZdZedd„ƒZedd„ƒZedd„ƒZedd „ƒZd S) ฺ ABCRecordsrcCr)zƒ Initialize with bytes-like object conforming to the buffer interface (ie. bytes, bytearray, memoryview etc.). Nr)r ฺbufferrrr ฺ__init__}r zABCRecords.__init__cCr)z+ Returns the size of inner buffer. Nrrrrr r ƒr zABCRecords.size_in_bytescCr)zB Return next batch of records (ABCRecordBatch instances). Nrrrrr ฺ next_batchˆr zABCRecords.next_batchcCr)zB True if there are more batches to read, False otherwise. Nrrrrr ฺhas_nextr zABCRecords.has_nextN) rrrrrr$r r%r&rrrr r"zs   r"N)ฺabcrrrrrrr"rrrr ฺs 3'