Versions in this module Expand all Collapse all v1 v1.0.1 Jul 20, 2023 Changes in this version + type DefaultFrame struct + func NewDefaultFrame(pool pool.Pool[*DefaultFrame]) *DefaultFrame + func (f *DefaultFrame) AddRef() + func (f *DefaultFrame) AddRelation(relation pool.Reference) + func (f *DefaultFrame) Append(packet rtp.Packet) bool + func (f *DefaultFrame) Clear() + func (f *DefaultFrame) Len() int + func (f *DefaultFrame) Packet(i int) rtp.Packet + func (f *DefaultFrame) PayloadType() uint8 + func (f *DefaultFrame) Range(fn func(i int, packet rtp.Packet) bool) bool + func (f *DefaultFrame) Release() bool + func (f *DefaultFrame) SetPayloadType(typ uint8) + func (f *DefaultFrame) SetTimestamp(timestamp uint32) + func (f *DefaultFrame) Timestamp() uint32 + func (f *DefaultFrame) Use() *DefaultFrame + type Frame interface + AddRelation func(relation pool.Reference) + Append func(packet rtp.Packet) bool + Clear func() + Len func() int + Packet func(i int) rtp.Packet + PayloadType func() uint8 + Range func(f func(i int, packet rtp.Packet) bool) bool + SetPayloadType func(typ uint8) + SetTimestamp func(timestamp uint32) + Timestamp func() uint32 + func NewFrame() Frame + func UseFrame(frame Frame) Frame + type FrameHandler interface + HandleFrame func(stream server.Stream, frame *IncomingFrame) + OnParseRTPError func(stream server.Stream, err error) (keep bool) + OnStreamClosed func(stream server.Stream) + type FrameHandlerFunc struct + HandleFrameFn func(stream server.Stream, frame *IncomingFrame) + OnParseRTPErrorFn func(stream server.Stream, err error) (keep bool) + OnStreamClosedFn func(stream server.Stream) + func (h FrameHandlerFunc) HandleFrame(stream server.Stream, frame *IncomingFrame) + func (h FrameHandlerFunc) OnParseRTPError(stream server.Stream, err error) (keep bool) + func (h FrameHandlerFunc) OnStreamClosed(stream server.Stream) + type FrameRTPHandler struct + func NewFrameRTPHandler(frameHandler FrameHandler) *FrameRTPHandler + func (h *FrameRTPHandler) HandlePacket(stream server.Stream, packet *rtp.IncomingPacket) (dropped, keep bool) + func (h *FrameRTPHandler) OnParseError(stream server.Stream, err error) (keep bool) + func (h *FrameRTPHandler) OnStreamClosed(stream server.Stream) + type FrameWriter interface + Frame func() Frame + Read func(p []byte) (n int, err error) + SetFrame func(frame Frame) + Size func() int + WriteTo func(w io.Writer) (n int64, err error) + func NewPayloadFrameWriter(frame Frame) FrameWriter + type FullFrameWriter struct + func NewFullFrameWriter(frame Frame) *FullFrameWriter + func (f *FullFrameWriter) DisablePayloadType() + func (f *FullFrameWriter) DisableSSRC() + func (f *FullFrameWriter) DisableSequenceNumber() + func (f *FullFrameWriter) DisableTimestamp() + func (f *FullFrameWriter) Frame() Frame + func (f *FullFrameWriter) PayloadType() (uint8, bool) + func (f *FullFrameWriter) Read(p []byte) (n int, err error) + func (f *FullFrameWriter) SSRC() (uint32, bool) + func (f *FullFrameWriter) SequenceNumber() (uint16, bool) + func (f *FullFrameWriter) SetFrame(frame Frame) + func (f *FullFrameWriter) SetPayloadType(payloadType uint8) + func (f *FullFrameWriter) SetSSRC(ssrc uint32) + func (f *FullFrameWriter) SetSequenceNumber(sequenceNumber uint16) + func (f *FullFrameWriter) SetTimestamp(timestamp uint32) + func (f *FullFrameWriter) Size() int + func (f *FullFrameWriter) Timestamp() (uint32, bool) + func (f *FullFrameWriter) WriteTo(w io.Writer) (n int64, err error) + func (f *FullFrameWriter) WriteToUDP(buffer *bytes.Buffer, udpConn *net.UDPConn) (err error) + type IncomingFrame struct + func (f *IncomingFrame) AddRef() + func (f *IncomingFrame) AddRelation(relation pool.Reference) + func (f *IncomingFrame) Append(packet rtp.Packet) bool + func (f *IncomingFrame) Clear() + func (f *IncomingFrame) End() time.Time + func (f *IncomingFrame) Len() int + func (f *IncomingFrame) Packet(i int) rtp.Packet + func (f *IncomingFrame) PayloadType() uint8 + func (f *IncomingFrame) Range(fn func(i int, packet rtp.Packet) bool) bool + func (f *IncomingFrame) Release() bool + func (f *IncomingFrame) SetPayloadType(typ uint8) + func (f *IncomingFrame) SetTimestamp(timestamp uint32) + func (f *IncomingFrame) Start() time.Time + func (f *IncomingFrame) Timestamp() uint32 + func (f *IncomingFrame) Use() *IncomingFrame + type PayloadFrameWriter struct + func (f *PayloadFrameWriter) Frame() Frame + func (f *PayloadFrameWriter) Read(p []byte) (n int, err error) + func (f *PayloadFrameWriter) SetFrame(frame Frame) + func (f *PayloadFrameWriter) Size() int + func (f *PayloadFrameWriter) WriteTo(w io.Writer) (n int64, err error)