rtmp

Apr 18, 2024

Changes in this version

type PushSession

+ func (s *PushSession) WriteMsg(msg base.RtmpMsg) error

Jul 13, 2023

Changes in this version

+ const Amf0TypeMarkerUndefined

+ const Amf0TypeMarkerUnsupported

Apr 11, 2023

Changes in this version

+ const Amf0TypeMarkerStrictArray

Mar 27, 2023

Changes in this version

type ClientSessionOption

+ TlsConfig *tls.Config

type PullSessionOption

+ TlsConfig *tls.Config

type PushSessionOption

+ TlsConfig *tls.Config

Nov 10, 2022

Changes in this version

+ var Amf0TypeMarkerArrayEndBytes = []byte

type Server

+ func (server *Server) ListenWithTLS(certFile, keyFile string) (err error)

Oct 7, 2022

Changes in this version

+ func Message2ChunksV(message net.Buffers, header *base.RtmpHeader) []byte

+ func MetadataEnsureWithSdf(b []byte) ([]byte, error)

+ func MetadataEnsureWithoutSdf(b []byte) ([]byte, error)

type ChunkComposer

+ func (c *ChunkComposer) SetReuseBufferFlag(val bool)

type ChunkDivider

+ func (d *ChunkDivider) Message2ChunksV(message net.Buffers, header *base.RtmpHeader) []byte

type ClientSessionOption

+ ReuseReadMessageBufferFlag bool

type ObjectPairArray

+ func (o ObjectPairArray) DebugString() string

type PullSessionOption

+ ReuseReadMessageBufferFlag bool

type StreamMsg

+ func (msg *StreamMsg) ResetAndFree()

Jun 15, 2022

Changes in this version

+ type AuthInfo struct

type PullSession

+ func (s *PullSession) WithOnPullSucc(onPullResult func()) *PullSession

+ func (s *PullSession) WithOnReadRtmpAvMsg(onReadRtmpAvMsg OnReadRtmpAvMsg) *PullSession

May 3, 2022

Changes in this version

type ClientSessionOption

+ PeerWinAckSize int

type PullSessionOption

+ PeerWinAckSize int

Mar 27, 2022

Changes in this version

+ var Log = nazalog.GetGlobalLogger()

+ type IPubSessionObserver interface

+ OnReadRtmpAvMsg func(msg base.RtmpMsg)

+ type IServerObserver interface

+ OnDelRtmpPubSession func(session *ServerSession)

+ OnDelRtmpSubSession func(session *ServerSession)

+ OnNewRtmpPubSession func(session *ServerSession) error

+ OnNewRtmpSubSession func(session *ServerSession) error

+ OnRtmpConnect func(session *ServerSession, opa ObjectPairArray)

+ type IServerSessionObserver interface

+ OnNewRtmpPubSession func(session *ServerSession) error

+ OnNewRtmpSubSession func(session *ServerSession) error

+ OnRtmpConnect func(session *ServerSession, opa ObjectPairArray)

Jan 23, 2022

Changes in this version

type ClientSessionOption

+ ReadBufSize int

+ WriteBufSize int

+ WriteChanSize int

type PullSessionOption

+ ReadBufSize int

type PushSessionOption

+ WriteBufSize int

+ WriteChanSize int

type ServerSession

+ DisposeByObserverFlag bool

type StreamMsg

+ func (msg *StreamMsg) Flush(n uint32)

+ func (msg *StreamMsg) Grow(n uint32)

+ func (msg *StreamMsg) Len() uint32

+ func (msg *StreamMsg) Reset()

+ func (msg *StreamMsg) Skip(n uint32)

Oct 24, 2021

Changes in this version

type ServerSession

+ func (s *ServerSession) Writev(msgs net.Buffers) error

Jul 31, 2021

Changes in this version

+ 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 MessagePacker

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

Jun 6, 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 ClientSession

+ func (s *ClientSession) Url() string

type ClientSessionOption

