writer

Documentation

Index

• type Cache
• type Client
  • func NewClient() Client
• 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) WriteMapped(subscriber mangos.Socket)
  • func (w *PostgresqlWriter) WriteRaw(subscriber mangos.Socket)
• type RawWriter
• 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)

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 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) 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 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)