csv

package

v0.0.0-...-ebf99ae Latest Latest Go to latest Published: Nov 2, 2021 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/MasteryConnect/pipe

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Read(delim rune) func(<-chan interface{}, chan<- interface{}, chan<- error)
func ReadStream(delim rune) func(<-chan interface{}, chan<- interface{}, chan<- error)
type To
- func (t To) T(in <-chan interface{}, out chan<- interface{}, errs chan<- error)

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrUnknownType = errors.New("unknown type")

ErrUnknownType is the error for when we don't know how to conver the message to a []string

Functions ¶

func Read ¶

func Read(delim rune) func(<-chan interface{}, chan<- interface{}, chan<- error)

Read will create a new csv reader per message

func ReadStream ¶

func ReadStream(delim rune) func(<-chan interface{}, chan<- interface{}, chan<- error)

ReadStream will read the string messages

Types ¶

type To ¶

type To struct {
	ShowHeader bool     // indicate if we should show the header on the first record
	Header     []string // let the user specify the header to be shown
	// contains filtered or unexported fields
}

To will convert incoming messages to a csv message output and send downstream

func (To) T ¶

func (t To) T(in <-chan interface{}, out chan<- interface{}, errs chan<- error)

T implements the Tfunc interface

Source Files ¶

View all Source files

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