rtmp

Documentation

Index

• Constants
• type ChunkReadCloser
• type ChunkReadWriteCloser
• type ChunkReader
• type ChunkWriteCloser
• type ChunkWriter
• type Reader
  • func NewReader(conn ChunkReader) *Reader
  • func (v *Reader) Close() error
  • func (v *Reader) Closed() bool
  • func (v *Reader) Read() (p *av.Packet, err error)
  • func (v *Reader) SaveStatics(streamid uint32, length uint64, isVideoFlag bool)
• type StaticsBW
• type Writer
  • func NewWriter(conn ChunkWriter) *Writer
  • func (w *Writer) Close() error
  • func (w *Writer) Closed() bool
  • func (w *Writer) SaveStatics(streamid uint32, length uint64, isVideoFlag bool)
  • func (w *Writer) SendPacket() error
  • func (w *Writer) Write(p *av.Packet) (err error)

Constants

const (
	SAVE_STATICS_INTERVAL = 5000
)

Types

type ChunkReadCloser

type ChunkReadCloser interface {
	io.Closer
	ChunkReader
}

type ChunkReadWriteCloser

type ChunkReadWriteCloser interface {
	io.Closer
	ChunkReader
	ChunkWriter
}

type ChunkReader

type ChunkReader interface {
	Read() (*core.ChunkStream, error)
}

type ChunkWriteCloser

type ChunkWriteCloser interface {
	io.Closer
	ChunkWriter
}

type ChunkWriter

type ChunkWriter interface {
	Write(*core.ChunkStream) error
}

type Reader

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

func NewReader

func NewReader(conn ChunkReader) *Reader

func (*Reader) Close

func (v *Reader) Close() error

func (*Reader) Closed

func (v *Reader) Closed() bool

func (*Reader) Read

func (v *Reader) Read() (p *av.Packet, err error)

func (*Reader) SaveStatics

func (v *Reader) SaveStatics(streamid uint32, length uint64, isVideoFlag bool)

type StaticsBW

type StaticsBW struct {
	StreamId               uint32
	VideoDatainBytes       uint64
	LastVideoDatainBytes   uint64
	VideoSpeedInBytesperMS uint64

	AudioDatainBytes       uint64
	LastAudioDatainBytes   uint64
	AudioSpeedInBytesperMS uint64

	LastTimestamp int64
}

type Writer

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

func NewWriter

func NewWriter(conn ChunkWriter) *Writer

func (*Writer) Close

func (w *Writer) Close() error

func (*Writer) Closed

func (w *Writer) Closed() bool

func (*Writer) SaveStatics

func (w *Writer) SaveStatics(streamid uint32, length uint64, isVideoFlag bool)

func (*Writer) SendPacket

func (w *Writer) SendPacket() error

func (*Writer) Write

func (w *Writer) Write(p *av.Packet) (err error)