csv

package
v0.0.0-...-5d6a5f9 Latest Latest
Warning

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

Go to latest
Published: Mar 23, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

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