hls

Documentation

Index

• func ClientAbsoluteURL(base *url.URL, relative string) (*url.URL, error)
• func FetchMediaPlaylist(httpClient *znet.Client, rawURL string) (*playlist.Media, []byte, error)
• func FetchPlaylist(httpClient *znet.Client, rawURL string) (playlist.Playlist, []byte, error)
• func FetchSegment(httpClient *znet.Client, rawURL string) ([]byte, error)
• func PickLeadingPlaylist(variants []*playlist.MultivariantVariant) *playlist.MultivariantVariant
• type AfterFirstPlaylistDownloadFunc
• type ClientAfterDownloadSegmentFunc
• type Publisher
  • func NewPublisher(ctx context.Context, session logic.ICustomizePubSessionContext) *Publisher
  • func (p *Publisher) Write(msg []byte) error
• type PullSession
  • func NewPullSession(uri string, hc *znet.Client, ...) *PullSession
  • func (c *PullSession) Close()
  • func (c *PullSession) SetParallel(n int)
  • func (c *PullSession) Start() error
  • func (c *PullSession) Wait() chan error

Functions

func ClientAbsoluteURL

func ClientAbsoluteURL(base *url.URL, relative string) (*url.URL, error)

func FetchMediaPlaylist

func FetchMediaPlaylist(httpClient *znet.Client, rawURL string) (*playlist.Media, []byte, error)

func FetchPlaylist

func FetchPlaylist(httpClient *znet.Client, rawURL string) (playlist.Playlist, []byte, error)

func FetchSegment

func FetchSegment(httpClient *znet.Client, rawURL string) ([]byte, error)

func PickLeadingPlaylist

func PickLeadingPlaylist(variants []*playlist.MultivariantVariant) *playlist.MultivariantVariant

Types

type AfterFirstPlaylistDownloadFunc

type AfterFirstPlaylistDownloadFunc func(playlist.Playlist, []byte)

type ClientAfterDownloadSegmentFunc

type ClientAfterDownloadSegmentFunc func(*playlist.MediaSegment, []byte)

type Publisher

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

func NewPublisher

func NewPublisher(ctx context.Context, session logic.ICustomizePubSessionContext) *Publisher

func (*Publisher) Write

func (p *Publisher) Write(msg []byte) error

type PullSession

type PullSession struct {
	URI                        string
	AfterFirstPlaylistDownload AfterFirstPlaylistDownloadFunc
	AfterDownloadSegment       ClientAfterDownloadSegmentFunc
	// contains filtered or unexported fields
}

func NewPullSession

func NewPullSession(uri string, hc *znet.Client, afterDownloadSegment ClientAfterDownloadSegmentFunc) *PullSession

func (*PullSession) Close

func (c *PullSession) Close()

Close closes all the Client resources.

func (*PullSession) SetParallel

func (c *PullSession) SetParallel(n int)

func (*PullSession) Start

func (c *PullSession) Start() error

func (*PullSession) Wait

func (c *PullSession) Wait() chan error

Wait waits for any error of the Client.