source

type BaseSource struct {
	ReadTimeout time.Duration
	// contains filtered or unexported fields
}

type CaptureFn func(changes chan Change) error

type Change struct {
	Checkpoint cursor.Checkpoint
	Message    *pb.Message
}

type FlushFn func()

type PGXSource struct {
	BaseSource

	SetupConnStr      string
	ReplConnStr       string
	ReplSlot          string
	CreateSlot        bool
	CreatePublication bool
	StartLSN          string
	DecodePlugin      string
	// contains filtered or unexported fields
}

type PulsarConsumerSource struct {
	BaseSource

	PulsarOption         pulsar.ClientOptions
	PulsarTopic          string
	PulsarSubscription   string
	PulsarReplicateState bool
	PulsarMaxReconnect   *uint
	// contains filtered or unexported fields
}

type PulsarReaderSource struct {
	BaseSource

	PulsarOption pulsar.ClientOptions
	PulsarTopic  string
	// contains filtered or unexported fields
}

type ReadFn func(ctx context.Context) (Change, error)

type RequeueSource interface {
	Source
	Requeue(cp cursor.Checkpoint, reason string)
}

type Source interface {
	Capture(cp cursor.Checkpoint) (changes chan Change, err error)
	Commit(cp cursor.Checkpoint)
	Error() error
	Stop() error
}