replication

var DynamicModule = wiring.DefineModule(
	"Dynamic",
	func(module wiring.Module) {
		module.Provide(func(c *config.Config) (statestorage.Storage, error) {
			name := config.GetOrDefault(c, config.PropertyStateStorageType, config.NoneStorage)
			return statestorage.NewStateStorage(name, c)
		})

		module.Provide(func(c *config.Config) (namingstrategy.NamingStrategy, error) {
			name := config.GetOrDefault(c, config.PropertyNamingStrategy, config.Debezium)
			return namingstrategyimpl.NewNamingStrategy(name, c)
		})

		module.Provide(func(c *config.Config) (sink.Sink, error) {
			name := config.GetOrDefault(c, config.PropertySink, config.Stdout)
			return sinkimpl.NewSink(name, c)
		})
	},
)

var StaticModule = wiring.DefineModule(
	"Static", func(module wiring.Module) {
		module.Provide(eventemitting.NewEventEmitterFromConfig)
		module.Provide(statestorage.NewStateStorageManager)
		module.Provide(sidechannelimpl.NewSideChannel)
		module.Provide(replicationcontextimpl.NewReplicationContext)
		module.Provide(logicalreplicationresolver.NewResolver, wiring.ForceInitialization())
		module.Provide(schema.NewNameGeneratorFromConfig)
		module.Provide(replicationchannel.NewReplicationChannel)
		module.Provide(sinkimpl.NewSinkManager)
		module.Provide(stream.NewStreamManager)
		module.Provide(snapshotting.NewSnapshotterFromConfig)
		module.Provide(taskmanagerimpl.NewTaskManager)
		module.Provide(publicationmanager.NewPublicationManager)
		module.Provide(systemcatalogimpl.NewSystemCatalog)
		module.Provide(typemanager.NewTypeManager)
		module.Provide(stats.NewStatsService)
	},
)