Versions in this module Expand all Collapse all v0 v0.0.1 Nov 29, 2022 Changes in this version + type Factory struct + NewInterceptorFn func(id string) (interceptor.Interceptor, error) + func (f *Factory) NewInterceptor(id string) (interceptor.Interceptor, error) + type Interceptor struct + BindLocalStreamFn func(i *interceptor.StreamInfo, writer interceptor.RTPWriter) interceptor.RTPWriter + BindRTCPReaderFn func(reader interceptor.RTCPReader) interceptor.RTCPReader + BindRTCPWriterFn func(writer interceptor.RTCPWriter) interceptor.RTCPWriter + BindRemoteStreamFn func(i *interceptor.StreamInfo, reader interceptor.RTPReader) interceptor.RTPReader + CloseFn func() error + UnbindLocalStreamFn func(i *interceptor.StreamInfo) + UnbindRemoteStreamFn func(i *interceptor.StreamInfo) + func (i *Interceptor) BindLocalStream(info *interceptor.StreamInfo, writer interceptor.RTPWriter) interceptor.RTPWriter + func (i *Interceptor) BindRTCPReader(reader interceptor.RTCPReader) interceptor.RTCPReader + func (i *Interceptor) BindRTCPWriter(writer interceptor.RTCPWriter) interceptor.RTCPWriter + func (i *Interceptor) BindRemoteStream(info *interceptor.StreamInfo, reader interceptor.RTPReader) interceptor.RTPReader + func (i *Interceptor) Close() error + func (i *Interceptor) UnbindLocalStream(info *interceptor.StreamInfo) + func (i *Interceptor) UnbindRemoteStream(info *interceptor.StreamInfo) + type RTCPReader struct + ReadFn func([]byte, interceptor.Attributes) (int, interceptor.Attributes, error) + func (r *RTCPReader) Read(b []byte, attributes interceptor.Attributes) (int, interceptor.Attributes, error) + type RTCPWriter struct + WriteFn func([]rtcp.Packet, interceptor.Attributes) (int, error) + func (w *RTCPWriter) Write(pkts []rtcp.Packet, attributes interceptor.Attributes) (int, error) + type RTPReader struct + ReadFn func([]byte, interceptor.Attributes) (int, interceptor.Attributes, error) + func (r *RTPReader) Read(b []byte, attributes interceptor.Attributes) (int, interceptor.Attributes, error) + type RTPWriter struct + WriteFn func(*rtp.Header, []byte, interceptor.Attributes) (int, error) + func (w *RTPWriter) Write(header *rtp.Header, payload []byte, attributes interceptor.Attributes) (int, error)
Go to main page