31 lines
716 B
Go
31 lines
716 B
Go
package main
|
|
|
|
import (
|
|
"git.timovolkmann.de/gyrogpsc/core"
|
|
"log"
|
|
)
|
|
|
|
const (
|
|
TCP_PORT = ":3010"
|
|
HTTP_PORT = ":3011"
|
|
SERIAL_PORT = "/dev/tty.usbmodem14201"
|
|
)
|
|
|
|
func main() {
|
|
log.Println("setup dispatcher")
|
|
dispatcher := core.NewDispatcher()
|
|
log.Println("initialize processing pipeline")
|
|
processor := core.NewPipeline(dispatcher, 50, 494)
|
|
processor.Run()
|
|
collectRoutines(processor)
|
|
log.Println("start http server")
|
|
core.HttpListenAndServe(dispatcher, HTTP_PORT)
|
|
}
|
|
|
|
func collectRoutines(proc core.Processor) {
|
|
// collect Sensor data from Serial UBX in Goroutine
|
|
go core.SerialCollector(proc, SERIAL_PORT)
|
|
// collect Sensor data from JSON over TCP in Goroutine
|
|
go core.TcpCollector(proc, TCP_PORT)
|
|
}
|