astilibav

May 21, 2024

Changes in this version

type DecoderOptions

+ ThreadCount int

+ ThreadType astiav.ThreadType

type EncoderOptions

+ ThreadCount int

+ ThreadType astiav.ThreadType

type FiltererOptions

+ ThreadCount int

+ ThreadType astiav.ThreadType

May 7, 2024

Changes in this version

type DemuxerOptions

+ IOContext *astiav.IOContext

Sep 28, 2023

Changes in this version

type AdaptiveDelayer

+ func (d *AdaptiveDelayer) SetMinimum(min time.Duration)

type AdaptiveDelayerOptions

+ Minimum time.Duration

+ StepsCount uint

Sep 28, 2023

Changes in this version

+ type FrameFillerFallbackFrameOptions struct

+ Frame *astiav.Frame

+ FrameAdapter FrameAdapter

+ Node astiencoder.Node

+ type FrameInterceptor struct

+ func NewFrameInterceptor(o FrameInterceptorOptions, eh *astiencoder.EventHandler, c *astikit.Closer, ...) (i *FrameInterceptor)

+ func (i *FrameInterceptor) HandleFrame(p FrameHandlerPayload)

+ func (i *FrameInterceptor) OutputCtx() Context

+ func (i *FrameInterceptor) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ func (i *FrameInterceptor) Stats() FrameInterceptorStats

+ type FrameInterceptorHandler func(f *astiav.Frame, i *FrameInterceptor) error

+ type FrameInterceptorOptions struct

+ Handler FrameInterceptorHandler

+ Node astiencoder.NodeOptions

+ OutputCtx Context

+ type FrameInterceptorStats struct

+ FramesAllocated uint64

+ FramesProcessed uint64

+ FramesReceived uint64

+ WorkDuration time.Duration

Sep 27, 2023

Changes in this version

type DecoderStats

+ FramesDispatched uint64

type EncoderStats

+ PacketsDispatched uint64

type FiltererStats

+ FramesDispatched uint64

type ForwarderStats

+ FramesDispatched uint64

type FrameFiller

+ func (ff *FrameFiller) WithFallbackFrameAndNode(a FrameAdapter, n astiencoder.Node) (dst *FrameFiller, err error)

type FrameRateEmulatorStats

+ FramesDispatched uint64

type RateEnforcer

+ func (r *RateEnforcer) FrameFiller() *FrameFiller

type RateEnforcerStats

+ FramesDispatched uint64

type SwitcherStats

+ FramesDispatched uint64

May 29, 2023

Changes in this version

type DemuxerOptions

+ FlushOnStart bool

May 28, 2023

Changes in this version

+ const StatNameAverageFrameDelay

+ type AdaptiveDelayer struct

+ func NewAdaptiveDelayer(o AdaptiveDelayerOptions) *AdaptiveDelayer

+ func (d *AdaptiveDelayer) Apply(t time.Time) time.Time

+ func (d *AdaptiveDelayer) Delay() time.Duration

+ func (d *AdaptiveDelayer) HandleFrame(delay time.Duration, n astiencoder.Node)

+ type AdaptiveDelayerOptions struct

+ LookBehind time.Duration

+ MarginGoingDown time.Duration

+ MarginGoingUp time.Duration

+ Maximum time.Duration

+ Start time.Duration

+ Step time.Duration

+ type ConstantDelayer struct

+ func NewConstantDelayer(delay time.Duration) *ConstantDelayer

+ func (d *ConstantDelayer) Apply(t time.Time) time.Time

+ func (d *ConstantDelayer) Delay() time.Duration

+ func (d *ConstantDelayer) HandleFrame(delay time.Duration, n astiencoder.Node)

+ type Delayer interface

+ Apply func(t time.Time) time.Time

+ Delay func() time.Duration

+ HandleFrame func(delay time.Duration, n astiencoder.Node)

type RateEnforcerOptions

+ Delayer Delayer

May 5, 2023

Changes in this version

type SwitcherOptions

+ FrameTimeout time.Duration

May 1, 2023

Changes in this version

+ const EventNameSwitcherSwitchedOut

+ var NanosecondRational = astiav.NewRational(1, 1e9)

