downstream

package

v1.0.0 Latest Latest Go to latest Published: Sep 11, 2024 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var UpStreamerManager = &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)