scipipe

Oct 14, 2021

Changes in this version

+ func FinalizePaths(tempExecDir string, ips ...*FileIP) error

type BaseProcess

+ func (p *BaseProcess) Audit(msg interface{})

+ func (p *BaseProcess) Auditf(msg string, parts ...interface{})

type FileIP

+ func (ip *FileIP) FinalizePath()

type IP

+ FinalizePath func()

type InParamPort

+ func (pt *InParamPort) Fail(msg interface{})

+ func (pt *InParamPort) Failf(msg string, parts ...interface{})

type InPort

+ func (pt *InPort) Fail(msg interface{})

+ func (pt *InPort) Failf(msg string, parts ...interface{})

type OutParamPort

+ func (pt *OutParamPort) Fail(msg interface{})

+ func (pt *OutParamPort) Failf(msg string, parts ...interface{})

type OutPort

+ func (pt *OutPort) Fail(msg interface{})

+ func (pt *OutPort) Failf(msg string, parts ...interface{})

Aug 28, 2021

Changes in this version

type BaseProcess

+ func (p *BaseProcess) Fail(msg interface{})

type FileIP

+ func (ip *FileIP) Fail(msg interface{})

+ func (ip *FileIP) Failf(msg string, parts ...interface{})

type Process

+ func (p *Process) Fail(msg interface{})

+ func (p *Process) Failf(msg string, parts ...interface{})

type Sink

+ func (p *Sink) Fail(msg interface{})

+ func (p *Sink) Failf(msg string, parts ...interface{})

type Task

+ func (t *Task) Audit(msg string)

+ func (t *Task) Auditf(msg string, parts ...interface{})

+ func (t *Task) Fail(msg interface{})

+ func (t *Task) Failf(msg string, parts ...interface{})

type Workflow

+ func (wf *Workflow) Auditf(msg string, parts ...interface{})

+ func (wf *Workflow) Fail(msg interface{})

+ func (wf *Workflow) Failf(msg string, parts ...interface{})

type WorkflowProcess

+ Fail func(interface{})

+ Failf func(string, ...interface{})

Jun 28, 2021

Changes in this version

type BaseProcess

+ func (p *BaseProcess) Failf(message string, vs ...interface{})

May 21, 2019

Changes in this version

type FileIP

+ func (ip *FileIP) String() string

Jul 26, 2018

Changes in this version

+ const FSRootPlaceHolder

+ const Version

+ func AtomizeIPs(tempExecDir string, ips ...*FileIP)

+ func LogAuditf(componentName string, message string, values ...interface{})

+ func LogAuditln(componentName string, message string)

type AuditInfo

+ ExecTimeNS time.Duration

+ OutFiles map[string]string

+ Tags map[string]string

+ func UnmarshalAuditInfoJSONFile(fileName string) (auditInfo *AuditInfo)

type BaseProcess

+ func (p *BaseProcess) CloseOutParamPorts()

+ func (p *BaseProcess) DeleteInParamPort(portName string)

+ func (p *BaseProcess) DeleteOutParamPort(portName string)

+ func (p *BaseProcess) InParamPort(portName string) *InParamPort

+ func (p *BaseProcess) InParamPorts() map[string]*InParamPort

+ func (p *BaseProcess) InitInParamPort(proc WorkflowProcess, portName string)

+ func (p *BaseProcess) InitOutParamPort(proc WorkflowProcess, portName string)

+ func (p *BaseProcess) OutParamPort(portName string) *OutParamPort

+ func (p *BaseProcess) OutParamPorts() map[string]*OutParamPort

+ func (p *BaseProcess) Ready() (isReady bool)

type FileIP

+ func (ip *FileIP) AddTag(k string, v string)

+ func (ip *FileIP) AddTags(tags map[string]string)

+ func (ip *FileIP) Tag(k string) string

+ func (ip *FileIP) Tags() map[string]string

+ func (ip *FileIP) TempDir() string

+ type InParamPort struct

+ Chan chan string

+ RemotePorts map[string]*OutParamPort

+ func NewInParamPort(name string) *InParamPort

+ func (pip *InParamPort) AddRemotePort(pop *OutParamPort)

+ func (pip *InParamPort) CloseConnection(popName string)

+ func (pip *InParamPort) From(pop *OutParamPort)

+ func (pip *InParamPort) FromFloat(floats ...float64)

+ func (pip *InParamPort) FromInt(ints ...int)

+ func (pip *InParamPort) FromStr(strings ...string)

+ func (pip *InParamPort) Name() string

+ func (pip *InParamPort) Process() WorkflowProcess

+ func (pip *InParamPort) Ready() bool

+ func (pip *InParamPort) Recv() string

+ func (pip *InParamPort) Send(param string)

+ func (pip *InParamPort) SetProcess(p WorkflowProcess)

+ func (pip *InParamPort) SetReady(ready bool)

type InPort

+ func (pt *InPort) From(rpt *OutPort)

+ func (pt *InPort) Ready() bool

+ func (pt *InPort) SetReady(ready bool)

+ type OutParamPort struct

+ RemotePorts map[string]*InParamPort

+ func NewOutParamPort(name string) *OutParamPort

+ func (pop *OutParamPort) AddRemotePort(pip *InParamPort)

+ func (pop *OutParamPort) Close()

+ func (pop *OutParamPort) Disconnect(pipName string)

+ func (pop *OutParamPort) Name() string

+ func (pop *OutParamPort) Process() WorkflowProcess

+ func (pop *OutParamPort) Ready() bool

+ func (pop *OutParamPort) Send(param string)

+ func (pop *OutParamPort) SetProcess(p WorkflowProcess)

+ func (pop *OutParamPort) SetReady(ready bool)

+ func (pop *OutParamPort) To(pip *InParamPort)

type OutPort

+ func (pt *OutPort) Ready() bool

+ func (pt *OutPort) SetReady(ready bool)

+ func (pt *OutPort) To(rpt *InPort)

+ type PortInfo struct

type Process

+ PathFuncs map[string]func(*Task) string

+ PortInfo map[string]*PortInfo

+ func (p *Process) InParam(portName string) *InParamPort

+ func (p *Process) OutParam(portName string) *OutParamPort

+ func (p *Process) SetOut(outPortName string, pathPattern string)

+ func (p *Process) SetOutFunc(outPortName string, pathFmtFunc func(task *Task) (path string))

type Sink

+ func (p *Sink) From(outPort *OutPort)

+ func (p *Sink) FromParam(outParamPort *OutParamPort)

type Task

+ Process *Process

+ Tags map[string]string

+ func (t *Task) Tag(tagName string) string

+ func (t *Task) TempDir() string

type Workflow

+ PlotConf WorkflowPlotConf

+ func (wf *Workflow) DotGraph() (dot string)

+ func (wf *Workflow) PlotGraph(filePath string)

+ func (wf *Workflow) PlotGraphPDF(filePath string)

+ func (wf *Workflow) ProcsSorted() []WorkflowProcess

+ type WorkflowPlotConf struct

+ EdgeLabels bool

type WorkflowProcess

+ InParamPorts func() map[string]*InParamPort

+ OutParamPorts func() map[string]*OutParamPort

+ Ready func() bool

May 26, 2018

Changes in this version

+ func InitLogAuditToFile(filePath string)

type Workflow

+ func NewWorkflowCustomLogFile(name string, maxConcurrentTasks int, logFile string) *Workflow

Apr 20, 2018

Changes in this version

+ func CheckWithMsg(err error, errMsg string)

+ func Fail(vs ...interface{})

+ func Failf(msg string, vs ...interface{})

type AuditInfo

+ FinishTime time.Time

+ ID string

+ ProcessName string

+ StartTime time.Time

+ type BaseIP struct

+ func NewBaseIP(path string) *BaseIP

+ func (ip *BaseIP) ID() string

type BaseProcess

+ func (p *BaseProcess) CloseAllOutPorts()

+ func (p *BaseProcess) CloseOutPorts()

+ func (p *BaseProcess) CloseParamOutPorts()

+ type FileIP struct

+ SubStream *InPort

+ func NewFileIP(path string) *FileIP

+ func (ip *FileIP) AddKey(k string, v string)

+ func (ip *FileIP) AddKeys(keys map[string]string)

+ func (ip *FileIP) Atomize()

+ func (ip *FileIP) AuditFilePath() string

+ func (ip *FileIP) AuditInfo() *AuditInfo

+ func (ip *FileIP) CreateFifo()

+ func (ip *FileIP) Exists() bool

+ func (ip *FileIP) FifoFileExists() bool

+ func (ip *FileIP) FifoPath() string

+ func (ip *FileIP) Key(k string) string

+ func (ip *FileIP) Keys() map[string]string

+ func (ip *FileIP) Open() *os.File

+ func (ip *FileIP) OpenTemp() *os.File

+ func (ip *FileIP) OpenWriteTemp() *os.File

+ func (ip *FileIP) Param(key string) string

+ func (ip *FileIP) Path() string

+ func (ip *FileIP) Read() []byte

+ func (ip *FileIP) ReadAuditFile() []byte

+ func (ip *FileIP) RemoveFifo()

+ func (ip *FileIP) SetAuditInfo(ai *AuditInfo)

+ func (ip *FileIP) Size() int64

+ func (ip *FileIP) TempFileExists() bool

+ func (ip *FileIP) TempPath() string

+ func (ip *FileIP) UnMarshalJSON(v interface{})

+ func (ip *FileIP) Write(dat []byte)

+ func (ip *FileIP) WriteAuditLogToFile()

+ type FileIPGenerator struct

+ FilePaths []string

+ func NewFileIPGenerator(wf *Workflow, name string, filePaths ...string) (p *FileIPGenerator)

+ func (p *FileIPGenerator) Out() *OutPort

+ func (p *FileIPGenerator) Run()

type IP

+ Digest func() string

+ EnsureStaged func()

+ EnsureUnstaged func()

+ ID func() string

+ ParamType func() int

+ StagedPath func() string

+ URL func() string

type Task

+ InIPs map[string]*FileIP

+ OutIPs map[string]*FileIP

+ func (t *Task) InIP(portName string) *FileIP

+ func (t *Task) OutIP(portName string) *FileIP

+ func (t *Task) OutPath(portName string) string

type Workflow

+ func (wf *Workflow) RunToRegex(procNamePatterns ...string)

Feb 7, 2018

Changes in this version

+ func ConnectFrom(inPort *InPort, outPort *OutPort)

+ func ConnectTo(outPort *OutPort, inPort *InPort)

+ type BaseProcess struct

+ func NewBaseProcess(wf *Workflow, name string) BaseProcess

+ func (p *BaseProcess) Connected() (isConnected bool)

+ func (p *BaseProcess) DeleteInPort(portName string)

+ func (p *BaseProcess) DeleteOutPort(portName string)

+ func (p *BaseProcess) DeleteParamInPort(portName string)

+ func (p *BaseProcess) DeleteParamOutPort(portName string)

+ func (p *BaseProcess) InPort(portName string) *InPort

+ func (p *BaseProcess) InPorts() map[string]*InPort

+ func (p *BaseProcess) InitInPort(proc WorkflowProcess, portName string)

+ func (p *BaseProcess) InitOutPort(proc WorkflowProcess, portName string)

+ func (p *BaseProcess) InitParamInPort(proc WorkflowProcess, portName string)

+ func (p *BaseProcess) InitParamOutPort(proc WorkflowProcess, portName string)

+ func (p *BaseProcess) Name() string

+ func (p *BaseProcess) OutPort(portName string) *OutPort

+ func (p *BaseProcess) OutPorts() map[string]*OutPort

+ func (p *BaseProcess) ParamInPort(portName string) *ParamInPort

+ func (p *BaseProcess) ParamInPorts() map[string]*ParamInPort

+ func (p *BaseProcess) ParamOutPort(portName string) *ParamOutPort

+ func (p *BaseProcess) ParamOutPorts() map[string]*ParamOutPort

+ func (p *BaseProcess) Workflow() *Workflow

+ type EmptyWorkflowProcess struct

+ func (ep *EmptyWorkflowProcess) InPorts() map[string]*InPort

+ func (ep *EmptyWorkflowProcess) OutPorts() map[string]*OutPort

+ func (ep *EmptyWorkflowProcess) ParamInPorts() map[string]*ParamInPort

+ func (ep *EmptyWorkflowProcess) ParamOutPorts() map[string]*ParamOutPort

+ type IP struct

+ SubStream *InPort

+ func NewIP(path string) *IP

+ func (ip *IP) AddKey(k string, v string)

+ func (ip *IP) AddKeys(keys map[string]string)

+ func (ip *IP) Atomize()

+ func (ip *IP) AuditFilePath() string

+ func (ip *IP) AuditInfo() *AuditInfo

+ func (ip *IP) CreateFifo()

+ func (ip *IP) Exists() bool

+ func (ip *IP) FifoFileExists() bool

+ func (ip *IP) FifoPath() string

+ func (ip *IP) Key(k string) string

+ func (ip *IP) Keys() map[string]string

+ func (ip *IP) Open() *os.File

+ func (ip *IP) OpenTemp() *os.File

+ func (ip *IP) OpenWriteTemp() *os.File

+ func (ip *IP) Param(key string) string

+ func (ip *IP) Path() string

+ func (ip *IP) Read() []byte

+ func (ip *IP) ReadAuditFile() []byte

+ func (ip *IP) RemoveFifo()

+ func (ip *IP) SetAuditInfo(ai *AuditInfo)

+ func (ip *IP) Size() int64

+ func (ip *IP) TempFileExists() bool

+ func (ip *IP) TempPath() string

+ func (ip *IP) UnMarshalJSON(v interface{})

+ func (ip *IP) WriteAuditLogToFile()

+ func (ip *IP) WriteTempFile(dat []byte)

type IPGen

+ func (ipg *IPGen) Connected() bool

+ func (ipg *IPGen) OutPorts() map[string]*OutPort

+ type InPort struct

+ Chan chan *IP

+ RemotePorts map[string]*OutPort

+ func NewInPort(name string) *InPort

+ func (pt *InPort) AddRemotePort(rpt *OutPort)

+ func (pt *InPort) CloseConnection(rptName string)

+ func (pt *InPort) Connect(rpt *OutPort)

+ func (pt *InPort) Connected() bool

+ func (pt *InPort) Disconnect(rptName string)

+ func (pt *InPort) Name() string

+ func (pt *InPort) Process() WorkflowProcess

+ func (pt *InPort) Recv() *IP

+ func (pt *InPort) Send(ip *IP)

+ func (pt *InPort) SetConnectedStatus(connected bool)

+ func (pt *InPort) SetProcess(p WorkflowProcess)

+ type OutPort struct

+ RemotePorts map[string]*InPort

+ func NewOutPort(name string) *OutPort

+ func (pt *OutPort) AddRemotePort(rpt *InPort)

+ func (pt *OutPort) Close()

+ func (pt *OutPort) Connect(rpt *InPort)

+ func (pt *OutPort) Connected() bool

+ func (pt *OutPort) Disconnect(rptName string)

+ func (pt *OutPort) Name() string

+ func (pt *OutPort) Process() WorkflowProcess

+ func (pt *OutPort) Send(ip *IP)

+ func (pt *OutPort) SetConnectedStatus(connected bool)

+ func (pt *OutPort) SetProcess(p WorkflowProcess)

+ type ParamInPort struct

+ Chan chan string

+ RemotePorts map[string]*ParamOutPort

+ func NewParamInPort(name string) *ParamInPort

+ func (pip *ParamInPort) AddRemotePort(pop *ParamOutPort)

+ func (pip *ParamInPort) CloseConnection(popName string)

+ func (pip *ParamInPort) Connect(pop *ParamOutPort)

