socket

package
v0.57.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 10, 2019 License: MIT Imports: 16 Imported by: 1

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

Types

type FromSocketOpSpec

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

func (*FromSocketOpSpec) Kind

type FromSocketProcedureSpec

type FromSocketProcedureSpec struct {
	plan.DefaultCost
	URL     string
	Decoder string
}

func (*FromSocketProcedureSpec) Copy

func (*FromSocketProcedureSpec) Kind

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL