liner

README

liner

line processing utility for golang

go get -u github.com/0x75960

usage

import (

	// ...

	"github.com/0x75960/liner"
)

func main() {

	f, err := os.Open("/path/to/files")
	if err != nil {
		log.Fatalln(err)
	}

	defer f.Close()

	for line := range liner.LinesIn(f) {
		fmt.Println(line)
	}

	proc(f)

}

Documentation

Index

• func LinesIn(r io.Reader) (o chan string)
• func LinesInProcessing(cmd *exec.Cmd) (o chan string, err error)
• func NewConcurrentLineProcessor(handler func(string) error, concurrency uint, strategy ErrStrategy) func(io.Reader)
• func NewLineProcessor(handler func(string) error, strategy ErrStrategy) func(io.Reader)
• type ErrStrategy

Functions

func LinesIn

func LinesIn(r io.Reader) (o chan string)

LinesIn from io.Reader

func LinesInProcessing

func LinesInProcessing(cmd *exec.Cmd) (o chan string, err error)

LinesInProcessing Command

func NewConcurrentLineProcessor

func NewConcurrentLineProcessor(handler func(string) error, concurrency uint, strategy ErrStrategy) func(io.Reader)

NewConcurrentLineProcessor from handler and strategy

func NewLineProcessor

func NewLineProcessor(handler func(string) error, strategy ErrStrategy) func(io.Reader)

NewLineProcessor from handler and strategy

Types

type ErrStrategy

type ErrStrategy int

ErrStrategy when encounting error

const (
	// IgnoreWhenError (no logging and continue)
	IgnoreWhenError ErrStrategy = iota

	// LogWhenError (continue)
	LogWhenError

	// StopWhenError (not continue)
	StopWhenError
)