scipipe: github.com/scipipe/scipipe/components Index | Files

package components

import "github.com/scipipe/scipipe/components"

Index

Package Files

accumulator.go concatenator.go fanout.go file_globber.go file_reader.go file_splitter.go file_writer.go merger.go streamtosubstream.go stringgen.go strtobyte.go utils.go

func Check Uses

func Check(err error)

func NewStrToByte Uses

func NewStrToByte() *strToByte

type AccumulatorInt Uses

type AccumulatorInt struct {
    scipipe.Process
    In          *scipipe.FilePort
    Out         *scipipe.FilePort
    Accumulator int
    OutPath     string
}

func NewAccumulatorInt Uses

func NewAccumulatorInt(outPath string) *AccumulatorInt

func (*AccumulatorInt) Run Uses

func (proc *AccumulatorInt) Run()

type Concatenator Uses

type Concatenator struct {
    scipipe.Process

    In      *scipipe.FilePort
    Out     *scipipe.FilePort
    OutPath string
    // contains filtered or unexported fields
}

func NewConcatenator Uses

func NewConcatenator(name string, outPath string) *Concatenator

func (*Concatenator) IsConnected Uses

func (proc *Concatenator) IsConnected() bool

func (*Concatenator) Name Uses

func (proc *Concatenator) Name() string

func (*Concatenator) Run Uses

func (proc *Concatenator) Run()

type FanOut Uses

type FanOut struct {
    scipipe.Process

    InFile *scipipe.FilePort
    // contains filtered or unexported fields
}

FanOut sends *FileTarget received on the InFile in-bound port, and sends them on all out-ports created via the Out method.

func NewFanOut Uses

func NewFanOut(name string) *FanOut

NewFanOut creates a new FanOut process

func (*FanOut) IsConnected Uses

func (proc *FanOut) IsConnected() bool

func (*FanOut) Name Uses

func (proc *FanOut) Name() string

func (*FanOut) Out Uses

func (p *FanOut) Out(portName string) *scipipe.FilePort

func (*FanOut) Run Uses

func (proc *FanOut) Run()

Run runs the FanOut process

type FileGlobber Uses

type FileGlobber struct {
    scipipe.Process
    Out *scipipe.FilePort
    // contains filtered or unexported fields
}

func NewFileGlobber Uses

func NewFileGlobber(globPattern string) *FileGlobber

func (*FileGlobber) IsConnected Uses

func (p *FileGlobber) IsConnected() bool

func (*FileGlobber) Run Uses

func (p *FileGlobber) Run()

type FileReader Uses

type FileReader struct {
    scipipe.Process
    FilePath chan string
    OutLine  chan []byte
}

FileReader takes a file path on its FilePath in-port, and returns the file content as []byte on its out-port Out

func NewFileReader Uses

func NewFileReader() *FileReader

Instantiate a new FileReader

func (*FileReader) Run Uses

func (proc *FileReader) Run()

Run the FileReader

type FileSplitter Uses

type FileSplitter struct {
    scipipe.Process

    InFile        *scipipe.FilePort
    OutSplitFile  *scipipe.FilePort
    LinesPerSplit int
    // contains filtered or unexported fields
}

func NewFileSplitter Uses

func NewFileSplitter(name string, linesPerSplit int) *FileSplitter

func (*FileSplitter) IsConnected Uses

func (proc *FileSplitter) IsConnected() bool

func (*FileSplitter) Name Uses

func (proc *FileSplitter) Name() string

func (*FileSplitter) Run Uses

func (proc *FileSplitter) Run()

type FileWriter Uses

type FileWriter struct {
    scipipe.Process
    In       chan []byte
    FilePath chan string
}

FileWriter takes a file path on its FilePath in-port, file contents on its In in-port and write the file contents to a file with the specified path.

func NewFileWriter Uses

func NewFileWriter() *FileWriter

func NewFileWriterFromPath Uses

func NewFileWriterFromPath(path string) *FileWriter

func (*FileWriter) IsConnected Uses

func (proc *FileWriter) IsConnected() bool

func (*FileWriter) Run Uses

func (proc *FileWriter) Run()

type Merger Uses

type Merger struct {
    Out *scipipe.FilePort
    // contains filtered or unexported fields
}

func NewMerger Uses

func NewMerger() *Merger

func (*Merger) Connect Uses

func (proc *Merger) Connect(outPort *scipipe.FilePort)

func (*Merger) Run Uses

func (proc *Merger) Run()

type StreamToSubStream Uses

type StreamToSubStream struct {
    scipipe.Process

    In           *scipipe.FilePort
    OutSubStream *scipipe.FilePort
    // contains filtered or unexported fields
}

StreamToSubStream takes a normal stream of InformationPacket's representing individual files, and returns one InformationPacket where the incoming IPs are sent on its substream.

func NewStreamToSubStream Uses

func NewStreamToSubStream(name string) *StreamToSubStream

Instantiate a new StreamToSubStream

func (*StreamToSubStream) IsConnected Uses

func (p *StreamToSubStream) IsConnected() bool

func (*StreamToSubStream) Name Uses

func (p *StreamToSubStream) Name() string

func (*StreamToSubStream) Run Uses

func (p *StreamToSubStream) Run()

Run the StreamToSubStream

type StringGen Uses

type StringGen struct {
    scipipe.Process

    Strings []string
    Out     *scipipe.ParamPort
    // contains filtered or unexported fields
}

StringGen takes a number of strings and returns a generator process which sends the strings, one by one, on its `Out` port

func NewStringGen Uses

func NewStringGen(name string, strings ...string) *StringGen

Instantiate a new StringGen

func (*StringGen) IsConnected Uses

func (proc *StringGen) IsConnected() bool

func (*StringGen) Name Uses

func (proc *StringGen) Name() string

func (*StringGen) Run Uses

func (proc *StringGen) Run()

Run the StringGen

Package components imports 9 packages (graph). Updated 2017-06-17. Refresh now. Tools for package owners.