persistence

package

v1.6.0 Latest Latest Go to latest Published: Mar 24, 2024 License: GPL-3.0 Imports: 13 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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