Documentation ¶
Index ¶
Constants ¶
View Source
const FIREHOSE_APP_ID = "firehose"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WebsocketSink ¶
type WebsocketSink struct { sinks.DropCounter // contains filtered or unexported fields }
func NewWebsocketSink ¶
func (*WebsocketSink) Identifier ¶
func (sink *WebsocketSink) Identifier() string
func (*WebsocketSink) Run ¶
func (sink *WebsocketSink) Run(inputChan <-chan *events.Envelope)
func (*WebsocketSink) ShouldReceiveErrors ¶
func (sink *WebsocketSink) ShouldReceiveErrors() bool
func (*WebsocketSink) StreamId ¶
func (sink *WebsocketSink) StreamId() string
Click to show internal directories.
Click to hide internal directories.