Versions in this module Expand all Collapse all v2 v2.0.0 Feb 25, 2025 Changes in this version + var GlobalCommandOptions = make([]CommandOption, 0) + var LogCompiledCommand bool = true + 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 ProbeReader(r io.Reader, kwargs ...KwArgs) (string, error) + func ProbeReaderWithTimeout(r io.Reader, timeOut time.Duration, kwargs KwArgs) (string, error) + func ProbeReaderWithTimeoutExec(r io.Reader, timeOut time.Duration, 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 CommandOption func(cmd *exec.Cmd) + type CompilationOption func(s *Stream, cmd *exec.Cmd) + func SeparateProcessGroup() CompilationOption + 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 + FfmpegPath string + 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 OutputContext(ctx context.Context, 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(options ...CompilationOption) *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(options ...CompilationOption) error + func (s *Stream) RunLinux() error + func (s *Stream) RunWithResource(cpuRequest, cpuLimit float32) error + func (s *Stream) SetFfmpegPath(path string) *Stream + func (s *Stream) SetPts(expr string) *Node + func (s *Stream) Silent(isSilent bool) *Stream + 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 Other modules containing this package github.com/warmans/ffmpeg-go