position

package

v0.11.1 Latest Latest Go to latest Published: Mar 19, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation ¶

Index ¶

type Position
- func ParseSDKPosition(sdkPos opencdc.Position) (Position, error)
- func (p Position) LSN() (pglogrepl.LSN, error)
- func (p Position) ToSDKPosition() opencdc.Position
type SnapshotPosition
type SnapshotPositions
type Type
- func (i Type) String() string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Position ¶

type Position struct {
	Type      Type              `json:"type"`
	Snapshots SnapshotPositions `json:"snapshots,omitempty"`
	LastLSN   string            `json:"last_lsn,omitempty"`
}

func ParseSDKPosition ¶

func ParseSDKPosition(sdkPos opencdc.Position) (Position, error)

func (Position) LSN ¶

func (p Position) LSN() (pglogrepl.LSN, error)

LSN returns the last LSN (Log Sequence Number) in the position.

func (Position) ToSDKPosition ¶

func (p Position) ToSDKPosition() opencdc.Position

type SnapshotPosition ¶

type SnapshotPosition struct {
	LastRead    int64 `json:"last_read"`
	SnapshotEnd int64 `json:"snapshot_end"`
}

type SnapshotPositions ¶

type SnapshotPositions map[string]SnapshotPosition

type Type ¶

type Type int

const (
	TypeInitial Type = iota
	TypeSnapshot
	TypeCDC
)

func (Type) String ¶

func (i Type) String() string

Source Files ¶

View all Source files

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