services

Documentation

Index

• type AISMessage
• type AISStreamManager
  • func NewAISStreamManager(apiKey string, database *sql.DB) *AISStreamManager
  • func (a *AISStreamManager) StartStreaming(mmsis []string) error

Types

type AISMessage

type AISMessage struct {
	MessageType string          `json:"messageType"`
	Message     json.RawMessage `json:"message"`
	MetaData    json.RawMessage `json:"metaData"`
}

Simple message type if we don't want to use aisstream package

type AISStreamManager

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

func NewAISStreamManager

func NewAISStreamManager(apiKey string, database *sql.DB) *AISStreamManager

func (*AISStreamManager) StartStreaming

func (a *AISStreamManager) StartStreaming(mmsis []string) error