persistence

Documentation

Index

• Constants
• 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) 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) SkipMessage() (bytesRead int, err error)
• type Recorder
  • func NewRecorder() Recorder
  • func (r *Recorder) AddSlot(messageType MessageType, address string)
  • func (r *Recorder) IsRunning() bool
  • func (r *Recorder) Start() error
  • func (r *Recorder) Stop() 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

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) 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) 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) AddSlot

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

func (*Recorder) IsRunning

func (r *Recorder) IsRunning() bool

func (*Recorder) Start

func (r *Recorder) Start() error

func (*Recorder) Stop

func (r *Recorder) Stop() 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)