catalog

package

Go to main page

Versions in this module

v1

v1.2.4

Sep 20, 2024

v1.2.3

Sep 10, 2024

v1.2.3-hotfix-20241101

Oct 31, 2024

v1.2.3-hotfix-20241016

Oct 16, 2024

v1.2.3-hotfix-20241010

Oct 11, 2024

v1.2.3-hotfix-20240916

Sep 14, 2024

v1.2.2

Jul 11, 2024

Changes in this version

type BaseEntryImpl

+ func (be *BaseEntryImpl[T]) HasDropIntentLocked() bool

v1.2.2-20240715

Jul 15, 2024

v1.2.1

Jun 28, 2024

Changes in this version

type ObjectEntry

+ HasPrintedPrepareComapct bool

+ func (entry *ObjectEntry) CheckPrintPrepareCompact() bool

+ func (entry *ObjectEntry) CheckPrintPrepareCompactLocked() bool

+ func (entry *ObjectEntry) InMemoryDeletesExistedLocked() bool

+ func (entry *ObjectEntry) IsDeletesFlushedBefore(ts types.TS) bool

+ func (entry *ObjectEntry) PrintPrepareCompactDebugLog()

type TableDataFactory

+ var DefaultTableDataFactory TableDataFactory

v1.2.1-20240709

Jul 9, 2024

v1.2.0

May 17, 2024

Changes in this version

type BaseEntry

+ DeleteBeforeLocked func(ts types.TS) bool

type BaseEntryImpl

+ func (be *BaseEntryImpl[T]) DeleteBeforeLocked(ts types.TS) bool

+ func (be *BaseEntryImpl[T]) GetDeleteAtLocked() types.TS

+ func (be *BaseEntryImpl[T]) IsVisibleWithLock(txn txnif.TxnReader, mu *sync.RWMutex) (ok bool, err error)

+ func (be *BaseEntryImpl[T]) NeedWaitCommittingLocked(startTS types.TS) (bool, txnif.TxnReader)

+ func (be *BaseEntryImpl[T]) TryGetTerminatedTSLocked(waitIfcommitting bool) (terminated bool, TS types.TS)

type Catalog

+ func (catalog *Catalog) DropDBEntryByName(name string, txn txnif.AsyncTxn) (isNewMVCCNode bool, deleted *DBEntry, err error)

+ func (catalog *Catalog) RemoveDBEntry(database *DBEntry) error

type DBEntry

+ func (e *DBEntry) GetObjectEntryByID(id *common.ID) (obj *ObjectEntry, err error)

type DataFactory

+ MakeObjectFactory func() ObjectDataFactory

+ MakeTombstoneFactory func() TombstoneFactory

+ type DeleteEntry struct

+ ObjectID objectio.ObjectId

+ func (d DeleteEntry) Less(o DeleteEntry) bool

type EntryCommand

+ func NewDeltalocCmd(id uint32, cmdType uint16, commonID *common.ID, ...) *EntryCommand[*MetadataMVCCNode, *BlockNode]

type LoopProcessor

+ TombstoneFn func(data.Tombstone) error

+ func (p *LoopProcessor) OnTombstone(tombstone data.Tombstone) error

type MetadataMVCCNode

+ NeedCheckDeleteChainWhenCommit bool

+ type ObjectDataFactory = func(meta *ObjectEntry) data.Object

type ObjectEntry

+ func (entry *ObjectEntry) GetLocation() objectio.Location

+ func (entry *ObjectEntry) GetObjectData() data.Object

+ func (entry *ObjectEntry) GetPKZoneMap(ctx context.Context, fs fileservice.FileService) (zm index.ZM, err error)

+ func (entry *ObjectEntry) GetSchema() *Schema

+ func (entry *ObjectEntry) GetSchemaLocked() *Schema

+ func (entry *ObjectEntry) HasCommittedPersistedData() bool

+ func (entry *ObjectEntry) HasPersistedData() bool

+ func (entry *ObjectEntry) InMemoryDeletesExisted() bool

+ func (entry *ObjectEntry) InitData(factory DataFactory)

+ func (entry *ObjectEntry) MustGetObjectStats() (objectio.ObjectStats, error)

+ func (entry *ObjectEntry) ObjectPersisted() bool

+ func (entry *ObjectEntry) PrepareCompact() bool

+ func (entry *ObjectEntry) PrepareCompactLocked() bool

type Processor

+ OnTombstone func(tombstone data.Tombstone) error

type Schema

+ func MockSnapShotSchema() *Schema

+ func (s *Schema) IsSecondaryIndexTable() bool

type TableEntry

+ func (entry *TableEntry) GCTombstone(id objectio.ObjectId)

+ func (entry *TableEntry) GetDeleteList() *btree.BTreeG[DeleteEntry]

+ func (entry *TableEntry) GetLastestSchemaLocked() *Schema

+ func (entry *TableEntry) GetOrCreateTombstone(obj *ObjectEntry, factory TombstoneFactory) data.Tombstone

+ func (entry *TableEntry) TryGetTombstone(oid objectio.ObjectId) data.Tombstone

+ type TombstoneFactory = func(meta *ObjectEntry) data.Tombstone

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

v1.1.1

Feb 2, 2024

Changes in this version

+ const AttrPKVal

type BaseNode

+ IdempotentUpdate func(vun T)

type DBNode

+ func (node *DBNode) TestSetAccId(id uint32)

type EmptyMVCCNode

+ func (e *EmptyMVCCNode) IdempotentUpdate(vun *EmptyMVCCNode)

type MVCCNode

+ func (e *MVCCNode[T]) IdempotentUpdate(un *MVCCNode[T])

type MetadataMVCCNode

+ func (e *MetadataMVCCNode) IdempotentUpdate(un *MetadataMVCCNode)

+ type ObjStat struct

+ func (s *ObjStat) GetCompSize() int

+ func (s *ObjStat) GetLoaded() bool

+ func (s *ObjStat) GetOriginSize() int

+ func (s *ObjStat) GetRemainingRows() int

+ func (s *ObjStat) GetRows() int

+ func (s *ObjStat) GetSortKeyZonemap() index.ZM

+ func (s *ObjStat) SetRemainingRows(rows int)

+ func (s *ObjStat) SetRows(rows int)

+ func (s *ObjStat) String(composeSortKey bool) string

type ObjectEntry

+ Stat ObjStat

+ func (entry *ObjectEntry) SetObjectStatsForPreviousNode(nodes []*MVCCNode[*ObjectMVCCNode])

type ObjectMVCCNode

+ func (e *ObjectMVCCNode) IdempotentUpdate(vun *ObjectMVCCNode)

type TableMVCCNode

+ func (e *TableMVCCNode) IdempotentUpdate(un *TableMVCCNode)

v1.1.0

Dec 29, 2023

Changes in this version

+ const EntryNode_CreateAt

+ const EntryNode_DeleteAt

+ const IOET_WALTxnCommand_Object

+ const IOET_WALTxnCommand_Object_CurrVer

+ const IOET_WALTxnCommand_Object_V1

+ const ObjectAttr_CreateAt

+ const ObjectAttr_ID

+ const ObjectAttr_ObjectStats

+ const ObjectAttr_SegNode

+ const ObjectAttr_Sorted

+ const ObjectAttr_State

+ const SnapshotAttr_ObjectMaxBlock

+ var SystemObject_Columns_ID types.Uuid

+ var SystemObject_DB_ID types.Uuid

+ var SystemObject_Table_ID types.Uuid

+ func ActiveObjectWithNoTxnFilter(be *BaseEntryImpl[*ObjectMVCCNode]) bool

type BaseEntryImpl

+ func (be *BaseEntryImpl[T]) CreateWithStartAndEnd(start, end types.TS, baseNode T)

type BlockEntry

+ func (entry *BlockEntry) GetObject() *ObjectEntry

type Catalog

+ func (catalog *Catalog) GetUsageMemo() any

+ func (catalog *Catalog) OnReplayObjectBatch(objectInfo *containers.Batch)

+ func (catalog *Catalog) SetUsageMemo(memo any)

type DBEntry

+ func MockDBEntryWithAccInfo(accId uint64, dbId uint64) *DBEntry

type EntryMVCCNode

+ func ReadEntryNodeTuple(bat *containers.Batch, row int) (un *EntryMVCCNode)

+ func (un *EntryMVCCNode) AppendTuple(bat *containers.Batch)

+ func (un *EntryMVCCNode) AppendTupleWithCommitTS(bat *containers.Batch, ts types.TS)

type IDAlloctor

+ func (alloc *IDAlloctor) CurrObject() uint64

+ func (alloc *IDAlloctor) NextObject() uint64

+ func (alloc *IDAlloctor) OnReplayObjectID(id uint64)

type LoopProcessor

+ ObjectFn func(*ObjectEntry) error

+ PostObjectFn func(*ObjectEntry) error

+ func (p *LoopProcessor) OnObject(Object *ObjectEntry) error

+ func (p *LoopProcessor) OnPostObject(Object *ObjectEntry) error

+ type ObjectEntry struct

+ ID types.Objectid

+ func MockObjEntryWithTbl(tbl *TableEntry, size uint64) *ObjectEntry

+ func NewObjectEntry(table *TableEntry, id *objectio.ObjectId, txn txnif.AsyncTxn, state EntryState) *ObjectEntry

+ func NewObjectEntryByMetaLocation(table *TableEntry, id *objectio.ObjectId, start, end types.TS, ...) *ObjectEntry

+ func NewReplayObjectEntry() *ObjectEntry

+ func NewStandaloneObject(table *TableEntry, ts types.TS) *ObjectEntry

+ func NewSysObjectEntry(table *TableEntry, id types.Uuid) *ObjectEntry

+ func (entry *ObjectEntry) AddEntryLocked(block *BlockEntry)

+ func (entry *ObjectEntry) AsCommonID() *common.ID

+ func (entry *ObjectEntry) BlockCnt() int

+ func (entry *ObjectEntry) CheckAndLoad() error

+ func (entry *ObjectEntry) CollectBlockEntries(commitFilter func(be *BaseEntryImpl[*MetadataMVCCNode]) bool, ...) []*BlockEntry

+ func (entry *ObjectEntry) CreateBlock(txn txnif.AsyncTxn, state EntryState, dataFactory BlockDataFactory, ...) (created *BlockEntry, err error)

+ func (entry *ObjectEntry) DropBlockEntry(id *objectio.Blockid, txn txnif.AsyncTxn) (deleted *BlockEntry, err error)

+ func (entry *ObjectEntry) GetAppendableBlock() (blk *BlockEntry)

