rosbag

type BagHeader struct {
	IndexPos   uint64 // offset of first record after the chunk section
	ConnCount  uint32 // number of unique connections in the file
	ChunkCount uint32 // number of chunk records in the file
}

type ChunkInfo struct {
	ChunkPos  uint64            // offset of the chunk record
	StartTime uint64            // timestamp of earliest message in the chunk in nanoseconds
	EndTime   uint64            // timestamp of latest message in the chunk in nanoseconds
	Count     uint32            // number of connections in the chunk
	Data      map[uint32]uint32 // map of connID to message count
}

type Connection struct {
	Conn  uint32           // unique connection ID
	Topic string           // topic on which the messages are stored
	Data  ConnectionHeader // connection header
}

type ConnectionHeader struct {
	Topic             string  // name of the topic the subscriber is connecting to
	Type              string  // message type
	MD5Sum            string  // md5sum of message type
	MessageDefinition []byte  // full text of message definition (output of gendeps --cat)
	CallerID          *string // name of node sending data
	Latching          *bool   // publisher is in latching mode (i.e sends the last value published to new subscribers)
}

type ErrHeaderKeyNotFound struct {
	// contains filtered or unexported fields
}

type ErrUnexpectedOpHeader struct {
	// contains filtered or unexported fields
}

type ErrUnsupportedCompression struct {
	// contains filtered or unexported fields
}

type IndexData struct {
	Conn  uint32              // connection ID
	Count uint32              // number of messages on *conn* in the preceding chunk
	Data  []MessageIndexEntry // *count* repeating occurrences of timestamps and message offsets
}

type Info struct {
	MessageStartTime uint64
	MessageEndTime   uint64
	MessageCount     uint64

	ChunkInfos  []*ChunkInfo
	Connections map[uint32]*Connection
}

type Iterator interface {
	Next() (*Connection, *Message, error)
	More() bool
}

type Message struct {
	Conn uint32 // ID for connection on which message arrived
	Time uint64 // time at which the message was received in nanoseconds
	Data []byte // serialized message data in ROS serialization format
}

type MessageIndexEntry struct {
	Time   uint64 // time at which the message was recorded in nanoseconds
	Offset uint32 // byte offset of the message within the uncompressed chunk data
}

type OpCode byte

type Reader struct {
	// contains filtered or unexported fields
}

type ScanOption func(*scanOptions)

type Writer struct {
	// contains filtered or unexported fields
}

type WriterOption func(c *bagWriterConfig)