This package implements client and server for logtail push model.

GetDataWindowForLogtail returns the batch according to the writeSchema.

GetStorageUsageHistory is for debug to show these storage usage changes.

LoadSpecifiedCkpBatch loads a specified checkpoint data batch.

MockUsageData generates accCnt * dbCnt * tblCnt UsageDatas.

for test.

WithLazyThreshold sets lazyThreshold to lazy seconds.

func (l BlockLocations) append iterator Location is a fixed-length unmodifiable byte array.

for ver1-3.

for ver1-3.

for ver1-3.

for ver1-3.

for ver1-3.

for ver1-3.

supporting `show accounts` in checkpoint.

mo_snapshot's schema.

mo_snapshot's schema.

mo_snapshot's schema.

mo_snapshot's schema.

mo_snapshot's schema.

mo_snapshot's schema.

mo_snapshot's schema.

mo_snapshot's schema.

func (l BlockLocations) append iterator Location is a fixed-length unmodifiable byte array.

func (l BlockLocations) append iterator Location is a fixed-length unmodifiable byte array.

func (l BlockLocations) append iterator Location is a fixed-length unmodifiable byte array.

func (l BlockLocations) append iterator Location is a fixed-length unmodifiable byte array.

mo_snapshot's schema.

changes for mo_columns.

changes for mo_databases.

changes for mo_tables.

changes for user tables.

func (l BlockLocations) append iterator Location is a fixed-length unmodifiable byte array.

func (l BlockLocations) append iterator Location is a fixed-length unmodifiable byte array.

latest version.

previous version.

BoundTableOperator holds a read only reader, knows how to iterate catalog entries.

CatalogLogtailRespBuilder knows how to make api-entry from db and table entry.

Logtail manager holds sorted txn handles.

Reader is a snapshot of all txn prepared between from and to.

CatalogLogtailRespBuilder knows how to make api-entry from block entry.

Logtailer provides logtail for the specified table.