position

Documentation

Index

• Constants
• Variables
• type IteratorType
• type Position
  • func ParseSDKPosition(p sdk.Position) (*Position, error)
  • func (p Position) ConvertToSDKPosition() (sdk.Position, error)

Constants

const (
	TypeSnapshot = "s"
	TypeCDC      = "c"
)

Variables

var ErrUnknownIteratorType = errors.New("unknown iterator type")

Types

type IteratorType

type IteratorType string

IteratorType describe position type.

type Position

type Position struct {
	// IteratorType - shows in what iterator was created position.
	IteratorType IteratorType

	// Snapshot information.
	// SnapshotLastProcessedVal - last processed value from ordering column.
	SnapshotLastProcessedVal any
	// SnapshotMaxValue - max value from ordering column.
	SnapshotMaxValue any

	// CDC information.
	// CDCLastID - last processed id from tracking table.
	CDCLastID int
	// TrackingTableName tracking table name.
	TrackingTableName string
}

Position represents SAP Hana position.

func ParseSDKPosition

func ParseSDKPosition(p sdk.Position) (*Position, error)

ParseSDKPosition parses SDK position and returns Position.

func (Position) ConvertToSDKPosition

func (p Position) ConvertToSDKPosition() (sdk.Position, error)

ConvertToSDKPosition formats and returns sdk.Position.