replication

Documentation

Index

• Variables
• func OverridesModule(config *sysconfig.SystemConfig) wiring.Module
• type Replicator
  • func NewReplicator(config *sysconfig.SystemConfig) (*Replicator, error)
  • func (r *Replicator) StartReplication() *cli.ExitError
  • func (r *Replicator) StopReplication() *cli.ExitError

Variables

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)
	},
)

Functions

func OverridesModule

func OverridesModule(
	config *sysconfig.SystemConfig,
) wiring.Module

Types

type Replicator

type Replicator struct {
	// contains filtered or unexported fields
}

Replicator is the main controller for all things logical replication, such as the logical replication connection, the side channel connection, and other services necessary to run the event stream generation.

func NewReplicator

func NewReplicator(
	config *sysconfig.SystemConfig,
) (*Replicator, error)

NewReplicator instantiates a new instance of the Replicator.

func (*Replicator) StartReplication

func (r *Replicator) StartReplication() *cli.ExitError

StartReplication initiates the actual replication process

func (*Replicator) StopReplication

func (r *Replicator) StopReplication() *cli.ExitError

StopReplication initiates a clean shutdown of the replication process. This call blocks until the shutdown process has finished.