rtmp

package

Go to main page

Versions in this module

v0

v0.37.16

Sep 8, 2024

v0.37.15

Aug 25, 2024

v0.37.14

Aug 25, 2024

Changes in this version

type ServerSession

+ func (s *ServerSession) DoAck(stream *Stream) error

+ func (s *ServerSession) DoCommandAmf3Message(stream *Stream) error

+ func (s *ServerSession) DoDataMessageAmf0(stream *Stream) error

+ func (s *ServerSession) DoUserControl(stream *Stream) error

+ func (s *ServerSession) DoWinAckSize(stream *Stream) error

v0.37.13

Aug 24, 2024

v0.37.12

Aug 24, 2024

Changes in this version

type ServerSession

+ func (s *ServerSession) DoCommandMessage(stream *Stream) error

v0.37.11

Aug 24, 2024

v0.37.10

Aug 24, 2024

Changes in this version

type Stream

+ Header base.RtmpHeader

v0.37.9

Aug 24, 2024

Changes in this version

type Stream

+ func (stream *Stream) ToAvMsg() base.RtmpMsg

v0.37.8

Aug 24, 2024

v0.37.7

Aug 24, 2024

v0.37.6

Aug 24, 2024

v0.37.5

Aug 24, 2024

Changes in this version

+ const Amf0TypeMarkerBoolean

+ const Amf0TypeMarkerEcmaArray

+ const Amf0TypeMarkerLongString

+ const Amf0TypeMarkerNull

+ const Amf0TypeMarkerNumber

+ const Amf0TypeMarkerObject

+ const Amf0TypeMarkerObjectEnd

+ const Amf0TypeMarkerStrictArray

+ const Amf0TypeMarkerString

+ const Amf0TypeMarkerUndefined

+ const Amf0TypeMarkerUnsupported

+ const CsidAmf

+ const CsidAudio

+ const CsidVideo

+ const Msid1

+ var Amf0 amf0

+ var Amf0TypeMarkerArrayEndBytes = []byte

+ var Amf0TypeMarkerObjectEndBytes = []byte

+ var LocalChunkSize = 4096

+ var Log = nazalog.GetGlobalLogger()

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

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

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

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

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

+ type AuthInfo struct

+ 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 ChunkComposer struct

+ func NewChunkComposer() *ChunkComposer

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

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

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

+ type ChunkDivider struct

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

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

+ type ClientSession struct

+ func NewClientSession(sessionType base.SessionType, modOptions ...ModClientSessionOption) *ClientSession

+ func (s *ClientSession) AppName() string

+ func (s *ClientSession) Dispose() 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) Start(rawUrl string) error

+ func (s *ClientSession) StreamName() string

+ func (s *ClientSession) UniqueKey() string

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

+ func (s *ClientSession) Url() string

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

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

+ type ClientSessionOption struct

+ DoTimeoutMs int

+ HandshakeComplexFlag bool

+ PeerWinAckSize int

+ ReadAvTimeoutMs int

+ ReadBufSize int

+ ReuseReadMessageBufferFlag bool

+ TlsConfig *tls.Config

+ WriteAvTimeoutMs int

+ WriteBufSize int

+ WriteChanSize int

+ type HandshakeClientComplex struct

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

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

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

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

+ type HandshakeClientSimple struct

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

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

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

+ func (c *HandshakeClientSimple) WriteC2(writer 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(writer io.Writer) 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 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)

+ type MessagePacker struct

+ func NewMessagePacker() *MessagePacker

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

+ 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) DebugString() string

+ 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 PullSession struct

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

+ func (s *PullSession) AppName() string

+ func (s *PullSession) Dispose() error

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

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

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

+ func (s *PullSession) RawQuery() string

+ func (s *PullSession) Start(rawUrl string) error

+ func (s *PullSession) StreamName() string

+ func (s *PullSession) UniqueKey() string

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

+ func (s *PullSession) Url() string

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

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

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

+ type PullSessionOption struct

+ HandshakeComplexFlag bool

+ PeerWinAckSize int

+ PullTimeoutMs int

+ ReadAvTimeoutMs int

+ ReadBufSize int

+ ReuseReadMessageBufferFlag bool

+ TlsConfig *tls.Config

+ type PushSession struct

+ IsFresh bool

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

+ func (s *PushSession) AppName() string

+ func (s *PushSession) Dispose() error

+ 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) Start(rawUrl string) error

+ func (s *PushSession) StreamName() string

+ func (s *PushSession) UniqueKey() string

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

+ func (s *PushSession) Url() string

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

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

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

+ type PushSessionOption struct

+ HandshakeComplexFlag bool

+ PushTimeoutMs int

+ TlsConfig *tls.Config

+ WriteAvTimeoutMs int

+ WriteBufSize int

+ WriteChanSize int

+ type Server struct

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

+ func (server *Server) Dispose()

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

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

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

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

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

+ func (server *Server) RunLoop() error

+ type ServerSession struct

+ DisposeByObserverFlag bool

+ IsFresh bool

+ ShouldWaitVideoKeyFrame bool

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

+ func (s *ServerSession) AppName() string

+ func (s *ServerSession) Dispose() error

+ 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) RunLoop() (err error)

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

+ func (s *ServerSession) StreamName() string

+ func (s *ServerSession) UniqueKey() string

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

+ func (s *ServerSession) Url() string

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

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

+ type ServerSessionType int

+ const ServerSessionTypePub

+ const ServerSessionTypeSub

+ const ServerSessionTypeUnknown

+ type Stream struct

+ func NewStream() *Stream

+ type StreamMsg struct

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

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

+ func (msg *StreamMsg) Len() uint32

+ func (msg *StreamMsg) Reset()

+ func (msg *StreamMsg) ResetAndFree()

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL