gstreamer

Aug 19, 2024

Changes in this version

type Callbacks

+ func (c *Callbacks) OnEOSSent()

+ func (c *Callbacks) SetOnEOSSent(f func())

Apr 23, 2024

Changes in this version

type Bin

+ func (b *Bin) SetShouldLink(f func(string) bool)

type Callbacks

+ BuildReady chan struct{}

Sep 8, 2023

Changes in this version

+ func BuildQueue(name string, latency uint64, leaky bool) (*gst.Element, error)

+ type Bin struct

+ func (b *Bin) AddElement(e *gst.Element) error

+ func (b *Bin) AddElements(elements ...*gst.Element) error

+ func (b *Bin) AddSinkBin(sink *Bin) error

+ func (b *Bin) AddSourceBin(src *Bin) error

+ func (b *Bin) NewBin(name string) *Bin

+ func (b *Bin) RemoveSinkBin(name string) (bool, error)

+ func (b *Bin) RemoveSourceBin(name string) (bool, error)

+ func (b *Bin) SetEOSFunc(f func() bool)

+ func (b *Bin) SetGetSinkPad(f func(sinkName string) *gst.Pad)

+ func (b *Bin) SetGetSrcPad(f func(srcName string) *gst.Pad)

+ func (b *Bin) SetLinkFunc(f func() error)

+ func (b *Bin) SetState(state gst.State) error

+ type Callbacks struct

+ GstReady chan struct{}

+ func (c *Callbacks) AddOnStop(f func() error)

+ func (c *Callbacks) AddOnTrackAdded(f func(*config.TrackSource))

+ func (c *Callbacks) AddOnTrackMuted(f func(string))

+ func (c *Callbacks) AddOnTrackRemoved(f func(string))

+ func (c *Callbacks) AddOnTrackUnmuted(f func(string, time.Duration))

+ func (c *Callbacks) OnError(err error)

+ func (c *Callbacks) OnStop() error

+ func (c *Callbacks) OnTrackAdded(ts *config.TrackSource)

+ func (c *Callbacks) OnTrackMuted(trackID string)

+ func (c *Callbacks) OnTrackRemoved(trackID string)

+ func (c *Callbacks) OnTrackUnmuted(trackID string, pts time.Duration)

+ func (c *Callbacks) SetOnError(f func(error))

+ type Pipeline struct

+ func NewPipeline(name string, latency uint64, callbacks *Callbacks) (*Pipeline, error)

+ func (p *Pipeline) AddElement(e *gst.Element) error

+ func (p *Pipeline) AddElements(elements ...*gst.Element) error

+ func (p *Pipeline) AddSinkBin(sink *Bin) error

+ func (p *Pipeline) AddSourceBin(src *Bin) error

+ func (p *Pipeline) DebugBinToDotData(details gst.DebugGraphDetails) string

+ func (p *Pipeline) Link() error

+ func (p *Pipeline) Run() error

+ func (p *Pipeline) SendEOS()

+ func (p *Pipeline) SetState(state gst.State) error

+ func (p *Pipeline) SetWatch(watch func(msg *gst.Message) bool)

+ func (p *Pipeline) Stop()

+ type State int

+ const StateBuilding

+ const StateEOS

+ const StateFinished

+ const StateRunning

+ const StateStarted

+ const StateStopping

+ func (s State) String() string

+ type StateManager struct

+ func (s *StateManager) GetState() State

+ func (s *StateManager) GetStateLocked() State

+ func (s *StateManager) LockState()

+ func (s *StateManager) LockStateShared()

+ func (s *StateManager) UnlockState()

+ func (s *StateManager) UnlockStateShared()

+ func (s *StateManager) UpgradeState(state State) (State, bool)