ftl

Documentation

Index

• type CheckUserFunc
• type CombineSlices
  • func (s *CombineSlices) ModifyPacket(pkt *av.Packet, streams []av.CodecData, vidx, aidx int) (drop bool, err error)
• type Conn
• type Deframer
  • func (f *Deframer) Deframe(rp *rtp.Packet) ([]av.Packet, error)
• type H264Parser
  • func (p *H264Parser) CodecData() (av.CodecData, error)
  • func (p *H264Parser) ParseFrame(packet []byte) ([]av.Packet, error)
• type NullParser
  • func (p NullParser) CodecData() (av.CodecData, error)
  • func (NullParser) ParseFrame(packet []byte) ([]av.Packet, error)
• type Parser
• type PublishFunc
• type Server
  • func (s *Server) Listen(addr string) (err error)
  • func (s *Server) Serve() error

Types

type CheckUserFunc

type CheckUserFunc func(channelID string, nonce, hmacProvided []byte) (auth model.ChannelAuth, err error)

type CombineSlices

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

CombineSlices is a filter that combines packets with the same timestamp, as seen with video generated by low-latency profiles.

func (*CombineSlices) ModifyPacket

func (s *CombineSlices) ModifyPacket(pkt *av.Packet, streams []av.CodecData, vidx, aidx int) (drop bool, err error)

type Conn

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

type Deframer

type Deframer struct {
	SSRC        uint32
	PayloadType uint8
	ClockRate   uint64
	Parser      Parser
	// contains filtered or unexported fields
}

func (*Deframer) Deframe

func (f *Deframer) Deframe(rp *rtp.Packet) ([]av.Packet, error)

type H264Parser

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

func (*H264Parser) CodecData

func (p *H264Parser) CodecData() (av.CodecData, error)

func (*H264Parser) ParseFrame

func (p *H264Parser) ParseFrame(packet []byte) ([]av.Packet, error)

type NullParser

type NullParser struct {
	Info av.CodecData
}

func (NullParser) CodecData

func (p NullParser) CodecData() (av.CodecData, error)

func (NullParser) ParseFrame

func (NullParser) ParseFrame(packet []byte) ([]av.Packet, error)

type Parser

type Parser interface {
	ParseFrame([]byte) ([]av.Packet, error)
	CodecData() (av.CodecData, error)
}

type PublishFunc

type PublishFunc func(auth model.ChannelAuth, kind, remoteAddr string, src av.Demuxer) error

type Server

type Server struct {
	CheckUser CheckUserFunc
	Publish   PublishFunc
	Listener  net.Listener
	RTPSocket net.PacketConn

	RTPAdvertisePort int
	// contains filtered or unexported fields
}

func (*Server) Listen

func (s *Server) Listen(addr string) (err error)

func (*Server) Serve

func (s *Server) Serve() error