rtsp

type Channel interface {
	SetSDP(tx Transaction, sdp *sdp.Message, raw []byte) bool
	SDP() *sdp.Message
	Raw() []byte
	Lock(tx Transaction) bool
	Source() Transaction
	Input() chan *Package
	Play(tx Transaction) error
	Record(tx Transaction) error
	Teardown(tx Transaction) error
}

type HandlerFunc func(req Request, res Response, tx Transaction) error

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

type Package struct {
	Ch          int
	Len         uint32
	Order       int
	Interleaved bool
	Data        []byte
}

type Request interface {
	Method() methods.Method
	URL() *url.URL
	Path() string
	Stream() string
	Headers() map[string][]string
	Header(key string) ([]string, bool)
	Transport() (header.TransportHeader, bool)
	CSeq() string
	Proto() string
	SessionID() string
	ContentType() string
	Body() []byte
	Encode() []byte
	ParseSDP() (*sdp.Message, error)
	Channel() string
}

type Response interface {
	SetHeader(key string, value ...string)
	SetBody(body []byte)
	SetStatus(status string)
	SetCode(code uint64)
	Encoding() []byte
}

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

type ServerOption func(s *Server)

type Transaction interface {
	ID() string
	IP() net.IP
	Status() status.Status
	Forward(p *Package, wg *sync.WaitGroup) error
	Response(res Response) error
	Request(req Request) error
	Medias() map[string]*Media
	AddMedia(media *Media)
	PreReady(sdp *sdp.Message) bool
	PreRecord(sdp *sdp.Message) bool
	PrePlay(sdp *sdp.Message) bool
	PreInit()
	Interleaved() bool
	ReadInterleavedFrame(frame []byte) (int, uint32, error)
	WriteInterleavedFrame(channel int, frame []byte) error
	Read(buf []byte) (int, error)
	RTCP() int
	RTP() int
	Close() error
}

type TransactionController interface {
	CreateTx(trans *transport, rf *rtcpFamily) *transaction
	DeleteTx(id *transaction)
	GetCh(ch string) (Channel, bool)
	GetOrCreateCh(ch string) Channel
	Forward(p *Package, addr *net.UDPAddr)
}

type Transport interface {
	Addr() string
	IP() net.IP
	Parse() (*request, error)
	Write(data []byte) error
	Read(buf []byte) (int, error)
	Conn() net.Conn
	Close() error
}

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