sysconfig

Documentation

Index

• type EventEmitterProvider
• type LogicalReplicationResolverProvider
• type NameGeneratorProvider
• type PublicationManagerProvider
• type ReplicationChannelProvider
• type ReplicationContextProvider
• type SideChannelProvider
• type SinkManagerProvider
• type SnapshotterProvider
• type StateStorageManagerProvider
• type StreamManagerProvider
• type SystemCatalogProvider
• type SystemConfig
  • func NewSystemConfig(config *spiconfig.Config) *SystemConfig
• type TaskManagerProvider
• type TypeManagerProvider

Types

type EventEmitterProvider

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

type LogicalReplicationResolverProvider

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

type NameGeneratorProvider

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

type PublicationManagerProvider

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

type ReplicationChannelProvider

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

type ReplicationContextProvider

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

type SideChannelProvider

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

type SinkManagerProvider

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

type SnapshotterProvider

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

type StateStorageManagerProvider

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

type StreamManagerProvider

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

type SystemCatalogProvider

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

type SystemConfig

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
}

func NewSystemConfig

func NewSystemConfig(
	config *spiconfig.Config,
) *SystemConfig

type TaskManagerProvider

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

type TypeManagerProvider

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