subscription

Documentation

Index

• type AudioSubscription
  • func NewAudioSubscription(outputTrack *webrtc.TrackLocalStaticRTP, controller SubscriptionController) (*AudioSubscription, error)
  • func (s *AudioSubscription) Unsubscribe() error
  • func (s *AudioSubscription) WriteRTP(packet rtp.Packet) error
• type KeyFrameRequest
• type Subscription
• type SubscriptionController
• type VideoSubscription
  • func NewVideoSubscription(info webrtc_ext.TrackInfo, controller SubscriptionController, ...) (*VideoSubscription, <-chan KeyFrameRequest, error)
  • func (s *VideoSubscription) Unsubscribe() error
  • func (s *VideoSubscription) WriteRTP(packet rtp.Packet) error

Types

type AudioSubscription

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

func NewAudioSubscription

func NewAudioSubscription(
	outputTrack *webrtc.TrackLocalStaticRTP,
	controller SubscriptionController,
) (*AudioSubscription, error)

func (*AudioSubscription) Unsubscribe

func (s *AudioSubscription) Unsubscribe() error

func (*AudioSubscription) WriteRTP

func (s *AudioSubscription) WriteRTP(packet rtp.Packet) error

type KeyFrameRequest

type KeyFrameRequest struct{}

type Subscription

type Subscription interface {
	Unsubscribe() error
	WriteRTP(packet rtp.Packet) error
}

type SubscriptionController

type SubscriptionController interface {
	AddTrack(track *webrtc.TrackLocalStaticRTP) (*webrtc.RTPSender, error)
	RemoveTrack(sender *webrtc.RTPSender) error
}

type VideoSubscription

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

func NewVideoSubscription

func NewVideoSubscription(
	info webrtc_ext.TrackInfo,
	controller SubscriptionController,
	logger *logrus.Entry,
	telemetryBuilder *telemetry.ChildBuilder,
) (*VideoSubscription, <-chan KeyFrameRequest, error)

Creates a new video subscription. Returns a subscription along with a channel that informs the parent about key frame requests from the subscriptions. When the channel is closed, the subscription's go-routine is stopped.

func (*VideoSubscription) Unsubscribe

func (s *VideoSubscription) Unsubscribe() error

func (*VideoSubscription) WriteRTP

func (s *VideoSubscription) WriteRTP(packet rtp.Packet) error