ingest

Documentation

Index

• Variables
• type Manager
  • func (m *Manager) Cleanup()
  • func (m *Manager) Initialize() error
  • func (m *Manager) OfferSDP(name, remoteIP string, sendCandidate playrtc.CandidateSender) (*playrtc.Sender, error)
  • func (m *Manager) PopulateLive(infos []*model.ChannelInfo)
  • func (m *Manager) Publish(auth model.ChannelAuth, kind, remote string, src av.Demuxer) error
  • func (m *Manager) ServeTS(rw http.ResponseWriter, req *http.Request, name string) error
  • func (m *Manager) ServeWeb(rw http.ResponseWriter, req *http.Request, name string) error
• type PublishEvent

Variables

var ErrNoChannel = errors.New("channel not found")

Types

type Manager

type Manager struct {
	OpusBitrate  int
	PublishEvent PublishEvent
	FTL          ftl.Server
	WorkDir      string
	UseDASH      bool
	RTCHost      string
	// contains filtered or unexported fields
}

func (*Manager) Cleanup

func (m *Manager) Cleanup()

func (*Manager) Initialize

func (m *Manager) Initialize() error

func (*Manager) OfferSDP

func (m *Manager) OfferSDP(name, remoteIP string, sendCandidate playrtc.CandidateSender) (*playrtc.Sender, error)

func (*Manager) PopulateLive

func (m *Manager) PopulateLive(infos []*model.ChannelInfo)

func (*Manager) Publish

func (m *Manager) Publish(auth model.ChannelAuth, kind, remote string, src av.Demuxer) error

func (*Manager) ServeTS

func (m *Manager) ServeTS(rw http.ResponseWriter, req *http.Request, name string) error

func (*Manager) ServeWeb

func (m *Manager) ServeWeb(rw http.ResponseWriter, req *http.Request, name string) error

type PublishEvent

type PublishEvent func(auth model.ChannelAuth, live bool, thumb grabber.Result)