factory

func CreateChannelProvider(
	db libkv.DB,
	discordSession *discordgo.Session,
	serverID pkg.ServerID,
) pkg.ChannelIDProvider

func CreateChannelProviderTx(
	db libkv.DB,
	discordSession *discordgo.Session,
	serverID pkg.ServerID,
) pkg.ChannelIDProviderTx

func CreateCommandConsumer(
	db libkv.DB,
	saramaClientProvider libkafka.SaramaClientProvider,
	syncProducer libkafka.SyncProducer,
	kafkaGroup libkafka.Group,
	branch base.Branch,
	batchSize libkafka.BatchSize,
	discordSession *discordgo.Session,
	serverID pkg.ServerID,
	sentryClient libsentry.Client,
) run.Func

func CreateExistsHandler(discordSession *discordgo.Session) http.Handler

func CreateListSessionChannelsHandler(
	discordSession *discordgo.Session,
	serverID pkg.ServerID,
) http.Handler

func CreateListStoreChannelsHandler(
	db libkv.DB,
) http.Handler

func CreateSendCommandObjectExecutor(
	permissionChecker cqrsiam.PermissionChecker,
	db libkv.DB,
	discordSession *discordgo.Session,
	serverID pkg.ServerID,
) cdb.CommandObjectExecutorTx

func CreateSendTestMessageHandler(
	db libkv.DB,
	discordSession *discordgo.Session,
	serverID pkg.ServerID,
) http.Handler

func CreateUpdateChannelHandler(
	db libkv.DB,
	discordSession *discordgo.Session,
	serverID pkg.ServerID,
) http.Handler