downstream

package

v1.0.2 Latest Latest Go to latest Published: Jan 10, 2025 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var DownStreamerManager = &downStreamerManager{streams: sync.Map{}}

func Launch(name string, downStreamer DownStreamer, duration time.Duration) error

func Stop(name string) error

type DownStreamer interface {
	Pull(context.Context) (bool, error)
}

type FlvDownStreamer struct {
	Url    string
	Writer io.Writer
	// contains filtered or unexported fields
}

func NewFlvDownStreamer(url string, writer io.Writer) *FlvDownStreamer

func (d *FlvDownStreamer) AfterReadHeader(data []av.CodecData) error

func (d *FlvDownStreamer) LogStatistic(done chan bool)

func (d *FlvDownStreamer) Pull(ctx context.Context) (bool, error)