persistence

Jun 1, 2023

Changes in this version

+ func Compress(inFile, outFile string) error

type Recorder

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

+ func (r *Recorder) IsPaused() bool

+ func (r *Recorder) IsRecording() bool

+ func (r *Recorder) SetPaused(paused bool)

+ func (r *Recorder) StartReceiving()

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

+ func (r *Recorder) StopReceiving()

+ func (r *Recorder) StopRecording() error

Jul 24, 2022

Changes in this version

type Recorder

+ Paused bool

+ func (r *Recorder) StartWithName(name string) error

Dec 3, 2021

Changes in this version

type Reader

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

May 8, 2021

Changes in this version

type Reader

+ func (l *Reader) IsCompressed() bool

+ func (l *Reader) IsIndexed() bool

May 6, 2021

Changes in this version

+ const HeaderSize

type MessageId

+ const MessageIndex2021

+ const MessageSslVisionTracker2020

+ func (m MessageId) String() string

type Reader

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

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

type Recorder

+ func (r *Recorder) IsRunning() bool

+ type RecorderSlot struct

+ MessageType MessageType

+ ReceivedMessages int

type Writer

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

Oct 28, 2019

Changes in this version

+ func ParseMessage(data []byte, message proto.Message) error

+ type Broadcaster struct

+ SkipNonRunningStages bool

+ Slots []*Slot

+ func NewBroadcaster() Broadcaster

+ func (b *Broadcaster) AddSlot(messageType MessageType, address string)

+ func (b *Broadcaster) Start(filename string) error

+ func (b *Broadcaster) Stop()

+ type Message struct

+ Message []byte

+ MessageType MessageType

+ Timestamp int64

+ func (m *Message) ParseReferee() (*sslproto.Referee, error)

+ func (m *Message) ParseVisionWrapper() (*sslproto.SSL_WrapperPacket, error)

+ type MessageId int

+ const MessageBlank

+ const MessageSslRefbox2013

+ const MessageSslVision2010

+ const MessageSslVision2014

+ const MessageUnknown

+ type MessageType struct

+ Id MessageId

+ Name string

+ type Reader struct

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

+ func (l *Reader) Close() error

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

+ func (l *Reader) HasMessage() bool

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

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

+ type Recorder struct

+ Slots []*Slot

+ func NewRecorder() Recorder

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

+ func (r *Recorder) RegisterToInterrupt()

+ func (r *Recorder) Start() error

+ func (r *Recorder) Stop() error

+ type Slot struct

+ MessageType MessageType

+ ReceivedMessages int

+ type Writer struct

+ Open bool

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

+ func (l *Writer) Close() error

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