Versions in this module Expand all Collapse all v0 v0.1.0 Jan 18, 2021 Changes in this version + const MediaProcessingCallbackQueue + const VideoTranscodingQueue + func MediaProcessingCallbackProducer(ch Channel, data MediaProcessingCallbackParams) error + func VideoTranscodingProducer(ch Channel, data VideoTranscodingParams) error + type Channel interface + Consume func(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error) + Publish func(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error + QueueDeclare func(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error) + type MediaProcessingCallbackParams struct + MediaFilesCount int + MediaUUID uuid.UUID + type Options struct + Concurrency uint + Database *ent.Client + Host string + Logger logging.ILogger + Password string + Port int + Storage storage.Storage + Transcoder transcoding.ITranscoder + Username string + type Queue struct + Args amqp.Table + AutoDelete bool + Durable bool + Exclusive bool + Handler func(*Worker, <-chan amqp.Delivery) + Name string + NoWait bool + type VideoTranscodingParams struct + AudioBitrate int + AudioCodec string + AudioRate int + BufferSize int + Crf uint32 + FrameRate int + HlsPlaylistType string + HlsSegmentDuration int + KeyframeInterval int + MediaUUID uuid.UUID + OriginalFile transcoding.OriginalFile + RenditionName string + TargetBandwidth uint64 + VideoBitRate int + VideoCodec string + VideoHeight int + VideoMaxBitRate int + VideoWidth int + type Worker struct + Client *amqp.Connection + Queues map[string]amqp.Queue + func New(opts Options) (*Worker, error) + func (w *Worker) Close() error + func (w *Worker) Consume() error + func (w *Worker) Init() error v0.1.0-rc9 Dec 17, 2020 v0.1.0-rc10 Jan 7, 2021