moqtrelay

Documentation

Index

• func NewGroupReader(buf GroupBuffer) moqt.GroupReader
• type GroupBuffer
  • func NewGroupBuffer(seq moqt.GroupSequence, buf []byte) GroupBuffer
  • func (w *GroupBuffer) Close() error
  • func (g *GroupBuffer) GroupSequence() moqt.GroupSequence
  • func (r *GroupBuffer) Read(buf []byte) (int, error)
  • func (r *GroupBuffer) ReadFrame() ([]byte, error)
  • func (w *GroupBuffer) Write(buf []byte) (int, error)
  • func (w *GroupBuffer) WriteFrame(frame []byte) error
• type RelayManager
  • func NewRelayManager() RelayManager
• type TrackBuffer
  • func NewTrackBuffer(subscription moqt.SubscribeConfig) *TrackBuffer
  • func (t *TrackBuffer) AddGroup(g GroupBuffer) error
  • func (t *TrackBuffer) RemoveGroup(seq moqt.GroupSequence)
• type TrackManager

Functions

func NewGroupReader

func NewGroupReader(buf GroupBuffer) moqt.GroupReader

Types

type GroupBuffer

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

func NewGroupBuffer

func NewGroupBuffer(seq moqt.GroupSequence, buf []byte) GroupBuffer

func (*GroupBuffer) Close

func (w *GroupBuffer) Close() error

func (*GroupBuffer) GroupSequence

func (g *GroupBuffer) GroupSequence() moqt.GroupSequence

func (*GroupBuffer) Read

func (r *GroupBuffer) Read(buf []byte) (int, error)

func (*GroupBuffer) ReadFrame

func (r *GroupBuffer) ReadFrame() ([]byte, error)

func (*GroupBuffer) Write

func (w *GroupBuffer) Write(buf []byte) (int, error)

func (*GroupBuffer) WriteFrame

func (w *GroupBuffer) WriteFrame(frame []byte) error

type RelayManager

type RelayManager interface {
	RelayAnnouncements(moqt.Session, moqt.AnnounceConfig) error

	/*
	 * Serve subscription to the relay manager
	 */
	RelayTrack(moqt.Session, moqt.SubscribeConfig) error

	TrackManager
}

func NewRelayManager

func NewRelayManager() RelayManager

type TrackBuffer

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

func NewTrackBuffer

func NewTrackBuffer(subscription moqt.SubscribeConfig) *TrackBuffer

func (*TrackBuffer) AddGroup

func (t *TrackBuffer) AddGroup(g GroupBuffer) error

func (*TrackBuffer) RemoveGroup

func (t *TrackBuffer) RemoveGroup(seq moqt.GroupSequence)

type TrackManager

type TrackManager interface {
	//
	ServeAnnouncements([]moqt.Announcement) error

	ServeTrack(moqt.SubscribeConfig, *TrackBuffer) error
}