+ DoTimeoutMs int

+ ReadAvTimeoutMs int

+ WriteAvTimeoutMs int

type ClientSessionType

+ const CstPullSession

+ const CstPushSession

+ 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 3, 2021

Changes in this version

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 PullSessionOption

+ HandshakeComplexFlag bool

type PushSessionOption

+ HandshakeComplexFlag bool

Mar 21, 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 PullSession

+ func (s *PullSession) URL() string

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

type PushSession

+ func (s *PushSession) URL() string

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

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

type ServerSession

+ func (s *ServerSession) URL() string

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

Dec 27, 2020

Changes in this version

type ClientSession

+ func (s *ClientSession) AppName() string

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

+ func (s *ClientSession) RawQuery() string

+ func (s *ClientSession) StreamName() string

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

type PullSession

+ func (s *PullSession) AppName() string

+ func (s *PullSession) RawQuery() string

+ func (s *PullSession) StreamName() string

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

type PushSession

+ func (s *PushSession) AppName() string

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

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

+ func (s *PushSession) RawQuery() string

+ func (s *PushSession) StreamName() string

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

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

Nov 21, 2020

Changes in this version

type ClientSession

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

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

type PullSession

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

+ func (s *PullSession) IsAlive(interval uint32) (ret bool)

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

type Server

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

type ServerObserver

+ OnRTMPConnect func(session *ServerSession, opa ObjectPairArray)

type ServerSession

+ RawQuery string

+ func (s *ServerSession) IsAlive(interval uint32) (ret bool)

+ func (s *ServerSession) RemoteAddr() string

type ServerSessionObserver

+ OnRTMPConnect func(session *ServerSession, opa ObjectPairArray)

Oct 23, 2020

Changes in this version

type ObjectPairArray

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

type ServerSession

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

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

Aug 23, 2020

Changes in this version

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

Jul 18, 2020

Changes in this version

+ const AVCPacketTypeNALU

+ const HEVCPacketTypeNALU

type AVMsg

+ func (msg AVMsg) IsAVCKeyNALU() bool

+ func (msg AVMsg) IsHEVCKeyNALU() bool

+ func (msg AVMsg) IsVideoKeyNALU() bool

+ type OnCompleteMessage func(stream *Stream) error

type Server

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

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

type ServerObserver

+ OnDelRTMPPubSession func(session *ServerSession)

+ OnDelRTMPSubSession func(session *ServerSession)

+ OnNewRTMPPubSession func(session *ServerSession) bool

+ OnNewRTMPSubSession func(session *ServerSession) bool

type ServerSessionObserver

+ OnNewRTMPPubSession func(session *ServerSession)

+ OnNewRTMPSubSession func(session *ServerSession)

Jun 20, 2020

Changes in this version

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

+ type ObjectPairArray []ObjectPair

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

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

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

type PullSession

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

+ func (s *PullSession) UniqueKey() string

type PushSession

+ IsFresh bool

Jun 13, 2020

Changes in this version

type ClientSession

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

type PubSessionObserver

+ OnReadRTMPAVMsg func(msg AVMsg)

type PushSession

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

+ func (s *PushSession) Status() PushSessionStatus

+ func (s *PushSession) UniqueKey() string

+ type PushSessionStatus uint32

+ const PushSessionStatusConnected

+ const PushSessionStatusConnecting

+ const PushSessionStatusError

+ const PushSessionStatusInit

Jun 6, 2020

Changes in this version

type Server

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

Apr 18, 2020

Changes in this version

+ const AACPacketTypeRaw

+ const AACPacketTypeSeqHeader

+ const AVCInterFrame

+ const AVCKeyFrame

+ const AVCPacketTypeNalu

+ const AVCPacketTypeSeqHeader

+ const HEVCInterFrame

+ const HEVCKeyFrame

+ const HEVCPacketTypeNalu

+ const HEVCPacketTypeSeqHeader

+ const SoundFormatAAC

type AVMsg

