rtmp

Aug 19, 2021

Changes in this version

+ const Amf0TypeMarkerBoolean

+ const Amf0TypeMarkerEcmaArray

+ const Amf0TypeMarkerLongString

+ const Amf0TypeMarkerNull

+ const Amf0TypeMarkerNumber

+ const Amf0TypeMarkerObject

+ const Amf0TypeMarkerObjectEnd

+ const Amf0TypeMarkerString

+ const CsidAmf

+ const CsidAudio

+ const CsidVideo

+ const Msid1

+ var Amf0 amf0

+ var Amf0TypeMarkerObjectEndBytes = []byte

+ var ErrAmfInvalidType = errors.New("lal.rtmp: invalid amf0 type")

+ var ErrAmfNotExist = errors.New("lal.rtmp: not exist")

+ var ErrAmfTooShort = errors.New("lal.rtmp: too short to unmarshal amf0 data")

+ var ErrRtmp = errors.New("lal.rtmp: fxxk")

+ type Buffer struct

+ func NewBuffer(n int) *Buffer

+ func (b *Buffer) Bytes() []byte

+ func (b *Buffer) Len() int

+ func (b *Buffer) ModWritePos(pos int)

+ func (b *Buffer) Reset()

+ func (b *Buffer) Write(p []byte) (n int, err error)

+ func (b *Buffer) WriteByte(c byte) error

+ func (b *Buffer) WriteTo(w io.Writer) (n int64, err error)

type ClientSession

+ func (s *ClientSession) Url() string

type ClientSessionOption

+ DoTimeoutMs int

+ ReadAvTimeoutMs int

+ WriteAvTimeoutMs int

type ClientSessionType

+ const CstPullSession

+ const CstPushSession

type MessagePacker

+ func (packer *MessagePacker) ChunkAndWrite(writer io.Writer, csid int, typeid uint8, streamid int) error

+ type OnReadRtmpAvMsg func(msg base.RtmpMsg)

type PubSessionObserver

+ OnReadRtmpAvMsg func(msg base.RtmpMsg)

type PullSession

+ func (s *PullSession) Url() string

type PullSessionOption

+ PullTimeoutMs int

+ ReadAvTimeoutMs int

type PushSession

+ func (s *PushSession) Url() string

type PushSessionOption

+ PushTimeoutMs int

+ WriteAvTimeoutMs int

type Server

+ func (server *Server) OnNewRtmpPubSession(session *ServerSession)

+ func (server *Server) OnNewRtmpSubSession(session *ServerSession)

+ func (server *Server) OnRtmpConnect(session *ServerSession, opa ObjectPairArray)

type ServerObserver

+ OnDelRtmpPubSession func(session *ServerSession)

+ OnDelRtmpSubSession func(session *ServerSession)

+ OnNewRtmpPubSession func(session *ServerSession) bool

+ OnNewRtmpSubSession func(session *ServerSession) bool

+ OnRtmpConnect func(session *ServerSession, opa ObjectPairArray)

type ServerSession

+ ShouldWaitVideoKeyFrame bool

+ func (s *ServerSession) Url() string

type ServerSessionObserver

+ OnNewRtmpPubSession func(session *ServerSession)

+ OnNewRtmpSubSession func(session *ServerSession)

+ OnRtmpConnect func(session *ServerSession, opa ObjectPairArray)

May 1, 2021

Changes in this version

type ClientSession

+ func (s *ClientSession) URL() string

+ func (s *ClientSession) WaitChan() <-chan error

+ func (s *ClientSession) Write(msg []byte) error

type ClientSessionOption

+ HandshakeComplexFlag bool

type HandshakeClientComplex

+ func (c *HandshakeClientComplex) ReadS0S1(reader io.Reader) error

+ func (c *HandshakeClientComplex) ReadS2(reader io.Reader) error

type HandshakeClientSimple

+ func (c *HandshakeClientSimple) ReadS0S1(reader io.Reader) error

+ func (c *HandshakeClientSimple) ReadS2(reader io.Reader) error

+ type IHandshakeClient interface

+ ReadS0S1 func(reader io.Reader) error

+ ReadS2 func(reader io.Reader) error

+ WriteC0C1 func(writer io.Writer) error

+ WriteC2 func(writer io.Writer) error

type PullSession

+ func (s *PullSession) URL() string

+ func (s *PullSession) WaitChan() <-chan error

type PullSessionOption

+ HandshakeComplexFlag bool

type PushSession

+ func (s *PushSession) URL() string

+ func (s *PushSession) WaitChan() <-chan error

+ func (s *PushSession) Write(msg []byte) error

type PushSessionOption

+ HandshakeComplexFlag bool

type ServerSession

+ func (s *ServerSession) Write(msg []byte) error

Mar 19, 2021

Changes in this version

+ const AMF0TypeMarkerBoolean

+ const AMF0TypeMarkerEcmaArray

+ const AMF0TypeMarkerLongString

+ const AMF0TypeMarkerNull

+ const AMF0TypeMarkerNumber

+ const AMF0TypeMarkerObject

+ const AMF0TypeMarkerObjectEnd

+ const AMF0TypeMarkerString

+ const CSIDAMF

+ const CSIDAudio

+ const CSIDVideo

+ const MSID1

+ var AMF0 amf0

+ var AMF0TypeMarkerObjectEndBytes = []byte

+ var ErrAMFInvalidType = errors.New("lal.rtmp: invalid amf0 type")

+ var ErrAMFNotExist = errors.New("lal.rtmp: not exist")

+ var ErrAMFTooShort = errors.New("lal.rtmp: too short to unmarshal amf0 data")

+ var ErrClientSessionTimeout = errors.New("lal.rtmp: client session timeout")

+ var ErrRTMP = errors.New("lal.rtmp: fxxk")

+ var LocalChunkSize = 4096

+ func BuildMetadata(width int, height int, audiocodecid int, videocodecid int) ([]byte, error)

+ func Message2Chunks(message []byte, header *base.RTMPHeader) []byte

+ type ChunkComposer struct

+ func NewChunkComposer() *ChunkComposer

+ func (c *ChunkComposer) RunLoop(reader io.Reader, cb OnCompleteMessage) error

+ func (c *ChunkComposer) SetPeerChunkSize(val uint32)

+ type ChunkDivider struct

+ func (d *ChunkDivider) Message2Chunks(message []byte, header *base.RTMPHeader) []byte

+ type ClientSession struct

+ UniqueKey string

+ func NewClientSession(t ClientSessionType, modOptions ...ModClientSessionOption) *ClientSession

+ func (s *ClientSession) AppName() string

+ func (s *ClientSession) AsyncWrite(msg []byte) error

+ func (s *ClientSession) Dispose()

+ func (s *ClientSession) Do(rawURL string) error

+ func (s *ClientSession) Flush() error

+ func (s *ClientSession) GetStat() base.StatSession

+ func (s *ClientSession) IsAlive() (readAlive, writeAlive bool)

+ func (s *ClientSession) RawQuery() string

+ func (s *ClientSession) StreamName() string

+ func (s *ClientSession) UpdateStat(interval uint32)

+ func (s *ClientSession) Wait() <-chan error

+ type ClientSessionOption struct

+ DoTimeoutMS int

+ ReadAVTimeoutMS int

+ WriteAVTimeoutMS int

+ type ClientSessionType int

+ const CSTPullSession

+ const CSTPushSession

+ type HandshakeClient interface

+ ReadS0S1S2 func(reader io.Reader) error

+ WriteC0C1 func(writer io.Writer) error

+ WriteC2 func(writer io.Writer) error

+ type HandshakeClientComplex struct

+ func (c *HandshakeClientComplex) ReadS0S1S2(reader io.Reader) error

+ func (c *HandshakeClientComplex) WriteC0C1(writer io.Writer) error

+ func (c *HandshakeClientComplex) WriteC2(write io.Writer) error

+ type HandshakeClientSimple struct

+ func (c *HandshakeClientSimple) ReadS0S1S2(reader io.Reader) error

+ func (c *HandshakeClientSimple) WriteC0C1(writer io.Writer) error

+ func (c *HandshakeClientSimple) WriteC2(write io.Writer) error

+ type HandshakeServer struct

+ func (s *HandshakeServer) ReadC0C1(reader io.Reader) (err error)

+ func (s *HandshakeServer) ReadC2(reader io.Reader) error

+ func (s *HandshakeServer) WriteS0S1S2(write io.Writer) error

+ type MessagePacker struct

+ func NewMessagePacker() *MessagePacker

+ type ModClientSessionOption func(option *ClientSessionOption)

+ type ModPullSessionOption func(option *PullSessionOption)

+ type ModPushSessionOption func(option *PushSessionOption)

+ type ObjectPair struct

+ Key string

+ Value interface{}

+ type ObjectPairArray []ObjectPair

