streams

Documentation

Index

• func GetAll() (names []string)
• func GetProducer(url string) (core.Producer, error)
• func HandleFunc(scheme string, handler Handler)
• func HasProducer(url string) bool
• func Init()
• func ParseQuery(s string) url.Values
• type Handler
• type Producer
  • func (p *Producer) AddTrack(media *core.Media, codec *core.Codec, track *core.Receiver) error
  • func (p *Producer) Dial() error
  • func (p *Producer) GetMedias() []*core.Media
  • func (p *Producer) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error)
  • func (p *Producer) MarshalJSON() ([]byte, error)
  • func (p *Producer) SetSource(s string)
• type Stream
  • func Get(name string) *Stream
  • func New(name string, source any) *Stream
  • func NewStream(source any) *Stream
  • func NewTemplate(name string, source any) *Stream
  • func (s *Stream) AddConsumer(cons core.Consumer) (err error)
  • func (s *Stream) AddInternalConsumer(conn core.Consumer)
  • func (s *Stream) AddInternalProducer(conn core.Producer)
  • func (s *Stream) AddProducer(prod core.Producer)
  • func (s *Stream) MarshalJSON() ([]byte, error)
  • func (s *Stream) Play(source string) error
  • func (s *Stream) RemoveConsumer(cons core.Consumer)
  • func (s *Stream) RemoveInternalConsumer(conn core.Consumer)
  • func (s *Stream) RemoveProducer(prod core.Producer)
  • func (s *Stream) SetSource(source string)

Functions

func GetAll

func GetAll() (names []string)

func GetProducer

func GetProducer(url string) (core.Producer, error)

func HandleFunc

func HandleFunc(scheme string, handler Handler)

func HasProducer

func HasProducer(url string) bool

func Init

func Init()

func ParseQuery

func ParseQuery(s string) url.Values

Types

type Handler

type Handler func(url string) (core.Producer, error)

type Producer

type Producer struct {
	core.Listener
	// contains filtered or unexported fields
}

func (*Producer) AddTrack

func (p *Producer) AddTrack(media *core.Media, codec *core.Codec, track *core.Receiver) error

func (*Producer) Dial

func (p *Producer) Dial() error

func (*Producer) GetMedias

func (p *Producer) GetMedias() []*core.Media

func (*Producer) GetTrack

func (p *Producer) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error)

func (*Producer) MarshalJSON

func (p *Producer) MarshalJSON() ([]byte, error)

func (*Producer) SetSource

func (p *Producer) SetSource(s string)

type Stream

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

func Get

func Get(name string) *Stream

func New

func New(name string, source any) *Stream

func NewStream

func NewStream(source any) *Stream

func NewTemplate

func NewTemplate(name string, source any) *Stream

func (*Stream) AddConsumer

func (s *Stream) AddConsumer(cons core.Consumer) (err error)

func (*Stream) AddInternalConsumer

func (s *Stream) AddInternalConsumer(conn core.Consumer)

func (*Stream) AddInternalProducer

func (s *Stream) AddInternalProducer(conn core.Producer)

func (*Stream) AddProducer

func (s *Stream) AddProducer(prod core.Producer)

func (*Stream) MarshalJSON

func (s *Stream) MarshalJSON() ([]byte, error)

func (*Stream) Play

func (s *Stream) Play(source string) error

func (*Stream) RemoveConsumer

func (s *Stream) RemoveConsumer(cons core.Consumer)

func (*Stream) RemoveInternalConsumer

func (s *Stream) RemoveInternalConsumer(conn core.Consumer)

func (*Stream) RemoveProducer

func (s *Stream) RemoveProducer(prod core.Producer)

func (*Stream) SetSource

func (s *Stream) SetSource(source string)