+ type FiltererFrameHandlerStrategy string

+ const FiltererFrameHandlerStrategyDefault

+ const FiltererFrameHandlerStrategyPTS

+ type FiltererInputContextChange struct

+ func (c FiltererInputContextChange) String() string

+ type FiltererInputContextChanges map[astiencoder.Node]FiltererInputContextChange

+ func (cs FiltererInputContextChanges) String() string

+ type FiltererOnInputContextChangesFunc func(cs FiltererInputContextChanges, f *Filterer) (ignore bool)

type FiltererOptions

+ FrameHandlerStrategy FiltererFrameHandlerStrategy

+ OnInputContextChanges FiltererOnInputContextChangesFunc

+ type FrameAdapter func(f *astiav.Frame) error

+ func EmptyAudioFrameAdapter(nbSamples, sampleRate int, cl *astiav.ChannelLayout, sf astiav.SampleFormat) FrameAdapter

+ func EmptyVideoFrameAdapter(cr astiav.ColorRange, pf astiav.PixelFormat, width, height int) FrameAdapter

+ type FrameFiller struct

+ func NewFrameFiller(c *astikit.Closer, eh *astiencoder.EventHandler, target interface{}) *FrameFiller

+ func (ff *FrameFiller) Get() (*astiav.Frame, astiencoder.Node)

+ func (ff *FrameFiller) Put(f *astiav.Frame, n astiencoder.Node)

+ func (ff *FrameFiller) WithFallbackFrame(a FrameAdapter) (dst *FrameFiller, err error)

+ func (ff *FrameFiller) WithPreviousFrame() *FrameFiller

type FrameRestamper

+ func NewFrameRestamperWithOffset(o FrameRestamperOffseter, frameDuration int64, timeBase astiav.Rational) FrameRestamper

+ type FrameRestamperOffseter interface

+ Offset func(f *astiav.Frame, frameDuration int64, timeBase astiav.Rational) int64

+ type FrameRestamperOffseterWithStartFromZero struct

+ func NewFrameRestamperOffseterWithStartFromZero() *FrameRestamperOffseterWithStartFromZero

+ func (o *FrameRestamperOffseterWithStartFromZero) Offset(f *astiav.Frame, frameDuration int64, timeBase astiav.Rational) int64

+ func (o *FrameRestamperOffseterWithStartFromZero) Paused()

+ type FrameRestamperStartPTSFunc func() int64

+ func FrameRestamperStartPTSFuncFromPTSReference(r *PTSReference, timeBase astiav.Rational) FrameRestamperStartPTSFunc

type RateEnforcerOptions

+ FrameFiller *FrameFiller

+ PTSReference *PTSReference

+ UpdatePTSReferenceOnFrame bool

+ type Switcher struct

+ func NewSwitcher(o SwitcherOptions, eh *astiencoder.EventHandler, c *astikit.Closer, ...) (s *Switcher, err error)

+ func (s *Switcher) Connect(h FrameHandler)

+ func (s *Switcher) Disconnect(h FrameHandler)

+ func (s *Switcher) HandleFrame(p FrameHandlerPayload)

+ func (s *Switcher) OutputCtx() Context

+ func (s *Switcher) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ func (s *Switcher) Stats() SwitcherStats

+ func (s *Switcher) Switch(n astiencoder.Node)

+ type SwitcherOptions struct

+ FrameDuration int64

+ Node astiencoder.NodeOptions

+ OutputCtx Context

+ type SwitcherStats struct

+ FramesAllocated uint64

+ FramesDispached uint64

+ FramesProcessed uint64

+ FramesReceived uint64

+ WorkDuration time.Duration

Apr 21, 2023

Changes in this version

type DecoderOptions

+ EnforceMonotonicDTS bool

Apr 2, 2023

Changes in this version

type PTSReference

+ func NewPTSReference() *PTSReference

+ func (r *PTSReference) Update(pts int64, t time.Time, timeBase astiav.Rational) *PTSReference

+ func (r PTSReference) PTSFromTime(t time.Time, timeBase astiav.Rational) int64

+ func (r PTSReference) TimeFromPTS(pts int64, timeBase astiav.Rational) time.Time

type RateEnforcerOptions

+ PTSReferences map[astiencoder.Node]*PTSReference

Mar 31, 2023

Changes in this version

type Context

+ ColorRange astiav.ColorRange

Nov 16, 2022

Changes in this version

+ const StatNameReadRate

+ const StatNameWrittenRate

type Decoder

+ func (d *Decoder) Stats() DecoderStats

+ type DecoderStats struct

+ BytesReceived uint64

+ FramesAllocated uint64

+ FramesDispached uint64

+ PacketsAllocated uint64

+ PacketsProcessed uint64

+ PacketsReceived uint64

+ WorkDuration time.Duration

type Demuxer

+ func (d *Demuxer) Stats() DemuxerStats

+ type DemuxerStats struct

+ BytesRead uint64

+ PacketsAllocated uint64

+ PacketsDispatched uint64

type Encoder

+ func (e *Encoder) Stats() EncoderStats

+ type EncoderStats struct

+ FramesAllocated uint64

+ FramesProcessed uint64

+ FramesReceived uint64

+ PacketsAllocated uint64

+ PacketsDispached uint64

+ WorkDuration time.Duration

type Filterer

+ func (f *Filterer) Stats() FiltererStats

+ type FiltererStats struct

+ FramesAllocated uint64

+ FramesDispached uint64

+ FramesProcessed uint64

+ FramesReceived uint64

+ WorkDuration time.Duration

type Forwarder

+ func (f *Forwarder) Stats() ForwarderStats

+ type ForwarderStats struct

+ FramesAllocated uint64

+ FramesDispached uint64

+ FramesProcessed uint64

+ FramesReceived uint64

+ WorkDuration time.Duration

type FrameRateEmulator

+ func (r *FrameRateEmulator) Stats() FrameRateEmulatorStats

+ type FrameRateEmulatorStats struct

+ FramesAllocated uint64

+ FramesDispached uint64

+ FramesProcessed uint64

+ FramesReceived uint64

+ WorkDuration time.Duration

type Muxer

+ func (m *Muxer) Stats() MuxerStats

+ type MuxerStats struct

+ BytesWritten uint64

+ PacketsAllocated uint64

+ PacketsProcessed uint64

+ PacketsReceived uint64

+ WorkDuration time.Duration

type PktDumper

+ func (d *PktDumper) Stats() PktDumperStats

+ type PktDumperStats struct

+ PacketsAllocated uint64

+ PacketsProcessed uint64

+ PacketsReceived uint64

+ WorkDuration time.Duration

type PktPiper

+ func (p *PktPiper) Stats() PktPiperStats

+ type PktPiperStats struct

+ PacketsAllocated uint64

+ PacketsDispatched uint64

+ PacketsProcessed uint64

+ PacketsReceived uint64

+ WorkDuration time.Duration

type RateEnforcer

+ func (r *RateEnforcer) Stats() RateEnforcerStats

+ type RateEnforcerStats struct

+ FramesAllocated uint64

+ FramesDelay time.Duration

+ FramesDispached uint64

+ FramesFilled uint64

+ FramesProcessed uint64

+ FramesReceived uint64

+ WorkDuration time.Duration

Oct 14, 2022

Changes in this version

+ func EventHandlerLogAdapter(o EventHandlerLogAdapterOptions) astiencoder.EventHandlerLogAdapter

+ type EventHandlerLogAdapterOptions struct

+ LogLevel astiav.LogLevel

+ LoggerLevelFunc func(l astiav.LogLevel) (ll astikit.LoggerLevel, processed, stop bool)

Oct 13, 2022

Changes in this version

+ type WithLogOptions struct

+ LogLevel astiav.LogLevel

+ LoggerLevelFunc func(l astiav.LogLevel, msg *string) (ll astikit.LoggerLevel, ok bool)

Oct 11, 2022

Changes in this version

type FrameRateEmulator

+ func (r *FrameRateEmulator) SetFlushOnStop(flushOnStop bool)

type FrameRateEmulatorOptions

+ FlushOnStop bool

Oct 11, 2022

Changes in this version

+ const StatNameAllocatedFrames

+ const StatNameAllocatedPackets

type Context

+ FrameSize int

type Demuxer