+ func ParseMetadata(b []byte) (ObjectPairArray, error)

+ func (o ObjectPairArray) Find(key string) interface{}

+ func (o ObjectPairArray) FindNumber(key string) (int, error)

+ func (o ObjectPairArray) FindString(key string) (string, error)

+ type OnCompleteMessage func(stream *Stream) error

+ type OnReadRTMPAVMsg func(msg base.RTMPMsg)

+ type PubSessionObserver interface

+ OnReadRTMPAVMsg func(msg base.RTMPMsg)

+ type PullSession struct

+ func NewPullSession(modOptions ...ModPullSessionOption) *PullSession

+ func (s *PullSession) AppName() string

+ func (s *PullSession) Dispose()

+ func (s *PullSession) GetStat() base.StatSession

+ func (s *PullSession) IsAlive() (readAlive, writeAlive bool)

+ func (s *PullSession) Pull(rawURL string, onReadRTMPAVMsg OnReadRTMPAVMsg) error

+ func (s *PullSession) RawQuery() string

+ func (s *PullSession) StreamName() string

+ func (s *PullSession) UniqueKey() string

+ func (s *PullSession) UpdateStat(interval uint32)

+ func (s *PullSession) Wait() <-chan error

+ type PullSessionOption struct

+ PullTimeoutMS int

+ ReadAVTimeoutMS int

+ type PushSession struct

+ IsFresh bool

+ func NewPushSession(modOptions ...ModPushSessionOption) *PushSession

+ func (s *PushSession) AppName() string

+ func (s *PushSession) AsyncWrite(msg []byte) error

+ func (s *PushSession) Dispose()

+ func (s *PushSession) Flush() error

+ func (s *PushSession) GetStat() base.StatSession

+ func (s *PushSession) IsAlive() (readAlive, writeAlive bool)

+ func (s *PushSession) Push(rawURL string) error

+ func (s *PushSession) RawQuery() string

+ func (s *PushSession) StreamName() string

+ func (s *PushSession) UniqueKey() string

+ func (s *PushSession) UpdateStat(interval uint32)

+ func (s *PushSession) Wait() <-chan error

+ type PushSessionOption struct

+ PushTimeoutMS int

+ WriteAVTimeoutMS int

+ type Server struct

+ func NewServer(observer ServerObserver, addr string) *Server

+ func (server *Server) Dispose()

+ func (server *Server) Listen() (err error)

+ func (server *Server) OnNewRTMPPubSession(session *ServerSession)

+ func (server *Server) OnNewRTMPSubSession(session *ServerSession)

+ func (server *Server) OnRTMPConnect(session *ServerSession, opa ObjectPairArray)

+ func (server *Server) RunLoop() error

+ type ServerObserver interface

+ OnDelRTMPPubSession func(session *ServerSession)

+ OnDelRTMPSubSession func(session *ServerSession)

+ OnNewRTMPPubSession func(session *ServerSession) bool

+ OnNewRTMPSubSession func(session *ServerSession) bool

+ OnRTMPConnect func(session *ServerSession, opa ObjectPairArray)

+ type ServerSession struct

+ IsFresh bool

+ UniqueKey string

+ func NewServerSession(observer ServerSessionObserver, conn net.Conn) *ServerSession

+ func (s *ServerSession) AppName() string

+ func (s *ServerSession) AsyncWrite(msg []byte) error

+ func (s *ServerSession) Dispose()

+ func (s *ServerSession) Flush() error

+ func (s *ServerSession) GetStat() base.StatSession

+ func (s *ServerSession) IsAlive() (readAlive, writeAlive bool)

+ func (s *ServerSession) RawQuery() string

+ func (s *ServerSession) RemoteAddr() string

+ func (s *ServerSession) RunLoop() (err error)

+ func (s *ServerSession) SetPubSessionObserver(observer PubSessionObserver)

+ func (s *ServerSession) StreamName() string

+ func (s *ServerSession) URL() string

+ func (s *ServerSession) UpdateStat(interval uint32)

+ type ServerSessionObserver interface

+ OnNewRTMPPubSession func(session *ServerSession)

+ OnNewRTMPSubSession func(session *ServerSession)

+ OnRTMPConnect func(session *ServerSession, opa ObjectPairArray)

+ type ServerSessionType int

+ const ServerSessionTypePub

+ const ServerSessionTypeSub

+ const ServerSessionTypeUnknown

+ type Stream struct

+ func NewStream() *Stream

+ type StreamMsg struct