sysconfig

type EventEmitterProvider = func(
	*config.Config, replicationcontext.ReplicationContext, stream.Manager,
	pgtypes.TypeManager, task.TaskManager, *stats.Service,
) (*eventemitting.EventEmitter, error)

type LogicalReplicationResolverProvider = func(
	*config.Config, replicationcontext.ReplicationContext,
	systemcatalog.SystemCatalog, pgtypes.TypeManager, task.TaskManager,
) (eventhandlers.BaseReplicationEventHandler, error)

type NameGeneratorProvider = func(
	*config.Config, namingstrategy.NamingStrategy,
) schema.NameGenerator

type PublicationManagerProvider = func(
	*config.Config, sidechannel.SideChannel,
) publication.PublicationManager

type ReplicationChannelProvider = func(
	replicationcontext.ReplicationContext, pgtypes.TypeManager,
	task.TaskManager, publication.PublicationManager, *stats.Service,
) (*replicationchannel.ReplicationChannel, error)

type ReplicationContextProvider func(
	*config.Config, *pgx.ConnConfig, statestorage.Manager, sidechannel.SideChannel,
) (replicationcontext.ReplicationContext, error)

type SideChannelProvider = func(
	statestorage.Manager, *pgx.ConnConfig,
) (sidechannel.SideChannel, error)

type SinkManagerProvider = func(
	statestorage.Manager, sink.Sink,
) sink.Manager

type SnapshotterProvider = func(
	*config.Config, statestorage.Manager, sidechannel.SideChannel,
	task.TaskManager, publication.PublicationManager, pgtypes.TypeManager, *stats.Service,
) (*snapshotting.Snapshotter, error)

type StateStorageManagerProvider = func(
	statestorage.Storage,
) statestorage.Manager

type StreamManagerProvider = func(
	schema.NameGenerator, pgtypes.TypeManager, sink.Manager,
) (stream.Manager, error)

type SystemCatalogProvider = func(
	*config.Config, *pgx.ConnConfig, sidechannel.SideChannel, pgtypes.TypeManager,
	*snapshotting.Snapshotter, task.TaskManager, publication.PublicationManager, statestorage.Manager,
) (systemcatalog.SystemCatalog, error)

type SystemConfig struct {
	*spiconfig.Config

	PgxConfig                          *pgx.ConnConfig
	EventEmitterProvider               EventEmitterProvider
	LogicalReplicationResolverProvider LogicalReplicationResolverProvider
	NameGeneratorProvider              NameGeneratorProvider
	NamingStrategyProvider             namingstrategy.Factory
	ReplicationChannelProvider         ReplicationChannelProvider
	ReplicationContextProvider         ReplicationContextProvider
	SideChannelProvider                SideChannelProvider
	SinkFactory                        sink.Factory
	SinkManagerProvider                SinkManagerProvider
	SnapshotterProvider                SnapshotterProvider
	StateStorageProvider               statestorage.StorageProvider
	StateStorageManagerProvider        StateStorageManagerProvider
	StreamManagerProvider              StreamManagerProvider
	SystemCatalogProvider              SystemCatalogProvider
	TypeManagerProvider                TypeManagerProvider
	TaskManagerProvider                TaskManagerProvider
	PublicationManagerProvider         PublicationManagerProvider
}

type TaskManagerProvider = func(
	*config.Config,
) (task.TaskManager, error)

type TypeManagerProvider = func(
	sidechannel.SideChannel,
) (pgtypes.TypeManager, error)