Versions in this module Expand all Collapse all v0 v0.0.1 Jun 7, 2024 Changes in this version + const ErrCannotSetupWhilstPipelineIsActive + const ErrPipelineIsAlreadyActive + type Error string + func (e Error) Error() string + type Options struct + func NewOptions(size int, address, videoSource, videoDestination, imageDestination string, ...) *Options + func (o *Options) Clone() *Options + func (o *Options) GetAddress() string + func (o *Options) GetImageDestination() string + func (o *Options) GetSize() int + func (o *Options) GetTranscodeOptions() ffmpeg.TranscodeOptions + func (o *Options) GetVideoDestination() string + func (o *Options) GetVideoSource() string + func (o *Options) IsEmpty() bool + func (o *Options) Replace(options *Options) + type Pipeline interface + Active func() bool + Close func() (err error) + Done func() <-chan struct{} + Download func(ctx context.Context) (err error) + Metadata func(ctx context.Context) (err error) + Operation func() <-chan *grpc_runner_v1.OperationRequest + Retry func(ctx context.Context, response *grpc_runner_v1.StreamResponse) (err error) + Run func(ctx context.Context) (err error) + Setup func(options *Options) (err error) + Stream func() <-chan *grpc_runner_v1.StreamRequest + Transcode func(ctx context.Context) (err error) + Upload func(ctx context.Context) (err error) + func New() Pipeline + func NewWithOptions(options *Options) Pipeline
Go to main page