+ func (d *Demuxer) ProbeInfo() *DemuxerProbeInfo

+ type DemuxerEmulateRateOptions struct

+ BufferDuration time.Duration

+ Enabled bool

+ type DemuxerLoopOptions struct

+ Enabled bool

type DemuxerOptions

+ ProbeDuration time.Duration

+ type DemuxerProbeInfo struct

+ FirstPTS DemuxerProbeInfoFirstPTS

+ func (i DemuxerProbeInfo) PTSReference() PTSReference

+ type DemuxerProbeInfoFirstPTS struct

+ Streams map[int]bool

+ Timebase astiav.Rational

+ Value int64

+ type FrameRateEmulator struct

+ func NewFrameRateEmulator(o FrameRateEmulatorOptions, eh *astiencoder.EventHandler, c *astikit.Closer, ...) (r *FrameRateEmulator)

+ func (r *FrameRateEmulator) Connect(h FrameHandler)

+ func (r *FrameRateEmulator) Disconnect(h FrameHandler)

+ func (r *FrameRateEmulator) HandleFrame(p FrameHandlerPayload)

+ func (r *FrameRateEmulator) OutputCtx() Context

+ func (r *FrameRateEmulator) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type FrameRateEmulatorOptions struct

+ Node astiencoder.NodeOptions

+ OutputCtx Context

+ PTSReference PTSReference

+ type PTSReference struct

+ PTS int64

+ Time time.Time

+ TimeBase astiav.Rational

May 27, 2022

Changes in this version

+ type PktPiper struct

+ func NewPktPiper(o PktPiperOptions, eh *astiencoder.EventHandler, c *astikit.Closer, ...) (p *PktPiper)

+ func (p *PktPiper) Connect(h PktHandler)

+ func (p *PktPiper) Disconnect(h PktHandler)

+ func (p *PktPiper) OutputCtx() Context

+ func (p *PktPiper) Pipe(data []byte)

+ func (p *PktPiper) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type PktPiperOptions struct

+ Node astiencoder.NodeOptions

+ OutputCtx Context

+ Restamper PktRestamper

type PktRestamper

+ func NewPktRestamperWithTime(fillGaps bool, timeBase astiav.Rational) PktRestamper

Mar 26, 2022

Changes in this version

+ func WithLog(lvl astiav.LogLevel) astiencoder.EventHandlerLogOption

type EventLog

+ Format string

Mar 24, 2022

Changes in this version

type Context

+ Rotation float64

type EventLog

+ Fmt string

Feb 20, 2022

Changes in this version

type Context

+ Dictionary *Dictionary

+ MediaType astiav.MediaType

+ SampleFormat astiav.SampleFormat

type DecoderOptions

+ CodecParameters *astiav.CodecParameters

type DemuxerOptions

+ Dictionary *Dictionary

+ type Dictionary struct

+ func NewDefaultDictionary(i string) *Dictionary

+ func NewDefaultDictionaryf(format string, args ...interface{}) *Dictionary

+ func NewDictionary(content, keyValSep, pairsSep string, flags astiav.DictionaryFlags) *Dictionary

type Muxer

+ func (m *Muxer) FormatContext() *astiav.FormatContext

Dec 17, 2021

Changes in this version

type Demuxer

+ func (d *Demuxer) SetLoop(loop bool)

Nov 21, 2021

Changes in this version

type Context

+ ThreadType *int

Nov 4, 2021

Changes in this version

type DecoderOptions

+ Name string

May 4, 2021

Changes in this version

+ const EventNameFirstFrameOut

type Context

+ Index int

+ func (ctx Context) Descriptor() Descriptor

type Decoder

+ func (d *Decoder) Close() error

type Demuxer

+ func (d *Demuxer) Close() error

+ func (d *Demuxer) Streams() (ss []*Stream)

type DemuxerOptions

+ EmulateRateBufferDuration time.Duration

+ ReadFrameErrorHandler DemuxerReadFrameErrorHandler

+ type DemuxerReadFrameErrorHandler func(d *Demuxer, ret int) (stop, handled bool)

type Descriptor

+ func NewDescriptor(timeBase avutil.Rational) Descriptor

type Encoder

