mcap.records module

class mcap.records.Attachment(create_time: int, log_time: int, name: str, media_type: str, data: bytes)[source]

Bases: McapRecord

create_time: int
data: bytes
log_time: int
media_type: str
name: str
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder)[source]
class mcap.records.AttachmentIndex(offset: int, length: int, log_time: int, create_time: int, data_size: int, name: str, media_type: str)[source]

Bases: McapRecord

create_time: int
data_size: int
length: int
log_time: int
media_type: str
name: str
offset: int
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder)[source]
class mcap.records.Channel(id: int, topic: str, message_encoding: str, metadata: Dict[str, str], schema_id: int)[source]

Bases: McapRecord

id: int
message_encoding: str
metadata: Dict[str, str]
static read(stream: ReadDataStream)[source]
schema_id: int
topic: str
write(stream: RecordBuilder)[source]
class mcap.records.Chunk(compression: str, data: bytes, message_end_time: int, message_start_time: int, uncompressed_crc: int, uncompressed_size: int)[source]

Bases: McapRecord

compression: str
data: bytes
message_end_time: int
message_start_time: int
static read(stream: ReadDataStream)[source]
uncompressed_crc: int
uncompressed_size: int
write(stream: RecordBuilder)[source]
class mcap.records.ChunkIndex(chunk_length: int, chunk_start_offset: int, compression: str, compressed_size: int, message_end_time: int, message_index_length: int, message_index_offsets: Dict[int, int], message_start_time: int, uncompressed_size: int)[source]

Bases: McapRecord

chunk_length: int
chunk_start_offset: int
compressed_size: int
compression: str
message_end_time: int
message_index_length: int
message_index_offsets: Dict[int, int]
message_start_time: int
static read(stream: ReadDataStream)[source]
uncompressed_size: int
write(stream: RecordBuilder)[source]
class mcap.records.DataEnd(data_section_crc: int)[source]

Bases: McapRecord

data_section_crc: int
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder)[source]
class mcap.records.Footer(summary_start: int, summary_offset_start: int, summary_crc: int)[source]

Bases: McapRecord

static read(stream: ReadDataStream)[source]
summary_crc: int
summary_offset_start: int
summary_start: int
write(stream: RecordBuilder)[source]
class mcap.records.Header(profile: str, library: str)[source]

Bases: McapRecord

library: str
profile: str
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder)[source]
class mcap.records.McapRecord[source]

Bases: object

write(stream: RecordBuilder) → None[source]
class mcap.records.Message(channel_id: int, log_time: int, data: bytes, publish_time: int, sequence: int)[source]

Bases: McapRecord

channel_id: int
data: bytes
log_time: int
publish_time: int
static read(stream: ReadDataStream, length: int)[source]
sequence: int
write(stream: RecordBuilder)[source]
class mcap.records.MessageIndex(channel_id: int, records: List[Tuple[int, int]])[source]

Bases: McapRecord

channel_id: int
static read(stream: ReadDataStream)[source]
records: List[Tuple[int, int]]
write(stream: RecordBuilder)[source]
class mcap.records.Metadata(name: str, metadata: Dict[str, str])[source]

Bases: McapRecord

metadata: Dict[str, str]
name: str
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder) → None[source]
class mcap.records.MetadataIndex(offset: int, length: int, name: str)[source]

Bases: McapRecord

length: int
name: str
offset: int
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder) → None[source]
class mcap.records.Schema(id: int, data: bytes, encoding: str, name: str)[source]

Bases: McapRecord

data: bytes
encoding: str
id: int
name: str
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder)[source]
class mcap.records.Statistics(attachment_count: int, channel_count: int, channel_message_counts: Dict[int, int], chunk_count: int, message_count: int, message_end_time: int, message_start_time: int, metadata_count: int, schema_count: int)[source]

Bases: McapRecord

attachment_count: int
channel_count: int
channel_message_counts: Dict[int, int]
chunk_count: int
message_count: int
message_end_time: int
message_start_time: int
metadata_count: int
static read(stream: ReadDataStream)[source]
schema_count: int
write(stream: RecordBuilder)[source]
class mcap.records.SummaryOffset(group_opcode: int, group_start: int, group_length: int)[source]

Bases: McapRecord

group_length: int
group_opcode: int
group_start: int
static read(stream: ReadDataStream)[source]
write(stream: RecordBuilder)[source]