sink

type ApplyFn func(sourceRemaining int, message source.Change, committed chan cursor.Checkpoint) error

type BaseSink struct {
	CleanFn CleanFn
	// contains filtered or unexported fields
}

type CleanFn func()

type PGXSink struct {
	BaseSink

	ConnStr     string
	SourceID    string
	Renice      int64
	LogReader   io.Reader
	BatchTXSize int
	// contains filtered or unexported fields
}

type PulsarSink struct {
	BaseSink

	PulsarOption pulsar.ClientOptions
	PulsarTopic  string
	// For overriding the cluster list to be replicated to
	ReplicatedClusters []string

	SetupTracker SetupTracker
	// contains filtered or unexported fields
}

type SetupTracker func(client pulsar.Client, topic string) (cursor.Tracker, error)

type Sink interface {
	Setup() (cp cursor.Checkpoint, err error)
	Apply(changes chan source.Change) (committed chan cursor.Checkpoint)
	Error() error
	Stop() error
}