+ func (e *Encoder) Close() error

type Forwarder

+ func (f *Forwarder) Close() error

type Muxer

+ func (m *Muxer) Close() error

type PktDumper

+ func (d *PktDumper) Close() error

+ type PktRestamperStartFromZero struct

+ func (r *PktRestamperStartFromZero) Restamp(pkt *avcodec.Packet)

+ type PktRestamperWithPktDuration struct

+ func (r *PktRestamperWithPktDuration) Add(delta int64, idx int)

+ func (r *PktRestamperWithPktDuration) Restamp(pkt *avcodec.Packet)

type RateEnforcer

+ func (r *RateEnforcer) Close() error

type RateEnforcerOptions

+ AdaptSlotsToIncomingFrames bool

+ type Stream struct

+ CodecParameters *avcodec.CodecParameters

+ Ctx Context

+ ID int

+ Index int

Dec 8, 2020

Changes in this version

+ const StatNameFilledRate

+ func NewFrameRateEnforcerFiller(fn func(fm *avutil.Frame) error, c *astikit.Closer) (f *frameRateEnforcerFiller, err error)

type AvError

+ func (e AvError) Is(err error) bool

+ type RateEnforcerFiller interface

+ Fill func() *avutil.Frame

+ NoFill func(f *avutil.Frame)

type RateEnforcerOptions

+ Filler RateEnforcerFiller

Oct 29, 2020

Changes in this version

+ const EventNameLog

+ const EventNameRateEnforcerSwitchedIn

+ const EventNameRateEnforcerSwitchedOut

+ func HandleLogs(eh *astiencoder.EventHandler)

+ func LoggerEventHandlerAdapter(o LoggerEventHandlerAdapterOptions, i astikit.StdLogger, ...)

type Context

+ func (ctx Context) String() string

+ type EventLog struct

+ Level int

+ Msg string

+ Parent string

+ type LoggerEventHandlerAdapterOptions struct

+ IgnoredLogMessages []string

type PktHandlerPayload

+ Node astiencoder.Node

Oct 22, 2020

Changes in this version

+ const StatNameOutgoingRate

+ const StatNameProcessedRate

type FrameHandlerPayload

+ func (p *FrameHandlerPayload) Close()

type PktHandlerPayload

+ func (p *PktHandlerPayload) Close()

Sep 28, 2020

Changes in this version

+ const RateEnforcerSwitchedIn

+ const RateEnforcerSwitchedOut

+ const StatNameAverageDelay

+ const StatNameDispatchRatio

+ const StatNameIncomingRate

+ const StatNameRepeatedRate

+ const StatNameWorkRatio

type DemuxerOptions

+ ProbeCtx context.Context

type Filterer

+ func (f *Filterer) Close() error

type FiltererOptions

+ EmulateRate avutil.Rational

Apr 16, 2020

Changes in this version

type Decoder

+ func (d *Decoder) OutputCtx() Context

type DecoderOptions

+ OutputCtx Context

+ type EmitFunc func(name string, payload interface{})

type Filterer

+ func (f *Filterer) OutputCtx() Context

type FiltererOptions

+ OutputCtx Context

type FiltererSwitcher

+ SetEmitFunc func(fn EmitFunc)

type Forwarder

+ func (f *Forwarder) OutputCtx() Context

type ForwarderOptions

+ OutputCtx Context

+ type OutputContexter interface

+ OutputCtx func() Context

type RateEnforcer

+ func (r *RateEnforcer) OutputCtx() Context

type RateEnforcerOptions

+ OutputCtx Context

Mar 6, 2020

Changes in this version

+ type Dict struct

+ func NewDefaultDict(i string) *Dict

+ func NewDefaultDictf(format string, args ...interface{}) *Dict

+ func NewDict(i, keyValSep, pairsSep string, flags int) *Dict

+ func (d *Dict) Parse(i **avutil.Dictionary) (err error)

Dec 4, 2019

Changes in this version

+ const EventNameFiltererSwitchInDone

+ const EventNameFiltererSwitchOutDone

+ const EventNameRateEnforcerSwitched

+ var PktDumpFile = func(pkt *avcodec.Packet, args PktDumperHandlerArgs) (err error)

