codecs

type AudioStreamDecoder ¶

type AudioStreamDecoder interface {
	Push(data []byte)
	EndInput()
	Next() (*model.AudioFrame, error)
	Close() error
}

AudioStreamDecoder is a generic interface for decoding compressed audio formats (like MP3, WAV, FLAC) into raw PCM AudioFrames suitable for LiveKit WebRTC output.

func NewAACAudioStreamDecoder() AudioStreamDecoder

func NewFFmpegAudioStreamDecoder(inputFormat string, sampleRate int, numChannels int) AudioStreamDecoder

func NewFLACAudioStreamDecoder() AudioStreamDecoder

func NewMP3AudioStreamDecoder() AudioStreamDecoder

func NewOpusAudioStreamDecoder(sampleRate int, numChannels int) AudioStreamDecoder

func NewPCMAudioStreamDecoder(sampleRate int, numChannels int) AudioStreamDecoder

type DecoderType ¶

type DecoderType string

const (
	DecoderTypePCM  DecoderType = "pcm"
	DecoderTypeMP3  DecoderType = "mp3"
	DecoderTypeOpus DecoderType = "opus"
)

type FFmpegAudioStreamDecoder ¶ added in v0.1.3

type FFmpegAudioStreamDecoder struct {
	// contains filtered or unexported fields
}

func (d *FFmpegAudioStreamDecoder) Close() error

func (d *FFmpegAudioStreamDecoder) EndInput()

func (d *FFmpegAudioStreamDecoder) Next() (*model.AudioFrame, error)

func (d *FFmpegAudioStreamDecoder) Push(data []byte)

type MP3AudioStreamDecoder ¶

type MP3AudioStreamDecoder struct {
	// contains filtered or unexported fields
}

func (d *MP3AudioStreamDecoder) Close() error

func (d *MP3AudioStreamDecoder) EndInput()

func (d *MP3AudioStreamDecoder) Next() (*model.AudioFrame, error)

func (d *MP3AudioStreamDecoder) Push(data []byte)

type OpusAudioStreamDecoder ¶ added in v0.1.2

type OpusAudioStreamDecoder struct {
	// contains filtered or unexported fields
}

func (d *OpusAudioStreamDecoder) Close() error

func (d *OpusAudioStreamDecoder) EndInput()

func (d *OpusAudioStreamDecoder) Next() (*model.AudioFrame, error)

func (d *OpusAudioStreamDecoder) Push(data []byte)

type PCMAudioStreamDecoder ¶

type PCMAudioStreamDecoder struct {
	// contains filtered or unexported fields
}

PCMAudioStreamDecoder implements AudioStreamDecoder for raw PCM streams

func (d *PCMAudioStreamDecoder) Close() error

func (d *PCMAudioStreamDecoder) EndInput()

func (d *PCMAudioStreamDecoder) Next() (*model.AudioFrame, error)

func (d *PCMAudioStreamDecoder) Push(data []byte)