Versions in this module Expand all Collapse all v1 v1.0.0 Aug 7, 2024 Changes in this version type DB + func (db *DB) GetMessageStatsByVesselForTypeJSON(messageType int) ([]byte, error) + func (db *DB) GetMessageStatsByVesselForVesselJSON(mmsi int) ([]byte, error) + func (db *DB) GetMessageStatsByVesselJSON() ([]byte, error) + func (db *DB) GetMessageStatsJSON() ([]byte, error) + type HTTPApiFunc func(w http.ResponseWriter, r *http.Request) error v0 v0.0.1 May 14, 2018 Changes in this version type DB + func (db *DB) GetFeedId(address string) (int, error) + func (db *DB) GetFeeds() ([]*Feed, error) + type Feed struct + Active bool + CreatedAt time.Time + FeedID int64 + RemoteAddress string + type MonstahManager struct + DB *DB + func NewMonstahManager(db *DB) *MonstahManager + func (mm *MonstahManager) Shutdown() v0.0.0 Jul 28, 2017 Changes in this version + func CreateRouter(server *HTTPServer) (*mux.Router, error) + type DB struct + func (db *DB) AddMessage(mmsi int64, messageType int64, message []byte, raw []byte) error + func (db *DB) AddPacket(raw string) error + func (db *DB) GetMessageStatsByVesselForTypeJson(messageType int) ([]byte, error) + func (db *DB) GetMessageStatsByVesselForVesselJson(mmsi int) ([]byte, error) + func (db *DB) GetMessageStatsByVesselJson() ([]byte, error) + func (db *DB) GetMessageStatsJson() ([]byte, error) + func (db *DB) GetPositionsForVessel(mmsi int) ([]*Position, error) + func (db *DB) GetPositionsForVesselGeojson(mmsi int) ([]byte, error) + func (db *DB) GetVessel(mmsi int) (*Vessel, error) + func (db *DB) GetVessels() ([]*Vessel, error) + func (db *DB) GetVesselsGeojson() ([]byte, error) + func (db *DB) Open(connectionString string) error + func (db *DB) UpdatePosition(r nmeaais.DecoderOutput) + func (db *DB) UpdatePositionFromPositionReportClassA(m *nmeaais.PositionReportClassA) error + func (db *DB) UpdatePositionFromPositionReportClassBStandard(m *nmeaais.PositionReportClassBStandard) error + func (db *DB) UpdateVessel(r nmeaais.DecoderOutput) + func (db *DB) UpdateVesselFromPositionReportClassA(m *nmeaais.PositionReportClassA) error + func (db *DB) UpdateVesselFromPositionReportClassBStandard(m *nmeaais.PositionReportClassBStandard) error + func (db *DB) UpdateVesselFromStaticAndVoyageRelatedData(m *nmeaais.StaticAndVoyageRelatedData) error + func (db *DB) UpdateVesselFromStaticDataReportA(m *nmeaais.StaticDataReportA) error + func (db *DB) UpdateVesselFromStaticDataReportB(m *nmeaais.StaticDataReportB) error + type HTTPServer struct + DB *DB + func NewHTTPServer(db *DB) *HTTPServer + func (s *HTTPServer) GetMessageStats(w http.ResponseWriter, r *http.Request, vars map[string]string) error + func (s *HTTPServer) GetMessageStatsByVessel(w http.ResponseWriter, r *http.Request, vars map[string]string) error + func (s *HTTPServer) GetMessageStatsByVesselForType(w http.ResponseWriter, r *http.Request, vars map[string]string) error + func (s *HTTPServer) GetMessageStatsByVesselForVessel(w http.ResponseWriter, r *http.Request, vars map[string]string) error + func (s *HTTPServer) GetPositionsForVessel(w http.ResponseWriter, r *http.Request, vars map[string]string) error + func (s *HTTPServer) GetVesselByMmsi(w http.ResponseWriter, r *http.Request, vars map[string]string) error + func (s *HTTPServer) GetVessels(w http.ResponseWriter, r *http.Request, vars map[string]string) error + type HttpApiFunc func(w http.ResponseWriter, r *http.Request, vars map[string]string) error + type Monstah struct + DB *DB + func NewMonstah(db *DB) *Monstah + func (m *Monstah) Decode(address string) + func (m *Monstah) Shutdown() + type Position struct + CreatedAt time.Time + Latitude null.Float + Longitude null.Float + MMSI int64 + type Vessel struct + Breadth null.Int + CallSign null.String + CourseOverGround null.Float + Destination null.String + Draught null.Float + Latitude null.Float + Length null.Int + Longitude null.Float + MMSI int64 + NavigationStatus null.String + ShipType null.String + SpeedOverGround null.Float + TrueHeading null.Float + UpdatedAt time.Time + VesselName null.String