segmenter

Documentation

Index

• Variables
• type FFMpegVideoSegmenter
  • func NewFFMpegVideoSegmenter(workDir string, strmID string, localRtmpUrl string, opt SegmenterOptions) *FFMpegVideoSegmenter
  • func (s *FFMpegVideoSegmenter) Cleanup()
  • func (s *FFMpegVideoSegmenter) PollPlaylist(ctx context.Context) (*VideoPlaylist, error)
  • func (s *FFMpegVideoSegmenter) PollSegment(ctx context.Context) (*VideoSegment, error)
  • func (s *FFMpegVideoSegmenter) RTMPToHLS(ctx context.Context, cleanup bool) error
• type SegmenterOptions
• type VideoPlaylist
• type VideoSegment
• type VideoSegmenter

Variables

var ErrSegmenter = errors.New("SegmenterError")

var ErrSegmenterTimeout = errors.New("SegmenterTimeout")

var PlaylistRetryCount = 5

var PlaylistRetryWait = 500 * time.Millisecond

Types

type FFMpegVideoSegmenter

type FFMpegVideoSegmenter struct {
	WorkDir      string
	LocalRtmpUrl string
	StrmID       string

	SegLen time.Duration
	// contains filtered or unexported fields
}

FFMpegVideoSegmenter segments a RTMP stream by invoking FFMpeg and monitoring the file system.

func NewFFMpegVideoSegmenter

func NewFFMpegVideoSegmenter(workDir string, strmID string, localRtmpUrl string, opt SegmenterOptions) *FFMpegVideoSegmenter

func (*FFMpegVideoSegmenter) Cleanup

func (s *FFMpegVideoSegmenter) Cleanup()

func (*FFMpegVideoSegmenter) PollPlaylist

func (s *FFMpegVideoSegmenter) PollPlaylist(ctx context.Context) (*VideoPlaylist, error)

PollPlaylist monitors the filesystem and returns a new playlist as it becomes available

func (*FFMpegVideoSegmenter) PollSegment

func (s *FFMpegVideoSegmenter) PollSegment(ctx context.Context) (*VideoSegment, error)

PollSegment monitors the filesystem and returns a new segment as it becomes available

func (*FFMpegVideoSegmenter) RTMPToHLS

func (s *FFMpegVideoSegmenter) RTMPToHLS(ctx context.Context, cleanup bool) error

RTMPToHLS invokes FFMpeg to do the segmenting. This method blocks until the segmenter exits.

type SegmenterOptions

type SegmenterOptions struct {
	EnforceKeyframe bool //Enforce each segment starts with a keyframe
	SegLength       time.Duration
	StartSeq        int
}

type VideoPlaylist

type VideoPlaylist struct {
	Format stream.VideoFormat
	// Data   []byte
	Data *m3u8.MediaPlaylist
}

type VideoSegment

type VideoSegment struct {
	Codec  av.CodecType
	Format stream.VideoFormat
	Length time.Duration
	Data   []byte
	Name   string
	SeqNo  uint64
}

type VideoSegmenter

type VideoSegmenter interface {
	RTMPToHLS(ctx context.Context, cleanup bool) error
}