Documentation ¶
Overview ¶
Package socket implements a source that gets input from a socket connection and produces tables given a decoder. This is a good candidate for streaming use cases. For now, it produces a single table for everything that it receives from the start to the end of the connection.
Index ¶
Constants ¶
View Source
const FromSocketKind = "fromSocket"
Variables ¶
This section is empty.
Functions ¶
func NewSocketSource ¶
func NewSocketSource(spec *FromSocketProcedureSpec, rc io.ReadCloser, tp line.TimeProvider, dsid execute.DatasetID) (execute.Source, error)
Types ¶
type FromSocketOpSpec ¶
func (*FromSocketOpSpec) Kind ¶
func (s *FromSocketOpSpec) Kind() flux.OperationKind
type FromSocketProcedureSpec ¶
type FromSocketProcedureSpec struct { plan.DefaultCost URL string Decoder string }
func (*FromSocketProcedureSpec) Copy ¶
func (s *FromSocketProcedureSpec) Copy() plan.ProcedureSpec
func (*FromSocketProcedureSpec) Kind ¶
func (s *FromSocketProcedureSpec) Kind() plan.ProcedureKind
Click to show internal directories.
Click to hide internal directories.