rtmp

package

v0.0.0-...-587173a Latest Latest Go to latest Published: May 9, 2021 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zhyoulun/livego

Documentation ¶

Index ¶

Constants
type Client
type GetInFo
type PackWriterCloser
- func (p *PackWriterCloser) GetWriter() av.WriteCloser
type Server
- func NewRtmpServer(h av.Handler) *Server
- func (s *Server) Serve(ln net.Listener) (err error)
type StaticsBW
type Stream
- func NewStream(info av.Info) *Stream
- func (s *Stream) AddReader(r av.ReadCloser)
- func (s *Stream) AddWriter(w av.WriteCloser)
- func (s *Stream) CheckAlive() (n int)
- func (s *Stream) Copy(dst *Stream)
- func (s *Stream) GetReader() av.ReadCloser
- func (s *Stream) GetSinks() cmap.ConcurrentMap
- func (s *Stream) TransStart()
- func (s *Stream) TransStop()
type StreamManager
- func NewStreamManager() *StreamManager
- func (sm *StreamManager) CheckAlive()
- func (sm *StreamManager) GetStreams() cmap.ConcurrentMap
- func (sm *StreamManager) HandleReader(r av.ReadCloser)
- func (sm *StreamManager) HandleWriter(w av.WriteCloser)
- func (sm *StreamManager) MarshalJSON() ([]byte, error)
type StreamReadWriteCloser
type VirReader
- func NewVirReader(conn StreamReadWriteCloser) *VirReader
- func (v *VirReader) Close(err error)
- func (v *VirReader) Info() (ret av.Info)
- func (v *VirReader) Read(p *av.Packet) (err error)
- func (v *VirReader) SaveStatics(streamid uint32, length uint64, isVideoFlag bool)
type VirWriter
- func NewVirWriter(conn StreamReadWriteCloser) *VirWriter
- func (v *VirWriter) Check()
- func (v *VirWriter) Close(err error)
- func (v *VirWriter) DropPacket(pktQue chan *av.Packet, info av.Info)
- func (v *VirWriter) Info() (ret av.Info)
- func (v *VirWriter) SaveStatics(streamid uint32, length uint64, isVideoFlag bool)
- func (v *VirWriter) SendPacket() error
- func (v *VirWriter) Write(p *av.Packet) (err error)

Constants ¶

View Source

const (
	SAVE_STATICS_INTERVAL = 5000
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Client ¶

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

type GetInFo ¶

type GetInFo interface {
	GetURL() string
}

type PackWriterCloser ¶

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

func (*PackWriterCloser) GetWriter ¶

func (p *PackWriterCloser) GetWriter() av.WriteCloser

type Server ¶

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

func NewRtmpServer ¶

func NewRtmpServer(h av.Handler) *Server

func (*Server) Serve ¶

func (s *Server) Serve(ln net.Listener) (err error)

type StaticsBW ¶

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

	AudioDatainBytes       uint64
	LastAudioDatainBytes   uint64
	AudioSpeedInBytesperMS uint64

	LastTimestamp int64
}

type Stream ¶

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

func NewStream ¶

func NewStream(info av.Info) *Stream

func (*Stream) AddReader ¶

func (s *Stream) AddReader(r av.ReadCloser)

func (*Stream) AddWriter ¶

func (s *Stream) AddWriter(w av.WriteCloser)

func (*Stream) CheckAlive ¶

func (s *Stream) CheckAlive() (n int)

func (*Stream) Copy ¶

func (s *Stream) Copy(dst *Stream)

func (*Stream) GetReader ¶

func (s *Stream) GetReader() av.ReadCloser

func (*Stream) GetSinks ¶

func (s *Stream) GetSinks() cmap.ConcurrentMap

func (*Stream) TransStart ¶

func (s *Stream) TransStart()

func (*Stream) TransStop ¶

func (s *Stream) TransStop()

type StreamManager ¶

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

func NewStreamManager ¶

func NewStreamManager() *StreamManager

func (*StreamManager) CheckAlive ¶

func (sm *StreamManager) CheckAlive()

func (*StreamManager) GetStreams ¶

func (sm *StreamManager) GetStreams() cmap.ConcurrentMap

func (*StreamManager) HandleReader ¶

func (sm *StreamManager) HandleReader(r av.ReadCloser)

处理推流

func (*StreamManager) HandleWriter ¶

func (sm *StreamManager) HandleWriter(w av.WriteCloser)

处理拉流

func (*StreamManager) MarshalJSON ¶

func (sm *StreamManager) MarshalJSON() ([]byte, error)

type StreamReadWriteCloser ¶

type StreamReadWriteCloser interface {
	GetInFo
	Close(error)
	Write(chunkstream.ChunkStream) error
	Read(c *chunkstream.ChunkStream) error
	Flush() error
}

type VirReader ¶

type VirReader struct {
	av.RWBaser

	ReadBWInfo StaticsBW
	// contains filtered or unexported fields
}

func NewVirReader ¶

func NewVirReader(conn StreamReadWriteCloser) *VirReader

func (*VirReader) Close ¶

func (v *VirReader) Close(err error)

func (*VirReader) Info ¶

func (v *VirReader) Info() (ret av.Info)

func (*VirReader) Read ¶

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

func (*VirReader) SaveStatics ¶

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

type VirWriter ¶

type VirWriter struct {
	av.RWBaser

	WriteBWInfo StaticsBW
	// contains filtered or unexported fields
}

func NewVirWriter ¶

func NewVirWriter(conn StreamReadWriteCloser) *VirWriter

func (*VirWriter) Check ¶

func (v *VirWriter) Check()

func (*VirWriter) Close ¶

func (v *VirWriter) Close(err error)

func (*VirWriter) DropPacket ¶

func (v *VirWriter) DropPacket(pktQue chan *av.Packet, info av.Info)

func (*VirWriter) Info ¶

func (v *VirWriter) Info() (ret av.Info)

func (*VirWriter) SaveStatics ¶

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

func (*VirWriter) SendPacket ¶

func (v *VirWriter) SendPacket() error

func (*VirWriter) Write ¶

func (v *VirWriter) Write(p *av.Packet) (err error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
c
cache
chunkstream
core
message

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