Versions in this module Expand all Collapse all v0 v0.1.0 May 11, 2020 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
Go to main page