position

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

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