persistence

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)
  • func (l *Reader) Close() error
  • func (l *Reader) CreateChannel() (channel chan *Message)
  • func (l *Reader) HasMessage() bool
  • func (l *Reader) IsCompressed() bool
  • func (l *Reader) IsIndexed() bool
  • func (l *Reader) ReadIndex() (offsets []int64, err error)
  • func (l *Reader) ReadMessage() (msg *Message, err error)
  • func (l *Reader) ReadMessageAt(offset int64) (msg *Message, err error)
  • func (l *Reader) ReadMessageTimeAndType(offset int64) (*int64, *MessageId, error)
  • func (l *Reader) SkipMessage() (bytesRead int, err error)
• type Recorder
  • func NewRecorder() Recorder
  • func (r *Recorder) AddMessageConsumer(consumer func(*Message))
  • func (r *Recorder) AddSlot(messageType MessageType, address string)
  • 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
• type RecorderSlot
• type Writer
  • func NewWriter(filename string) (logWriter *Writer, err error)
  • func (l *Writer) Close() error
  • func (l *Writer) Write(msg *Message) (err error)
  • func (l *Writer) WriteIndex(offsets []int64) (err error)

Constants

const HeaderSize = 16

Functions

func Compress

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

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

func (l *Reader) IsCompressed() bool

func (*Reader) IsIndexed

func (l *Reader) IsIndexed() bool

func (*Reader) ReadIndex

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

func (*Reader) ReadMessage

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

func (*Reader) ReadMessageAt

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

func (*Reader) ReadMessageTimeAndType

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

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

func (*Recorder) AddSlot

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

func (*Recorder) IsPaused

func (r *Recorder) IsPaused() bool

func (*Recorder) IsRecording

func (r *Recorder) IsRecording() bool

func (*Recorder) SetPaused

func (r *Recorder) SetPaused(paused bool)

func (*Recorder) StartReceiving

func (r *Recorder) StartReceiving()

func (*Recorder) StartRecording

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

func (*Recorder) StopReceiving

func (r *Recorder) StopReceiving()

func (*Recorder) StopRecording

func (r *Recorder) StopRecording() error

type RecorderSlot

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

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