websocket

Documentation

Index

• type Counter
• type WebsocketSink
  • func NewWebsocketSink(appID string, ws remoteMessageWriter, messageDrainBufferSize uint, ...) *WebsocketSink
  • func (sink *WebsocketSink) AppID() string
  • func (sink *WebsocketSink) Identifier() string
  • func (sink *WebsocketSink) Run(inputChan <-chan *events.Envelope)
  • func (sink *WebsocketSink) SetCounter(counter Counter)
  • func (sink *WebsocketSink) ShouldReceiveErrors() bool

Types

type Counter

type Counter interface {
	Increment(events.Envelope_EventType)
}

type WebsocketSink

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

func NewWebsocketSink

func NewWebsocketSink(appID string, ws remoteMessageWriter, messageDrainBufferSize uint, writeTimeout time.Duration, dropsondeOrigin string) *WebsocketSink

func (*WebsocketSink) AppID

func (sink *WebsocketSink) AppID() string

func (*WebsocketSink) Identifier

func (sink *WebsocketSink) Identifier() string

func (*WebsocketSink) Run

func (sink *WebsocketSink) Run(inputChan <-chan *events.Envelope)

func (*WebsocketSink) SetCounter

func (sink *WebsocketSink) SetCounter(counter Counter)

func (*WebsocketSink) ShouldReceiveErrors

func (sink *WebsocketSink) ShouldReceiveErrors() bool