mq

Documentation

Index

• func NewKafkaDMLSink(ctx context.Context, changefeedID model.ChangeFeedID, sinkURI *url.URL, ...) (_ *dmlSink, err error)
• func NewPulsarDMLSink(ctx context.Context, changefeedID model.ChangeFeedID, sinkURI *url.URL, ...) (_ *dmlSink, err error)

Functions

func NewKafkaDMLSink

func NewKafkaDMLSink(
	ctx context.Context,
	changefeedID model.ChangeFeedID,
	sinkURI *url.URL,
	replicaConfig *config.ReplicaConfig,
	errCh chan error,
	factoryCreator kafka.FactoryCreator,
	producerCreator dmlproducer.Factory,
) (_ *dmlSink, err error)

NewKafkaDMLSink will verify the config and create a KafkaSink.

func NewPulsarDMLSink

func NewPulsarDMLSink(
	ctx context.Context,
	changefeedID model.ChangeFeedID,
	sinkURI *url.URL,
	replicaConfig *config.ReplicaConfig,
	errCh chan error,
	pulsarTopicManagerCreator manager.PulsarTopicManager,
	clientCreator pulsarConfig.FactoryCreator,
	producerCreator dmlproducer.PulsarFactory,
) (_ *dmlSink, err error)

NewPulsarDMLSink will verify the config and create a PulsarSink.