websocket

Documentation

Index

• func GetSink() api.Sink
• func GetSource() api.Source
• type WebsocketConfig
• type WebsocketSink
  • func (w *WebsocketSink) Close(ctx api.StreamContext) error
  • func (w *WebsocketSink) Collect(ctx api.StreamContext, item api.RawTuple) error
  • func (w *WebsocketSink) Connect(ctx api.StreamContext) error
  • func (w *WebsocketSink) Provision(ctx api.StreamContext, configs map[string]any) error
• type WebsocketSource
  • func (w *WebsocketSource) Close(ctx api.StreamContext) error
  • func (w *WebsocketSource) Connect(ctx api.StreamContext) error
  • func (w *WebsocketSource) Provision(ctx api.StreamContext, configs map[string]any) error
  • func (w *WebsocketSource) Subscribe(ctx api.StreamContext, ingest api.BytesIngest, ingestError api.ErrorIngest) error

Functions

func GetSink

func GetSink() api.Sink

func GetSource

func GetSource() api.Source

Types

type WebsocketConfig

type WebsocketConfig struct {
	Endpoint string `json:"datasource"`
}

type WebsocketSink

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

func (*WebsocketSink) Close

func (w *WebsocketSink) Close(ctx api.StreamContext) error

func (*WebsocketSink) Collect

func (w *WebsocketSink) Collect(ctx api.StreamContext, item api.RawTuple) error

func (*WebsocketSink) Connect

func (w *WebsocketSink) Connect(ctx api.StreamContext) error

func (*WebsocketSink) Provision

func (w *WebsocketSink) Provision(ctx api.StreamContext, configs map[string]any) error

type WebsocketSource

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

func (*WebsocketSource) Close

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

func (*WebsocketSource) Connect

func (w *WebsocketSource) Connect(ctx api.StreamContext) error

func (*WebsocketSource) Provision

func (w *WebsocketSource) Provision(ctx api.StreamContext, configs map[string]any) error

func (*WebsocketSource) Subscribe

func (w *WebsocketSource) Subscribe(ctx api.StreamContext, ingest api.BytesIngest, ingestError api.ErrorIngest) error