rosbag

package module

Go to main page

Versions in this module

v0

v0.0.8

Feb 22, 2021

Changes in this version

type RecordMessageData

+ func (record *RecordMessageData) ViewAs(v interface{}) error

v0.0.7

Jan 17, 2021

Changes in this version

type RecordMessageData

+ func (record *RecordMessageData) View(v interface{}) error

v0.0.6

Jan 17, 2021

v0.0.5

Jan 2, 2021

Changes in this version

type Record

+ Close func()

type RecordBase

+ func (record *RecordBase) Close()

type RecordMessageData

+ func (record *RecordMessageData) Close()

+ func (record *RecordMessageData) Transform() (map[string]interface{}, error)

v0.0.4

Dec 31, 2020

Changes in this version

type RecordBase

+ DataLen uint32

+ HeaderLen uint32

+ Raw []byte

+ func (record *RecordBase) Op() (Op, error)

type RecordMessageData

+ func (record *RecordMessageData) ConnectionHeader() *ConnectionHeader

v0.0.3

Dec 30, 2020

Changes in this version

type Record

+ Conns map[uint32]*ConnectionHeader

v0.0.2

Dec 29, 2020

Changes in this version

type Decoder

+ func (decoder *Decoder) Read(record *Record) (op Op, err error)

type Record

+ DataLen uint32

+ HeaderLen uint32

+ Raw []byte

+ func (record *Record) BagHeader() RecordBagHeader

+ func (record *Record) Chunk() RecordChunk

+ func (record *Record) ChunkCount() (uint32, error)

+ func (record *Record) ChunkInfo() RecordChunkInfo

+ func (record *Record) ChunkPos() (uint64, error)

+ func (record *Record) Compression() (Compression, error)

+ func (record *Record) Conn() (uint32, error)

+ func (record *Record) ConnCount() (uint32, error)

+ func (record *Record) Connection() RecordConnection

+ func (record *Record) ConnectionHeader() (*ConnectionHeader, error)

+ func (record *Record) Count() (uint32, error)

+ func (record *Record) EndTime() (time.Time, error)

+ func (record *Record) IndexData() RecordIndexData

+ func (record *Record) IndexPos() (uint64, error)

+ func (record *Record) MessageData() RecordMessageData

+ func (record *Record) Op() (Op, error)

+ func (record *Record) Size() (uint32, error)

+ func (record *Record) StartTime() (time.Time, error)

+ func (record *Record) Time() (time.Time, error)

+ func (record *Record) Topic() (string, error)

+ func (record *Record) UnmarshallTo(v map[string]interface{}) error

+ func (record *Record) Ver() (uint32, error)

v0.0.1

Dec 28, 2020

Changes in this version

+ type Compression string

+ const CompressionBZ2

+ const CompressionLZ4

+ const CompressionNone

+ type ConnectionHeader struct

+ MD5Sum string

+ MessageDefinition MessageDefinition

+ Topic string

+ Type string

+ func (header *ConnectionHeader) String() string

+ type Decoder struct

+ func NewDecoder(r io.Reader) *Decoder

+ func (decoder *Decoder) Next() (Record, error)

+ type MessageDefinition struct

+ ComplexMsgs []MessageDefinition

+ Fields []MessageFieldDefinition

+ Type string

+ func (def *MessageDefinition) String() string

+ type MessageFieldDefinition struct

+ ArraySize int

+ IsArray bool

+ MsgType string

+ Name string

+ Type MessageFieldType

+ Value []byte

+ func (def *MessageFieldDefinition) String() string

+ type MessageFieldType uint8

+ const MessageFieldTypeBool

+ const MessageFieldTypeComplex

+ const MessageFieldTypeDuration

+ const MessageFieldTypeFloat32

+ const MessageFieldTypeFloat64

+ const MessageFieldTypeInt16

+ const MessageFieldTypeInt32

+ const MessageFieldTypeInt64

+ const MessageFieldTypeInt8

+ const MessageFieldTypeString

+ const MessageFieldTypeTime

+ const MessageFieldTypeUint16

+ const MessageFieldTypeUint32

+ const MessageFieldTypeUint64

+ const MessageFieldTypeUint8

+ func (t MessageFieldType) String() string

+ type Op uint8

+ const OpBagHeader

+ const OpChunk

+ const OpChunkInfo

+ const OpConnection

+ const OpIndexData

+ const OpInvalid

+ const OpMessageData

+ type Record interface

+ Data func() *io.LimitedReader

+ Header func() []byte

+ String func() string

+ type RecordBagHeader struct

+ ChunkCount uint32

+ ConnCount uint32

+ IndexPos uint64

+ func NewRecordBagHeader(base *RecordBase) (*RecordBagHeader, error)

+ func (record *RecordBagHeader) String() string

+ type RecordBase struct

+ func (record *RecordBase) Data() *io.LimitedReader

+ func (record *RecordBase) Header() []byte

+ func (record *RecordBase) String() string

+ type RecordChunk struct

+ Compression Compression

+ Size uint32

+ func NewRecordChunk(base *RecordBase, conns map[uint32]*RecordConnection) (*RecordChunk, error)

+ func (record *RecordChunk) Next() (Record, error)

+ func (record *RecordChunk) String() string

+ type RecordChunkInfo struct

+ ChunkPos uint64

+ Count uint32

+ EndTime time.Time

+ StartTime time.Time

+ Ver uint32

+ func NewRecordChunkInfo(base *RecordBase) (*RecordChunkInfo, error)

+ func (record *RecordChunkInfo) String() string

+ type RecordConnection struct

+ Conn uint32

+ Topic string

+ func NewRecordConnection(base *RecordBase) (*RecordConnection, error)

+ func (record *RecordConnection) ConnectionHeader() *ConnectionHeader

+ func (record *RecordConnection) String() string

+ type RecordIndexData struct

+ Conn uint32

+ Count uint32

+ Ver uint32

+ func NewRecordIndexData(base *RecordBase) (*RecordIndexData, error)

+ func (record *RecordIndexData) String() string

+ type RecordMessageData struct

+ Conn *RecordConnection

+ Time time.Time

+ func NewRecordMessageData(base *RecordBase, conns map[uint32]*RecordConnection) (*RecordMessageData, error)

+ func (record *RecordMessageData) String() string

+ func (record *RecordMessageData) UnmarshallTo(v map[string]interface{}) error

+ type Rosbag struct

+ Record []Record

+ Version Version

+ type Version struct

+ Major uint

+ Minor uint

+ func (version *Version) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL