streams

Documentation

Index

• Constants
• 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 NewProducer(source string) *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 GetOrPatch(query url.Values) *Stream
  • func New(name string, source string) *Stream
  • func NewStream(source any) *Stream
  • func Patch(name string, source string) *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)

Constants

const SourceTemplate = "{input}"

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 NewProducer

func NewProducer(source string) *Producer

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 GetOrPatch

func GetOrPatch(query url.Values) *Stream

func New

func New(name string, source string) *Stream

func NewStream

func NewStream(source any) *Stream

func Patch

func Patch(name string, source string) *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)