+ func (msg AVMsg) IsHEVCKeyNalu() bool

+ func (msg AVMsg) IsHEVCKeySeqHeader() bool

+ func (msg AVMsg) IsVideoKeyNalu() bool

+ func (msg AVMsg) IsVideoKeySeqHeader() bool

Dec 13, 2019

Changes in this version

type AVMsg

+ func (msg AVMsg) IsAACSeqHeader() bool

+ func (msg AVMsg) IsAVCKeyNalu() bool

+ func (msg AVMsg) IsAVCKeySeqHeader() bool

Nov 8, 2019

Changes in this version

type AVMsg

+ Payload []byte

Nov 1, 2019

Changes in this version

+ type AVMsg struct

+ Header Header

+ Message []byte

type AVMsgObserver

+ OnReadRTMPAVMsg func(msg AVMsg)

+ type ClientSessionOption struct

+ ConnectTimeoutMS int

+ DoTimeoutMS int

+ ReadAVTimeoutMS int

+ WriteAVTimeoutMS int

type Header

+ TimestampAbs uint32

+ type ModClientSessionOption func(option *ClientSessionOption)

+ type ModPullSessionOption func(option *PullSessionOption)

+ type ModPushSessionOption func(option *PushSessionOption)

+ type OnReadRTMPAVMsg func(msg AVMsg)

type PullSession

+ func (s *PullSession) Dispose()

+ type PullSessionOption struct

+ ConnectTimeoutMS int

+ PullTimeoutMS int

+ ReadAVTimeoutMS int

type PushSession

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

+ func (s *PushSession) Dispose()

+ func (s *PushSession) Flush() error

+ type PushSessionOption struct

+ ConnectTimeoutMS int

+ PushTimeoutMS int

+ WriteAVTimeoutMS int

Oct 25, 2019

Changes in this version

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

Sep 27, 2019

Changes in this version

+ var ErrClientSessionTimeout = errors.New("rtmp.ClientSession timeout")

+ type ChunkDivider struct

+ func (d *ChunkDivider) Message2Chunks(message []byte, header *Header) []byte

type ClientSession

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

+ func (s *ClientSession) Dispose()

+ func (s *ClientSession) Flush() error

type ObjectPair

+ Key string

+ Value interface{}

type ServerSession

+ func (s *ServerSession) Flush() error

+ func (s *ServerSession) ModConnProps()

Sep 21, 2019

Changes in this version

type ServerObserver

+ DelRTMPPubSessionCB func(session *ServerSession)

+ DelRTMPSubSessionCB func(session *ServerSession)

type ServerSession

+ IsFresh bool

+ WaitKeyNalu bool

Sep 12, 2019

Changes in this version

type Group

+ UniqueKey string

type HandshakeClient

+ WriterC2 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 ServerSession

+ StreamNameWithRawQuery string

+ func (s *ServerSession) ReadableType() string

Sep 3, 2019

Changes in this version

+ const AMF0TypeMarkerBoolean

+ const AMF0TypeMarkerData

+ const AMF0TypeMarkerEcmaArray

+ const AMF0TypeMarkerLongString

+ const AMF0TypeMarkerMovieclip

+ const AMF0TypeMarkerNull

+ const AMF0TypeMarkerNumber

+ const AMF0TypeMarkerObject

+ const AMF0TypeMarkerObjectEnd

+ const AMF0TypeMarkerRecordset

+ const AMF0TypeMarkerReference

+ const AMF0TypeMarkerStrictArray

+ const AMF0TypeMarkerString

+ const AMF0TypeMarkerTypedObject

+ const AMF0TypeMarkerUndefined

+ const AMF0TypeMarkerUnsupported

+ const AMF0TypeMarkerXmlDocument

+ const CSIDAMF

+ const CSIDAudio

+ const CSIDVideo

+ const MSID0

+ const MSID1

+ const TypeidAudio

+ const TypeidDataMessageAMF0

