factory

func CreateCommandConsumer(
	currentTimeGetter libtime.CurrentTimeGetter,
	saramaClientProvider libkafka.SaramaClientProvider,
	syncProducer libkafka.SyncProducer,
	db libkv.DB,
	branch base.Branch,
	batchSize libkafka.BatchSize,
) run.Func

func CreateDiscordNotificationHandler(
	ctx context.Context,
	syncProducer libkafka.SyncProducer,
	branch base.Branch,
	initiator cqrsiam.Initiator,
	defaultChannelName discord.ChannelName,
	testChannelName discord.ChannelName,
) core.NotificationHandlerTx

func CreateNotificationConsumer(
	saramaClientProvider libkafka.SaramaClientProvider,
	syncProducer libkafka.SyncProducer,
	db libkv.DB,
	branch base.Branch,
	batchSize libkafka.BatchSize,
	initiator cqrsiam.Initiator,
	defaultChannelName discord.ChannelName,
	testChannelName discord.ChannelName,
) run.Func

func CreateNotificationHandler(
	ctx context.Context,
	syncProducer libkafka.SyncProducer,
	branch base.Branch,
	initiator cqrsiam.Initiator,
	defaultChannelName discord.ChannelName,
	testChannelName discord.ChannelName,
) core.NotificationHandlerTx

func CreateNotificationSender(
	syncProducer libkafka.SyncProducer,
	branch base.Branch,
) pkg.NotificationSender

func CreateSendHandler(
	ctx context.Context,
	syncProducer libkafka.SyncProducer,
	branch base.Branch,
	initiator cqrsiam.Initiator,
) http.Handler