writer

package
v1.1.92 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 6, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
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
)
View Source
const (
	SignalKEndpointsPath = "/signalk"
	SignalKHTTPPath      = "/signalk/v1/api/"
	SignalKWSPath        = "/signalk/v1/stream"
)

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.1.92

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

func NewGrafanaWriter added in v0.1.92

func NewGrafanaWriter(c *config.MQTTConfig) *GrafanaWriter

func (*GrafanaWriter) WriteMapped added in v0.1.92

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

type LWEWriter added in v0.1.29

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

func NewLWEWriter added in v0.1.29

func NewLWEWriter(c *config.LWEConfig) *LWEWriter

func (*LWEWriter) WriteRaw added in v0.1.29

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 added in v0.1.51

func (w *PostgresqlWriter) StartMappedWorkers()

func (*PostgresqlWriter) StartRawWorkers added in v0.1.51

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 added in v0.1.19

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

func NewSignalKWriter added in v0.1.19

func NewSignalKWriter(c *config.SignalKConfig) *SignalKWriter

func (*SignalKWriter) WriteMapped added in v0.1.19

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

type StdOutWriter added in v0.1.27

type StdOutWriter struct {
}

func NewStdOutWriter added in v0.1.27

func NewStdOutWriter() *StdOutWriter

func (*StdOutWriter) WriteMapped added in v0.1.27

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

func (*StdOutWriter) WriteRaw added in v0.1.27

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

func (*StdOutWriter) WriteRawString added in v0.1.91

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL