producer

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(mqConfig configs.MQ, logger *zap.Logger) (Client, error)
• type DownloadTaskCreatedProducer
  • func NewDownloadTaskCreatedProducer(client Client, logger *zap.Logger) (DownloadTaskCreatedProducer, error)

Constants

const (
	MessageQueueDownloadTaskCreated = "download_task_created"
)

Variables

var WireSet = wire.NewSet(
	NewClient,
	NewDownloadTaskCreatedProducer,
)

Types

type Client

type Client interface {
	Produce(ctx context.Context, queueName string, payload []byte) error
}

func NewClient

func NewClient(mqConfig configs.MQ, logger *zap.Logger) (Client, error)

type DownloadTaskCreatedProducer

type DownloadTaskCreatedProducer interface {
	Produce(ctx context.Context, downloadTaskID uint64) error
}

func NewDownloadTaskCreatedProducer

func NewDownloadTaskCreatedProducer(client Client, logger *zap.Logger) (DownloadTaskCreatedProducer, error)