rtmp

Documentation

Overview

Package rtmp provides RTMP connectivity.

Index

• func FromStream(stream *stream.Stream, reader stream.Reader, conn *Conn, nconn net.Conn, ...) error
• func ToStream(r *Reader, stream **stream.Stream) ([]*description.Media, error)
• type Conn
  • func NewClientConn(rw io.ReadWriter, u *url.URL, publish bool) (*Conn, error)
  • func NewServerConn(rw io.ReadWriter) (*Conn, *url.URL, bool, error)
  • func (c *Conn) BytesReceived() uint64
  • func (c *Conn) BytesSent() uint64
  • func (c *Conn) Read() (message.Message, error)
  • func (c *Conn) Write(msg message.Message) error
• type OnDataAC3Func
• type OnDataAV1Func
• type OnDataG711Func
• type OnDataH26xFunc
• type OnDataLPCMFunc
• type OnDataMPEG1AudioFunc
• type OnDataMPEG4AudioFunc
• type OnDataOpusFunc
• type OnDataVP9Func
• type Reader
  • func NewReader(conn *Conn) (*Reader, error)
  • func (r *Reader) OnDataAC3(track *format.AC3, cb OnDataAC3Func)
  • func (r *Reader) OnDataAV1(track *format.AV1, cb OnDataAV1Func)
  • func (r *Reader) OnDataG711(track *format.G711, cb OnDataG711Func)
  • func (r *Reader) OnDataH264(track *format.H264, cb OnDataH26xFunc)
  • func (r *Reader) OnDataH265(track *format.H265, cb OnDataH26xFunc)
  • func (r *Reader) OnDataLPCM(track *format.LPCM, cb OnDataLPCMFunc)
  • func (r *Reader) OnDataMPEG1Audio(track *format.MPEG1Audio, cb OnDataMPEG1AudioFunc)
  • func (r *Reader) OnDataMPEG4Audio(track *format.MPEG4Audio, cb OnDataMPEG4AudioFunc)
  • func (r *Reader) OnDataOpus(track *format.Opus, cb OnDataOpusFunc)
  • func (r *Reader) OnDataVP9(track *format.VP9, cb OnDataVP9Func)
  • func (r *Reader) Read() error
  • func (r *Reader) Tracks() []format.Format
• type Writer
  • func NewWriter(conn *Conn, videoTrack format.Format, audioTrack format.Format) (*Writer, error)
  • func (w *Writer) WriteH264(pts time.Duration, dts time.Duration, au [][]byte) error
  • func (w *Writer) WriteMPEG1Audio(pts time.Duration, h *mpeg1audio.FrameHeader, frame []byte) error
  • func (w *Writer) WriteMPEG4Audio(pts time.Duration, au []byte) error

Functions

func FromStream

func FromStream(
	stream *stream.Stream,
	reader stream.Reader,
	conn *Conn,
	nconn net.Conn,
	writeTimeout time.Duration,
) error

FromStream maps a MediaMTX stream to a RTMP stream.

func ToStream

func ToStream(r *Reader, stream **stream.Stream) ([]*description.Media, error)

ToStream maps a RTMP stream to a MediaMTX stream.

Types

type Conn

type Conn struct {
	// contains filtered or unexported fields
}

Conn is a RTMP connection.

func NewClientConn

func NewClientConn(rw io.ReadWriter, u *url.URL, publish bool) (*Conn, error)

NewClientConn initializes a client-side connection.

func NewServerConn

func NewServerConn(rw io.ReadWriter) (*Conn, *url.URL, bool, error)

NewServerConn initializes a server-side connection.

func (*Conn) BytesReceived

func (c *Conn) BytesReceived() uint64

BytesReceived returns the number of bytes received.

func (*Conn) BytesSent

func (c *Conn) BytesSent() uint64

BytesSent returns the number of bytes sent.

func (*Conn) Read

func (c *Conn) Read() (message.Message, error)

Read reads a message.

func (*Conn) Write

func (c *Conn) Write(msg message.Message) error

Write writes a message.

type OnDataAC3Func

type OnDataAC3Func func(pts time.Duration, frame []byte)

OnDataAC3Func is the prototype of the callback passed to OnDataAC3().

type OnDataAV1Func

type OnDataAV1Func func(pts time.Duration, tu [][]byte)

OnDataAV1Func is the prototype of the callback passed to OnDataAV1().

type OnDataG711Func

type OnDataG711Func func(pts time.Duration, samples []byte)

OnDataG711Func is the prototype of the callback passed to OnDataG711().