+ const TypeidVideo

+ var AMF0 amf0

+ var AMF0TypeMarkerObjectEndBytes = []byte

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

+ var ErrAMFTooShort = errors.New("lal.AMF0: too short.")

+ var LocalChunkSize = 4096

+ func Message2Chunks(message []byte, header *Header, chunkSize int) []byte

+ type AVMsgObserver interface

+ ReadRTMPAVMsgCB func(header Header, timestampAbs uint32, message []byte)

+ type ChunkComposer struct

+ func NewChunkComposer() *ChunkComposer

+ func (c *ChunkComposer) GetPeerChunkSize() int

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

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

+ type ClientSession struct

+ Conn connection.Connection

+ UniqueKey string

+ func NewClientSession(t ClientSessionType, obs PullSessionObserver, timeout ClientSessionTimeout) *ClientSession

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

+ func (s *ClientSession) TmpWrite(b []byte) error

+ func (s *ClientSession) WaitLoop() error

+ type ClientSessionTimeout struct

+ ConnectTimeoutMS int

+ DoTimeoutMS int

+ ReadAVTimeoutMS int

+ WriteAVTimeoutMS int

+ type ClientSessionType int

+ const CSTPullSession

+ const CSTPushSession

+ type CompleteMessageCB func(stream *Stream) error

+ type Group struct

+ func NewGroup(appName string, streamName string) *Group

+ func (group *Group) AddPubSession(session *ServerSession)

+ func (group *Group) AddSubSession(session *ServerSession)

+ func (group *Group) DelPubSession(session *ServerSession)

+ func (group *Group) DelSubSession(session *ServerSession)

+ func (group *Group) Dispose()

+ func (group *Group) IsInExist() bool

+ func (group *Group) IsTotalEmpty() bool

+ func (group *Group) Pull(addr string, connectTimeout int64)

+ func (group *Group) ReadRTMPAVMsgCB(header Header, timestampAbs uint32, message []byte)

+ func (group *Group) RunLoop()

+ func (group *Group) SetObserver(obs GroupObserver)

+ type GroupObserver interface

+ type HandshakeClient struct

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

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

+ func (c *HandshakeClient) 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 Header struct

+ CSID int

+ MsgLen int

+ MsgStreamID int

+ MsgTypeID int

+ Timestamp uint32

+ type MessagePacker struct

+ func NewMessagePacker() *MessagePacker

+ type ObjectPair struct

+ type PubSessionObserver interface

+ type PullSession struct

+ func NewPullSession(obs PullSessionObserver, timeout PullSessionTimeout) *PullSession

+ func (s *PullSession) Pull(rawURL string) error

+ type PullSessionObserver interface

+ type PullSessionTimeout struct

+ ConnectTimeoutMS int

+ PullTimeoutMS int

+ ReadAVTimeoutMS int

+ type PushSession struct

+ func NewPushSession(timeout PushSessionTimeout) *PushSession

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

+ type PushSessionTimeout struct

+ ConnectTimeoutMS int

+ PushTimeoutMS int

+ WriteAVTimeoutMS int

+ type Server struct

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

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

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

+ func (server *Server) Dispose()

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

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

+ func (server *Server) RunLoop() error

+ type ServerObserver interface

+ NewRTMPPubSessionCB func(session *ServerSession, group *Group) bool

+ NewRTMPSubSessionCB func(session *ServerSession, group *Group) bool

+ type ServerSession struct

+ AppName string

+ StreamName string

+ UniqueKey string

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

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

+ func (s *ServerSession) Dispose()

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

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

+ type ServerSessionObserver interface

+ NewRTMPPubSessionCB func(session *ServerSession)

+ NewRTMPSubSessionCB func(session *ServerSession)

+ type ServerSessionType int

+ const ServerSessionTypePub

+ const ServerSessionTypeSub

+ const ServerSessionTypeUnknown

+ type Stream struct

+ func NewStream() *Stream

+ type StreamMsg struct