csv

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)

Variables

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