router

package

v0.0.0-...-ff74eb6 Latest Latest Go to latest Published: Jul 10, 2019 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/notedit/rtclive

Links

Open Source Insights

Documentation ¶

Index ¶

type FFPublisher
- func NewFFPublisher(streamID string, streamURL string, capabilities map[string]*sdp.Capability) *FFPublisher
type MediaRouter
- func NewMediaRouter(routerID string, endpoint *mediaserver.Endpoint, ...) *MediaRouter
type Publisher
type RTCPublisher
- func NewRTCPublisher(sdpStr string, endpoint *mediaserver.Endpoint, ...) *RTCPublisher
- func NewRelayPublisher(offerStr string, answerStr string, endpoint *mediaserver.Endpoint, ...) *RTCPublisher
type RTCSubscriber
- func NewRTCSubscriber(sdpStr string, endpoint *mediaserver.Endpoint, ...) *RTCSubscriber
type Subscriber

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type FFPublisher ¶

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

FFPublisher publisher

func NewFFPublisher ¶

func NewFFPublisher(streamID string, streamURL string, capabilities map[string]*sdp.Capability) *FFPublisher

NewFFPublisher new ffmpeg publisher

func (*FFPublisher) GetAnswer ¶

func (p *FFPublisher) GetAnswer() string

GetAnswer get answer str

func (*FFPublisher) GetAudioTrack ¶

func (p *FFPublisher) GetAudioTrack() *mediaserver.IncomingStreamTrack

GetAudioTrack get audio track

func (*FFPublisher) GetID ¶

func (p *FFPublisher) GetID() string

GetID get publisher id

func (*FFPublisher) GetVideoTrack ¶

func (p *FFPublisher) GetVideoTrack() *mediaserver.IncomingStreamTrack

GetVideoTrack get video track

func (*FFPublisher) Start ¶

func (p *FFPublisher) Start() <-chan error

Start start the pipeline

func (*FFPublisher) Stop ¶

func (p *FFPublisher) Stop()

Stop stop this publisher

type MediaRouter ¶

type MediaRouter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

MediaRouter mediarouter

func NewMediaRouter ¶

func NewMediaRouter(routerID string, endpoint *mediaserver.Endpoint, capabilities map[string]*sdp.Capability, origin bool) *MediaRouter

func (*MediaRouter) CreateFFPublisher ¶

func (r *MediaRouter) CreateFFPublisher(streamID string, streamURL string) *FFPublisher

func (*MediaRouter) CreatePublisher ¶

func (r *MediaRouter) CreatePublisher(sdpStr string) *RTCPublisher

func (*MediaRouter) CreateRelayPublisher ¶

func (r *MediaRouter) CreateRelayPublisher(offerStr string, answerStr string) *RTCPublisher

func (*MediaRouter) CreateSubscriber ¶

func (r *MediaRouter) CreateSubscriber(sdpStr string) Subscriber

func (*MediaRouter) GetID ¶

func (r *MediaRouter) GetID() string

func (*MediaRouter) GetPublisher ¶

func (r *MediaRouter) GetPublisher() Publisher

func (*MediaRouter) GetSubscribers ¶

func (s *MediaRouter) GetSubscribers() map[string]Subscriber

func (*MediaRouter) GetSubscribersCount ¶

func (s *MediaRouter) GetSubscribersCount() int

func (*MediaRouter) IsOrgin ¶

func (r *MediaRouter) IsOrgin() bool

func (*MediaRouter) SetPublisher ¶

func (r *MediaRouter) SetPublisher(publisher Publisher)

func (*MediaRouter) Stop ¶

func (r *MediaRouter) Stop()

func (*MediaRouter) StopSubscriber ¶

func (r *MediaRouter) StopSubscriber(subscriberId string)

type Publisher ¶

type Publisher interface {
	GetID() string
	GetAnswer() string
	GetVideoTrack() *mediaserver.IncomingStreamTrack
	GetAudioTrack() *mediaserver.IncomingStreamTrack
	Stop()
}

Publisher interface

type RTCPublisher ¶

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

RTCPublisher struct

func NewRTCPublisher ¶

func NewRTCPublisher(sdpStr string, endpoint *mediaserver.Endpoint, capabilities map[string]*sdp.Capability) *RTCPublisher

NewRTCPublisher create new rtc publisher

func NewRelayPublisher ¶

func NewRelayPublisher(offerStr string, answerStr string, endpoint *mediaserver.Endpoint, capabilities map[string]*sdp.Capability) *RTCPublisher

func (*RTCPublisher) GetAnswer ¶

func (p *RTCPublisher) GetAnswer() string

GetAnswer get answer str

func (*RTCPublisher) GetAudioTrack ¶

func (p *RTCPublisher) GetAudioTrack() *mediaserver.IncomingStreamTrack

GetAudioTrack get audio track

func (*RTCPublisher) GetID ¶

func (p *RTCPublisher) GetID() string

GetID get publisher id

func (*RTCPublisher) GetVideoTrack ¶

func (p *RTCPublisher) GetVideoTrack() *mediaserver.IncomingStreamTrack

GetVideoTrack get video track

func (*RTCPublisher) Stop ¶

func (p *RTCPublisher) Stop()

Stop stop this publisher

type RTCSubscriber ¶

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

RTCSubscriber is a Subscriber interface

func NewRTCSubscriber ¶

func NewRTCSubscriber(sdpStr string, endpoint *mediaserver.Endpoint, capabilities map[string]*sdp.Capability) *RTCSubscriber

NewRTCSubscriber create new subscriber

func (*RTCSubscriber) Attach ¶

func (s *RTCSubscriber) Attach(publisher Publisher)

Attach to a publisher

func (*RTCSubscriber) GetAnswer ¶

func (s *RTCSubscriber) GetAnswer() string

GetAnswer return the answer sdp

func (*RTCSubscriber) GetID ¶

func (s *RTCSubscriber) GetID() string

GetID get subscriber id

func (*RTCSubscriber) GetPublisherID ¶

func (s *RTCSubscriber) GetPublisherID() string

GetPublisherID get publisher id

func (*RTCSubscriber) GetTransport ¶

func (s *RTCSubscriber) GetTransport() *mediaserver.Transport

GetTransport transport

func (*RTCSubscriber) Stop ¶

func (s *RTCSubscriber) Stop()

Stop stop it

type Subscriber ¶

type Subscriber interface {
	GetID() string
	GetAnswer() string
	Attach(publisher Publisher)
	GetTransport() *mediaserver.Transport
	Stop()
}

Subscriber interface

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL