package socket

import "github.com/influxdata/flux/stdlib/socket"

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, dsid execute.DatasetID) (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

Source Files ¶

from.go