writer

Documentation

Index

• Constants
• type Cache
• type Client
  • func NewClient() Client
• type GrafanaWriter
  • func NewGrafanaWriter(c *config.MQTTConfig) *GrafanaWriter
  • func (w *GrafanaWriter) WriteMapped(subscriber mangos.Socket)
• type LWEWriter
  • func NewLWEWriter(c *config.LWEConfig) *LWEWriter
  • func (w *LWEWriter) WriteRaw(subscriber mangos.Socket)
• type MappedWriter
• type MqttWriter
  • func NewMqttWriter(c *config.MQTTConfig) *MqttWriter
  • func (w *MqttWriter) WriteMapped(subscriber mangos.Socket)
• type PostgresqlWriter
  • func NewPostgresqlWriter(c *config.PostgresqlConfig) *PostgresqlWriter
  • func (w *PostgresqlWriter) StartMappedWorkers()
  • func (w *PostgresqlWriter) StartRawWorkers()
  • func (w *PostgresqlWriter) WriteMapped(subscriber mangos.Socket)
  • func (w *PostgresqlWriter) WriteRaw(subscriber mangos.Socket)
• type RawWriter
• type SignalKWriter
  • func NewSignalKWriter(c *config.SignalKConfig) *SignalKWriter
  • func (w *SignalKWriter) WriteMapped(subscriber mangos.Socket)
• type StdOutWriter
  • func NewStdOutWriter() *StdOutWriter
  • func (w *StdOutWriter) WriteMapped(subscriber mangos.Socket)
  • func (w *StdOutWriter) WriteRaw(subscriber mangos.Socket)
  • func (w *StdOutWriter) WriteRawString(subscriber mangos.Socket)
• type SubscribeMessage
• type SubscribeSection
• type WebsocketWriter
  • func NewWebsocketWriter() *WebsocketWriter
  • func (ws *WebsocketWriter) WitSelf(s string) *WebsocketWriter
  • func (ws *WebsocketWriter) WithURL(u string) *WebsocketWriter
  • func (ws *WebsocketWriter) WriteMapped(subscriber mangos.Socket)

Constants

const (
	MISCAddress = "239.192.0.1"
	MISCPort    = 60001
	TGTDAddress = "239.192.0.2"
	TGTDPort    = 60002
	SATDAddress = "239.192.0.3"
	SATDPort    = 60003
	NAVDAddress = "239.192.0.4"
	NAVDPort    = 60004
	VDRDAddress = "239.192.0.5"
	VDRDPort    = 60005
	RCOMAddress = "239.192.0.6"
	RCOMPort    = 60006
	TIMEAddress = "239.192.0.7"
	TIMEPort    = 60007
	PROPAddress = "239.192.0.8"
	PROPPort    = 60008
	USR1Address = "239.192.0.9"
	USR1Port    = 60009
	USR2Address = "239.192.0.10"
	USR2Port    = 60010
	USR3Address = "239.192.0.11"
	USR3Port    = 60011
	USR4Address = "239.192.0.12"
	USR4Port    = 60012
	USR5Address = "239.192.0.13"
	USR5Port    = 60013
	USR6Address = "239.192.0.14"
	USR6Port    = 60014
	USR7Address = "239.192.0.15"
	USR7Port    = 60015
	USR8Address = "239.192.0.16"
	USR8Port    = 60016
)

const (
	SignalKEndpointsPath = "/signalk"
	SignalKHTTPPath      = "/signalk/v1/api/"
	SignalKWSPath        = "/signalk/v1/stream"
)

Types

type Cache

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

type Client

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

Client is a middleman between the websocket connection and the hub.

func NewClient

func NewClient() Client

type GrafanaWriter

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

func NewGrafanaWriter

func NewGrafanaWriter(c *config.MQTTConfig) *GrafanaWriter

func (*GrafanaWriter) WriteMapped

func (w *GrafanaWriter) WriteMapped(subscriber mangos.Socket)

type LWEWriter

type LWEWriter struct {
	DestinationIdentification string
	SourceIdentification      string
	IncludeTimestamp          bool
	IncludeLineCount          bool
	// contains filtered or unexported fields
}

func NewLWEWriter

func NewLWEWriter(c *config.LWEConfig) *LWEWriter

func (*LWEWriter) WriteRaw

func (w *LWEWriter) WriteRaw(subscriber mangos.Socket)

type MappedWriter

type MappedWriter interface {
	WriteMapped(subscriber mangos.Socket)
}

RawWriter interface

type MqttWriter

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

func NewMqttWriter

func NewMqttWriter(c *config.MQTTConfig) *MqttWriter

func (*MqttWriter) WriteMapped

func (w *MqttWriter) WriteMapped(subscriber mangos.Socket)

type PostgresqlWriter

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

func NewPostgresqlWriter

func NewPostgresqlWriter(c *config.PostgresqlConfig) *PostgresqlWriter

func (*PostgresqlWriter) StartMappedWorkers

func (w *PostgresqlWriter) StartMappedWorkers()

func (*PostgresqlWriter) StartRawWorkers

func (w *PostgresqlWriter) StartRawWorkers()

func (*PostgresqlWriter) WriteMapped

func (w *PostgresqlWriter) WriteMapped(subscriber mangos.Socket)

func (*PostgresqlWriter) WriteRaw

func (w *PostgresqlWriter) WriteRaw(subscriber mangos.Socket)

type RawWriter

type RawWriter interface {
	WriteRaw(subscriber mangos.Socket)
}

RawWriter interface

type SignalKWriter

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

func NewSignalKWriter

func NewSignalKWriter(c *config.SignalKConfig) *SignalKWriter

func (*SignalKWriter) WriteMapped

func (w *SignalKWriter) WriteMapped(subscriber mangos.Socket)

type StdOutWriter

type StdOutWriter struct {
}

func NewStdOutWriter

func NewStdOutWriter() *StdOutWriter

func (*StdOutWriter) WriteMapped

func (w *StdOutWriter) WriteMapped(subscriber mangos.Socket)

func (*StdOutWriter) WriteRaw

func (w *StdOutWriter) WriteRaw(subscriber mangos.Socket)

func (*StdOutWriter) WriteRawString

func (w *StdOutWriter) WriteRawString(subscriber mangos.Socket)

type SubscribeMessage

type SubscribeMessage struct {
	Context     string             `json:"context"`
	Subscribe   []SubscribeSection `json:"subscribe"`
	Unsubscribe []SubscribeSection `json:"unsubscribe"`
}

type SubscribeSection

type SubscribeSection struct {
	Path string `json:"path"`
}

type WebsocketWriter

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

func NewWebsocketWriter

func NewWebsocketWriter() *WebsocketWriter

func (*WebsocketWriter) WitSelf

func (ws *WebsocketWriter) WitSelf(s string) *WebsocketWriter

func (*WebsocketWriter) WithURL

func (ws *WebsocketWriter) WithURL(u string) *WebsocketWriter

func (*WebsocketWriter) WriteMapped

func (ws *WebsocketWriter) WriteMapped(subscriber mangos.Socket)