router

Documentation

Index

• type FFPublisher
  • func NewFFPublisher(streamID string, streamURL string, capabilities map[string]*sdp.Capability) *FFPublisher
  • func (p *FFPublisher) GetAnswer() string
  • func (p *FFPublisher) GetAudioTrack() *mediaserver.IncomingStreamTrack
  • func (p *FFPublisher) GetID() string
  • func (p *FFPublisher) GetVideoTrack() *mediaserver.IncomingStreamTrack
  • func (p *FFPublisher) Start() <-chan error
  • func (p *FFPublisher) Stop()
• type MediaRouter
  • func NewMediaRouter(routerID string, endpoint *mediaserver.Endpoint, ...) *MediaRouter
  • func (r *MediaRouter) CreateFFPublisher(streamID string, streamURL string) *FFPublisher
  • func (r *MediaRouter) CreatePublisher(sdpStr string) *RTCPublisher
  • func (r *MediaRouter) CreateRelayPublisher(offerStr string, answerStr string) *RTCPublisher
  • func (r *MediaRouter) CreateSubscriber(sdpStr string) Subscriber
  • func (r *MediaRouter) GetID() string
  • func (r *MediaRouter) GetPublisher() Publisher
  • func (s *MediaRouter) GetSubscribers() map[string]Subscriber
  • func (s *MediaRouter) GetSubscribersCount() int
  • func (r *MediaRouter) IsOrgin() bool
  • func (r *MediaRouter) SetPublisher(publisher Publisher)
  • func (r *MediaRouter) Stop()
  • func (r *MediaRouter) StopSubscriber(subscriberId string)
• type Publisher
• type RTCPublisher
  • func NewRTCPublisher(sdpStr string, endpoint *mediaserver.Endpoint, ...) *RTCPublisher
  • func NewRelayPublisher(offerStr string, answerStr string, endpoint *mediaserver.Endpoint, ...) *RTCPublisher
  • func (p *RTCPublisher) GetAnswer() string
  • func (p *RTCPublisher) GetAudioTrack() *mediaserver.IncomingStreamTrack
  • func (p *RTCPublisher) GetID() string
  • func (p *RTCPublisher) GetVideoTrack() *mediaserver.IncomingStreamTrack
  • func (p *RTCPublisher) Stop()
• type RTCSubscriber
  • func NewRTCSubscriber(sdpStr string, endpoint *mediaserver.Endpoint, ...) *RTCSubscriber
  • func (s *RTCSubscriber) Attach(publisher Publisher)
  • func (s *RTCSubscriber) GetAnswer() string
  • func (s *RTCSubscriber) GetID() string
  • func (s *RTCSubscriber) GetPublisherID() string
  • func (s *RTCSubscriber) GetTransport() *mediaserver.Transport
  • func (s *RTCSubscriber) Stop()
• type Subscriber

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