Versions in this module Expand all Collapse all v0 v0.0.1 Nov 29, 2022 Changes in this version + type Attributes map[interface{}]interface + func (a Attributes) Get(key interface{}) interface{} + func (a Attributes) GetRTCPPackets(raw []byte) ([]rtcp.Packet, error) + func (a Attributes) GetRTPHeader(raw []byte) (*rtp.Header, error) + func (a Attributes) Set(key interface{}, val interface{}) + type Chain struct + func NewChain(interceptors []Interceptor) *Chain + func (i *Chain) BindLocalStream(ctx *StreamInfo, writer RTPWriter) RTPWriter + func (i *Chain) BindRTCPReader(reader RTCPReader) RTCPReader + func (i *Chain) BindRTCPWriter(writer RTCPWriter) RTCPWriter + func (i *Chain) BindRemoteStream(ctx *StreamInfo, reader RTPReader) RTPReader + func (i *Chain) Close() error + func (i *Chain) UnbindLocalStream(ctx *StreamInfo) + func (i *Chain) UnbindRemoteStream(ctx *StreamInfo) + type Factory interface + NewInterceptor func(id string) (Interceptor, error) + type Interceptor interface + BindLocalStream func(info *StreamInfo, writer RTPWriter) RTPWriter + BindRTCPReader func(reader RTCPReader) RTCPReader + BindRTCPWriter func(writer RTCPWriter) RTCPWriter + BindRemoteStream func(info *StreamInfo, reader RTPReader) RTPReader + UnbindLocalStream func(info *StreamInfo) + UnbindRemoteStream func(info *StreamInfo) + type NoOp struct + func (i *NoOp) BindLocalStream(_ *StreamInfo, writer RTPWriter) RTPWriter + func (i *NoOp) BindRTCPReader(reader RTCPReader) RTCPReader + func (i *NoOp) BindRTCPWriter(writer RTCPWriter) RTCPWriter + func (i *NoOp) BindRemoteStream(_ *StreamInfo, reader RTPReader) RTPReader + func (i *NoOp) Close() error + func (i *NoOp) UnbindLocalStream(_ *StreamInfo) + func (i *NoOp) UnbindRemoteStream(_ *StreamInfo) + type RTCPFeedback struct + Parameter string + Type string + type RTCPReader interface + Read func([]byte, Attributes) (int, Attributes, error) + type RTCPReaderFunc func([]byte, Attributes) (int, Attributes, error) + func (f RTCPReaderFunc) Read(b []byte, a Attributes) (int, Attributes, error) + type RTCPWriter interface + Write func(pkts []rtcp.Packet, attributes Attributes) (int, error) + type RTCPWriterFunc func(pkts []rtcp.Packet, attributes Attributes) (int, error) + func (f RTCPWriterFunc) Write(pkts []rtcp.Packet, attributes Attributes) (int, error) + type RTPHeaderExtension struct + ID int + URI string + type RTPReader interface + Read func([]byte, Attributes) (int, Attributes, error) + type RTPReaderFunc func([]byte, Attributes) (int, Attributes, error) + func (f RTPReaderFunc) Read(b []byte, a Attributes) (int, Attributes, error) + type RTPWriter interface + Write func(header *rtp.Header, payload []byte, attributes Attributes) (int, error) + type RTPWriterFunc func(header *rtp.Header, payload []byte, attributes Attributes) (int, error) + func (f RTPWriterFunc) Write(header *rtp.Header, payload []byte, attributes Attributes) (int, error) + type Registry struct + func (r *Registry) Add(f Factory) + func (r *Registry) Build(id string) (Interceptor, error) + type StreamInfo struct + Attributes Attributes + Channels uint16 + ClockRate uint32 + ID string + MimeType string + PayloadType uint8 + RTCPFeedback []RTCPFeedback + RTPHeaderExtensions []RTPHeaderExtension + SDPFmtpLine string + SSRC uint32
Go to main page