Versions in this module Expand all Collapse all v0 v0.3.1 Aug 16, 2021 Changes in this version + func AssertType(hasType, expectType string, action string) + func ConvertKwargsToCmdLineArgs(kwargs KwArgs) []string + func DebugNodes(node []DagNode) + func DebugOutGoingMap(node []DagNode, m map[int]map[Label][]NodeInfo) + func Probe(fileName string, kwargs ...KwArgs) (string, error) + func ProbeWithTimeout(fileName string, timeOut time.Duration, kwargs KwArgs) (string, error) + func ProbeWithTimeoutExec(fileName string, timeOut time.Duration, kwargs KwArgs) (string, error) + type Args []string + func (a Args) EscapeWith(chars string) Args + func (a Args) Sorted() Args + type DagEdge struct + DownStreamLabel Label + DownStreamNode DagNode + UpStreamLabel Label + UpStreamNode DagNode + UpStreamSelector Selector + func GetInComingEdges(downStreamNode DagNode, inComingEdgeMap map[Label]NodeInfo) []DagEdge + func GetOutGoingEdges(upStreamNode DagNode, outOutingEdgeMap map[Label][]NodeInfo) []DagEdge + type DagNode interface + Equal func(other DagNode) bool + Hash func() int + IncomingEdgeMap func() map[Label]NodeInfo + ShortRepr func() string + String func() string + func TopSort(downStreamNodes []DagNode) (sortedNodes []DagNode, outOutingEdgeMaps map[int]map[Label][]NodeInfo, ...) + type Graph struct + GraphOptions GraphOptions + Nodes []GraphNode + OutputStream string + type GraphNode struct + Args Args + InputStreams []string + KwArgs KwArgs + Name string + OutputStreams []string + type GraphOptions struct + OverWriteOutput bool + Timeout time.Duration + type KwArgs map[string]interface + func (a KwArgs) Copy() KwArgs + func (a KwArgs) EscapeWith(chars string) KwArgs + func (a KwArgs) GetDefault(k string, defaultV interface{}) interface{} + func (a KwArgs) GetString(k string) string + func (a KwArgs) HasKey(k string) bool + func (a KwArgs) PopDefault(k string, defaultV interface{}) interface{} + func (a KwArgs) PopString(k string) string + func (a KwArgs) SortedKeys() []string + func MergeKwArgs(args []KwArgs) KwArgs + type Label string + type Node struct + func FilterMultiOutput(streamSpec []*Stream, filterName string, args Args, kwArgs ...KwArgs) *Node + func NewFilterNode(name string, streamSpec []*Stream, maxInput int, args []string, kwargs KwArgs) *Node + func NewGlobalNode(name string, streamSpec []*Stream, args []string, kwargs KwArgs) *Node + func NewInputNode(name string, args []string, kwargs KwArgs) *Node + func NewMergeOutputsNode(name string, streamSpec []*Stream) *Node + func NewNode(streamSpec []*Stream, name string, incomingStreamTypes sets.String, ...) *Node + func NewOutputNode(name string, streamSpec []*Stream, args []string, kwargs KwArgs) *Node + func (n *Node) Equal(other DagNode) bool + func (n *Node) Get(a string) *Stream + func (n *Node) GetFilter(outgoingEdges []DagEdge) string + func (n *Node) GetInComingEdges() []DagEdge + func (n *Node) Hash() int + func (n *Node) IncomingEdgeMap() map[Label]NodeInfo + func (n *Node) ShortRepr() string + func (n *Node) Stream(label Label, selector Selector) *Stream + func (n *Node) String() string + type NodeInfo struct + Label Label + Node DagNode + Selector Selector + type RunHook struct + type Selector string + type Stream struct + Context context.Context + Label Label + Node *Node + Selector Selector + Type string + func Concat(streams []*Stream, kwargs ...KwArgs) *Stream + func Filter(streamSpec []*Stream, filterName string, args Args, kwArgs ...KwArgs) *Stream + func Input(filename string, kwargs ...KwArgs) *Stream + func MergeOutputs(streams ...*Stream) *Stream + func NewStream(node *Node, streamType string, label Label, selector Selector) *Stream + func Output(streams []*Stream, fileName string, kwargs ...KwArgs) *Stream + func (s *Stream) ASplit() *Node + func (s *Stream) Audio() *Stream + func (s *Stream) ColorChannelMixer(kwargs ...KwArgs) *Stream + func (s *Stream) Compile() *exec.Cmd + func (s *Stream) Concat(streams []*Stream, kwargs ...KwArgs) *Stream + func (s *Stream) Crop(x, y, w, h int, kwargs ...KwArgs) *Stream + func (s *Stream) DrawBox(x, y, w, h int, color string, thickness int, kwargs ...KwArgs) *Stream + func (s *Stream) Drawtext(text string, x, y int, escape bool, kwargs ...KwArgs) *Stream + func (s *Stream) Equal(other Stream) bool + func (s *Stream) ErrorToStdOut() *Stream + func (s *Stream) Filter(filterName string, args Args, kwArgs ...KwArgs) *Stream + func (s *Stream) Get(index string) *Stream + func (s *Stream) GetArgs() []string + func (s *Stream) GlobalArgs(args ...string) *Stream + func (s *Stream) HFlip(kwargs ...KwArgs) *Stream + func (s *Stream) Hash() int + func (s *Stream) Hue(kwargs ...KwArgs) *Stream + func (s *Stream) Output(fileName string, kwargs ...KwArgs) *Stream + func (s *Stream) OverWriteOutput() *Stream + func (s *Stream) Overlay(overlayParentNode *Stream, eofAction string, kwargs ...KwArgs) *Stream + func (s *Stream) OverwriteOutput(stream *Stream) *Stream + func (s *Stream) Run() error + func (s *Stream) RunLinux() error + func (s *Stream) SetPts(expr string) *Node + func (s *Stream) Split() *Node + func (s *Stream) String() string + func (s *Stream) Trim(kwargs ...KwArgs) *Stream + func (s *Stream) VFlip(kwargs ...KwArgs) *Stream + func (s *Stream) Video() *Stream + func (s *Stream) View(viewType ViewType) (string, error) + func (s *Stream) WithCpuCoreLimit(n float32) *Stream + func (s *Stream) WithCpuCoreRequest(n float32) *Stream + func (s *Stream) WithCpuSet(n string) *Stream + func (s *Stream) WithErrorOutput(out io.Writer) *Stream + func (s *Stream) WithInput(reader io.Reader) *Stream + func (s *Stream) WithMemSet(n string) *Stream + func (s *Stream) WithOutput(out ...io.Writer) *Stream + func (s *Stream) WithTimeout(timeOut time.Duration) *Stream + func (s *Stream) ZoomPan(kwargs ...KwArgs) *Stream + type ViewType string + const ViewTypeFlowChart + const ViewTypeStateDiagram