core

package

Go to main page

Versions in this module

v1

v1.9.2

May 17, 2024

Changes in this version

type Sender

+ func (s *Sender) Bind(track *Receiver)

+ func (s *Sender) Start()

v1.9.1

May 6, 2024

v1.9.0

Apr 30, 2024

v1.8.5

Jan 1, 2024

v1.8.4

Nov 19, 2023

v1.8.3

Nov 15, 2023

v1.8.2

Nov 4, 2023

v1.8.1

Oct 15, 2023

v1.8.0

Oct 14, 2023

v1.7.1

Sep 10, 2023

v1.7.0

Sep 2, 2023

Changes in this version

+ const BufferDisable

+ const BufferDrainAndClear

+ const BufferSize

+ const ConnDeadline

+ const ConnDialTimeout

+ const ProbeSize

+ const ProbeTimeout

type Codec

+ func (c *Codec) IsAudio() bool

+ func (c *Codec) IsVideo() bool

+ func (c *Codec) Kind() string

+ func (c *Codec) PrintName() string

type Info

+ SDP string

+ type OnceBuffer struct

+ func (o *OnceBuffer) Buffer() []byte

+ func (o *OnceBuffer) Len() int

+ func (o *OnceBuffer) Write(p []byte) (n int, err error)

+ func (o *OnceBuffer) WriteTo(w io.Writer) (n int64, err error)

+ type Packet struct

+ Composition uint32

+ Payload []byte

+ PayloadType uint8

+ Sequence uint16

+ Timestamp uint32

+ type ReadBuffer struct

+ BufferSize int

+ func NewReadBuffer(rd io.Reader) *ReadBuffer

+ func (r *ReadBuffer) Close() error

+ func (r *ReadBuffer) Peek(n int) ([]byte, error)

+ func (r *ReadBuffer) Read(p []byte) (n int, err error)

+ func (r *ReadBuffer) Reset()

+ func (r *ReadBuffer) Seek(offset int64, whence int) (int64, error)

type Receiver

+ func VA(receivers []*Receiver) (video, audio *Receiver)

+ type SuperConsumer struct

+ Medias []*Media

+ RemoteAddr string

+ SDP string

+ Send int

+ Senders []*Sender

+ Type string

+ URL string

+ UserAgent string

+ func (s *SuperConsumer) AddTrack(media *Media, codec *Codec, track *Receiver) error

+ func (s *SuperConsumer) Close() error

+ func (s *SuperConsumer) Codecs() []*Codec

+ func (s *SuperConsumer) GetMedias() []*Media

+ type SuperProducer struct

+ Medias []*Media

+ Receivers []*Receiver

+ Recv int

+ SDP string

+ Type string

+ URL string

+ func (s *SuperProducer) Close() error

+ func (s *SuperProducer) GetMedias() []*Media

+ func (s *SuperProducer) GetTrack(media *Media, codec *Codec) (*Receiver, error)

+ type WriteBuffer struct

+ func NewWriteBuffer(wr io.Writer) *WriteBuffer

+ func (w *WriteBuffer) Close() error

+ func (w *WriteBuffer) Reset(wr io.Writer)

+ func (w *WriteBuffer) Write(p []byte) (n int, err error)

+ func (w *WriteBuffer) WriteTo(wr io.Writer) (n int64, err error)

v1.6.2

Jul 20, 2023

v1.6.1

Jul 20, 2023

Changes in this version

+ const CodecPCML

v1.6.0

Jul 11, 2023

v1.5.0

May 4, 2023

Changes in this version

+ func Any(errs ...error) error

+ func Atoi(s string) (i int)

+ func Now90000() uint32

v1.4.0

Apr 23, 2023

Changes in this version

+ const CodecFLAC

v1.3.2

Apr 17, 2023

Changes in this version

type Media

+ func (m *Media) Equal(media *Media) bool

v1.3.1

Mar 26, 2023

v1.3.0

Mar 23, 2023

Changes in this version

+ const CodecAAC

+ const CodecAV1

+ const CodecAll

+ const CodecAny

+ const CodecELD

+ const CodecG722

+ const CodecH264

+ const CodecH265

+ const CodecJPEG

+ const CodecMP3

