consumer

Documentation

Index

• Variables
• type DownloadTaskCreatedHandler
  • func NewDownloadTaskCreatedHandler(downloadTaskLogic logic.DownloadTaskLogic, logger *zap.Logger) (DownloadTaskCreatedHandler, error)
• type RootConsumer
  • func NewRootConsumer(downloadTaskCreatedHandler DownloadTaskCreatedHandler, ...) RootConsumer

Variables

var WireSet = wire.NewSet(
	NewDownloadTaskCreatedHandler,
	NewRootConsumer,
)

Types

type DownloadTaskCreatedHandler

type DownloadTaskCreatedHandler interface {
	Handle(ctx context.Context, event database.DownloadTask) error
}

func NewDownloadTaskCreatedHandler

func NewDownloadTaskCreatedHandler(
	downloadTaskLogic logic.DownloadTaskLogic,
	logger *zap.Logger,
) (DownloadTaskCreatedHandler, error)

type RootConsumer

type RootConsumer interface {
	Start(ctx context.Context) error
}

func NewRootConsumer

func NewRootConsumer(
	downloadTaskCreatedHandler DownloadTaskCreatedHandler,
	mqConsumer consumer.Consumer,
	logger *zap.Logger,
) RootConsumer