pusher

package
v1.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 13, 2025 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var UpStreamerManager = &upStreamerManager{streams: sync.Map{}}

Functions

func Handler 

func Handler(h *avutil.RegisterHandler)

func Launch 

func Launch(name string, pusher Pusher, duration time.Duration) error

func Stop 

func Stop(name string) error

func StopAll 

func StopAll()

Types

type Expose added in v1.0.4 

type Expose struct {
	Name      string
	StartTime time.Time
	Dur       time.Duration
}

func GetAllStreamInfos 

func GetAllStreamInfos() (infos []Expose)

type Pusher 

type Pusher interface {
	Publish(ctx context.Context) error
}

type RtmpOverTcpUpStreamer 

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

func NewRtmpPusher 

func NewRtmpPusher(rtmpUrl string, filename string, option ...rtmp.Option) *RtmpOverTcpUpStreamer

func (*RtmpOverTcpUpStreamer) Publish 

func (r *RtmpOverTcpUpStreamer) Publish(ctx context.Context) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.