persistence

package

v1.9.1 Latest Latest Go to latest Published: Jul 10, 2025 License: GPL-3.0 Imports: 13 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/RoboCup-SSL/ssl-go-tools

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Compress(inFile, outFile string) error
type Message
type MessageId
- func (m MessageId) String() string
type MessageType
type Reader
- func NewReader(filename string) (logReader *Reader, err error)
type Recorder
- func NewRecorder() Recorder
type RecorderSlot
type Writer
- func NewWriter(filename string) (logWriter *Writer, err error)

Constants ¶

View Source

const HeaderSize = 16

Variables ¶

This section is empty.

Functions ¶

func Compress ¶ added in v1.4.0

func Compress(inFile, outFile string) error

Types ¶

type Message ¶

type Message struct {
	Timestamp   int64 // Receiver timestamp in ns
	MessageType MessageType
	Message     []byte
}

type MessageId ¶

type MessageId int

const (
	MessageBlank                MessageId = 0 //(ignore message)
	MessageUnknown              MessageId = 1 //(try to guess message type by parsing the data)
	MessageSslVision2010        MessageId = 2
	MessageSslRefbox2013        MessageId = 3
	MessageSslVision2014        MessageId = 4
	MessageSslVisionTracker2020 MessageId = 5
	MessageIndex2021            MessageId = 6
)

func (MessageId) String ¶ added in v1.1.0

func (m MessageId) String() string

type MessageType ¶

type MessageType struct {
	Id   MessageId
	Name string
}

type Reader ¶

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

func NewReader ¶

func NewReader(filename string) (logReader *Reader, err error)

func (*Reader) Close ¶

func (l *Reader) Close() error

func (*Reader) CreateChannel ¶

func (l *Reader) CreateChannel() (channel chan *Message)

func (*Reader) HasMessage ¶

func (l *Reader) HasMessage() bool

func (*Reader) IsCompressed ¶ added in v1.2.0

func (l *Reader) IsCompressed() bool

func (*Reader) IsIndexed ¶ added in v1.2.0

func (l *Reader) IsIndexed() bool

func (*Reader) ReadIndex ¶ added in v1.1.0

func (l *Reader) ReadIndex() (offsets []int64, err error)

func (*Reader) ReadMessage ¶

func (l *Reader) ReadMessage() (msg *Message, err error)

func (*Reader) ReadMessageAt ¶ added in v1.1.0

func (l *Reader) ReadMessageAt(offset int64) (msg *Message, err error)

func (*Reader) ReadMessageTimeAndType ¶ added in v1.3.0

func (l *Reader) ReadMessageTimeAndType(offset int64) (*int64, *MessageId, error)

func (*Reader) SkipMessage ¶

func (l *Reader) SkipMessage() (bytesRead int, err error)

type Recorder ¶

type Recorder struct {
	Slots []*RecorderSlot
	// contains filtered or unexported fields
}

func NewRecorder ¶

func NewRecorder() Recorder

func (*Recorder) AddMessageConsumer ¶ added in v1.4.0

func (r *Recorder) AddMessageConsumer(consumer func(*Message))

func (*Recorder) AddSlot ¶

func (r *Recorder) AddSlot(messageType MessageType, address string)

func (*Recorder) IsPaused ¶ added in v1.4.0

func (r *Recorder) IsPaused() bool

func (*Recorder) IsRecording ¶ added in v1.4.0

func (r *Recorder) IsRecording() bool

func (*Recorder) SetPaused ¶ added in v1.4.0

func (r *Recorder) SetPaused(paused bool)

func (*Recorder) StartReceiving ¶ added in v1.4.0

func (r *Recorder) StartReceiving()

func (*Recorder) StartRecording ¶ added in v1.4.0

func (r *Recorder) StartRecording(logFileName string) error

func (*Recorder) StopReceiving ¶ added in v1.4.0

func (r *Recorder) StopReceiving()

func (*Recorder) StopRecording ¶ added in v1.4.0

func (r *Recorder) StopRecording() error

type RecorderSlot ¶ added in v1.1.0

type RecorderSlot struct {
	ReceivedMessages int
	MessageType      MessageType
	// contains filtered or unexported fields
}

type Writer ¶

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

func NewWriter ¶

func NewWriter(filename string) (logWriter *Writer, err error)

func (*Writer) Close ¶

func (l *Writer) Close() error

func (*Writer) Write ¶

func (l *Writer) Write(msg *Message) (err error)

func (*Writer) WriteIndex ¶ added in v1.1.0

func (l *Writer) WriteIndex(offsets []int64) (err error)

Source Files ¶

View all Source files

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