+ func (pip *ParamInPort) ConnectStr(strings ...string)

+ func (pip *ParamInPort) Connected() bool

+ func (pip *ParamInPort) Name() string

+ func (pip *ParamInPort) Process() WorkflowProcess

+ func (pip *ParamInPort) Recv() string

+ func (pip *ParamInPort) Send(param string)

+ func (pip *ParamInPort) SetConnectedStatus(connected bool)

+ func (pt *ParamInPort) SetProcess(p WorkflowProcess)

+ type ParamOutPort struct

+ RemotePorts map[string]*ParamInPort

+ func NewParamOutPort(name string) *ParamOutPort

+ func (pop *ParamOutPort) AddRemotePort(pip *ParamInPort)

+ func (pop *ParamOutPort) Close()

+ func (pop *ParamOutPort) Connect(pip *ParamInPort)

+ func (pop *ParamOutPort) Connected() bool

+ func (pop *ParamOutPort) Disconnect(pipName string)

+ func (pop *ParamOutPort) Name() string

+ func (pop *ParamOutPort) Process() WorkflowProcess

+ func (pop *ParamOutPort) Send(param string)

+ func (pop *ParamOutPort) SetConnectedStatus(connected bool)

+ func (pt *ParamOutPort) SetProcess(p WorkflowProcess)

type Process

+ CommandPattern string

+ CoresPerTask int

+ CustomExecute func(*Task)

+ ExecMode ExecMode

+ OutPortsDoStream map[string]bool

+ PathFormatters map[string]func(*Task) string

+ Prepend string

+ Spawn bool

+ func (p *Process) In(portName string) *InPort

+ func (p *Process) Out(portName string) *OutPort

+ func (p *Process) SetPathCustom(outPortName string, pathFmtFunc func(task *Task) (path string))

+ func (p *Process) SetPathExtend(inPortName string, outPortName string, extension string)

+ func (p *Process) SetPathReplace(inPortName string, outPortName string, old string, new string)

+ func (p *Process) SetPathStatic(outPortName string, path string)

type Sink

+ func (p *Sink) ConnectParam(paramOutPort *ParamOutPort)

+ func (p *Sink) Connected() bool

+ type Task struct

+ Command string

+ CustomExecute func(*Task)

+ DataFolder string

+ Done chan int

+ ExecMode ExecMode

+ Image string

+ InTargets map[string]*IP

+ Name string

+ OutTargets map[string]*IP

+ Params map[string]string

+ func NewTask(workflow *Workflow, name string, cmdPat string, inTargets map[string]*IP, ...) *Task

+ func (t *Task) Execute()

+ func (t *Task) InPath(portName string) string

+ func (t *Task) Param(portName string) string

type Workflow

+ func (wf *Workflow) Name() string

+ func (wf *Workflow) RunProcsByName(procNames ...string)

+ func (wf *Workflow) RunTo(finalProcNames ...string)

+ func (wf *Workflow) RunToProcs(finalProcs ...WorkflowProcess)

+ type WorkflowProcess interface

+ Connected func() bool

+ InPorts func() map[string]*InPort

+ Name func() string

+ OutPorts func() map[string]*OutPort

+ ParamInPorts func() map[string]*ParamInPort

+ ParamOutPorts func() map[string]*ParamOutPort

+ Run func()

Jan 23, 2018

Changes in this version

type InformationPacket

+ func (ip *InformationPacket) FifoFileExists() bool

Nov 16, 2017

Changes in this version

+ const BUFSIZE

+ var Audit *log.Logger

+ var Debug *log.Logger

+ var Error *log.Logger

+ var Info *log.Logger

+ var LogExists bool

+ var Trace *log.Logger

+ var Warning *log.Logger

+ func Check(err error, errMsg string)

+ func CheckErr(err error)

+ func Connect(port1 *FilePort, port2 *FilePort)

+ func ExecCmd(cmd string) string

+ func ExpandParams(cmd string, params map[string]string) string