+ const CodecOpus

+ const CodecPCM

+ const CodecPCMA

+ const CodecPCMU

+ const CodecVP8

+ const CodecVP9

+ const DirectionRecvonly

+ const DirectionSendRecv

+ const DirectionSendonly

+ const KindAudio

+ const KindVideo

+ const PayloadTypeRAW

+ const UnsupportedCodec

+ const WrongMediaDirection

+ var ErrCantGetTrack = errors.New("can't get track")

+ func Assert(ok bool)

+ func Between(s, sub1, sub2 string) string

+ func Caller() string

+ func DecodeH264(fmtp string) string

+ func GetKind(name string) string

+ func MarshalSDP(name string, medias []*Media) ([]byte, error)

+ func RandString(size, base byte) string

+ type Codec struct

+ Channels uint16

+ ClockRate uint32

+ FmtpLine string

+ Name string

+ PayloadType uint8

+ func UnmarshalCodec(md *sdp.MediaDescription, payloadType string) *Codec

+ func (c *Codec) Clone() *Codec

+ func (c *Codec) IsRTP() bool

+ func (c *Codec) Match(remote *Codec) bool

+ func (c *Codec) String() string

+ func (c *Codec) Text() string

+ type Consumer interface

+ AddTrack func(media *Media, codec *Codec, track *Receiver) error

+ GetMedias func() []*Media

+ Stop func() error

+ type EventFunc func(msg any)

+ type HandlerFunc func(packet *rtp.Packet)

+ type Info struct

+ Medias []*Media

+ Receivers []*Receiver

+ Recv int

+ RemoteAddr string

+ Send int

+ Senders []*Sender

+ Type string

+ URL string

+ UserAgent string

+ type Listener struct

+ func (l *Listener) Fire(msg any)

+ func (l *Listener) Listen(f EventFunc)

+ type Media struct

+ Codecs []*Codec

+ Direction string

+ ID string

+ Kind string

+ func ParseQuery(query map[string][]string) (medias []*Media)

+ func UnmarshalMedia(md *sdp.MediaDescription) *Media

+ func (m *Media) Clone() *Media

+ func (m *Media) MarshalJSON() ([]byte, error)

+ func (m *Media) MatchAll() bool

+ func (m *Media) MatchCodec(remote *Codec) *Codec

+ func (m *Media) MatchMedia(remote *Media) (codec, remoteCodec *Codec)

+ func (m *Media) String() string

+ type Mode byte

+ const ModeActiveConsumer

+ const ModeActiveProducer

+ const ModePassiveConsumer

+ const ModePassiveProducer

+ func (m Mode) String() string

+ type Probe struct

+ func NewProbe(enable bool) *Probe

+ func (p *Probe) Active() bool

+ func (p *Probe) Append(v any)

+ type Producer interface

+ GetMedias func() []*Media

+ GetTrack func(media *Media, codec *Codec) (*Receiver, error)

+ Start func() error

+ Stop func() error

+ type Receiver struct

+ Codec *Codec

+ ID byte

+ Media *Media

+ func NewReceiver(media *Media, codec *Codec) *Receiver

+ func (t *Receiver) Close()

+ func (t *Receiver) MarshalJSON() ([]byte, error)

+ func (t *Receiver) Replace(target *Receiver)

+ func (t *Receiver) Senders() (senders []*Sender)

+ func (t *Receiver) String() string

+ func (t *Receiver) WriteRTP(packet *rtp.Packet)

+ type Sender struct

+ Codec *Codec

+ Handler HandlerFunc

+ Media *Media

+ func NewSender(media *Media, codec *Codec) *Sender

+ func (s *Sender) Close()

+ func (s *Sender) HandleRTP(track *Receiver)

+ func (s *Sender) MarshalJSON() ([]byte, error)

+ func (s *Sender) String() string

+ type Waiter struct

+ func (w *Waiter) Add(delta int)

+ func (w *Waiter) Done()

+ func (w *Waiter) Wait()

+ func (w *Waiter) WaitChan() <-chan struct{}

+ type Worker struct

+ func NewWorker(d time.Duration, f func() time.Duration) *Worker

+ func (w *Worker) Do()

+ func (w *Worker) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL