NewDiscardingWindow returns a new processing time based DiscardingWindow.

NewDiscardingWindowWithTSExtractor returns a new event time based DiscardingWindow.

NewTCPSink returns a new instance of TCPSink with an optional timeout (defaults to 10 seconds).

NewTCPSource returns a new instance of TCPSource.

NewWebSocketSink creates and returns a new WebSocketSink using an existing connection.

NewWebSocketSource creates and returns a new WebSocketSource using an existing connection.

Message represents a WebSocket message container.

TCPSink represents an outbound network socket connector.

TCPSource represents an inbound network socket connector.

WebSocketSink represents a Fiber WebSocket sink connector.

WebSocketSource represents a Fiber WebSocket source connector.