+ func InitLog(traceHandle io.Writer, debugHandle io.Writer, infoHandle io.Writer, ...)

+ func InitLogAudit()

+ func InitLogDebug()

+ func InitLogError()

+ func InitLogInfo()

+ func InitLogWarning()

+ type AuditInfo struct

+ Command string

+ ExecTimeMS time.Duration

+ Keys map[string]string

+ Params map[string]string

+ Upstream map[string]*AuditInfo

+ func NewAuditInfo() *AuditInfo

+ type ExecMode int

+ const ExecModeLocal

+ const ExecModeSLURM

+ type FilePort struct

+ InChan chan *InformationPacket

+ func NewFilePort() *FilePort

+ func (localPort *FilePort) Connect(remotePort *FilePort)

+ func (pt *FilePort) AddInChan(inChan chan *InformationPacket)

+ func (pt *FilePort) AddOutChan(outChan chan *InformationPacket)

+ func (pt *FilePort) Close()

+ func (pt *FilePort) IsConnected() bool

+ func (pt *FilePort) Recv() *InformationPacket

+ func (pt *FilePort) RunMergeInputs()

+ func (pt *FilePort) Send(ip *InformationPacket)

+ func (pt *FilePort) SetConnectedStatus(connected bool)

+ type IPGen struct

+ FilePaths []string

+ Out *FilePort

+ func NewIPGen(workflow *Workflow, name string, filePaths ...string) (fq *IPGen)

+ func (ipg *IPGen) IsConnected() bool

+ func (ipg *IPGen) Name() string

+ func (ipg *IPGen) Run()

+ type InformationPacket struct

+ SubStream *FilePort

+ func NewInformationPacket(path string) *InformationPacket

+ func (ip *InformationPacket) AddKey(k string, v string)

+ func (ip *InformationPacket) AddKeys(keys map[string]string)

+ func (ip *InformationPacket) Atomize()

+ func (ip *InformationPacket) CreateFifo()

+ func (ip *InformationPacket) Exists() bool

+ func (ip *InformationPacket) GetAuditFilePath() string

+ func (ip *InformationPacket) GetAuditInfo() *AuditInfo

+ func (ip *InformationPacket) GetFifoPath() string

+ func (ip *InformationPacket) GetKey(k string) string

+ func (ip *InformationPacket) GetKeys() map[string]string

+ func (ip *InformationPacket) GetParam(key string) string

+ func (ip *InformationPacket) GetPath() string

+ func (ip *InformationPacket) GetSize() int64

+ func (ip *InformationPacket) GetTempPath() string

+ func (ip *InformationPacket) Open() *os.File

+ func (ip *InformationPacket) OpenTemp() *os.File

+ func (ip *InformationPacket) OpenWriteTemp() *os.File

+ func (ip *InformationPacket) Read() []byte

+ func (ip *InformationPacket) ReadAuditFile() []byte

+ func (ip *InformationPacket) RemoveFifo()

+ func (ip *InformationPacket) SetAuditInfo(ai *AuditInfo)

+ func (ip *InformationPacket) TempFileExists() bool

+ func (ip *InformationPacket) UnMarshalJson(v interface{})

+ func (ip *InformationPacket) WriteAuditLogToFile()

+ func (ip *InformationPacket) WriteTempFile(dat []byte)

+ type ParamPort struct

+ Chan chan string

+ func NewParamPort() *ParamPort

+ func (pp *ParamPort) Close()

+ func (pp *ParamPort) Connect(otherParamPort *ParamPort)

+ func (pp *ParamPort) ConnectStr(strings ...string)

+ func (pp *ParamPort) IsConnected() bool

+ func (pp *ParamPort) Recv() string

+ func (pp *ParamPort) Send(param string)

+ func (pp *ParamPort) SetConnectedStatus(connected bool)

+ type Port interface

+ Connect func(Port)

+ IsConnected func() bool

+ SetConnectedStatus func(bool)

+ type Process interface

+ IsConnected func() bool

+ Name func() string

+ Run func()

+ type SciProcess struct

+ CommandPattern string

