srtp

Jul 26, 2023

Changes in this version

type ContextOption

+ func SRTCPReplayDetectorFactory(fn func() replaydetector.ReplayDetector) ContextOption

+ func SRTPReplayDetectorFactory(fn func() replaydetector.ReplayDetector) ContextOption

May 19, 2023

Changes in this version

type ProtectionProfile

+ const ProtectionProfileAeadAes256Gcm

May 3, 2023

Changes in this version

type Config

+ AcceptStreamTimeout time.Time

May 1, 2022

Changes in this version

type ProtectionProfile

+ const ProtectionProfileAes128CmHmacSha1_32

Jan 4, 2021

Changes in this version

type Config

+ BufferFactory func(packetType packetio.BufferPacketType, ssrc uint32) io.ReadWriteCloser

Dec 19, 2020

Changes in this version

+ type Config struct

+ Keys SessionKeys

+ LocalOptions []ContextOption

+ LoggerFactory logging.LoggerFactory

+ Profile ProtectionProfile

+ RemoteOptions []ContextOption

+ func (c *Config) ExtractSessionKeysFromDTLS(exporter KeyingMaterialExporter, isClient bool) error

+ type Context struct

+ func CreateContext(masterKey, masterSalt []byte, profile ProtectionProfile, opts ...ContextOption) (c *Context, err error)

+ func (c *Context) DecryptRTCP(dst, encrypted []byte, header *rtcp.Header) ([]byte, error)

+ func (c *Context) DecryptRTP(dst, encrypted []byte, header *rtp.Header) ([]byte, error)

+ func (c *Context) EncryptRTCP(dst, decrypted []byte, header *rtcp.Header) ([]byte, error)

+ func (c *Context) EncryptRTP(dst []byte, plaintext []byte, header *rtp.Header) ([]byte, error)

+ func (c *Context) Index(ssrc uint32) (uint32, bool)

+ func (c *Context) ROC(ssrc uint32) (uint32, bool)

+ func (c *Context) SetIndex(ssrc uint32, index uint32)

+ func (c *Context) SetROC(ssrc uint32, roc uint32)

+ type ContextOption func(*Context) error

+ func SRTCPNoReplayProtection() ContextOption

+ func SRTCPReplayProtection(windowSize uint) ContextOption

+ func SRTPNoReplayProtection() ContextOption

+ func SRTPReplayProtection(windowSize uint) ContextOption

+ type KeyingMaterialExporter interface

+ ExportKeyingMaterial func(label string, context []byte, length int) ([]byte, error)

+ type ProtectionProfile uint16

+ const ProtectionProfileAeadAes128Gcm

+ const ProtectionProfileAes128CmHmacSha1_80

+ type ReadStreamSRTCP struct

+ func (r *ReadStreamSRTCP) Close() error

+ func (r *ReadStreamSRTCP) GetSSRC() uint32

+ func (r *ReadStreamSRTCP) Read(buf []byte) (int, error)

+ func (r *ReadStreamSRTCP) ReadRTCP(buf []byte) (int, *rtcp.Header, error)

+ func (r *ReadStreamSRTCP) SetReadDeadline(t time.Time) error

+ type ReadStreamSRTP struct

+ func (r *ReadStreamSRTP) Close() error

+ func (r *ReadStreamSRTP) GetSSRC() uint32

+ func (r *ReadStreamSRTP) Read(buf []byte) (int, error)

+ func (r *ReadStreamSRTP) ReadRTP(buf []byte) (int, *rtp.Header, error)

+ func (r *ReadStreamSRTP) SetReadDeadline(t time.Time) error

+ type SessionKeys struct

+ LocalMasterKey []byte

+ LocalMasterSalt []byte

+ RemoteMasterKey []byte

+ RemoteMasterSalt []byte

+ type SessionSRTCP struct

+ func NewSessionSRTCP(conn net.Conn, config *Config) (*SessionSRTCP, error)

+ func (s *SessionSRTCP) AcceptStream() (*ReadStreamSRTCP, uint32, error)

+ func (s *SessionSRTCP) Close() error

+ func (s *SessionSRTCP) OpenReadStream(ssrc uint32) (*ReadStreamSRTCP, error)

+ func (s *SessionSRTCP) OpenWriteStream() (*WriteStreamSRTCP, error)

+ type SessionSRTP struct

+ func NewSessionSRTP(conn net.Conn, config *Config) (*SessionSRTP, error)

+ func (s *SessionSRTP) AcceptStream() (*ReadStreamSRTP, uint32, error)

+ func (s *SessionSRTP) Close() error

+ func (s *SessionSRTP) OpenReadStream(ssrc uint32) (*ReadStreamSRTP, error)

+ func (s *SessionSRTP) OpenWriteStream() (*WriteStreamSRTP, error)

+ type WriteStreamSRTCP struct

+ func (w *WriteStreamSRTCP) SetWriteDeadline(t time.Time) error

+ func (w *WriteStreamSRTCP) Write(b []byte) (int, error)

+ func (w *WriteStreamSRTCP) WriteRTCP(header *rtcp.Header, payload []byte) (int, error)

+ type WriteStreamSRTP struct

+ func (w *WriteStreamSRTP) SetWriteDeadline(t time.Time) error

+ func (w *WriteStreamSRTP) Write(b []byte) (int, error)

+ func (w *WriteStreamSRTP) WriteRTP(header *rtp.Header, payload []byte) (int, error)