Versions in this module Expand all Collapse all v0 v0.1.0 May 11, 2020 Changes in this version + var ErrInvalidReq = fmt.Errorf("invalid req url path") + var ErrNoKey = fmt.Errorf("No key for cache") + var ErrNoPublisher = fmt.Errorf("no publisher") + var ErrNoSupportAudioCodec = fmt.Errorf("no support audio codec") + var ErrNoSupportVideoCodec = fmt.Errorf("no support video codec") + type Server struct + func NewServer() *Server + func (server *Server) GetWriter(info av.Info) av.WriteCloser + func (server *Server) Serve(listener net.Listener) error + type Source struct + func NewSource(info av.Info) *Source + func (source *Source) Close(err error) + func (source *Source) DropPacket(pktQue chan *av.Packet, info av.Info) + func (source *Source) GetCacheInc() *TSCacheItem + func (source *Source) Info() (ret av.Info) + func (source *Source) SendPacket() error + func (source *Source) Write(p *av.Packet) (err error) + type TSCacheItem struct + func NewTSCacheItem(id string) *TSCacheItem + func (tcCacheItem *TSCacheItem) GenM3U8PlayList() ([]byte, error) + func (tcCacheItem *TSCacheItem) GetItem(key string) (TSItem, error) + func (tcCacheItem *TSCacheItem) ID() string + func (tcCacheItem *TSCacheItem) SetItem(key string, item TSItem) + type TSItem struct + Data []byte + Duration int + Name string + SeqNum int + func NewTSItem(name string, duration, seqNum int, b []byte) TSItem