Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
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
type PullSession ¶
type PullSession struct {
URI string
AfterFirstPlaylistDownload AfterFirstPlaylistDownloadFunc
AfterDownloadSegment ClientAfterDownloadSegmentFunc
// contains filtered or unexported fields
}
func NewPullSession ¶
func NewPullSession(uri string, hc *cnet.Client, afterDownloadSegment ClientAfterDownloadSegmentFunc) *PullSession
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.
Click to show internal directories.
Click to hide internal directories.