rtsp

Aug 29, 2020

Changes in this version

+ func BasicAuth(authLine string, method string, URL string) (string, error)

type RTSP

+ ASdp *SDPInfo

+ VSdp *SDPInfo

May 20, 2020

Changes in this version

type RTSPInfo

+ SDPRaw string

May 10, 2020

Changes in this version

+ const ANNOUNCE

+ const DATA

+ const DESCRIBE

+ const GET_PARAMETER

+ const OPTIONS

+ const PAUSE

+ const PLAY

+ const RECORD

+ const REDIRECT

+ const RTP_FIXED_HEADER_LENGTH

+ const RTSP_VERSION

+ const SETUP

+ const SET_PARAMETER

+ const TEARDOWN

+ const UDP_BUF_SIZE

+ func DigestAuth(authLine string, method string, URL string) (string, error)

+ func ListenRtsp(addr string) error

+ func ParseSDP(sdpRaw string) map[string]*SDPInfo

+ type RTPInfo struct

+ CSRCCnt int

+ Extension bool

+ Marker bool

+ Padding bool

+ Payload []byte

+ PayloadOffset int

+ PayloadType int

+ SSRC int

+ SequenceNumber int

+ Timestamp int

+ Version int

+ func ParseRTP(rtpBytes []byte) *RTPInfo

+ type RTPPack struct

+ Buffer []byte

+ Type RTPType

+ type RTPType int

+ const RTP_TYPE_AUDIO

+ const RTP_TYPE_AUDIOCONTROL

+ const RTP_TYPE_VIDEO

+ const RTP_TYPE_VIDEOCONTROL

+ func (rt RTPType) String() string

+ type RTSP struct

+ ACodec string

+ AControl string

+ AudioSpecificConfig []byte

+ Auth func(string) string

+ Conn *RichConn

+ ID string

+ PPS []byte

+ SDPMap map[string]*SDPInfo

+ SDPRaw string

+ SPS []byte

+ Timeout int

+ TransType TransType

+ Type SessionType

+ UDPClient *UDPClient

+ UDPServer *UDPServer

+ VCodec string

+ VControl string

+ func (client *RTSP) Request(method string, headers map[string]string) (*Response, error)

+ func (client *RTSP) RequestNoResp(method string, headers map[string]string) (err error)

+ func (client *RTSP) RequestWithPath(method string, path string, headers map[string]string, needResp bool) (resp *Response, err error)

+ func (rtsp *RTSP) PullStream(streamPath string, rtspUrl string) (result bool)

+ func (session *RTSP) AcceptPush()

+ func (session *RTSP) CheckAuth(authLine string, method string) error

+ func (session *RTSP) SendRTP(pack *RTPPack) (err error)

+ func (session *RTSP) SessionString() string

+ func (session *RTSP) Stop()

+ type RTSPClientInfo struct

+ Agent string

+ Sdp *sdp.Session

+ Seq int

+ Session string

+ type RTSPInfo struct

+ BufferRate int

+ Header *string

+ InBytes int

+ OutBytes int

+ StreamInfo *StreamInfo

+ SyncCount int64

+ URL string

+ type Request struct

+ Body string

+ Content string

+ Header map[string]string

+ Method string

+ URL string

+ Version string

+ func NewRequest(content string) *Request

+ func (r *Request) GetContentLength() int

+ func (r *Request) String() string

+ type Response struct

+ Body string

+ Header map[string]interface{}

+ Status string

+ StatusCode int

+ Version string

+ func NewResponse(statusCode int, status, cSeq, sid, body string) *Response

+ func (r *Response) SetBody(body string)

+ func (r *Response) String() string

+ type RichConn struct

+ func (conn *RichConn) Read(b []byte) (n int, err error)

+ func (conn *RichConn) Write(b []byte) (n int, err error)

+ type SDPInfo struct

+ AVType string

+ Codec string

+ Config []byte

+ Control string

+ IndexLength int

+ PayloadType int

+ Rtpmap int

+ SizeLength int

+ SpropParameterSets [][]byte

+ TimeScale int

+ type SessionType int

+ const SESSEION_TYPE_PLAYER

+ const SESSION_TYPE_PUSHER

+ func (st SessionType) String() string

+ type TransType int

+ const TRANS_TYPE_TCP

+ const TRANS_TYPE_UDP

+ func (tt TransType) String() string

+ type UDPClient struct

+ AConn *net.UDPConn

+ AControlConn *net.UDPConn

+ AControlPort int

+ APort int

+ Stoped bool

+ VConn *net.UDPConn

+ VControlConn *net.UDPConn

+ VControlPort int

+ VPort int

+ func (c *UDPClient) SendRTP(pack *RTPPack) (err error)

+ func (c *UDPClient) SetupAudio() (err error)

+ func (c *UDPClient) SetupVideo() (err error)

+ func (s *UDPClient) Stop()

+ type UDPServer struct

+ Session *RTSP

+ func (s *UDPServer) AddInputBytes(bytes int)

+ func (s *UDPServer) HandleRTP(pack *RTPPack)

+ func (s *UDPServer) SetupAudio() (err error)

+ func (s *UDPServer) SetupVideo() (err error)

+ func (s *UDPServer) Stop()