socket

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
• func NewSocketSource(spec *FromSocketProcedureSpec, rc io.ReadCloser, tp line.TimeProvider, ...) (execute.Source, error)
• type FromSocketOpSpec
  • func (s *FromSocketOpSpec) Kind() flux.OperationKind
• type FromSocketProcedureSpec
  • func (s *FromSocketProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *FromSocketProcedureSpec) Kind() plan.ProcedureKind

Constants

const FromSocketKind = "fromSocket"

Functions

func NewSocketSource

func NewSocketSource(spec *FromSocketProcedureSpec, rc io.ReadCloser, tp line.TimeProvider, dsid execute.DatasetID) (execute.Source, error)

Types

type FromSocketOpSpec

type FromSocketOpSpec struct {
	URL     string `json:"url"`
	Decoder string `json:"decoder"`
}

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