Documentation
¶
Index ¶
- func DefaultEventEmitterProvider(config *spiconfig.Config, replicationContext *context.ReplicationContext, ...) (*eventemitting.EventEmitter, error)
- func DefaultNamingStrategyProvider(config *spiconfig.Config) (namingstrategy.NamingStrategy, error)
- func DefaultSinkProvider(config *spiconfig.Config) (sink.Sink, error)
- func DefaultStateStorageProvider(config *spiconfig.Config) (statestorage.Storage, error)
- type EventEmitterProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultEventEmitterProvider ¶
func DefaultEventEmitterProvider( config *spiconfig.Config, replicationContext *context.ReplicationContext, sink sink.Sink, ) (*eventemitting.EventEmitter, error)
func DefaultNamingStrategyProvider ¶
func DefaultNamingStrategyProvider(config *spiconfig.Config) (namingstrategy.NamingStrategy, error)
func DefaultStateStorageProvider ¶
func DefaultStateStorageProvider(config *spiconfig.Config) (statestorage.Storage, error)
Types ¶
type EventEmitterProvider ¶
type EventEmitterProvider = func( config *spiconfig.Config, replicationContext *context.ReplicationContext, sink sink.Sink, ) (*eventemitting.EventEmitter, error)
Source Files
Click to show internal directories.
Click to hide internal directories.