position

Documentation

Index

• func ConvertToCDCPosition(p opencdc.Position) (opencdc.Position, error)
• type Position
  • func ParseRecordPosition(p opencdc.Position) (Position, error)
  • func (p Position) ToRecordPosition() opencdc.Position
• type Type

Functions

func ConvertToCDCPosition

func ConvertToCDCPosition(p opencdc.Position) (opencdc.Position, error)

Types

type Position

type Position struct {
	Key       string
	Timestamp time.Time
	Type      Type
}

func ParseRecordPosition

func ParseRecordPosition(p opencdc.Position) (Position, error)

func (Position) ToRecordPosition

func (p Position) ToRecordPosition() opencdc.Position

type Type

type Type int

const (
	TypeSnapshot Type = iota
	TypeCDC
)