core

Feb 25, 2023

Changes in this version

+ var ErrFail = fmt.Errorf("respone err")

+ var ErrReq = fmt.Errorf("req error")

+ type ChunkStream struct

+ CSID uint32

+ Data []byte

+ Format uint32

+ Length uint32

+ StreamID uint32

+ Timestamp uint32

+ TypeID uint32

+ type Conn struct

+ func NewConn(c net.Conn, bufferSize int) *Conn

+ func (conn *Conn) Close() error

+ func (conn *Conn) Flush() error

+ func (conn *Conn) HandshakeClient() (err error)

+ func (conn *Conn) HandshakeServer() (err error)

+ func (conn *Conn) LocalAddr() net.Addr

+ func (conn *Conn) NewAck(size uint32) ChunkStream

+ func (conn *Conn) NewSetChunkSize(size uint32) ChunkStream

+ func (conn *Conn) NewSetPeerBandwidth(size uint32) ChunkStream

+ func (conn *Conn) NewWindowAckSize(size uint32) ChunkStream

+ func (conn *Conn) Read(c *ChunkStream) error

+ func (conn *Conn) RemoteAddr() net.Addr

+ func (conn *Conn) SetBegin()

+ func (conn *Conn) SetDeadline(t time.Time) error

+ func (conn *Conn) SetRecorded()

+ func (conn *Conn) Write(c *ChunkStream) error

+ type ConnClient struct

+ func NewConnClient() *ConnClient

+ func (connClient *ConnClient) Close(err error)

+ func (connClient *ConnClient) DecodeBatch(r io.Reader, ver amf.Version) (ret []interface{}, err error)

+ func (connClient *ConnClient) Flush() error

+ func (connClient *ConnClient) GetInfo() (app string, name string, url string)

+ func (connClient *ConnClient) GetStreamId() uint32

+ func (connClient *ConnClient) Read(c *ChunkStream) (err error)

+ func (connClient *ConnClient) Start(url string, method string) error

+ func (connClient *ConnClient) Write(c ChunkStream) error

+ type ConnServer struct

+ ConnInfo ConnectInfo

+ PublishInfo PublishInfo

+ func NewConnServer(conn *Conn) *ConnServer

+ func (connServer *ConnServer) Close(err error)

+ func (connServer *ConnServer) Flush() error

+ func (connServer *ConnServer) GetInfo() (app string, name string, url string)

+ func (connServer *ConnServer) IsPublisher() bool

+ func (connServer *ConnServer) Read(c *ChunkStream) (err error)

+ func (connServer *ConnServer) ReadMsg() error

+ func (connServer *ConnServer) Write(c ChunkStream) error

+ type ConnectEvent struct

+ Code string

+ Description string

+ Level string

+ ObjectEncoding int

+ type ConnectInfo struct

+ App string

+ AudioCodecs int

+ Flashver string

+ Fpad bool

+ ObjectEncoding int

+ PageUrl string

+ SwfUrl string

+ TcUrl string

+ VideoCodecs int

+ VideoFunction int

+ type ConnectResp struct

+ Capabilities int

+ FMSVer string

+ type PublishInfo struct

+ Name string

+ Type string

+ type ReadWriter struct

+ func NewReadWriter(rw io.ReadWriter, bufSize int) *ReadWriter

+ func (rw *ReadWriter) Flush() error

+ func (rw *ReadWriter) Read(p []byte) (int, error)

+ func (rw *ReadWriter) ReadError() error

+ func (rw *ReadWriter) ReadUintBE(n int) (uint32, error)

+ func (rw *ReadWriter) ReadUintLE(n int) (uint32, error)

+ func (rw *ReadWriter) Write(p []byte) (int, error)

+ func (rw *ReadWriter) WriteError() error

+ func (rw *ReadWriter) WriteUintBE(v uint32, n int) error

+ func (rw *ReadWriter) WriteUintLE(v uint32, n int) error