segm

Documentation

Index

• Variables
• type ConcatOperation
  • func NewConcatOperation(ctx context.Context) *ConcatOperation
  • func (co *ConcatOperation) Closed() <-chan struct{}
  • func (co *ConcatOperation) Init(req ConcatRequest) error
  • func (co *ConcatOperation) Prune() error
  • func (co *ConcatOperation) Run() (progress chan ff.Progressable, failures chan error)
• type ConcatRequest
• type Segment
• type SliceOperation
  • func NewSliceOperation(ctx context.Context) *SliceOperation
  • func (so *SliceOperation) Closed() <-chan struct{}
  • func (so *SliceOperation) Init(req SliceRequest) error
  • func (so *SliceOperation) Purge() error
  • func (so *SliceOperation) Run() (progress chan ff.Progressable, segments chan *Segment, failures chan error)
• type SliceRequest

Variables

var ErrAlreadyInitialized = errors.New("operation was already initialized")

ErrAlreadyInitialized happened when Init() func called twice

var ErrAlreadyStarted = errors.New("operation was already started")

ErrAlreadyStarted happened when Run() func called twice

var ErrNotInitialized = errors.New("operation have not been initialized")

ErrNotInitialized happened when instance wasn't initialized by Init() func

Types

type ConcatOperation

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

ConcatOperation _

func NewConcatOperation

func NewConcatOperation(ctx context.Context) *ConcatOperation

NewConcatOperation _

func (*ConcatOperation) Closed

func (co *ConcatOperation) Closed() <-chan struct{}

Closed _

func (*ConcatOperation) Init

func (co *ConcatOperation) Init(req ConcatRequest) error

Init _

func (*ConcatOperation) Prune

func (co *ConcatOperation) Prune() error

Prune _

func (*ConcatOperation) Run

func (co *ConcatOperation) Run() (progress chan ff.Progressable, failures chan error)

Run _

type ConcatRequest

type ConcatRequest struct {
	OutFile  files.Filer
	Segments []*Segment
}

ConcatRequest _

type Segment

type Segment struct {
	// from 0 to inf
	Position int
	File     files.Filer
}

Segment _

type SliceOperation

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

SliceOperation _

func NewSliceOperation

func NewSliceOperation(ctx context.Context) *SliceOperation

NewSliceOperation _

func (*SliceOperation) Closed

func (so *SliceOperation) Closed() <-chan struct{}

Closed _

func (*SliceOperation) Init

func (so *SliceOperation) Init(req SliceRequest) error

Init _

func (*SliceOperation) Purge

func (so *SliceOperation) Purge() error

Purge removes all segments from tmp directory & also tmp directory itself

func (*SliceOperation) Run

func (so *SliceOperation) Run() (
	progress chan ff.Progressable,
	segments chan *Segment,
	failures chan error,
)

Run _

type SliceRequest

type SliceRequest struct {
	InFile         files.Filer
	OutPath        files.Pather
	KeepTimestamps bool
	SegmentSec     int
}

SliceRequest _