hls

Documentation

Index

• Variables
• type Server
  • func NewServer() *Server
  • func (self *Server) GetWriter(info av.Info) av.WriteCloser
  • func (self *Server) Serve(l net.Listener) error
• type Source
  • func NewSource(info av.Info) *Source
  • func (self *Source) Close(err error)
  • func (self *Source) DropPacket(pktQue chan av.Packet, info av.Info)
  • func (self *Source) GetCacheInc() *TSCacheItem
  • func (self *Source) Info() (ret av.Info)
  • func (self *Source) SendPacket() error
  • func (self *Source) Write(p av.Packet) error
• type TSCache
  • func NewTSCache() *TSCache
  • func (self *TSCache) Get(key string) *TSCacheItem
  • func (self *TSCache) Set(key string, e *TSCacheItem)
• type TSCacheItem
  • func NewTSCacheItem(id string) *TSCacheItem
  • func (self *TSCacheItem) GenM3U8PlayList() ([]byte, error)
  • func (self *TSCacheItem) GetItem(key string) (TSItem, error)
  • func (self *TSCacheItem) ID() string
  • func (self *TSCacheItem) SetItem(key string, item TSItem)
• type TSItem
  • func NewTSItem(name string, duration, seqNum int, b []byte) TSItem

Variables

var (
	ErrNoPublisher         = errors.New("No publisher")
	ErrInvalidReq          = errors.New("invalid req url path")
	ErrNoSupportVideoCodec = errors.New("no support video codec")
	ErrNoSupportAudioCodec = errors.New("no support audio codec")
)

var (
	ErrNoKey = errors.New("No key for cache")
)

Types

type Server

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

func NewServer

func NewServer() *Server

func (*Server) GetWriter

func (self *Server) GetWriter(info av.Info) av.WriteCloser

func (*Server) Serve

func (self *Server) Serve(l net.Listener) error

type Source

type Source struct {
	av.RWBaser
	// contains filtered or unexported fields
}

func NewSource

func NewSource(info av.Info) *Source

func (*Source) Close

func (self *Source) Close(err error)

func (*Source) DropPacket

func (self *Source) DropPacket(pktQue chan av.Packet, info av.Info)

func (*Source) GetCacheInc

func (self *Source) GetCacheInc() *TSCacheItem

func (*Source) Info

func (self *Source) Info() (ret av.Info)

func (*Source) SendPacket

func (self *Source) SendPacket() error

func (*Source) Write

func (self *Source) Write(p av.Packet) error

type TSCache

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

func NewTSCache

func NewTSCache() *TSCache

func (*TSCache) Get

func (self *TSCache) Get(key string) *TSCacheItem

func (*TSCache) Set

func (self *TSCache) Set(key string, e *TSCacheItem)

type TSCacheItem

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

func NewTSCacheItem

func NewTSCacheItem(id string) *TSCacheItem

func (*TSCacheItem) GenM3U8PlayList

func (self *TSCacheItem) GenM3U8PlayList() ([]byte, error)

TODO: found data race, fix it

func (*TSCacheItem) GetItem

func (self *TSCacheItem) GetItem(key string) (TSItem, error)

func (*TSCacheItem) ID

func (self *TSCacheItem) ID() string

func (*TSCacheItem) SetItem

func (self *TSCacheItem) SetItem(key string, item TSItem)

type TSItem

type TSItem struct {
	Name     string
	SeqNum   int
	Duration int
	Data     []byte
}

func NewTSItem

func NewTSItem(name string, duration, seqNum int, b []byte) TSItem