websocket

Documentation

Index

• type WebSocketSink
  • func (wss *WebSocketSink) Close(ctx api.StreamContext) error
  • func (wss *WebSocketSink) Collect(ctx api.StreamContext, data interface{}) error
  • func (wss *WebSocketSink) Configure(props map[string]interface{}) error
  • func (wss *WebSocketSink) Open(ctx api.StreamContext) error
  • func (wss *WebSocketSink) Ping(_ string, props map[string]interface{}) error
  • func (wss *WebSocketSink) Validate(props map[string]interface{}) error
• type WebsocketConf
• type WebsocketSource
  • func (wss *WebsocketSource) Close(ctx api.StreamContext) error
  • func (wss *WebsocketSource) Configure(datasource string, props map[string]interface{}) error
  • func (wss *WebsocketSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)
  • func (wss *WebsocketSource) Ping(dataSource string, props map[string]interface{}) error
  • func (wss *WebsocketSource) Validate(props map[string]interface{}) error

Types

type WebSocketSink

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

func (*WebSocketSink) Close

func (wss *WebSocketSink) Close(ctx api.StreamContext) error

func (*WebSocketSink) Collect

func (wss *WebSocketSink) Collect(ctx api.StreamContext, data interface{}) error

func (*WebSocketSink) Configure

func (wss *WebSocketSink) Configure(props map[string]interface{}) error

func (*WebSocketSink) Open

func (wss *WebSocketSink) Open(ctx api.StreamContext) error

func (*WebSocketSink) Ping

func (wss *WebSocketSink) Ping(_ string, props map[string]interface{}) error

func (*WebSocketSink) Validate

func (wss *WebSocketSink) Validate(props map[string]interface{}) error

type WebsocketConf

type WebsocketConf struct {
	Path string `json:"path"`
	Addr string `json:"addr"`
	// TODO: move this as a common config for all sinks
	SendError bool `json:"sendError"`
}

type WebsocketSource

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

func (*WebsocketSource) Close

func (wss *WebsocketSource) Close(ctx api.StreamContext) error

func (*WebsocketSource) Configure

func (wss *WebsocketSource) Configure(datasource string, props map[string]interface{}) error

func (*WebsocketSource) Open

func (wss *WebsocketSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)

func (*WebsocketSource) Ping

func (wss *WebsocketSource) Ping(dataSource string, props map[string]interface{}) error

func (*WebsocketSource) Validate

func (wss *WebsocketSource) Validate(props map[string]interface{}) error