util

package module
v0.0.0-...-379a920 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2015 License: MIT Imports: 6 Imported by: 2

README

#Util GoDoc package util provides useful stages to work with files and pipes.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Concat 

func Concat(ctx context.Context, name string) gonzo.Stage

Concatenates all the files from the input channel and passes them to output channel with the given name.

func Do 

func Do(do func(gonzo.File) gonzo.File) gonzo.Stage

A simple transformation gonzoStage, sends the file to output channel after passing it through the the "do" function.

func List 

func List(checkpoint string) gonzo.Stage

For The Glory of Debugging.

func Merge 

func Merge(ctx context.Context, pipes ...gonzo.Pipe) gonzo.Pipe

Merge concurrently Merges the output of multiple chan of gonzo.File into a pipe.

func Queue 

func Queue(pipe gonzo.Pipe, pipes ...gonzo.Pipe) gonzo.Pipe

Merges the output of multiple chan of gonzo.File into a pipe in a serial manner. (i.e Reads first chan until the end and moves to the next until the last channel is finished.

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.