+ var Version = Versions

+ func AddStream(ctxFormat *avformat.Context) *avformat.Stream

+ func CloneStream(i *avformat.Stream, ctxFormat *avformat.Context) (o *avformat.Stream, err error)

+ type AvError int

+ func NewAvError(ret int) AvError

+ func (e AvError) Error() string

+ func (e AvError) IsOneOf(rs ...int) bool

+ type Context struct

+ BitRate int

+ ChannelLayout uint64

+ Channels int

+ CodecID avcodec.CodecId

+ CodecName string

+ CodecType avcodec.MediaType

+ Dict string

+ FrameRate avutil.Rational

+ GlobalHeader bool

+ GopSize int

+ Height int

+ PixelFormat avutil.PixelFormat

+ SampleAspectRatio avutil.Rational

+ SampleFmt avcodec.AvSampleFormat

+ SampleRate int

+ ThreadCount *int

+ TimeBase avutil.Rational

+ Width int

+ func NewContextFromStream(s *avformat.Stream) Context

+ type Decoder struct

+ func NewDecoder(o DecoderOptions, eh *astiencoder.EventHandler, c *astidefer.Closer) (d *Decoder, err error)

+ func (d *Decoder) Connect(h FrameHandler)

+ func (d *Decoder) Disconnect(h FrameHandler)

+ func (d *Decoder) HandlePkt(p *PktHandlerPayload)

+ func (d *Decoder) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type DecoderOptions struct

+ CodecParams *avcodec.CodecParameters

+ Node astiencoder.NodeOptions

+ type Demuxer struct

+ func NewDemuxer(o DemuxerOptions, eh *astiencoder.EventHandler, c *astidefer.Closer) (d *Demuxer, err error)

+ func (d *Demuxer) Connect(h PktHandler)

+ func (d *Demuxer) ConnectForStream(h PktHandler, i *avformat.Stream)

+ func (d *Demuxer) CtxFormat() *avformat.Context

+ func (d *Demuxer) Disconnect(h PktHandler)

+ func (d *Demuxer) DisconnectForStream(h PktHandler, i *avformat.Stream)

+ func (d *Demuxer) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type DemuxerOptions struct

+ Dict string

+ EmulateRate bool

+ FindStreamInfoCtx context.Context

+ Format *avformat.InputFormat

+ Loop bool

+ Node astiencoder.NodeOptions

+ SeekToLive bool

+ URL string

+ type Descriptor interface

+ TimeBase func() avutil.Rational

+ type Encoder struct

+ func NewEncoder(o EncoderOptions, eh *astiencoder.EventHandler, c *astidefer.Closer) (e *Encoder, err error)

+ func (e *Encoder) AddStream(ctxFormat *avformat.Context) (o *avformat.Stream, err error)

+ func (e *Encoder) Connect(h PktHandler)

+ func (e *Encoder) Disconnect(h PktHandler)

+ func (e *Encoder) FrameSize() int

+ func (e *Encoder) HandleFrame(p *FrameHandlerPayload)

+ func (e *Encoder) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type EncoderOptions struct

+ Ctx Context

+ Node astiencoder.NodeOptions

+ type Filterer struct

+ func NewFilterer(o FiltererOptions, eh *astiencoder.EventHandler, c *astidefer.Closer) (f *Filterer, err error)

+ func (f *Filterer) Connect(h FrameHandler)

+ func (f *Filterer) Disconnect(h FrameHandler)

+ func (f *Filterer) HandleFrame(p *FrameHandlerPayload)

+ func (f *Filterer) SendCommand(target, cmd, arg string, flags int) (err error)

+ func (f *Filterer) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ func (f *Filterer) Switch(opt FiltererSwitchOptions) (nf *Filterer, err error)

+ type FiltererInput struct

+ Context Context

+ Node astiencoder.Node

+ type FiltererOptions struct

+ Content string

+ Inputs map[string]FiltererInput

+ Node astiencoder.NodeOptions

+ Restamper FrameRestamper

+ Switcher FiltererSwitcher

+ type FiltererSwitchOptions struct

+ Filter FiltererOptions

+ Workflow *astiencoder.Workflow

+ type FiltererSwitcher interface

+ IncIn func(n astiencoder.Node)

+ IncOut func()

+ Reset func()

+ ShouldIn func(n astiencoder.Node) (ko bool)

+ ShouldOut func() (ko bool)

+ Switch func()

+ type Forwarder struct

+ func NewForwarder(o ForwarderOptions, eh *astiencoder.EventHandler, c *astidefer.Closer) (f *Forwarder)

+ func (f *Forwarder) Connect(h FrameHandler)

+ func (f *Forwarder) Disconnect(h FrameHandler)

+ func (f *Forwarder) HandleFrame(p *FrameHandlerPayload)

+ func (f *Forwarder) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type ForwarderOptions struct

+ Node astiencoder.NodeOptions

+ Restamper FrameRestamper

+ type FrameHandler interface

+ HandleFrame func(p *FrameHandlerPayload)

+ type FrameHandlerConnector interface

+ Connect func(next FrameHandler)

+ Disconnect func(next FrameHandler)

+ type FrameHandlerPayload struct

+ Descriptor Descriptor

+ Frame *avutil.Frame

+ Node astiencoder.Node

+ type FrameRestamper interface

+ Restamp func(f *avutil.Frame)

+ func NewFrameRestamperWithFrameDuration(frameDuration int64) FrameRestamper

+ func NewFrameRestamperWithModulo(frameDuration int64) FrameRestamper

+ type Muxer struct

+ func NewMuxer(o MuxerOptions, eh *astiencoder.EventHandler, c *astidefer.Closer) (m *Muxer, err error)

+ func (m *Muxer) CtxFormat() *avformat.Context

+ func (m *Muxer) NewPktHandler(o *avformat.Stream) *MuxerPktHandler

+ func (m *Muxer) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type MuxerOptions struct

+ Format *avformat.OutputFormat

+ FormatName string

+ Node astiencoder.NodeOptions

+ Restamper PktRestamper

+ URL string

+ type MuxerPktHandler struct

+ func (h *MuxerPktHandler) HandlePkt(p *PktHandlerPayload)

+ type PktCond interface

+ UsePkt func(pkt *avcodec.Packet) bool

+ type PktDumper struct

+ func NewPktDumper(o PktDumperOptions, eh *astiencoder.EventHandler) (d *PktDumper, err error)

+ func (d *PktDumper) HandlePkt(p *PktHandlerPayload)

+ func (d *PktDumper) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ type PktDumperHandlerArgs struct

+ Pattern string

+ type PktDumperOptions struct

+ Data map[string]interface{}

+ Handler func(pkt *avcodec.Packet, args PktDumperHandlerArgs) error

+ Node astiencoder.NodeOptions

+ Pattern string

+ type PktHandler interface

+ HandlePkt func(p *PktHandlerPayload)

+ type PktHandlerConnector interface

+ Connect func(next PktHandler)

+ Disconnect func(next PktHandler)

+ type PktHandlerPayload struct

+ Descriptor Descriptor

+ Pkt *avcodec.Packet

+ type PktRestamper interface

+ Restamp func(pkt *avcodec.Packet)

+ func NewPktRestamperStartFromZero() PktRestamper

+ func NewPktRestamperWithPktDuration() PktRestamper

+ type RateEnforcer struct

+ func NewRateEnforcer(o RateEnforcerOptions, eh *astiencoder.EventHandler, c *astidefer.Closer) (r *RateEnforcer)

+ func (r *RateEnforcer) Connect(h FrameHandler)

+ func (r *RateEnforcer) Disconnect(h FrameHandler)

+ func (r *RateEnforcer) HandleFrame(p *FrameHandlerPayload)

+ func (r *RateEnforcer) Start(ctx context.Context, t astiencoder.CreateTaskFunc)

+ func (r *RateEnforcer) Switch(n astiencoder.Node)

+ type RateEnforcerOptions struct

+ Delay time.Duration

+ FrameRate avutil.Rational

+ Node astiencoder.NodeOptions

+ Restamper FrameRestamper

+ type Versions struct

+ AvCodec uint

+ AvDevice uint

+ AvFilter uint

+ AvUtil uint

+ Resample string

+ SWScale uint

+ func (v Versions) String() string