ingest

Documentation

Index

• func Interfaces(tripDirs []string) ([]string, error)
• func NewGPSChan(dirs []string) (<-chan gps.NMEA, error)
• func NewGPSPackets(dirs []string) (<-chan GPSPacket, error)
• func NewIfacePacketChan(tripDirs []string, iface string) (<-chan wlan.Packet, error)
• type GPSPacket
  • func (g *GPSPacket) Loc() gps.NMEA
  • func (g *GPSPacket) Pkt() wlan.Packet
• type LatLon
• type Rect
  • func (r *Rect) Contains(ll LatLon) bool
• type TimeMap
  • func NewTimeMap(ch <-chan GPSPacket) (TimeMap, error)
• type TimeMapDB
  • func NewTimeMapDB() *TimeMapDB
  • func (tdb *TimeMapDB) AddTrips(dir string) error
  • func (tdb *TimeMapDB) Load(path string) error
  • func (tdb *TimeMapDB) Save(path string) error

Functions

func Interfaces

func Interfaces(tripDirs []string) ([]string, error)

func NewGPSChan

func NewGPSChan(dirs []string) (<-chan gps.NMEA, error)

func NewGPSPackets

func NewGPSPackets(dirs []string) (<-chan GPSPacket, error)

func NewIfacePacketChan

func NewIfacePacketChan(tripDirs []string, iface string) (<-chan wlan.Packet, error)

Types

type GPSPacket

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

func (*GPSPacket) Loc

func (g *GPSPacket) Loc() gps.NMEA

func (*GPSPacket) Pkt

func (g *GPSPacket) Pkt() wlan.Packet

type LatLon

type LatLon struct {
	Lat float64
	Lon float64
}

type Rect

type Rect struct {
	TL LatLon
	BR LatLon
}

func (*Rect) Contains

func (r *Rect) Contains(ll LatLon) bool

type TimeMap

type TimeMap map[int64][]GPSPacket

func NewTimeMap

func NewTimeMap(ch <-chan GPSPacket) (TimeMap, error)

type TimeMapDB

type TimeMapDB struct {
	Trips   map[string]struct{}
	Packets TimeMap
}

func NewTimeMapDB

func NewTimeMapDB() *TimeMapDB

func (*TimeMapDB) AddTrips

func (tdb *TimeMapDB) AddTrips(dir string) error

func (*TimeMapDB) Load

func (tdb *TimeMapDB) Load(path string) error

func (*TimeMapDB) Save

func (tdb *TimeMapDB) Save(path string) error