gocsvstreamer: github.com/ryanbennettvoid/gocsvstreamer Index | Files | Directories

package gocsvstreamer

import "github.com/ryanbennettvoid/gocsvstreamer"

Index

Package Files

callback.go csvstreamer.go line.go

type Callback Uses

type Callback func(data interface{})

type CsvStreamer Uses

type CsvStreamer struct {
    Url              string
    Listeners        map[string][]Callback
    Columns          []string
    NumRowsProcessed int
    // contains filtered or unexported fields
}

func New Uses

func New() CsvStreamer

func (*CsvStreamer) Emit Uses

func (streamer *CsvStreamer) Emit(eventName string, data interface{})

func (*CsvStreamer) On Uses

func (streamer *CsvStreamer) On(eventName string, fn Callback)

func (*CsvStreamer) Run Uses

func (streamer *CsvStreamer) Run(ctx context.Context) error

type Line Uses

type Line struct {
    Columns []string
    Data    map[string]interface{}
}

func NewLine Uses

func NewLine() Line

func (*Line) AsString Uses

func (line *Line) AsString() string

Directories

PathSynopsis
events
example

Package gocsvstreamer imports 6 packages (graph) and is imported by 1 packages. Updated 2019-05-20. Refresh now. Tools for package owners.