rtsp

type Player struct {
	*Session
	Pusher *Pusher
	// contains filtered or unexported fields
}

type Pusher struct {
	*Session
	*RTSPClient

	UDPServer *UDPServer
	// contains filtered or unexported fields
}

type RTPInfo struct {
	Version        int
	Padding        bool
	Extension      bool
	CSRCCnt        int
	Marker         bool
	PayloadType    int
	SequenceNumber int
	Timestamp      int
	SSRC           int
	Payload        []byte
	PayloadOffset  int
}

type RTPPack struct {
	Type   RTPType
	Buffer *bytes.Buffer
}

type RTPType int

type RTSPClient struct {
	Server *Server
	SessionLogger
	Stoped     bool
	Status     string
	URL        string
	Path       string
	CustomPath string //custom path for pusher
	ID         string
	Conn       *RichConn
	Session    string
	Seq        int

	InBytes              int
	OutBytes             int
	TransType            TransType
	StartAt              time.Time
	Sdp                  *sdp.Session
	AControl             string
	VControl             string
	ACodec               string
	VCodec               string
	OptionIntervalMillis int64
	SDPRaw               string

	Agent string

	UDPServer   *UDPServer
	RTPHandles  []func(*RTPPack)
	StopHandles []func()
	// contains filtered or unexported fields
}

type Request struct {
	Method  string
	URL     string
	Version string
	Header  map[string]string
	Content string
	Body    string
}

type Response struct {
	Version    string
	StatusCode int
	Status     string
	Header     map[string]interface{}
	Body       string
}

type RichConn struct {
	net.Conn
	// contains filtered or unexported fields
}

type SDPInfo struct {
	AVType             string
	Codec              string
	TimeScale          int
	Control            string
	Rtpmap             int
	Config             []byte
	SpropParameterSets [][]byte
	PayloadType        int
	SizeLength         int
	IndexLength        int
}

type Server struct {
	SessionLogger
	TCPListener *net.TCPListener
	TCPPort     int
	Stoped      bool
	// contains filtered or unexported fields
}

type Session struct {
	SessionLogger
	ID     string
	Server *Server
	Conn   *RichConn

	Type      SessionType
	TransType TransType
	Path      string
	URL       string
	SDPRaw    string
	SDPMap    map[string]*SDPInfo

	AControl string
	VControl string
	ACodec   string
	VCodec   string

	// stats info
	InBytes  int
	OutBytes int
	StartAt  time.Time
	Timeout  int

	Stoped bool

	Pusher      *Pusher
	Player      *Player
	UDPClient   *UDPClient
	RTPHandles  []func(*RTPPack)
	StopHandles []func()
	// contains filtered or unexported fields
}

type SessionLogger struct {
	// contains filtered or unexported fields
}

type SessionType int

type TransType int

type UDPClient struct {
	*Session

	APort        int
	AConn        *net.UDPConn
	AControlPort int
	AControlConn *net.UDPConn
	VPort        int
	VConn        *net.UDPConn
	VControlPort int
	VControlConn *net.UDPConn

	Stoped bool
}

type UDPServer struct {
	*Session
	*RTSPClient

	APort        int
	AConn        *net.UDPConn
	AControlPort int
	AControlConn *net.UDPConn
	VPort        int
	VConn        *net.UDPConn
	VControlPort int
	VControlConn *net.UDPConn

	Stoped bool
}