+ CoresPerTask int

+ CustomExecute func(*SciTask)

+ ExecMode ExecMode

+ OutPortsDoStream map[string]bool

+ PathFormatters map[string]func(*SciTask) string

+ Prepend string

+ Spawn bool

+ func NewProc(workflow *Workflow, name string, cmd string) *SciProcess

+ func NewSciProcess(workflow *Workflow, name string, command string) *SciProcess

+ func ShellExpand(workflow *Workflow, name string, cmd string, inPaths map[string]string, ...) *SciProcess

+ func (p *SciProcess) GetInPorts() map[string]*FilePort

+ func (p *SciProcess) GetOutPorts() map[string]*FilePort

+ func (p *SciProcess) GetParamPorts() map[string]*ParamPort

+ func (p *SciProcess) In(portName string) *FilePort

+ func (p *SciProcess) Name() string

+ func (p *SciProcess) Out(portName string) *FilePort

+ func (p *SciProcess) PP(paramPortName string) *ParamPort

+ func (p *SciProcess) ParamPort(paramPortName string) *ParamPort

+ func (p *SciProcess) Run()

+ func (p *SciProcess) SetInPort(portName string, port *FilePort)

+ func (p *SciProcess) SetOutPort(portName string, port *FilePort)

+ func (p *SciProcess) SetParamPort(paramPortName string, paramPort *ParamPort)

+ func (p *SciProcess) SetPathCustom(outPortName string, pathFmtFunc func(task *SciTask) (path string))

+ func (p *SciProcess) SetPathExtend(inPortName string, outPortName string, extension string)

+ func (p *SciProcess) SetPathReplace(inPortName string, outPortName string, old string, new string)

+ func (p *SciProcess) SetPathStatic(outPortName string, path string)

+ func (proc *SciProcess) IsConnected() (isConnected bool)

+ type SciTask struct

+ Command string

+ CustomExecute func(*SciTask)

+ DataFolder string

+ Done chan int

+ ExecMode ExecMode

+ Image string

+ InTargets map[string]*InformationPacket

+ Name string

+ OutTargets map[string]*InformationPacket

+ Params map[string]string

+ func NewSciTask(workflow *Workflow, name string, cmdPat string, ...) *SciTask

+ func (t *SciTask) Execute()

+ func (t *SciTask) InPath(portName string) string

+ func (t *SciTask) Param(portName string) string

+ type ShellProcess interface

+ GetInPorts func() map[string]*FilePort

+ GetOutPorts func() map[string]*FilePort

+ In func(string) *FilePort

+ Out func(string) *FilePort

+ SetPathCustom func(outPortName string, pathFmtFunc func(task *SciTask) (path string))

+ SetPathExtend func(inPortName string, outPortName string, extension string)

+ SetPathReplace func(inPortName string, outPortName string, old string, new string)

+ SetPathStatic func(outPortName string, path string)

+ type Sink struct

+ func NewSink(name string) (s *Sink)

+ func (p *Sink) Connect(outPort *FilePort)

+ func (p *Sink) IsConnected() bool

+ func (p *Sink) Name() string

+ func (p *Sink) Run()

+ type Workflow struct

+ func NewWorkflow(name string, maxConcurrentTasks int) *Workflow

+ func (wf *Workflow) AddProc(proc Process)

+ func (wf *Workflow) AddProcs(procs ...Process)

+ func (wf *Workflow) ConnectLast(outPort *FilePort)

+ func (wf *Workflow) DecConcurrentTasks(slots int)

+ func (wf *Workflow) Driver() Process

+ func (wf *Workflow) IncConcurrentTasks(slots int)

+ func (wf *Workflow) NewProc(procName string, commandPattern string) *SciProcess

+ func (wf *Workflow) Proc(procName string) Process

+ func (wf *Workflow) Procs() map[string]Process

+ func (wf *Workflow) Run()

+ func (wf *Workflow) SetDriver(driver Process)

+ func (wf *Workflow) SetSink(sink *Sink)

+ func (wf *Workflow) Sink() *Sink