source

Sep 2, 2024

Changes in this version

+ const AckTrackerSize

Sep 16, 2023

Changes in this version

+ var ReceiverQueueSize = 5000

+ type BaseSource struct

+ ReadTimeout time.Duration

+ func (b *BaseSource) Capture(cp cursor.Checkpoint) (changes chan Change, err error)

+ func (b *BaseSource) Commit(cp cursor.Checkpoint)

+ func (b *BaseSource) Error() error

+ func (b *BaseSource) Stop() error

+ type CaptureFn func(changes chan Change) error

+ type Change struct

+ Checkpoint cursor.Checkpoint

+ Message *pb.Message

+ type FlushFn func()

+ type PGXSource struct

+ CreatePublication bool

+ CreateSlot bool

+ DecodePlugin string

+ ReplConnStr string

+ ReplSlot string

+ SetupConnStr string

+ StartLSN string

+ func (p *PGXSource) Capture(cp cursor.Checkpoint) (changes chan Change, err error)

+ func (p *PGXSource) Commit(cp cursor.Checkpoint)

+ func (p *PGXSource) Requeue(cp cursor.Checkpoint, reason string)

+ func (p *PGXSource) TxCounter() uint64

+ type PulsarConsumerSource struct

+ PulsarMaxReconnect *uint

+ PulsarOption pulsar.ClientOptions

+ PulsarReplicateState bool

+ PulsarSubscription string

+ PulsarTopic string

+ func (p *PulsarConsumerSource) Capture(cp cursor.Checkpoint) (changes chan Change, err error)

+ func (p *PulsarConsumerSource) Commit(cp cursor.Checkpoint)

+ func (p *PulsarConsumerSource) Requeue(cp cursor.Checkpoint, reason string)

+ type PulsarReaderSource struct

+ PulsarOption pulsar.ClientOptions

+ PulsarTopic string

+ func (p *PulsarReaderSource) Capture(cp cursor.Checkpoint) (changes chan Change, err error)

+ func (p *PulsarReaderSource) Commit(cp cursor.Checkpoint)

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

+ type RequeueSource interface

+ Requeue func(cp cursor.Checkpoint, reason string)

+ type Source interface

+ Capture func(cp cursor.Checkpoint) (changes chan Change, err error)

+ Commit func(cp cursor.Checkpoint)

+ Error func() error

+ Stop func() error