logparser

Documentation

Index

• Constants
• type GpsCoordinates
• type LogQueue
  • func NewLogQueue(config *config.Config, db *gorm.DB, metrics *metrics.Metrics) *LogQueue
  • func (q *LogQueue) AddLog(path string, dongleID string)
  • func (q *LogQueue) Start()
  • func (q *LogQueue) Stop()
• type SegmentData
  • func DecodeSegmentData(reader io.Reader) (SegmentData, error)

Constants

const QueueDepth = 100

Types

type GpsCoordinates

type GpsCoordinates struct {
	Latitude             float64
	Longitude            float64
	Time                 time.Time
	AccuracyMeters       float64
	SpeedMetersPerSecond float64
	Bearing              float64
}

type LogQueue

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

func NewLogQueue

func NewLogQueue(config *config.Config, db *gorm.DB, metrics *metrics.Metrics) *LogQueue

func (*LogQueue) AddLog

func (q *LogQueue) AddLog(path string, dongleID string)

func (*LogQueue) Start

func (q *LogQueue) Start()

func (*LogQueue) Stop

func (q *LogQueue) Stop()

type SegmentData

type SegmentData struct {
	GPSLocations      []GpsCoordinates
	EndCoordinates    GpsCoordinates
	EarliestTimestamp uint64
	LatestTimestamp   uint64
	CANPresent        bool
	DongleID          string
	InitLogMonoTime   uint64
	DeviceType        cereal.InitData_DeviceType
	CarModel          string
	GitRemote         string
	GitBranch         string
	StartOfRoute      bool
	EndOfRoute        bool
}

func DecodeSegmentData

func DecodeSegmentData(reader io.Reader) (SegmentData, error)