position

package

v0.1.0 Latest Latest Go to latest Published: Aug 14, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

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 ¶

View Source

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

Functions ¶

This section is empty.

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.
	// Last processed id.
	CDCID int64
	// Time Created time.
	Time time.Time
}

Position represents DB2 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.

Source Files ¶

View all Source files

position.go

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