logrepl

package

v0.1.0 Latest Latest Go to latest Published: Apr 5, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation ¶

Index ¶

func LSNToPosition(lsn pglogrepl.LSN) sdk.Position
func PositionToLSN(pos sdk.Position) (pglogrepl.LSN, error)
type CDCHandler
- func NewCDCHandler(rs *internal.RelationSet, keyColumn string, columns []string, ...) *CDCHandler
- func (h *CDCHandler) Handle(ctx context.Context, m pglogrepl.Message, lsn pglogrepl.LSN) error
type CDCIterator
- func NewCDCIterator(ctx context.Context, conn *pgx.Conn, config Config) (*CDCIterator, error)
type Config

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func LSNToPosition ¶

func LSNToPosition(lsn pglogrepl.LSN) sdk.Position

LSNToPosition converts a Postgres LSN to a Conduit position.

func PositionToLSN ¶

func PositionToLSN(pos sdk.Position) (pglogrepl.LSN, error)

PositionToLSN converts a Conduit position to a Postgres LSN.

Types ¶

type CDCHandler ¶

type CDCHandler struct {
	// contains filtered or unexported fields
}

CDCHandler is responsible for handling logical replication messages, converting them to a record and sending them to a channel.

func NewCDCHandler ¶

func NewCDCHandler(
	rs *internal.RelationSet,
	keyColumn string,
	columns []string,
	out chan<- sdk.Record,
) *CDCHandler

func (*CDCHandler) Handle ¶

func (h *CDCHandler) Handle(ctx context.Context, m pglogrepl.Message, lsn pglogrepl.LSN) error

Handle is the handler function that receives all logical replication messages.

type CDCIterator ¶

type CDCIterator struct {
	// contains filtered or unexported fields
}

CDCIterator asynchronously listens for events from the logical replication slot and returns them to the caller through Next.

func NewCDCIterator ¶

func NewCDCIterator(ctx context.Context, conn *pgx.Conn, config Config) (*CDCIterator, error)

NewCDCIterator sets up the subscription to a logical replication slot and starts a goroutine that listens to events. The goroutine will keep running until either the context is canceled or Teardown is called.

func (*CDCIterator) Ack ¶

func (i *CDCIterator) Ack(ctx context.Context, pos sdk.Position) error

Ack forwards the acknowledgment to the subscription.

func (*CDCIterator) Next ¶

func (i *CDCIterator) Next(ctx context.Context) (sdk.Record, error)

Next returns the next record retrieved from the subscription. This call will block until either a record is returned from the subscription, the subscription stops because of an error or the context gets canceled.

func (*CDCIterator) Teardown ¶

func (i *CDCIterator) Teardown(ctx context.Context) error

Teardown stops the CDC subscription and blocks until the subscription is done or the context gets canceled. If the subscription stopped with an unexpected error, the error is returned.

type Config ¶

type Config struct {
	Position        sdk.Position
	SlotName        string
	PublicationName string
	TableName       string
	KeyColumnName   string
	Columns         []string
}

Config holds configuration values for CDCIterator.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
internal

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL