logparser

Documentation

Index

• Constants
• type GpsCoordinates
• type LogQueue
  • func NewLogQueue(config *config.Config, db *gorm.DB, storage storage.Storage, ...) *LogQueue
  • func (q *LogQueue) AddLog(path string, dongleID string, routeInfo v1dot4.RouteInfo)
  • 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
	LogMonoTime          uint64
	SpeedMetersPerSecond float64
	Bearing              float64
	Distance             float64
}

type LogQueue

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

func NewLogQueue

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

func (*LogQueue) AddLog

func (q *LogQueue) AddLog(path string, dongleID string, routeInfo v1dot4.RouteInfo)

func (*LogQueue) Start

func (q *LogQueue) Start()

func (*LogQueue) Stop

func (q *LogQueue) Stop()

type SegmentData

type SegmentData struct {
	GPSLocations            []GpsCoordinates
	EndCoordinates          GpsCoordinates
	EndLogMonoTime          uint64
	FirstClockWallTimeNanos uint64
	FirstClockLogMonoTime   uint64
	CANPresent              bool
	GitDirty                bool
	GitCommit               string
	Version                 string
	DongleID                string
	Radar                   bool
	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)