type OnDataH26xFunc

type OnDataH26xFunc func(pts time.Duration, au [][]byte)

OnDataH26xFunc is the prototype of the callback passed to OnDataH26x().

type OnDataLPCMFunc

type OnDataLPCMFunc func(pts time.Duration, samples []byte)

OnDataLPCMFunc is the prototype of the callback passed to OnDataLPCM().

type OnDataMPEG1AudioFunc

type OnDataMPEG1AudioFunc func(pts time.Duration, frame []byte)

OnDataMPEG1AudioFunc is the prototype of the callback passed to OnDataMPEG1Audio().

type OnDataMPEG4AudioFunc

type OnDataMPEG4AudioFunc func(pts time.Duration, au []byte)

OnDataMPEG4AudioFunc is the prototype of the callback passed to OnDataMPEG4Audio().

type OnDataOpusFunc

type OnDataOpusFunc func(pts time.Duration, packet []byte)

OnDataOpusFunc is the prototype of the callback passed to OnDataOpus().

type OnDataVP9Func

type OnDataVP9Func func(pts time.Duration, frame []byte)

OnDataVP9Func is the prototype of the callback passed to OnDataVP9().

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

Reader is a wrapper around Conn that provides utilities to demux incoming data.

func NewReader

func NewReader(conn *Conn) (*Reader, error)

NewReader allocates a Reader.

func (*Reader) OnDataAC3

func (r *Reader) OnDataAC3(track *format.AC3, cb OnDataAC3Func)

OnDataAC3 sets a callback that is called when AC-3 data is received.

func (*Reader) OnDataAV1

func (r *Reader) OnDataAV1(track *format.AV1, cb OnDataAV1Func)

OnDataAV1 sets a callback that is called when AV1 data is received.

func (*Reader) OnDataG711

func (r *Reader) OnDataG711(track *format.G711, cb OnDataG711Func)

OnDataG711 sets a callback that is called when G711 data is received.

func (*Reader) OnDataH264

func (r *Reader) OnDataH264(track *format.H264, cb OnDataH26xFunc)

OnDataH264 sets a callback that is called when H264 data is received.

func (*Reader) OnDataH265

func (r *Reader) OnDataH265(track *format.H265, cb OnDataH26xFunc)

OnDataH265 sets a callback that is called when H265 data is received.

func (*Reader) OnDataLPCM

func (r *Reader) OnDataLPCM(track *format.LPCM, cb OnDataLPCMFunc)

OnDataLPCM sets a callback that is called when LPCM data is received.

func (*Reader) OnDataMPEG1Audio

func (r *Reader) OnDataMPEG1Audio(track *format.MPEG1Audio, cb OnDataMPEG1AudioFunc)

OnDataMPEG1Audio sets a callback that is called when MPEG-1 Audio data is received.

func (*Reader) OnDataMPEG4Audio

func (r *Reader) OnDataMPEG4Audio(track *format.MPEG4Audio, cb OnDataMPEG4AudioFunc)

OnDataMPEG4Audio sets a callback that is called when MPEG-4 Audio data is received.

func (*Reader) OnDataOpus

func (r *Reader) OnDataOpus(track *format.Opus, cb OnDataOpusFunc)

OnDataOpus sets a callback that is called when Opus data is received.

func (*Reader) OnDataVP9

func (r *Reader) OnDataVP9(track *format.VP9, cb OnDataVP9Func)

OnDataVP9 sets a callback that is called when VP9 data is received.

func (*Reader) Read

func (r *Reader) Read() error

Read reads data.

func (*Reader) Tracks

func (r *Reader) Tracks() []format.Format

Tracks returns detected tracks

type Writer

type Writer struct {
	// contains filtered or unexported fields
}

Writer is a wrapper around Conn that provides utilities to mux outgoing data.

func NewWriter

func NewWriter(conn *Conn, videoTrack format.Format, audioTrack format.Format) (*Writer, error)

NewWriter allocates a Writer.

func (*Writer) WriteH264

func (w *Writer) WriteH264(pts time.Duration, dts time.Duration, au [][]byte) error

WriteH264 writes H264 data.

func (*Writer) WriteMPEG1Audio

func (w *Writer) WriteMPEG1Audio(pts time.Duration, h *mpeg1audio.FrameHeader, frame []byte) error

WriteMPEG1Audio writes MPEG-1 Audio data.

func (*Writer) WriteMPEG4Audio

func (w *Writer) WriteMPEG4Audio(pts time.Duration, au []byte) error

WriteMPEG4Audio writes MPEG-4 Audio data.