+ func (entry *ObjectEntry) GetAppendableBlockCnt() int

+ func (entry *ObjectEntry) GetBlockEntryByID(id *objectio.Blockid) (blk *BlockEntry, err error)

+ func (entry *ObjectEntry) GetBlockEntryByIDLocked(id *objectio.Blockid) (blk *BlockEntry, err error)

+ func (entry *ObjectEntry) GetCatalog() *Catalog

+ func (entry *ObjectEntry) GetCompSize() int

+ func (entry *ObjectEntry) GetFirstBlkEntry() *BlockEntry

+ func (entry *ObjectEntry) GetInMemoryObjectInfo() *ObjectMVCCNode

+ func (entry *ObjectEntry) GetLoaded() bool

+ func (entry *ObjectEntry) GetNextObjectIndex() uint16

+ func (entry *ObjectEntry) GetNonAppendableBlockCnt() int

+ func (entry *ObjectEntry) GetObjectStats() (stats objectio.ObjectStats)

+ func (entry *ObjectEntry) GetOriginSize() int

+ func (entry *ObjectEntry) GetRemainingRows() int

+ func (entry *ObjectEntry) GetRows() int

+ func (entry *ObjectEntry) GetSortKeyZonemap() index.ZM

+ func (entry *ObjectEntry) GetTable() *TableEntry

+ func (entry *ObjectEntry) GetTerminationTS() (ts types.TS, terminated bool)

+ func (entry *ObjectEntry) Is1PC() bool

+ func (entry *ObjectEntry) IsActive() bool

+ func (entry *ObjectEntry) IsAppendable() bool

+ func (entry *ObjectEntry) IsSorted() bool

+ func (entry *ObjectEntry) LastAppendableBlock() (blk *BlockEntry)

+ func (entry *ObjectEntry) Less(b *ObjectEntry) int

+ func (entry *ObjectEntry) LoadObjectInfoForLastNode() (stats objectio.ObjectStats, err error)

+ func (entry *ObjectEntry) LoadObjectInfoWithTxnTS(startTS types.TS) (objectio.ObjectStats, error)

+ func (entry *ObjectEntry) MakeBlockIt(reverse bool) *common.GenericSortedDListIt[*BlockEntry]

+ func (entry *ObjectEntry) MakeCommand(id uint32) (cmd txnif.TxnCmd, err error)

+ func (entry *ObjectEntry) NeedPrefetchObjectMetaForObjectInfo(nodes []*MVCCNode[*ObjectMVCCNode]) (needPrefetch bool, blk *BlockEntry)

+ func (entry *ObjectEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (entry *ObjectEntry) PrepareRollback() (err error)

+ func (entry *ObjectEntry) RemoveEntry(block *BlockEntry) (err error)

+ func (entry *ObjectEntry) ReplayAddEntryLocked(block *BlockEntry)

+ func (entry *ObjectEntry) Repr() string

+ func (entry *ObjectEntry) Set1PC()

+ func (entry *ObjectEntry) SetRemainingRows(rows int)

+ func (entry *ObjectEntry) SetSorted()

+ func (entry *ObjectEntry) StatsString(composeSortKey bool) string

+ func (entry *ObjectEntry) String() string

+ func (entry *ObjectEntry) StringLocked() string

+ func (entry *ObjectEntry) StringWithLevel(level common.PPLevel) string

+ func (entry *ObjectEntry) StringWithLevelLocked(level common.PPLevel) string

+ func (entry *ObjectEntry) TreeMaxDropCommitEntry() BaseEntry

+ func (entry *ObjectEntry) UpdateObjectInfo(txn txnif.TxnReader, stats *objectio.ObjectStats) (isNewNode bool, err error)

+ type ObjectMVCCNode struct

+ func NewEmptyObjectMVCCNode() *ObjectMVCCNode

+ func NewObjectInfoWithMetaLocation(metaLoc objectio.Location, id *objectio.ObjectId) *ObjectMVCCNode

+ func NewObjectInfoWithObjectID(id *objectio.ObjectId) *ObjectMVCCNode

+ func NewObjectInfoWithObjectStats(stats *objectio.ObjectStats) *ObjectMVCCNode

+ func ReadObjectInfoTuple(bat *containers.Batch, row int) (e *ObjectMVCCNode)

+ func (e *ObjectMVCCNode) AppendTuple(sid *types.Objectid, batch *containers.Batch)

+ func (e *ObjectMVCCNode) CloneAll() *ObjectMVCCNode

+ func (e *ObjectMVCCNode) CloneData() *ObjectMVCCNode

+ func (e *ObjectMVCCNode) IsEmpty() bool

+ func (e *ObjectMVCCNode) ReadFromWithVersion(r io.Reader, ver uint16) (n int64, err error)

+ func (e *ObjectMVCCNode) String() string

+ func (e *ObjectMVCCNode) Update(vun *ObjectMVCCNode)

+ func (e *ObjectMVCCNode) WriteTo(w io.Writer) (n int64, err error)

+ type ObjectNode struct

+ IsLocal bool

+ SortHint uint64

+ func (node *ObjectNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (node *ObjectNode) String() string

+ func (node *ObjectNode) WriteTo(w io.Writer) (n int64, err error)

type Processor

+ OnObject func(Object *ObjectEntry) error

+ OnPostObject func(Object *ObjectEntry) error

type Schema

+ ObjectMaxBlocks uint16

type TableEntry

+ func MockTableEntryWithDB(dbEntry *DBEntry, tblId uint64) *TableEntry

+ func (entry *TableEntry) CreateObject(txn txnif.AsyncTxn, state EntryState, opts *objectio.CreateObjOpt) (created *ObjectEntry, err error)

+ func (entry *TableEntry) DropObjectEntry(id *types.Objectid, txn txnif.AsyncTxn) (deleted *ObjectEntry, err error)

+ func (entry *TableEntry) GetObjectByID(id *types.Objectid) (obj *ObjectEntry, err error)

+ func (entry *TableEntry) GetObjectsByID(id *types.Segmentid) (obj []*ObjectEntry, err error)

+ func (entry *TableEntry) LastAppendableObject() (obj *ObjectEntry)

+ func (entry *TableEntry) MakeObjectIt(reverse bool) *common.GenericSortedDListIt[*ObjectEntry]

v1.0.2

Dec 21, 2023

Changes in this version

type TableEntry

+ func (entry *TableEntry) ObjectStats(level common.PPLevel) (stat TableStat, w bytes.Buffer)

+ type TableStat struct

+ Csize int

+ Loaded int

+ OSize int

+ ObjectCnt int

+ Rows int

v1.0.1

Dec 15, 2023

Changes in this version

type SegStat

+ func (s *SegStat) GetCompSize() int

+ func (s *SegStat) GetLoaded() bool

+ func (s *SegStat) GetOriginSize() int

+ func (s *SegStat) GetRemainingRows() int

+ func (s *SegStat) GetRows() int

+ func (s *SegStat) GetSortKeyZonemap() index.ZM

+ func (s *SegStat) SetOriginSize(size int)

+ func (s *SegStat) SetRemainingRows(rows int)

+ func (s *SegStat) SetRows(rows int)

type SegmentEntry

+ func (entry *SegmentEntry) GetFirstBlkEntry() *BlockEntry

v1.0.0

Nov 13, 2023

Changes in this version

+ const AccountIDDbName

+ const AccountIDDbNameTblName

+ const IOET_WALTxnCommand_Table_V2

+ const IOET_WALTxnCommand_Table_V3

type BaseEntryImpl

+ func (be *BaseEntryImpl[T]) GetCreatedAtLocked() types.TS

type BaseNode

+ ReadFromWithVersion func(r io.Reader, ver uint16) (n int64, err error)

type BlockEntry

+ func (entry *BlockEntry) GetDeltaLocAndCommitTS() (objectio.Location, types.TS)

type ColDef

+ EnumValues string

type EmptyMVCCNode

+ func (e *EmptyMVCCNode) ReadFromWithVersion(r io.Reader, ver uint16) (n int64, err error)

type LoopProcessor

+ PostDatabaseFn func(*DBEntry) error

+ PostTableFn func(*TableEntry) error

+ func (p *LoopProcessor) OnPostDatabase(database *DBEntry) error

+ func (p *LoopProcessor) OnPostTable(table *TableEntry) error

type MVCCNode

+ func (e *MVCCNode[T]) ReadFromWithVersion(r io.Reader, ver uint16) (n int64, err error)

type MetadataMVCCNode

+ func (e *MetadataMVCCNode) ReadFromWithVersion(r io.Reader, ver uint16) (n int64, err error)

type Processor

+ OnPostDatabase func(database *DBEntry) error

+ OnPostTable func(table *TableEntry) error

type Schema

+ CatalogVersion uint32

+ var SystemColumnSchema_V1 *Schema

+ var SystemTableSchema_V1 *Schema

+ func (s *Schema) EstimateRowSize() (size int)

+ func (s *Schema) ReadFromWithVersion(r io.Reader, ver uint16) (n int64, err error)

+ type SegStat struct

+ Loaded bool

+ OriginSize int

+ RemainingRows int

+ Rows int

+ SortKeyZonemap index.ZM

+ func (s *SegStat) String(composeSortKey bool) string

type SegmentEntry

+ Stat SegStat

+ func (entry *SegmentEntry) IsSortedLocked() bool

+ func (entry *SegmentEntry) LoadObjectInfo() error

type TableEntry

+ DeletedDirties []*BlockEntry

+ Stats common.TableCompactStat

+ func (entry *TableEntry) ObjectStatsString(level common.PPLevel) string

type TableMVCCNode

+ func (e *TableMVCCNode) ReadFromWithVersion(r io.Reader, ver uint16) (n int64, err error)

v1.0.0-rc2

Oct 24, 2023

v1.0.0-rc1

Aug 24, 2023

v0

v0.8.1

Oct 9, 2023

v0.8.0

Jun 30, 2023

Changes in this version

+ const AccessInfoSize

+ const BlockNodeSize

+ const EntryMVCCNodeSize

+ const IOET_WALTxnCommand_Block

+ const IOET_WALTxnCommand_Block_CurrVer

+ const IOET_WALTxnCommand_Block_V1

+ const IOET_WALTxnCommand_Database

+ const IOET_WALTxnCommand_Database_CurrVer

+ const IOET_WALTxnCommand_Database_V1

+ const IOET_WALTxnCommand_Segment

+ const IOET_WALTxnCommand_Segment_CurrVer

+ const IOET_WALTxnCommand_Segment_V1

+ const IOET_WALTxnCommand_Table

+ const IOET_WALTxnCommand_Table_CurrVer

+ const IOET_WALTxnCommand_Table_V1

+ const SegmentAttr_SegNode

+ const SnapshotAttr_SchemaExtra

+ func CompareBaseNode(e, o *MVCCNode[T]) int

+ func EncodeAccessInfo(ai *accessInfo) []byte

+ func EncodeBlockNode(node *BlockNode) []byte

+ func EncodeEntryMVCCNode(node *EntryMVCCNode) []byte

+ func IsFakePkName(name string) bool

+ func NewEmptyMVCCNodeFactory(factory func() T) func() *MVCCNode[T]

+ type BaseEntryImpl struct

+ func NewBaseEntry(factory func() T) *BaseEntryImpl[T]

+ func (be *BaseEntryImpl[T]) CloneCommittedInRange(start, end types.TS) BaseEntry

+ func (be *BaseEntryImpl[T]) ConflictCheck(txn txnif.TxnReader) (err error)

+ func (be *BaseEntryImpl[T]) CreateWithTS(ts types.TS, baseNode T)

+ func (be *BaseEntryImpl[T]) CreateWithTxn(txn txnif.AsyncTxn, baseNode T)

+ func (be *BaseEntryImpl[T]) DeleteAfter(ts types.TS) bool

+ func (be *BaseEntryImpl[T]) DeleteBefore(ts types.TS) bool

+ func (be *BaseEntryImpl[T]) DeleteLocked(txn txnif.TxnReader) (isNewNode bool, err error)

+ func (be *BaseEntryImpl[T]) DropEntryLocked(txn txnif.TxnReader) (isNewNode bool, err error)

+ func (be *BaseEntryImpl[T]) GetCreatedAt() types.TS

+ func (be *BaseEntryImpl[T]) GetDeleteAt() types.TS

+ func (be *BaseEntryImpl[T]) GetVisibility(txn txnif.TxnReader) (visible, dropped bool)

+ func (be *BaseEntryImpl[T]) GetVisibilityLocked(txn txnif.TxnReader) (visible, dropped bool)

+ func (be *BaseEntryImpl[T]) HasDropCommitted() bool

+ func (be *BaseEntryImpl[T]) HasDropCommittedLocked() bool

+ func (be *BaseEntryImpl[T]) IsVisible(txn txnif.TxnReader, mu *sync.RWMutex) (ok bool, err error)

+ func (be *BaseEntryImpl[T]) NeedWaitCommitting(startTS types.TS) (bool, txnif.TxnReader)

+ func (be *BaseEntryImpl[T]) PPString(level common.PPLevel, depth int, prefix string) string

+ func (be *BaseEntryImpl[T]) PrepareAdd(txn txnif.TxnReader) (err error)

+ func (be *BaseEntryImpl[T]) String() string

+ func (be *BaseEntryImpl[T]) StringLocked() string

+ func (be *BaseEntryImpl[T]) TryGetTerminatedTS(waitIfcommitting bool) (terminated bool, TS types.TS)

+ type BaseNode interface

+ CloneAll func() T

+ CloneData func() T

+ ReadFrom func(r io.Reader) (n int64, err error)

+ String func() string

+ Update func(vun T)

+ WriteTo func(w io.Writer) (n int64, err error)

type BlockEntry

+ ID types.Blockid

+ func (entry *BlockEntry) BuildDeleteObjectName() objectio.ObjectName

+ func (entry *BlockEntry) CreateWithLoc(ts types.TS, metaLoc objectio.Location, deltaLoc objectio.Location)

+ func (entry *BlockEntry) CreateWithTxnAndMeta(txn txnif.AsyncTxn, metaLoc objectio.Location, deltaLoc objectio.Location)

+ func (entry *BlockEntry) FastGetMetaLoc() objectio.Location

+ func (entry *BlockEntry) GetDeltaLoc() objectio.Location

+ func (entry *BlockEntry) GetDeltaPersistedTS() types.TS

+ func (entry *BlockEntry) GetDeltaPersistedTSByTxn(txn txnif.TxnReader) types.TS

+ func (entry *BlockEntry) GetMetaLoc() objectio.Location

+ func (entry *BlockEntry) GetPKZoneMap(ctx context.Context, fs fileservice.FileService) (zm *index.ZM, err error)

+ func (entry *BlockEntry) GetVisibleDeltaLoc(txn txnif.TxnReader) objectio.Location

+ func (entry *BlockEntry) GetVisibleMetaLoc(txn txnif.TxnReader) objectio.Location

+ func (entry *BlockEntry) HasPersistedData() bool

+ func (entry *BlockEntry) HasPersistedDeltaData() bool

+ func (entry *BlockEntry) Less(b *BlockEntry) int

+ func (entry *BlockEntry) UpdateDeltaLoc(txn txnif.TxnReader, deltaloc objectio.Location) (isNewNode bool, err error)

+ func (entry *BlockEntry) UpdateMetaLoc(txn txnif.TxnReader, metaLoc objectio.Location) (isNewNode bool, err error)

+ type BlockNode struct

+ func (node *BlockNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (node *BlockNode) WriteTo(w io.Writer) (n int64, err error)

type ColDef

+ FakePK bool

+ SeqNum uint16

+ func (def *ColDef) IsRealPrimary() bool

type DBEntry

+ ID uint64

+ func (e *DBEntry) AsCommonID() *common.ID

+ func (e *DBEntry) GetDatType() string

+ func (e *DBEntry) GetID() uint64

+ func (e *DBEntry) IsSubscription() bool

+ func (e *DBEntry) Less(b *DBEntry) int

+ func (e *DBEntry) PrettyNameIndex() string

+ func (e *DBEntry) RenameTableInTxn(old, new string, tid uint64, tenantID uint32, txn txnif.TxnReader, first bool) error

+ func (e *DBEntry) RollbackRenameTable(fullname string, tid uint64)

+ type DBNode struct

+ func (node *DBNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (node *DBNode) WriteTo(w io.Writer) (n int64, err error)

+ type EmptyMVCCNode struct

+ func NewEmptyEmptyMVCCNode() *EmptyMVCCNode

+ func (e *EmptyMVCCNode) CloneAll() *EmptyMVCCNode

+ func (e *EmptyMVCCNode) CloneData() *EmptyMVCCNode

+ func (e *EmptyMVCCNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (e *EmptyMVCCNode) String() string

+ func (e *EmptyMVCCNode) Update(vun *EmptyMVCCNode)

+ func (e *EmptyMVCCNode) WriteTo(w io.Writer) (n int64, err error)

type EntryCommand

+ ID *common.ID

+ func (cmd *EntryCommand[T, N]) GetCurrVersion() uint16

+ func (cmd *EntryCommand[T, N]) MarshalBinary() (buf []byte, err error)

+ func (cmd *EntryCommand[T, N]) UnmarshalBinary(buf []byte) (err error)

type EntryMVCCNode

+ func DecodeEntryMVCCNode(v []byte) *EntryMVCCNode

+ type MVCCNode struct

+ BaseNode T

+ func (e *MVCCNode[T]) ApplyCommit() (err error)

+ func (e *MVCCNode[T]) ApplyRollback() (err error)

+ func (e *MVCCNode[T]) CloneAll() *MVCCNode[T]

+ func (e *MVCCNode[T]) CloneData() *MVCCNode[T]

+ func (e *MVCCNode[T]) IsNil() bool

+ func (e *MVCCNode[T]) PrepareCommit() (err error)

+ func (e *MVCCNode[T]) PrepareRollback() (err error)

+ func (e *MVCCNode[T]) ReadFrom(r io.Reader) (n int64, err error)

+ func (e *MVCCNode[T]) String() string

+ func (e *MVCCNode[T]) Update(un *MVCCNode[T])

+ func (e *MVCCNode[T]) WriteTo(w io.Writer) (n int64, err error)

+ type Node interface

+ ReadFrom func(r io.Reader) (n int64, err error)

+ WriteTo func(w io.Writer) (n int64, err error)

type Schema

+ Extra *apipb.SchemaExtra

+ NameMap map[string]int

+ Partitioned int8

+ SeqnumMap map[uint16]int

+ Version uint32

+ func (s *Schema) AllSeqnums() []uint16

+ func (s *Schema) AppendFakePKCol() error

+ func (s *Schema) ApplyAlterTable(req *apipb.AlterTableReq) error

+ func (s *Schema) GetPrimaryKey() *ColDef

+ func (s *Schema) GetSeqnum(attr string) uint16

+ func (s *Schema) IsSameColumns(other *Schema) bool

+ func (s *Schema) MustGetExtraBytes() []byte

+ func (s *Schema) MustRestoreExtra(data []byte)

type SegmentEntry

+ ID objectio.Segmentid

+ func (entry *SegmentEntry) GetNextObjectIndex() uint16

+ func (entry *SegmentEntry) Less(b *SegmentEntry) int

+ func (entry *SegmentEntry) ReplayAddEntryLocked(block *BlockEntry)

+ type SegmentNode struct

+ IsLocal bool

+ SortHint uint64

+ func (node *SegmentNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (node *SegmentNode) String() string

+ func (node *SegmentNode) WriteTo(w io.Writer) (n int64, err error)

type TableEntry

+ ID uint64

+ func (entry *TableEntry) AlterTable(ctx context.Context, txn txnif.TxnReader, req *apipb.AlterTableReq) (isNewNode bool, newSchema *Schema, err error)

+ func (entry *TableEntry) ApplyCommit() (err error)

+ func (entry *TableEntry) CreateWithTxnAndSchema(txn txnif.AsyncTxn, schema *Schema)

+ func (entry *TableEntry) FreezeAppend()

+ func (entry *TableEntry) GetID() uint64

+ func (entry *TableEntry) GetLastestSchema() *Schema

+ func (entry *TableEntry) GetVersionSchema(ver uint32) *Schema

+ func (entry *TableEntry) GetVisibilityAndName(txn txnif.TxnReader) (visible, dropped bool, name string)

+ func (entry *TableEntry) GetVisibleSchema(txn txnif.TxnReader) *Schema

+ func (entry *TableEntry) Less(b *TableEntry) int

type TableMVCCNode

+ Schema *Schema

+ type TableNode struct

+ func (node *TableNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (node *TableNode) WriteTo(w io.Writer) (n int64, err error)

v0.7.0

Feb 18, 2023

Changes in this version

+ const SegmentAttr_Sorted

type BlockEntry

+ func NewBlockEntryWithMeta(segment *SegmentEntry, txn txnif.AsyncTxn, state EntryState, ...) *BlockEntry

+ func NewStandaloneBlockWithLoc(segment *SegmentEntry, id uint64, ts types.TS, metaLoc string, delLoc string) *BlockEntry

type Catalog

+ func (catalog *Catalog) GCByTS(ctx context.Context, ts types.TS)

type ColDef

+ ClusterBy bool

+ func ColDefFromAttribute(attr engine.Attribute) (*ColDef, error)

+ func (def *ColDef) IsClusterBy() bool

type DBEntry

+ func (e *DBEntry) Close()

type MetaBaseEntry

+ func (be *MetaBaseEntry) CreateWithLoc(ts types.TS, metaLoc string, deltaLoc string)

+ func (be *MetaBaseEntry) CreateWithTxnAndMeta(txn txnif.AsyncTxn, metaLoc string, deltaLoc string)

type Schema

+ Constraint []byte

+ SecondaryIndex string

+ UniqueIndex string

+ func (s *Schema) AppendSortColWithAttribute(attr engine.Attribute, sorIdx int, isPrimary bool) error

+ func (s *Schema) GetSingleSortKeyType() types.Type

type SegmentEntry

+ func (entry *SegmentEntry) Close()

+ func (entry *SegmentEntry) CreateBlockWithMeta(txn txnif.AsyncTxn, state EntryState, dataFactory BlockDataFactory, ...) (created *BlockEntry, err error)

+ func (entry *SegmentEntry) GetNonAppendableBlockCnt() int

+ func (entry *SegmentEntry) IsSorted() bool

+ func (entry *SegmentEntry) SetSorted()

type TableBaseEntry

+ func (be *TableBaseEntry) UpdateConstraint(txn txnif.TxnReader, cstr []byte) (isNewNode bool, err error)

type TableEntry

+ func (entry *TableEntry) Close()

+ func (entry *TableEntry) LastNonAppendableSegmemt() (seg *SegmentEntry)

type TableMVCCNode

+ SchemaConstraints string

v0.6.0

Nov 29, 2022

Changes in this version

+ const AttrAborted

+ const AttrCommitTs

+ const AttrRowID

+ const CmdUpdateBlock

+ const CmdUpdateDatabase

+ const CmdUpdateSegment

+ const CmdUpdateTable

+ const PhyAddrColumnComment

+ const PhyAddrColumnName

+ const SegmentAttr_CreateAt

+ const SegmentAttr_ID

+ const SegmentAttr_State

+ const SnapshotAttr_BlockMaxRow

+ const SnapshotAttr_DBID

+ const SnapshotAttr_SegID

+ const SnapshotAttr_SegmentMaxBlock

+ const SnapshotAttr_TID

+ const TenantSysID

+ var PhyAddrColumnType types.Type

+ func CompareDBBaseNode(e, o txnif.MVCCNode) int

+ func CompareMetaBaseNode(e, o txnif.MVCCNode) int

+ func CompareTableBaseNode(e, o txnif.MVCCNode) int

+ func MarshalOnUpdate(w *bytes.Buffer, data OnUpdate) (err error)

+ func NewEmptyDBMVCCNode() txnif.MVCCNode

+ func NewEmptyMetadataMVCCNode() txnif.MVCCNode

+ func NewEmptyTableMVCCNode() txnif.MVCCNode

+ func UnMarshalOnUpdate(r io.Reader, data *OnUpdate) (n int64, err error)

type BaseEntry

+ CloneCommittedInRange func(start, end types.TS) (ret BaseEntry)

+ GetIndexes func() []*wal.Index

+ GetLatestNodeLocked func() txnif.MVCCNode

+ HasCommittedNodeInRange func(minTs, MaxTs types.TS) bool

+ HasDropCommitted func() bool

+ HasDropCommittedLocked func() bool

+ IsCreatingOrAborted func() bool

+ IsVisible func(ts types.TS, mu *sync.RWMutex) (ok bool, err error)

+ PPString func(common.PPLevel, int, string) string

+ RLock func()

+ RUnlock func()

+ ReadOneNodeFrom func(r io.Reader) (n int64, err error)

+ StringLocked func() string

+ WriteOneNodeTo func(w io.Writer) (n int64, err error)

type BlockEntry

+ func (entry *BlockEntry) Is1PC() bool

+ func (entry *BlockEntry) PrepareCompact() bool

+ func (entry *BlockEntry) Set1PC()

+ func (entry *BlockEntry) StringWithLevel(level common.PPLevel) string

+ func (entry *BlockEntry) StringWithLevelLocked(level common.PPLevel) string

type Catalog

+ func NewEmptyCatalog() *Catalog

+ func (catalog *Catalog) CreateDBEntryByTS(name string, ts types.TS) (*DBEntry, error)

+ func (catalog *Catalog) CreateDBEntryWithID(name, createSql string, id uint64, txn txnif.AsyncTxn) (*DBEntry, error)

+ func (catalog *Catalog) DropDBEntryByID(id uint64, txn txnif.AsyncTxn) (newEntry bool, deleted *DBEntry, err error)

+ func (catalog *Catalog) GetDBEntryByName(tenantID uint32, name string, ts types.TS) (db *DBEntry, err error)

+ func (catalog *Catalog) GetItemNodeByIDLocked(id uint64) *common.GenericDLNode[*DBEntry]

+ func (catalog *Catalog) OnReplayBlockBatch(ins, insTxn, del, delTxn *containers.Batch, dataFactory DataFactory)

+ func (catalog *Catalog) OnReplayDatabaseBatch(ins, insTxn, del, delTxn *containers.Batch)

+ func (catalog *Catalog) OnReplaySegmentBatch(ins, insTxn, del, delTxn *containers.Batch, dataFactory DataFactory)

+ func (catalog *Catalog) OnReplayTableBatch(ins, insTxn, insCol, del, delTxn *containers.Batch, dataFactory DataFactory)

+ func (catalog *Catalog) TxnGetDBEntryByID(id uint64, txn txnif.AsyncTxn) (*DBEntry, error)

+ func (catalog *Catalog) TxnGetDBEntryByName(name string, txn txnif.AsyncTxn) (*DBEntry, error)

type ColDef

+ OnUpdate OnUpdate

+ PhyAddr bool

+ func (def *ColDef) IsAutoIncrement() bool

+ func (def *ColDef) IsPhyAddr() bool

+ type ComputeIndexInfo struct

+ Field []string

+ Name string

+ TableName string

+ Unique bool

+ type DBBaseEntry struct

+ ID uint64

+ func NewDBBaseEntry(id uint64) *DBBaseEntry

+ func NewReplayDBBaseEntry() *DBBaseEntry

+ func (be *DBBaseEntry) CloneCommittedInRange(start, end types.TS) BaseEntry

+ func (be *DBBaseEntry) CreateWithTS(ts types.TS)

+ func (be *DBBaseEntry) CreateWithTxn(txn txnif.AsyncTxn)

+ func (be *DBBaseEntry) DeleteAfter(ts types.TS) bool

+ func (be *DBBaseEntry) DeleteBefore(ts types.TS) bool

+ func (be *DBBaseEntry) DeleteLocked(txn txnif.TxnReader) (isNewNode bool, err error)

+ func (be *DBBaseEntry) DoCompre(voe BaseEntry) int

+ func (be *DBBaseEntry) DropEntryLocked(txn txnif.TxnReader) (isNewNode bool, err error)

+ func (be *DBBaseEntry) GetCreatedAt() types.TS

+ func (be *DBBaseEntry) GetDeleteAt() types.TS

+ func (be *DBBaseEntry) GetID() uint64

+ func (be *DBBaseEntry) GetVisibility(ts types.TS) (visible, dropped bool)

+ func (be *DBBaseEntry) GetVisibilityLocked(ts types.TS) (visible, dropped bool)

+ func (be *DBBaseEntry) HasDropCommitted() bool

+ func (be *DBBaseEntry) HasDropCommittedLocked() bool

+ func (be *DBBaseEntry) IsVisible(ts types.TS, mu *sync.RWMutex) (ok bool, err error)

+ func (be *DBBaseEntry) NeedWaitCommitting(startTS types.TS) (bool, txnif.TxnReader)

+ func (be *DBBaseEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (be *DBBaseEntry) PrepareAdd(txn txnif.TxnReader) (err error)

+ func (be *DBBaseEntry) ReadAllFrom(r io.Reader) (n int64, err error)

+ func (be *DBBaseEntry) ReadOneNodeFrom(r io.Reader) (n int64, err error)

+ func (be *DBBaseEntry) String() string

+ func (be *DBBaseEntry) StringLocked() string

+ func (be *DBBaseEntry) TryGetTerminatedTS(waitIfcommitting bool) (terminated bool, TS types.TS)

+ func (be *DBBaseEntry) WriteAllTo(w io.Writer) (n int64, err error)

+ func (be *DBBaseEntry) WriteOneNodeTo(w io.Writer) (n int64, err error)

type DBEntry

+ func NewDBEntryByTS(catalog *Catalog, name string, ts types.TS) *DBEntry

+ func NewDBEntryWithID(catalog *Catalog, name string, createSql string, id uint64, txn txnif.AsyncTxn) *DBEntry

+ func (e *DBEntry) CreateTableEntryWithTableId(schema *Schema, txn txnif.AsyncTxn, dataFactory TableDataFactory, ...) (created *TableEntry, err error)

+ func (e *DBEntry) DropTableEntryByID(id uint64, txn txnif.AsyncTxn) (newEntry bool, deleted *TableEntry, err error)

+ func (e *DBEntry) GetCreateAt() types.Timestamp

+ func (e *DBEntry) GetCreateSql() string

+ func (e *DBEntry) GetFullName() string

+ func (e *DBEntry) GetItemNodeByIDLocked(id uint64) *common.GenericDLNode[*TableEntry]

+ func (e *DBEntry) GetRoleID() uint32

+ func (e *DBEntry) GetTableEntryByName(tenantID uint32, name string, ts types.TS) (entry *TableEntry, err error)

+ func (e *DBEntry) GetTenantID() uint32

+ func (e *DBEntry) GetUserID() uint32

+ func (e *DBEntry) Is1PC() bool

+ func (e *DBEntry) Set1PC()

+ func (e *DBEntry) StringWithLevel(level common.PPLevel) string

+ func (e *DBEntry) StringWithlevelLocked(level common.PPLevel) string

+ func (e *DBEntry) TxnGetTableEntryByID(id uint64, txn txnif.AsyncTxn) (entry *TableEntry, err error)

+ func (e *DBEntry) TxnGetTableEntryByName(name string, txn txnif.AsyncTxn) (entry *TableEntry, err error)

+ type DBMVCCNode struct

+ func (e *DBMVCCNode) ApplyCommit(index *wal.Index) (err error)

+ func (e *DBMVCCNode) ApplyRollback(index *wal.Index) (err error)

+ func (e *DBMVCCNode) CloneAll() txnif.MVCCNode

+ func (e *DBMVCCNode) CloneData() txnif.MVCCNode

+ func (e *DBMVCCNode) PrepareCommit() (err error)

+ func (e *DBMVCCNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (e *DBMVCCNode) String() string

+ func (e *DBMVCCNode) Update(vun txnif.MVCCNode)

+ func (e *DBMVCCNode) WriteTo(w io.Writer) (n int64, err error)

type Default

+ Expr []byte

+ NullAbility bool

+ OriginString string

+ func (d *Default) Marshal() ([]byte, error)

+ func (d *Default) Unmarshal(data []byte) (err error)

type EntryCommand

+ func (cmd *EntryCommand) ApplyCommit()

+ func (cmd *EntryCommand) ApplyRollback()

+ func (cmd *EntryCommand) SetReplayTxn(txn txnif.AsyncTxn)

+ type EntryMVCCNode struct

+ CreatedAt types.TS

+ DeletedAt types.TS

+ func (un *EntryMVCCNode) ApplyCommit(ts types.TS) (err error)

+ func (un *EntryMVCCNode) Clone() *EntryMVCCNode

+ func (un *EntryMVCCNode) CloneData() *EntryMVCCNode

+ func (un *EntryMVCCNode) Delete()

+ func (un *EntryMVCCNode) GetCreatedAt() types.TS

+ func (un *EntryMVCCNode) GetDeletedAt() types.TS

+ func (un *EntryMVCCNode) HasDropCommitted() bool

+ func (un *EntryMVCCNode) HasDropIntent() bool

+ func (un *EntryMVCCNode) IsCreating() bool

+ func (un *EntryMVCCNode) PrepareCommit() (err error)

+ func (un *EntryMVCCNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (un *EntryMVCCNode) String() string

+ func (un *EntryMVCCNode) WriteTo(w io.Writer) (n int64, err error)

+ type MetaBaseEntry struct

+ ID uint64

+ func NewMetaBaseEntry(id uint64) *MetaBaseEntry

+ func NewReplayMetaBaseEntry() *MetaBaseEntry

+ func (be *MetaBaseEntry) CloneCommittedInRange(start, end types.TS) BaseEntry

+ func (be *MetaBaseEntry) CreateWithTS(ts types.TS)

+ func (be *MetaBaseEntry) CreateWithTxn(txn txnif.AsyncTxn)

+ func (be *MetaBaseEntry) DeleteAfter(ts types.TS) bool

+ func (be *MetaBaseEntry) DeleteBefore(ts types.TS) bool

+ func (be *MetaBaseEntry) DeleteLocked(txn txnif.TxnReader) (isNewNode bool, err error)

+ func (be *MetaBaseEntry) DoCompre(voe BaseEntry) int

+ func (be *MetaBaseEntry) DropEntryLocked(txn txnif.TxnReader) (isNewNode bool, err error)

+ func (be *MetaBaseEntry) GetCreatedAt() types.TS

+ func (be *MetaBaseEntry) GetDeleteAt() types.TS

+ func (be *MetaBaseEntry) GetDeltaLoc() string

+ func (be *MetaBaseEntry) GetID() uint64

+ func (be *MetaBaseEntry) GetMetaLoc() string

+ func (be *MetaBaseEntry) GetVisibility(ts types.TS) (visible, dropped bool)

+ func (be *MetaBaseEntry) GetVisibilityLocked(ts types.TS) (visible, dropped bool)

+ func (be *MetaBaseEntry) GetVisibleDeltaLoc(ts types.TS) string

+ func (be *MetaBaseEntry) GetVisibleMetaLoc(ts types.TS) string

+ func (be *MetaBaseEntry) HasDropCommitted() bool

+ func (be *MetaBaseEntry) HasDropCommittedLocked() bool

+ func (be *MetaBaseEntry) HasPersistedData() bool

+ func (be *MetaBaseEntry) HasPersistedDeltaData() bool

+ func (be *MetaBaseEntry) IsVisible(ts types.TS, mu *sync.RWMutex) (ok bool, err error)

+ func (be *MetaBaseEntry) NeedWaitCommitting(startTS types.TS) (bool, txnif.TxnReader)

+ func (be *MetaBaseEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (be *MetaBaseEntry) ReadAllFrom(r io.Reader) (n int64, err error)

+ func (be *MetaBaseEntry) ReadOneNodeFrom(r io.Reader) (n int64, err error)

+ func (be *MetaBaseEntry) String() string

+ func (be *MetaBaseEntry) StringLocked() string

+ func (be *MetaBaseEntry) TryGetTerminatedTS(waitIfcommitting bool) (terminated bool, TS types.TS)

+ func (be *MetaBaseEntry) UpdateDeltaLoc(txn txnif.TxnReader, deltaloc string) (isNewNode bool, err error)

+ func (be *MetaBaseEntry) UpdateMetaLoc(txn txnif.TxnReader, metaloc string) (isNewNode bool, err error)

+ func (be *MetaBaseEntry) WriteAllTo(w io.Writer) (n int64, err error)

+ func (be *MetaBaseEntry) WriteOneNodeTo(w io.Writer) (n int64, err error)

+ type MetadataMVCCNode struct

+ DeltaLoc string

+ MetaLoc string

+ func (e *MetadataMVCCNode) ApplyCommit(index *wal.Index) (err error)

+ func (e *MetadataMVCCNode) ApplyRollback(index *wal.Index) (err error)

+ func (e *MetadataMVCCNode) CloneAll() txnif.MVCCNode

+ func (e *MetadataMVCCNode) CloneData() txnif.MVCCNode

+ func (e *MetadataMVCCNode) PrepareCommit() (err error)

+ func (e *MetadataMVCCNode) PrepareRollback() (err error)

+ func (e *MetadataMVCCNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (e *MetadataMVCCNode) String() string

+ func (e *MetadataMVCCNode) Update(vun txnif.MVCCNode)

+ func (e *MetadataMVCCNode) UpdateDeltaLoc(deltaLoc string)

+ func (e *MetadataMVCCNode) UpdateMetaLoc(metaLoc string)

+ func (e *MetadataMVCCNode) WriteTo(w io.Writer) (n int64, err error)

+ type OnUpdate struct

+ Expr []byte

+ OriginString string

+ func (u *OnUpdate) Marshal() ([]byte, error)

+ func (u *OnUpdate) Unmarshal(data []byte) (err error)

type Schema

+ AcInfo accessInfo

+ Createsql string

+ IndexInfos []*ComputeIndexInfo

+ Partition string

+ PhyAddrKey *ColDef

+ Relkind string

+ View string

+ func (s *Schema) AppendColWithAttribute(attr engine.Attribute) error

+ func (s *Schema) AppendPKColWithAttribute(attr engine.Attribute, idx int) error

+ func (s *Schema) ReadFromBatch(bat *containers.Batch, offset int) (next int)

type SegmentEntry

+ func (entry *SegmentEntry) GetAppendableBlock() (blk *BlockEntry)

+ func (entry *SegmentEntry) GetTerminationTS() (ts types.TS, terminated bool)

+ func (entry *SegmentEntry) Is1PC() bool

+ func (entry *SegmentEntry) Set1PC()

+ func (entry *SegmentEntry) StringWithLevel(level common.PPLevel) string

+ func (entry *SegmentEntry) StringWithLevelLocked(level common.PPLevel) string

+ type TableBaseEntry struct

+ ID uint64

+ func NewReplayTableBaseEntry() *TableBaseEntry

+ func NewTableBaseEntry(id uint64) *TableBaseEntry

+ func (be *TableBaseEntry) CloneCommittedInRange(start, end types.TS) BaseEntry

+ func (be *TableBaseEntry) CreateWithTS(ts types.TS)

+ func (be *TableBaseEntry) CreateWithTxn(txn txnif.AsyncTxn)

+ func (be *TableBaseEntry) DeleteAfter(ts types.TS) bool

+ func (be *TableBaseEntry) DeleteBefore(ts types.TS) bool

+ func (be *TableBaseEntry) DeleteLocked(txn txnif.TxnReader) (isNewNode bool, err error)

+ func (be *TableBaseEntry) DoCompre(voe BaseEntry) int

+ func (be *TableBaseEntry) DropEntryLocked(txnCtx txnif.TxnReader) (isNewNode bool, err error)

+ func (be *TableBaseEntry) GetCreatedAt() types.TS

+ func (be *TableBaseEntry) GetDeleteAt() types.TS

+ func (be *TableBaseEntry) GetID() uint64

+ func (be *TableBaseEntry) GetVisibility(ts types.TS) (visible, dropped bool)

+ func (be *TableBaseEntry) GetVisibilityLocked(ts types.TS) (visible, dropped bool)

+ func (be *TableBaseEntry) HasDropCommitted() bool

+ func (be *TableBaseEntry) HasDropCommittedLocked() bool

+ func (be *TableBaseEntry) IsVisible(ts types.TS, mu *sync.RWMutex) (ok bool, err error)

+ func (be *TableBaseEntry) NeedWaitCommitting(startTS types.TS) (bool, txnif.TxnReader)

+ func (be *TableBaseEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (be *TableBaseEntry) PrepareAdd(txn txnif.TxnReader) (err error)

+ func (be *TableBaseEntry) ReadAllFrom(r io.Reader) (n int64, err error)

+ func (be *TableBaseEntry) ReadOneNodeFrom(r io.Reader) (n int64, err error)

+ func (be *TableBaseEntry) String() string

+ func (be *TableBaseEntry) StringLocked() string

+ func (be *TableBaseEntry) TryGetTerminatedTS(waitIfcommitting bool) (terminated bool, TS types.TS)

+ func (be *TableBaseEntry) WriteAllTo(w io.Writer) (n int64, err error)

+ func (be *TableBaseEntry) WriteOneNodeTo(w io.Writer) (n int64, err error)

type TableEntry

+ func NewTableEntryWithTableId(db *DBEntry, schema *Schema, txnCtx txnif.AsyncTxn, ...) *TableEntry

+ func (entry *TableEntry) GetColDefs() []*ColDef

+ func (entry *TableEntry) GetFullName() string

+ func (entry *TableEntry) GetTerminationTS() (ts types.TS, terminated bool)

+ func (entry *TableEntry) Is1PC() bool

+ func (entry *TableEntry) Set1PC()

+ func (entry *TableEntry) StringLockedWithLevel(level common.PPLevel) string

+ func (entry *TableEntry) StringWithLevel(level common.PPLevel) string

+ type TableMVCCNode struct

+ func (e *TableMVCCNode) ApplyCommit(index *wal.Index) (err error)

+ func (e *TableMVCCNode) ApplyRollback(index *wal.Index) (err error)

+ func (e *TableMVCCNode) CloneAll() txnif.MVCCNode

+ func (e *TableMVCCNode) CloneData() txnif.MVCCNode

+ func (e *TableMVCCNode) PrepareCommit() (err error)

+ func (e *TableMVCCNode) ReadFrom(r io.Reader) (n int64, err error)

+ func (e *TableMVCCNode) String() string

+ func (e *TableMVCCNode) Update(vun txnif.MVCCNode)

+ func (e *TableMVCCNode) WriteTo(w io.Writer) (n int64, err error)

v0.5.1

Aug 17, 2022

v0.5.0

Jul 14, 2022

Changes in this version

+ const CatalogName

+ const CmdCreateBlock

+ const CmdCreateDatabase

+ const CmdCreateSegment

+ const CmdCreateTable

+ const CmdDropBlock

+ const CmdDropDatabase

+ const CmdDropSegment

+ const CmdDropTable

+ const CmdLogBlock

+ const CmdLogDatabase

+ const CmdLogSegment

+ const CmdLogTable

+ const DefaultReplayCacheSize

+ const ETCatalogCheckpoint

+ const HiddenColumnComment

+ const HiddenColumnName

+ const ModelAttrET

+ const ModelAttrID

+ const ModelAttrInfo

+ const ModelAttrLogIdx

+ const ModelAttrName

+ const ModelAttrOpT

+ const ModelAttrParentID

+ const ModelAttrTS

+ const ModelSchemaName

+ const SortKeyNamePrefx

+ const SystemBlock_Columns_ID

+ const SystemBlock_DB_ID

+ const SystemBlock_Table_ID

+ const SystemCatalogName

+ const SystemColAttr_Comment

+ const SystemColAttr_ConstraintType

+ const SystemColAttr_DBName

+ const SystemColAttr_DefaultExpr

+ const SystemColAttr_HasExpr

+ const SystemColAttr_IsAutoIncrement

+ const SystemColAttr_IsDropped

+ const SystemColAttr_IsHidden

+ const SystemColAttr_IsUnsigned

+ const SystemColAttr_Length

+ const SystemColAttr_Name

+ const SystemColAttr_NullAbility

+ const SystemColAttr_Num

+ const SystemColAttr_RelName

+ const SystemColAttr_Type

+ const SystemColNoConstraint

+ const SystemColPKConstraint

+ const SystemDBAttr_CatalogName

+ const SystemDBAttr_CreateSQL

+ const SystemDBAttr_Name

+ const SystemDBID

+ const SystemDBName

+ const SystemIndexRel

+ const SystemMaterializedRel

+ const SystemOrdinaryRel

+ const SystemPersistRel

+ const SystemRelAttr_Comment

+ const SystemRelAttr_CreateSQL

+ const SystemRelAttr_DBName

+ const SystemRelAttr_Kind

+ const SystemRelAttr_Name

+ const SystemRelAttr_Persistence

+ const SystemSegment_Columns_ID

+ const SystemSegment_DB_ID

+ const SystemSegment_Table_ID

+ const SystemSequenceRel

+ const SystemTable_Columns_ID

+ const SystemTable_Columns_Name

+ const SystemTable_DB_ID

+ const SystemTable_DB_Name

+ const SystemTable_Table_ID

+ const SystemTable_Table_Name

+ const SystemTransientRel

+ const SystemViewRel

+ var EmptyCheckpoint = new(Checkpoint)

+ var ErrCheckpoint = errors.New("tae catalog: checkpoint")

+ var ErrDuplicate = errors.New("tae catalog: duplicate")

+ var ErrNotFound = errors.New("tae catalog: not found")

+ var ErrNotPermitted = errors.New("tae catalog: operation not permitted")

+ var ErrSchemaValidation = errors.New("tae catalog: schema validation")

+ var ErrStopCurrRecur = errors.New("tae catalog: stop current recursion")

+ var HiddenColumnType types.Type

+ var OpNames = map[OpT]string

+ func ActiveWithNoTxnFilter(be *BaseEntry) bool

+ func AppendableBlkFilter(be *BlockEntry) bool

+ func CheckpointOp(ckpEntry *CheckpointEntry, entry *BaseEntry, item CheckpointItem, ...)

+ func CheckpointSelectOp(entry *BaseEntry, minTs, maxTs uint64) bool

+ func CmdName(t int16) string

+ func CompareUint64(left, right uint64) int

+ func EstimateBlockSize(meta *BlockEntry, rows uint32) uint32

+ func EstimateColumnBlockSize(colIdx int, rows uint32, meta *BlockEntry) uint32

+ func GetAttrIdx(attrs []string, name string) int

+ func MarshalDefault(w *bytes.Buffer, typ types.Type, data Default) (err error)

+ func MockBatch(schema *Schema, rows int) *containers.Batch

+ func MockTxnFactory(catalog *Catalog) txnbase.TxnFactory

+ func MockTxnStoreFactory(catalog *Catalog) txnbase.TxnStoreFactory

+ func NonAppendableBlkFilter(be *BlockEntry) bool

+ func OpName(op OpT) string

+ func UnMarshalDefault(r io.Reader, typ types.Type, data *Default) (n int64, err error)

+ type BaseEntry struct

+ CreateAt uint64

+ DeleteAt uint64

+ ID uint64

+ PrevCommit *CommitInfo

+ func NewReplayBaseEntry() *BaseEntry

+ func (be *BaseEntry) ApplyCommit(index *wal.Index) error

+ func (be *BaseEntry) ApplyDeleteCmd(ts uint64, index *wal.Index) error

+ func (be *BaseEntry) ApplyRollback() error

+ func (be *BaseEntry) Clone() *BaseEntry

+ func (be *BaseEntry) CloneCreate() *BaseEntry

+ func (be *BaseEntry) CreateAfter(ts uint64) bool

+ func (be *BaseEntry) CreateAndDropInSameTxn() bool

+ func (be *BaseEntry) CreateBefore(ts uint64) bool

+ func (be *BaseEntry) DeleteAfter(ts uint64) bool

+ func (be *BaseEntry) DeleteBefore(ts uint64) bool

+ func (be *BaseEntry) DoCompre(oe *BaseEntry) int

+ func (be *BaseEntry) DropEntryLocked(txnCtx txnif.TxnReader) error

+ func (be *BaseEntry) GetID() uint64

+ func (be *BaseEntry) GetLogIndex() *wal.Index

+ func (be *BaseEntry) GetTxn() txnif.TxnReader

+ func (be *BaseEntry) GetTxnID() uint64

+ func (be *BaseEntry) HasActiveTxn() bool

+ func (be *BaseEntry) HasCreated() bool

+ func (be *BaseEntry) HasDropped() bool

+ func (be *BaseEntry) InTxnOrRollbacked() bool

+ func (be *BaseEntry) IsCommitted() bool

+ func (be *BaseEntry) IsCommitting() bool

+ func (be *BaseEntry) IsCreatedUncommitted() bool

+ func (be *BaseEntry) IsDroppedCommitted() bool

+ func (be *BaseEntry) IsDroppedUncommitted() bool

+ func (be *BaseEntry) IsSameTxn(ctx txnif.TxnReader) bool

+ func (be *BaseEntry) IsTerminated(waitIfcommitting bool) bool

+ func (be *BaseEntry) MaxCommittedTS() uint64

+ func (be *BaseEntry) PrepareCommit() error

+ func (be *BaseEntry) PrepareRollback() error

+ func (be *BaseEntry) PrepareWrite(txn txnif.TxnReader, rwlocker *sync.RWMutex) (err error)

+ func (be *BaseEntry) ReadFrom(r io.Reader) (n int64, err error)

+ func (be *BaseEntry) SameTxn(o *BaseEntry) bool

+ func (be *BaseEntry) String() string

+ func (be *BaseEntry) TxnCanRead(txn txnif.AsyncTxn, rwlocker *sync.RWMutex) (ok bool, err error)

+ func (be *BaseEntry) WriteTo(w io.Writer) (n int64, err error)

+ type BlockDataFactory = func(meta *BlockEntry) data.Block

+ type BlockEntry struct

+ func NewBlockEntry(segment *SegmentEntry, txn txnif.AsyncTxn, state EntryState, ...) *BlockEntry

+ func NewReplayBlockEntry() *BlockEntry

+ func NewStandaloneBlock(segment *SegmentEntry, id uint64, ts uint64) *BlockEntry

+ func NewSysBlockEntry(segment *SegmentEntry, id uint64) *BlockEntry

+ func (entry *BlockEntry) AsCommonID() *common.ID

+ func (entry *BlockEntry) Clone() CheckpointItem

+ func (entry *BlockEntry) CloneCreate() CheckpointItem

+ func (entry *BlockEntry) Compare(o common.NodePayload) int

+ func (entry *BlockEntry) DestroyData() (err error)

+ func (entry *BlockEntry) GetBlockData() data.Block

+ func (entry *BlockEntry) GetCatalog() *Catalog

+ func (entry *BlockEntry) GetFileTs() (uint64, error)

+ func (entry *BlockEntry) GetSchema() *Schema

+ func (entry *BlockEntry) GetSegment() *SegmentEntry

+ func (entry *BlockEntry) GetTerminationTS() (ts uint64, terminated bool)

+ func (entry *BlockEntry) InitData(factory DataFactory)

+ func (entry *BlockEntry) IsActive() bool

+ func (entry *BlockEntry) IsAppendable() bool

+ func (entry *BlockEntry) MakeCommand(id uint32) (cmd txnif.TxnCmd, err error)

+ func (entry *BlockEntry) MakeKey() []byte

+ func (entry *BlockEntry) MakeLogEntry() *EntryCommand

+ func (entry *BlockEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (entry *BlockEntry) PrepareRollback() (err error)

+ func (entry *BlockEntry) ReadFrom(r io.Reader) (n int64, err error)

+ func (entry *BlockEntry) Repr() string

+ func (entry *BlockEntry) String() string

+ func (entry *BlockEntry) StringLocked() string

+ func (entry *BlockEntry) WriteTo(w io.Writer) (n int64, err error)

+ type Catalog struct

+ func MockCatalog(dir, name string, cfg *store.StoreCfg, scheduler tasks.TaskScheduler) *Catalog

+ func OpenCatalog(dir, name string, cfg *store.StoreCfg, scheduler tasks.TaskScheduler, ...) (*Catalog, error)

+ func (catalog *Catalog) AddColumnCnt(cnt int)

+ func (catalog *Catalog) AddEntryLocked(database *DBEntry) error

+ func (catalog *Catalog) AddTableCnt(cnt int)

+ func (catalog *Catalog) Checkpoint(maxTs uint64) (err error)

+ func (catalog *Catalog) CheckpointClosure(maxTs uint64) tasks.FuncT

+ func (catalog *Catalog) Close() error

+ func (catalog *Catalog) CoarseColumnCnt() int

+ func (catalog *Catalog) CoarseDBCnt() int

+ func (catalog *Catalog) CoarseTableCnt() int

+ func (catalog *Catalog) CreateDBEntry(name string, txnCtx txnif.AsyncTxn) (*DBEntry, error)

+ func (catalog *Catalog) DropDBEntry(name string, txnCtx txnif.AsyncTxn) (deleted *DBEntry, err error)

+ func (catalog *Catalog) GetCheckpointed() *Checkpoint

+ func (catalog *Catalog) GetDBEntry(name string, txnCtx txnif.AsyncTxn) (*DBEntry, error)

+ func (catalog *Catalog) GetDatabaseByID(id uint64) (db *DBEntry, err error)

+ func (catalog *Catalog) GetScheduler() tasks.TaskScheduler

+ func (catalog *Catalog) GetStore() store.Store

+ func (catalog *Catalog) InitSystemDB()

+ func (catalog *Catalog) MakeDBIt(reverse bool) *common.LinkIt

+ func (catalog *Catalog) PPString(level common.PPLevel, depth int, prefix string) string

+ func (catalog *Catalog) PrepareCheckpoint(startTs, endTs uint64) *CheckpointEntry

+ func (catalog *Catalog) RecurLoop(processor Processor) (err error)

+ func (catalog *Catalog) RemoveEntry(database *DBEntry) error

+ func (catalog *Catalog) ReplayCmd(txncmd txnif.TxnCmd, dataFactory DataFactory, idxCtx *wal.Index, ...)

+ func (catalog *Catalog) ReplayTableRows()

+ func (catalog *Catalog) SimplePPString(level common.PPLevel) string

+ type Checkpoint struct

+ CommitId uint64

+ LSN uint64

+ MaxTS uint64

+ func (ckp *Checkpoint) String() string

+ type CheckpointEntry struct

+ Entries []*EntryCommand

+ LogIndexes []*wal.Index

+ MaxIndex wal.Index

+ MaxTS uint64

+ MinTS uint64

+ func NewCheckpointEntry(minTs, maxTs uint64) *CheckpointEntry

+ func NewEmptyCheckpointEntry() *CheckpointEntry

+ func (e *CheckpointEntry) AddCommand(cmd *EntryCommand)

+ func (e *CheckpointEntry) AddIndex(index *wal.Index)

+ func (e *CheckpointEntry) GetMaxIndex() *wal.Index

+ func (e *CheckpointEntry) MakeLogEntry() (logEntry LogEntry, err error)

+ func (e *CheckpointEntry) Marshal() (buf []byte, err error)

+ func (e *CheckpointEntry) PrintItems()

+ func (e *CheckpointEntry) Unmarshal(buf []byte) (err error)

+ type CheckpointItem interface

+ Clone func() CheckpointItem

+ CloneCreate func() CheckpointItem

+ MakeLogEntry func() *EntryCommand

+ StringLocked func() string

+ type ColDef struct

+ AutoIncrement int8

+ Comment string

+ Default Default

+ Hidden int8

+ Idx int

+ Name string

+ NullAbility int8

+ Primary int8

+ SortIdx int8

+ SortKey int8

+ Type types.Type

+ func (def *ColDef) GetName() string

+ func (def *ColDef) GetType() types.Type

+ func (def *ColDef) IsHidden() bool

+ func (def *ColDef) IsPrimary() bool

+ func (def *ColDef) IsSortKey() bool

+ func (def *ColDef) Nullable() bool

+ type CommitInfo struct

+ CurrOp OpT

+ LogIndex *wal.Index

+ Txn txnif.TxnReader

+ func (info *CommitInfo) Clone() *CommitInfo

+ func (info *CommitInfo) ReadFrom(r io.Reader) (n int64, err error)

+ func (info *CommitInfo) WriteTo(w io.Writer) (n int64, err error)

+ type ComposedFilter struct

+ BlockFilters []func(*BlockEntry) bool

+ CommitFilters []func(*BaseEntry) bool

+ func NewComposedFilter() *ComposedFilter

+ func (filter *ComposedFilter) AddBlockFilter(f func(*BlockEntry) bool)

+ func (filter *ComposedFilter) AddCommitFilter(f func(*BaseEntry) bool)

+ func (filter *ComposedFilter) FilteBlock(be *BlockEntry) bool

+ func (filter *ComposedFilter) FilteCommit(be *BaseEntry) bool

+ type DBEntry struct

+ func NewDBEntry(catalog *Catalog, name string, txnCtx txnif.AsyncTxn) *DBEntry

+ func NewReplayDBEntry() *DBEntry

+ func NewSystemDBEntry(catalog *Catalog) *DBEntry

+ func (e *DBEntry) AddEntryLocked(table *TableEntry) (err error)

+ func (e *DBEntry) CoarseTableCnt() int

+ func (e *DBEntry) Compare(o common.NodePayload) int

+ func (e *DBEntry) CreateTableEntry(schema *Schema, txnCtx txnif.AsyncTxn, dataFactory TableDataFactory) (created *TableEntry, err error)

+ func (e *DBEntry) DropTableEntry(name string, txnCtx txnif.AsyncTxn) (deleted *TableEntry, err error)

+ func (e *DBEntry) GetBlockEntryByID(id *common.ID) (blk *BlockEntry, err error)

+ func (e *DBEntry) GetCatalog() *Catalog

+ func (e *DBEntry) GetName() string

+ func (e *DBEntry) GetTableEntry(name string, txnCtx txnif.AsyncTxn) (entry *TableEntry, err error)

+ func (e *DBEntry) GetTableEntryByID(id uint64) (table *TableEntry, err error)

+ func (e *DBEntry) IsSystemDB() bool

+ func (e *DBEntry) MakeCommand(id uint32) (txnif.TxnCmd, error)

+ func (e *DBEntry) MakeTableIt(reverse bool) *common.LinkIt

+ func (e *DBEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (e *DBEntry) PrepareRollback() (err error)

+ func (e *DBEntry) RecurLoop(processor Processor) (err error)

+ func (e *DBEntry) RemoveEntry(table *TableEntry) (err error)

+ func (e *DBEntry) String() string

+ func (e *DBEntry) StringLocked() string

+ func (entry *DBEntry) Clone() CheckpointItem

+ func (entry *DBEntry) CloneCreate() CheckpointItem

+ func (entry *DBEntry) CloneCreateEntry() *DBEntry

+ func (entry *DBEntry) IsActive() bool

+ func (entry *DBEntry) MakeLogEntry() *EntryCommand

+ func (entry *DBEntry) ReadFrom(r io.Reader) (n int64, err error)

+ func (entry *DBEntry) WriteTo(w io.Writer) (n int64, err error)

+ type DataFactory interface

+ MakeBlockFactory func(segFile file.Segment) BlockDataFactory

+ MakeSegmentFactory func() SegmentDataFactory

+ MakeTableFactory func() TableDataFactory

+ type Default struct

+ Null bool

+ Set bool

+ Value any

+ type EntryCommand struct

+ Block *BlockEntry

+ DB *DBEntry

+ DBID uint64

+ Segment *SegmentEntry

+ SegmentID uint64

+ Table *TableEntry

+ TableID uint64

+ func (cmd *EntryCommand) Desc() string

+ func (cmd *EntryCommand) GetID() (uint64, *common.ID)

+ func (cmd *EntryCommand) GetLogIndex() *wal.Index

+ func (cmd *EntryCommand) GetTs() uint64

+ func (cmd *EntryCommand) GetType() int16

+ func (cmd *EntryCommand) IDString() string

+ func (cmd *EntryCommand) Marshal() (buf []byte, err error)

+ func (cmd *EntryCommand) ReadFrom(r io.Reader) (n int64, err error)

+ func (cmd *EntryCommand) String() string

+ func (cmd *EntryCommand) Unmarshal(buf []byte) (err error)

+ func (cmd *EntryCommand) VerboseString() string

+ func (cmd *EntryCommand) WriteTo(w io.Writer) (n int64, err error)

+ type EntryState int8

+ const ES_Appendable

+ const ES_Frozen

+ const ES_NotAppendable

+ func (es EntryState) Repr() string

+ type EntryType uint8

+ const ETBlock

+ const ETColDef

+ const ETDatabase

+ const ETSegment

+ const ETTable

+ type IDAlloctor struct

+ func NewIDAllocator() *IDAlloctor

+ func (alloc *IDAlloctor) CurrBlock() uint64

+ func (alloc *IDAlloctor) CurrDB() uint64

+ func (alloc *IDAlloctor) CurrSegment() uint64

+ func (alloc *IDAlloctor) CurrTable() uint64

+ func (alloc *IDAlloctor) IDStates() string

+ func (alloc *IDAlloctor) Init(prevDb, prevTbl, prevSeg, prevBlk uint64)

+ func (alloc *IDAlloctor) NextBlock() uint64

+ func (alloc *IDAlloctor) NextDB() uint64

+ func (alloc *IDAlloctor) NextSegment() uint64

+ func (alloc *IDAlloctor) NextTable() uint64

+ func (alloc *IDAlloctor) OnReplayBlockID(id uint64)

+ func (alloc *IDAlloctor) OnReplayDBID(id uint64)

+ func (alloc *IDAlloctor) OnReplaySegmentID(id uint64)

+ func (alloc *IDAlloctor) OnReplayTableID(id uint64)

+ type IndexInfo struct

+ Columns []uint16

+ Id uint64

+ Name string

+ Type IndexT

+ func NewIndexInfo(name string, typ IndexT, colIdx ...int) *IndexInfo

+ type IndexT uint16

+ const ZoneMap

+ type LogEntry = entry.Entry

+ type LoopProcessor struct

+ BlockFn func(*BlockEntry) error

+ DatabaseFn func(*DBEntry) error

+ PostSegmentFn func(*SegmentEntry) error

+ SegmentFn func(*SegmentEntry) error

+ TableFn func(*TableEntry) error

+ func (p *LoopProcessor) OnBlock(block *BlockEntry) error

+ func (p *LoopProcessor) OnDatabase(database *DBEntry) error

+ func (p *LoopProcessor) OnPostSegment(segment *SegmentEntry) error

+ func (p *LoopProcessor) OnSegment(segment *SegmentEntry) error

+ func (p *LoopProcessor) OnTable(table *TableEntry) error

+ type OpT int8

+ const OpCreate

+ const OpHardDelete

+ const OpSoftDelete

+ const OpUpdate

+ type PersistentType int8

+ const PT_Permanent

+ const PT_Temporary

+ type Processor interface

+ OnBlock func(block *BlockEntry) error

+ OnDatabase func(database *DBEntry) error

+ OnPostSegment func(segment *SegmentEntry) error

+ OnSegment func(segment *SegmentEntry) error

+ OnTable func(table *TableEntry) error

+ type Replayer struct

+ func NewReplayer(dataFactory DataFactory, catalog *Catalog) *Replayer

+ func (replayer *Replayer) ReplayerHandle(group uint32, commitId uint64, payload []byte, typ uint16, info any)

+ type Schema struct

+ BlockMaxRows uint32

+ ColDefs []*ColDef

+ Comment string

+ HiddenKey *ColDef

+ Name string

+ NameIndex map[string]int

+ SegmentMaxBlocks uint16

+ SortKey *SortKey

+ var SystemColumnSchema *Schema

+ var SystemDBSchema *Schema

+ var SystemTableSchema *Schema

+ func MockCompoundSchema(colCnt int, pkIdx ...int) *Schema

+ func MockSchema(colCnt int, pkIdx int) *Schema

+ func MockSchemaAll(colCnt int, pkIdx int, from ...int) *Schema

+ func NewEmptySchema(name string) *Schema

+ func (s *Schema) AllNames() []string

+ func (s *Schema) AllNullables() []bool

+ func (s *Schema) AllTypes() []types.Type

+ func (s *Schema) AppendCol(name string, typ types.Type) error

+ func (s *Schema) AppendColDef(def *ColDef) (err error)

+ func (s *Schema) AppendColWithDefault(name string, typ types.Type, val Default) error

+ func (s *Schema) AppendPKCol(name string, typ types.Type, idx int) error

+ func (s *Schema) AppendSortKey(name string, typ types.Type, idx int, isPrimary bool) error

+ func (s *Schema) Attrs() []string

+ func (s *Schema) Clone() *Schema

+ func (s *Schema) Finalize(rebuild bool) (err error)

+ func (s *Schema) GetColIdx(attr string) int

+ func (s *Schema) GetSingleSortKey() *ColDef

+ func (s *Schema) GetSingleSortKeyIdx() int

+ func (s *Schema) GetSortKeyCnt() int

+ func (s *Schema) GetSortKeyType() types.Type

+ func (s *Schema) HasPK() bool

+ func (s *Schema) HasSortKey() bool

+ func (s *Schema) IsCompoundPK() bool

+ func (s *Schema) IsCompoundSortKey() bool

+ func (s *Schema) IsPartOfPK(idx int) bool

+ func (s *Schema) IsSinglePK() bool

+ func (s *Schema) IsSingleSortKey() bool

+ func (s *Schema) Marshal() (buf []byte, err error)

+ func (s *Schema) Nullables() []bool

+ func (s *Schema) ReadFrom(r io.Reader) (n int64, err error)

+ func (s *Schema) String() string

+ func (s *Schema) Types() []types.Type

+ type SegmentDataFactory = func(meta *SegmentEntry) data.Segment

+ type SegmentEntry struct

+ func NewReplaySegmentEntry() *SegmentEntry

+ func NewSegmentEntry(table *TableEntry, txn txnif.AsyncTxn, state EntryState, ...) *SegmentEntry

+ func NewStandaloneSegment(table *TableEntry, id uint64, ts uint64) *SegmentEntry

+ func NewSysSegmentEntry(table *TableEntry, id uint64) *SegmentEntry

+ func (entry *SegmentEntry) AddEntryLocked(block *BlockEntry)

+ func (entry *SegmentEntry) AsCommonID() *common.ID

+ func (entry *SegmentEntry) BlockCnt() int

+ func (entry *SegmentEntry) Clone() CheckpointItem

+ func (entry *SegmentEntry) CloneCreate() CheckpointItem

+ func (entry *SegmentEntry) CollectBlockEntries(commitFilter func(be *BaseEntry) bool, blockFilter func(be *BlockEntry) bool) []*BlockEntry

+ func (entry *SegmentEntry) Compare(o common.NodePayload) int

+ func (entry *SegmentEntry) CreateBlock(txn txnif.AsyncTxn, state EntryState, dataFactory BlockDataFactory) (created *BlockEntry, err error)

+ func (entry *SegmentEntry) DestroyData() (err error)

+ func (entry *SegmentEntry) DropBlockEntry(id uint64, txn txnif.AsyncTxn) (deleted *BlockEntry, err error)

+ func (entry *SegmentEntry) GetAppendableBlockCnt() int

+ func (entry *SegmentEntry) GetBlockEntryByID(id uint64) (blk *BlockEntry, err error)

+ func (entry *SegmentEntry) GetBlockEntryByIDLocked(id uint64) (blk *BlockEntry, err error)

+ func (entry *SegmentEntry) GetCatalog() *Catalog

+ func (entry *SegmentEntry) GetScheduler() tasks.TaskScheduler

+ func (entry *SegmentEntry) GetSegmentData() data.Segment

+ func (entry *SegmentEntry) GetTable() *TableEntry

+ func (entry *SegmentEntry) InitData(factory DataFactory)

+ func (entry *SegmentEntry) IsActive() bool

+ func (entry *SegmentEntry) IsAppendable() bool

+ func (entry *SegmentEntry) LastAppendableBlock() (blk *BlockEntry)

+ func (entry *SegmentEntry) MakeBlockIt(reverse bool) *common.LinkIt

+ func (entry *SegmentEntry) MakeCommand(id uint32) (cmd txnif.TxnCmd, err error)

+ func (entry *SegmentEntry) MakeLogEntry() *EntryCommand

+ func (entry *SegmentEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (entry *SegmentEntry) PrepareRollback() (err error)

+ func (entry *SegmentEntry) ReadFrom(r io.Reader) (n int64, err error)

+ func (entry *SegmentEntry) RemoveEntry(block *BlockEntry) (err error)

+ func (entry *SegmentEntry) Repr() string

+ func (entry *SegmentEntry) String() string

+ func (entry *SegmentEntry) StringLocked() string

+ func (entry *SegmentEntry) TreeMaxDropCommitEntry() *BaseEntry

+ func (entry *SegmentEntry) WriteTo(w io.Writer) (n int64, err error)

+ type SortKey struct

+ Defs []*ColDef

+ func NewSortKey() *SortKey

+ func (cpk *SortKey) AddDef(def *ColDef) (ok bool)

+ func (cpk *SortKey) GetDef(pos int) *ColDef

+ func (cpk *SortKey) GetSingleIdx() int

+ func (cpk *SortKey) HasColumn(idx int) (found bool)

+ func (cpk *SortKey) IsPrimary() bool

+ func (cpk *SortKey) IsSinglePK() bool

+ func (cpk *SortKey) Size() int

+ type TableDataFactory = func(meta *TableEntry) data.Table

+ type TableEntry struct

+ func MockStaloneTableEntry(id uint64, schema *Schema) *TableEntry

+ func NewReplayTableEntry() *TableEntry

+ func NewSystemTableEntry(db *DBEntry, id uint64, schema *Schema) *TableEntry

+ func NewTableEntry(db *DBEntry, schema *Schema, txnCtx txnif.AsyncTxn, ...) *TableEntry

+ func (entry *TableEntry) AddEntryLocked(segment *SegmentEntry)

+ func (entry *TableEntry) AddRows(delta uint64) uint64

+ func (entry *TableEntry) AsCommonID() *common.ID

+ func (entry *TableEntry) Clone() CheckpointItem

+ func (entry *TableEntry) CloneCreate() CheckpointItem

+ func (entry *TableEntry) CloneCreateEntry() *TableEntry

+ func (entry *TableEntry) Compare(o common.NodePayload) int

+ func (entry *TableEntry) CreateSegment(txn txnif.AsyncTxn, state EntryState, dataFactory SegmentDataFactory) (created *SegmentEntry, err error)

+ func (entry *TableEntry) DropSegmentEntry(id uint64, txn txnif.AsyncTxn) (deleted *SegmentEntry, err error)

+ func (entry *TableEntry) GetCatalog() *Catalog

+ func (entry *TableEntry) GetDB() *DBEntry

+ func (entry *TableEntry) GetRows() uint64

+ func (entry *TableEntry) GetSchema() *Schema

+ func (entry *TableEntry) GetSegmentByID(id uint64) (seg *SegmentEntry, err error)

+ func (entry *TableEntry) GetTableData() data.Table

+ func (entry *TableEntry) IsActive() bool

+ func (entry *TableEntry) IsVirtual() bool

+ func (entry *TableEntry) LastAppendableSegmemt() (seg *SegmentEntry)

+ func (entry *TableEntry) MakeCommand(id uint32) (cmd txnif.TxnCmd, err error)

+ func (entry *TableEntry) MakeLogEntry() *EntryCommand

+ func (entry *TableEntry) MakeSegmentIt(reverse bool) *common.LinkIt

+ func (entry *TableEntry) PPString(level common.PPLevel, depth int, prefix string) string

+ func (entry *TableEntry) PrepareRollback() (err error)

+ func (entry *TableEntry) ReadFrom(r io.Reader) (n int64, err error)

+ func (entry *TableEntry) RecurLoop(processor Processor) (err error)

+ func (entry *TableEntry) RemoveEntry(segment *SegmentEntry) (err error)

+ func (entry *TableEntry) RemoveRows(delta uint64) uint64

+ func (entry *TableEntry) String() string

+ func (entry *TableEntry) StringLocked() string

+ func (entry *TableEntry) WriteTo(w io.Writer) (n int64, err error)

+ type TableType int8

+ const TT_Index

+ const TT_MaterializedView

+ const TT_Ordinary

+ const TT_Sequence

+ const TT_View

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