worker

package

v0.0.0-...-23f8949 Latest Latest Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

MediaWorker 媒体处理 Worker

func NewMediaWorker(
	mongoDB *mongo.Database,
	minioClient *minioclient.Client,
	kafkaCfg *kafka.ConsumerConfig,
) (*MediaWorker, error)

NewMediaWorker 创建媒体处理 Worker

func (w *MediaWorker) Start(ctx context.Context) error

Start 启动 Worker

func (w *MediaWorker) Stop() error

Stop 停止 Worker