watermark

Documentation

Index

• type SnapshotContext
  • func NewSnapshotContext(snapshotName string) *SnapshotContext
  • func (sc *SnapshotContext) GetOrCreateWatermark(table systemcatalog.BaseTable) (watermark *Watermark, created bool)
  • func (sc *SnapshotContext) GetWatermark(table systemcatalog.BaseTable) (watermark *Watermark, present bool)
  • func (sc *SnapshotContext) MarshalBinary() (data []byte, err error)
  • func (sc *SnapshotContext) UnmarshalBinary(data []byte) error
• type Watermark
  • func (w *Watermark) Complete() bool
  • func (w *Watermark) DataTypes() map[string]uint32
  • func (w *Watermark) HasValidLowWatermark() bool
  • func (w *Watermark) HighWatermark() map[string]any
  • func (w *Watermark) LowWatermark() map[string]any
  • func (w *Watermark) MarkComplete()
  • func (w *Watermark) MarkIncomplete()
  • func (w *Watermark) SetHighWatermark(values map[string]any)
  • func (w *Watermark) SetLowWatermark(values map[string]any)

Types

type SnapshotContext

type SnapshotContext struct {
	// contains filtered or unexported fields
}

func NewSnapshotContext

func NewSnapshotContext(
	snapshotName string,
) *SnapshotContext

func (*SnapshotContext) GetOrCreateWatermark

func (sc *SnapshotContext) GetOrCreateWatermark(
	table systemcatalog.BaseTable,
) (watermark *Watermark, created bool)

func (*SnapshotContext) GetWatermark

func (sc *SnapshotContext) GetWatermark(
	table systemcatalog.BaseTable,
) (watermark *Watermark, present bool)

func (*SnapshotContext) MarshalBinary

func (sc *SnapshotContext) MarshalBinary() (data []byte, err error)

func (*SnapshotContext) UnmarshalBinary

func (sc *SnapshotContext) UnmarshalBinary(
	data []byte,
) error

type Watermark

type Watermark struct {
	// contains filtered or unexported fields
}

func (*Watermark) Complete

func (w *Watermark) Complete() bool

func (*Watermark) DataTypes

func (w *Watermark) DataTypes() map[string]uint32

func (*Watermark) HasValidLowWatermark

func (w *Watermark) HasValidLowWatermark() bool

func (*Watermark) HighWatermark

func (w *Watermark) HighWatermark() map[string]any

func (*Watermark) LowWatermark

func (w *Watermark) LowWatermark() map[string]any

func (*Watermark) MarkComplete

func (w *Watermark) MarkComplete()

func (*Watermark) MarkIncomplete

func (w *Watermark) MarkIncomplete()

func (*Watermark) SetHighWatermark

func (w *Watermark) SetHighWatermark(
	values map[string]any,
)

func (*Watermark) SetLowWatermark

func (w *Watermark) SetLowWatermark(
	values map[string]any,
)