forwarder

package

v0.1.6 Latest Latest Go to latest Published: Feb 24, 2023 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func OutLoop(conn net.Conn, pullURL string, rawURL string, in In) error

func Pull(in In, pullURL string, fn func(tag httpflv.Tag)) error

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

Flv flv pull session

func (s *Flv) Pull(pullURL string, fn func(tag httpflv.Tag)) error

Pull pull flv stream

func (s *Flv) Shutdown() error

Shutdown shutdown flv session

type In interface {
	Pull(pullURL string, fn func(tag httpflv.Tag)) error
	Shutdown() error
}

In live stream pull interface

func GetIn(tp string) In

GetIn get pull session

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

Rtmp rtmp pull session

func (s *Rtmp) Pull(pullURL string, fn func(tag httpflv.Tag)) error

Pull pull rtmp stream

func (s *Rtmp) Shutdown() error

Shutdown shutdown rtmp session