Documentation
¶
Overview ¶
This source 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
Source Files
Click to show internal directories.
Click to hide internal directories.