PiPEline

Documentation

Index

• type CmdFunc
• type InChan
• type OutChan
• type Pipe
  • func New() *Pipe
  • func (this *Pipe) Exec(args ...interface{}) OutChan
  • func (this *Pipe) SetCmd(c CmdFunc)
  • func (this *Pipe) SetPipeCmd(c PipeCmdFunc, count int)
• type PipeCmdFunc

Types

type CmdFunc

type CmdFunc func(args ...interface{}) InChan

type InChan

type InChan chan interface{}

type OutChan

type OutChan chan interface{}

type Pipe

type Pipe struct {
	Cmd     CmdFunc
	PipeCmd PipeCmdFunc
	Count   int
}

func New

func New() *Pipe

func (*Pipe) Exec

func (this *Pipe) Exec(args ...interface{}) OutChan

func (*Pipe) SetCmd

func (this *Pipe) SetCmd(c CmdFunc)

func (*Pipe) SetPipeCmd

func (this *Pipe) SetPipeCmd(c PipeCmdFunc, count int)

type PipeCmdFunc

type PipeCmdFunc func(in InChan) OutChan