engine

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

v1.2.2-20240715

Jul 15, 2024

v1.2.1

Jun 28, 2024

v1.2.1-20240709

Jul 9, 2024

v1.2.0

May 17, 2024

Changes in this version

type Engine

+ Stats func(ctx context.Context, key pb.StatsInfoKey, sync bool) *pb.StatsInfo

type EntireEngine

+ func (e *EntireEngine) Stats(ctx context.Context, key pb.StatsInfoKey, sync bool) *pb.StatsInfo

+ func (e *EntireEngine) TryToSubscribeTable(ctx context.Context, dbID, tbID uint64) error

+ func (e *EntireEngine) UnsubscribeTable(ctx context.Context, dbID, tbID uint64) error

+ type LogtailEngine interface

+ TryToSubscribeTable func(context.Context, uint64, uint64) error

+ UnsubscribeTable func(context.Context, uint64, uint64) error

type Node

+ Header objectio.InfoHeader

+ NeedExpandRanges bool

+ type Ranges interface

+ Append func([]byte)

+ GetAllBytes func() []byte

+ GetBytes func(i int) []byte

+ Len func() int

+ SetBytes func([]byte)

+ Size func() int

+ Slice func(i, j int) []byte

type Reader

+ GetOrderBy func() []*plan.OrderBySpec

+ SetFilterZM func(objectio.ZoneMap)

+ SetOrderBy func([]*plan.OrderBySpec)

type Relation

+ ApproxObjectsNum func(ctx context.Context) int

+ MergeObjects func(ctx context.Context, objstats []objectio.ObjectStats, policyName string, ...) (*api.MergeCommitEntry, error)

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

Changes in this version

type Relation

+ CopyTableDef func(context.Context) *plan.TableDef

v1.1.1

Feb 2, 2024

Changes in this version

type Relation

+ TableRenameInTxn func(ctx context.Context, constraint [][]byte) error

v1.1.0

Dec 29, 2023

Changes in this version

type Relation

+ GetTableDef func(context.Context) *plan.TableDef

v1.0.2

Dec 21, 2023

v1.0.1

Dec 15, 2023

v1.0.0

Nov 13, 2023

Changes in this version

type Attribute

+ EnumVlaues string

type ConstraintPB

+ func (m *ConstraintPB) GetStreamConfigsDef() *StreamConfigsDef

+ type ConstraintPB_StreamConfigsDef struct

+ StreamConfigsDef *StreamConfigsDef

+ func (m *ConstraintPB_StreamConfigsDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConstraintPB_StreamConfigsDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConstraintPB_StreamConfigsDef) ProtoSize() (n int)

type ConstraintType

+ const StreamConfig

type Reader

+ Count func() *ReaderCount

+ type ReaderCount struct

+ BytesRead atomic.Uint64

+ DbName atomic.Value

+ RowsRead atomic.Uint64

+ TableId atomic.Uint64

+ TableName atomic.Value

+ func (rc *ReaderCount) AddRows(rowsRead, bytesRead uint64)

+ func (rc *ReaderCount) Bytes() uint64

+ func (rc *ReaderCount) CopyFrom(src *ReaderCount)

+ func (rc *ReaderCount) Database() string

+ func (rc *ReaderCount) Init()

+ func (rc *ReaderCount) ReplaceRows(rowsRead, bytesRead uint64)

+ func (rc *ReaderCount) ReplaceTableName(dbName, tableName string, tableId uint64)

+ func (rc *ReaderCount) Rows() uint64

+ func (rc *ReaderCount) String() string

+ func (rc *ReaderCount) Table() string

+ func (rc *ReaderCount) TableID() uint64

type Relation

+ UpdateObjectInfos func(context.Context) error

+ type StreamConfigsDef struct

+ Configs []*plan.Property

+ func (*StreamConfigsDef) Descriptor() ([]byte, []int)

+ func (*StreamConfigsDef) ProtoMessage()

+ func (def *StreamConfigsDef) ToPBVersion() ConstraintPB

+ func (m *StreamConfigsDef) GetConfigs() []*plan.Property

+ func (m *StreamConfigsDef) Marshal() (dAtA []byte, err error)

+ func (m *StreamConfigsDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamConfigsDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamConfigsDef) ProtoSize() (n int)

+ func (m *StreamConfigsDef) Reset()

+ func (m *StreamConfigsDef) String() string

+ func (m *StreamConfigsDef) Unmarshal(dAtA []byte) error

+ func (m *StreamConfigsDef) XXX_DiscardUnknown()

+ func (m *StreamConfigsDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamConfigsDef) XXX_Merge(src proto.Message)

+ func (m *StreamConfigsDef) XXX_Size() int

+ func (m *StreamConfigsDef) XXX_Unmarshal(b []byte) 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

+ var ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")

+ func IsMemtable(tblRange []byte) bool

type Attribute

+ Seqnum uint16

+ func (*Attribute) Descriptor() ([]byte, []int)

+ func (*Attribute) ProtoMessage()

+ func (m *Attribute) GetAlg() github_com_matrixorigin_matrixone_pkg_compress.T

+ func (m *Attribute) GetAutoIncrement() bool

+ func (m *Attribute) GetClusterBy() bool

+ func (m *Attribute) GetComment() string

+ func (m *Attribute) GetDefault() *plan.Default

+ func (m *Attribute) GetID() uint64

+ func (m *Attribute) GetIsHidden() bool

+ func (m *Attribute) GetIsRowId() bool

+ func (m *Attribute) GetName() string

+ func (m *Attribute) GetOnUpdate() *plan.OnUpdate

+ func (m *Attribute) GetPrimary() bool

+ func (m *Attribute) Marshal() (dAtA []byte, err error)

+ func (m *Attribute) MarshalTo(dAtA []byte) (int, error)

+ func (m *Attribute) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Attribute) ProtoSize() (n int)

+ func (m *Attribute) Reset()

+ func (m *Attribute) String() string

+ func (m *Attribute) Unmarshal(dAtA []byte) error

+ func (m *Attribute) XXX_DiscardUnknown()

+ func (m *Attribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Attribute) XXX_Merge(src proto.Message)

+ func (m *Attribute) XXX_Size() int

+ func (m *Attribute) XXX_Unmarshal(b []byte) error

type AttributeDef

+ func (*AttributeDef) Descriptor() ([]byte, []int)

+ func (*AttributeDef) ProtoMessage()

+ func (def *AttributeDef) ToPBVersion() TableDefPB

+ func (m *AttributeDef) GetAttr() Attribute

+ func (m *AttributeDef) Marshal() (dAtA []byte, err error)

+ func (m *AttributeDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *AttributeDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AttributeDef) ProtoSize() (n int)

+ func (m *AttributeDef) Reset()

+ func (m *AttributeDef) String() string

+ func (m *AttributeDef) Unmarshal(dAtA []byte) error

+ func (m *AttributeDef) XXX_DiscardUnknown()

+ func (m *AttributeDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AttributeDef) XXX_Merge(src proto.Message)

+ func (m *AttributeDef) XXX_Size() int

+ func (m *AttributeDef) XXX_Unmarshal(b []byte) error

type ClusterByDef

+ func (*ClusterByDef) Descriptor() ([]byte, []int)

+ func (*ClusterByDef) ProtoMessage()

+ func (def *ClusterByDef) ToPBVersion() TableDefPB

+ func (m *ClusterByDef) GetName() string

+ func (m *ClusterByDef) Marshal() (dAtA []byte, err error)

+ func (m *ClusterByDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterByDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClusterByDef) ProtoSize() (n int)

+ func (m *ClusterByDef) Reset()

+ func (m *ClusterByDef) String() string

+ func (m *ClusterByDef) Unmarshal(dAtA []byte) error

+ func (m *ClusterByDef) XXX_DiscardUnknown()

+ func (m *ClusterByDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterByDef) XXX_Merge(src proto.Message)

+ func (m *ClusterByDef) XXX_Size() int

+ func (m *ClusterByDef) XXX_Unmarshal(b []byte) error

type CommentDef

+ func (*CommentDef) Descriptor() ([]byte, []int)

+ func (*CommentDef) ProtoMessage()

+ func (def *CommentDef) ToPBVersion() TableDefPB

+ func (m *CommentDef) GetComment() string

+ func (m *CommentDef) Marshal() (dAtA []byte, err error)

+ func (m *CommentDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *CommentDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CommentDef) ProtoSize() (n int)

+ func (m *CommentDef) Reset()

+ func (m *CommentDef) String() string

+ func (m *CommentDef) Unmarshal(dAtA []byte) error

+ func (m *CommentDef) XXX_DiscardUnknown()

+ func (m *CommentDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CommentDef) XXX_Merge(src proto.Message)

+ func (m *CommentDef) XXX_Size() int

+ func (m *CommentDef) XXX_Unmarshal(b []byte) error

type Constraint

+ ToPBVersion func() ConstraintPB

type ConstraintDef

+ func (def *ConstraintDef) ToPBVersion() TableDefPB

+ type ConstraintDefPB struct

+ Cts []ConstraintPB

+ func (*ConstraintDefPB) Descriptor() ([]byte, []int)

+ func (*ConstraintDefPB) ProtoMessage()

+ func (def *ConstraintDefPB) FromPBVersion() *ConstraintDef

+ func (m *ConstraintDefPB) GetCts() []ConstraintPB

+ func (m *ConstraintDefPB) Marshal() (dAtA []byte, err error)

+ func (m *ConstraintDefPB) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConstraintDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConstraintDefPB) ProtoSize() (n int)

+ func (m *ConstraintDefPB) Reset()

+ func (m *ConstraintDefPB) String() string

+ func (m *ConstraintDefPB) Unmarshal(dAtA []byte) error

+ func (m *ConstraintDefPB) XXX_DiscardUnknown()

+ func (m *ConstraintDefPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConstraintDefPB) XXX_Merge(src proto.Message)

+ func (m *ConstraintDefPB) XXX_Size() int

+ func (m *ConstraintDefPB) XXX_Unmarshal(b []byte) error

+ type ConstraintPB struct

+ Ct isConstraintPB_Ct

+ func (*ConstraintPB) Descriptor() ([]byte, []int)

+ func (*ConstraintPB) ProtoMessage()

+ func (*ConstraintPB) XXX_OneofWrappers() []interface{}

+ func (def *ConstraintPB) FromPBVersion() Constraint

+ func (m *ConstraintPB) GetCt() isConstraintPB_Ct

+ func (m *ConstraintPB) GetForeignKeyDef() *ForeignKeyDef

+ func (m *ConstraintPB) GetIndexDef() *IndexDef

+ func (m *ConstraintPB) GetPrimaryKeyDef() *PrimaryKeyDef

+ func (m *ConstraintPB) GetRefChildTableDef() *RefChildTableDef

+ func (m *ConstraintPB) Marshal() (dAtA []byte, err error)

+ func (m *ConstraintPB) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConstraintPB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConstraintPB) ProtoSize() (n int)

+ func (m *ConstraintPB) Reset()

+ func (m *ConstraintPB) String() string

+ func (m *ConstraintPB) Unmarshal(dAtA []byte) error

+ func (m *ConstraintPB) XXX_DiscardUnknown()

+ func (m *ConstraintPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConstraintPB) XXX_Merge(src proto.Message)

+ func (m *ConstraintPB) XXX_Size() int

+ func (m *ConstraintPB) XXX_Unmarshal(b []byte) error

+ type ConstraintPB_ForeignKeyDef struct

+ ForeignKeyDef *ForeignKeyDef

+ func (m *ConstraintPB_ForeignKeyDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConstraintPB_ForeignKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConstraintPB_ForeignKeyDef) ProtoSize() (n int)

+ type ConstraintPB_IndexDef struct

+ IndexDef *IndexDef

+ func (m *ConstraintPB_IndexDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConstraintPB_IndexDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConstraintPB_IndexDef) ProtoSize() (n int)

+ type ConstraintPB_PrimaryKeyDef struct

+ PrimaryKeyDef *PrimaryKeyDef

+ func (m *ConstraintPB_PrimaryKeyDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConstraintPB_PrimaryKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConstraintPB_PrimaryKeyDef) ProtoSize() (n int)

+ type ConstraintPB_RefChildTableDef struct

+ RefChildTableDef *RefChildTableDef

+ func (m *ConstraintPB_RefChildTableDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConstraintPB_RefChildTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConstraintPB_RefChildTableDef) ProtoSize() (n int)

type Database

+ GetCreateSql func(context.Context) string

+ IsSubscription func(context.Context) bool

type Engine

+ AllocateIDByKey func(ctx context.Context, key string) (uint64, error)

+ type EngineType int8

+ const Disttae

+ const Memory

+ const UNKNOWN

type EntireEngine

+ func (e *EntireEngine) AllocateIDByKey(ctx context.Context, key string) (uint64, error)

type ForeignKeyDef

+ func (*ForeignKeyDef) Descriptor() ([]byte, []int)

+ func (*ForeignKeyDef) ProtoMessage()

+ func (def *ForeignKeyDef) ToPBVersion() ConstraintPB

+ func (m *ForeignKeyDef) GetFkeys() []*plan.ForeignKeyDef

+ func (m *ForeignKeyDef) Marshal() (dAtA []byte, err error)

+ func (m *ForeignKeyDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ForeignKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ForeignKeyDef) ProtoSize() (n int)

+ func (m *ForeignKeyDef) Reset()

+ func (m *ForeignKeyDef) String() string

+ func (m *ForeignKeyDef) Unmarshal(dAtA []byte) error

+ func (m *ForeignKeyDef) XXX_DiscardUnknown()

+ func (m *ForeignKeyDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ForeignKeyDef) XXX_Merge(src proto.Message)

+ func (m *ForeignKeyDef) XXX_Size() int

+ func (m *ForeignKeyDef) XXX_Unmarshal(b []byte) error

type IndexDef

+ func (*IndexDef) Descriptor() ([]byte, []int)

+ func (*IndexDef) ProtoMessage()

+ func (def *IndexDef) ToPBVersion() ConstraintPB

+ func (m *IndexDef) GetIndexes() []*plan.IndexDef

+ func (m *IndexDef) Marshal() (dAtA []byte, err error)

+ func (m *IndexDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *IndexDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IndexDef) ProtoSize() (n int)

+ func (m *IndexDef) Reset()

+ func (m *IndexDef) String() string

+ func (m *IndexDef) Unmarshal(dAtA []byte) error

+ func (m *IndexDef) XXX_DiscardUnknown()

+ func (m *IndexDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IndexDef) XXX_Merge(src proto.Message)

+ func (m *IndexDef) XXX_Size() int

+ func (m *IndexDef) XXX_Unmarshal(b []byte) error

type IndexTableDef

+ func (*IndexTableDef) Descriptor() ([]byte, []int)

+ func (*IndexTableDef) ProtoMessage()

+ func (def *IndexTableDef) ToPBVersion() TableDefPB

+ func (m *IndexTableDef) GetColNames() []string

+ func (m *IndexTableDef) GetName() string

+ func (m *IndexTableDef) GetTyp() IndexT

+ func (m *IndexTableDef) Marshal() (dAtA []byte, err error)

+ func (m *IndexTableDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *IndexTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IndexTableDef) ProtoSize() (n int)

+ func (m *IndexTableDef) Reset()

+ func (m *IndexTableDef) String() string

+ func (m *IndexTableDef) Unmarshal(dAtA []byte) error

+ func (m *IndexTableDef) XXX_DiscardUnknown()

+ func (m *IndexTableDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IndexTableDef) XXX_Merge(src proto.Message)

+ func (m *IndexTableDef) XXX_Size() int

+ func (m *IndexTableDef) XXX_Unmarshal(b []byte) error

type PartitionDef

+ Partitioned int8

+ func (*PartitionDef) Descriptor() ([]byte, []int)

+ func (*PartitionDef) ProtoMessage()

+ func (def *PartitionDef) ToPBVersion() TableDefPB

+ func (m *PartitionDef) GetPartition() string

+ func (m *PartitionDef) Marshal() (dAtA []byte, err error)

+ func (m *PartitionDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *PartitionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PartitionDef) ProtoSize() (n int)

+ func (m *PartitionDef) Reset()

+ func (m *PartitionDef) String() string

+ func (m *PartitionDef) Unmarshal(dAtA []byte) error

+ func (m *PartitionDef) XXX_DiscardUnknown()

+ func (m *PartitionDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PartitionDef) XXX_Merge(src proto.Message)

+ func (m *PartitionDef) XXX_Size() int

+ func (m *PartitionDef) XXX_Unmarshal(b []byte) error

type PrimaryKeyDef

+ func (*PrimaryKeyDef) Descriptor() ([]byte, []int)

+ func (*PrimaryKeyDef) ProtoMessage()

+ func (def *PrimaryKeyDef) ToPBVersion() ConstraintPB

+ func (m *PrimaryKeyDef) GetPkey() *plan.PrimaryKeyDef

+ func (m *PrimaryKeyDef) Marshal() (dAtA []byte, err error)

+ func (m *PrimaryKeyDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *PrimaryKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PrimaryKeyDef) ProtoSize() (n int)

+ func (m *PrimaryKeyDef) Reset()

+ func (m *PrimaryKeyDef) String() string

+ func (m *PrimaryKeyDef) Unmarshal(dAtA []byte) error

+ func (m *PrimaryKeyDef) XXX_DiscardUnknown()

+ func (m *PrimaryKeyDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrimaryKeyDef) XXX_Merge(src proto.Message)

+ func (m *PrimaryKeyDef) XXX_Size() int

+ func (m *PrimaryKeyDef) XXX_Unmarshal(b []byte) error

type PropertiesDef

+ func (*PropertiesDef) Descriptor() ([]byte, []int)

+ func (*PropertiesDef) ProtoMessage()

+ func (def *PropertiesDef) ToPBVersion() TableDefPB

+ func (m *PropertiesDef) GetProperties() []Property

+ func (m *PropertiesDef) Marshal() (dAtA []byte, err error)

+ func (m *PropertiesDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *PropertiesDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PropertiesDef) ProtoSize() (n int)

+ func (m *PropertiesDef) Reset()

+ func (m *PropertiesDef) String() string

+ func (m *PropertiesDef) Unmarshal(dAtA []byte) error

+ func (m *PropertiesDef) XXX_DiscardUnknown()

+ func (m *PropertiesDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PropertiesDef) XXX_Merge(src proto.Message)

+ func (m *PropertiesDef) XXX_Size() int

+ func (m *PropertiesDef) XXX_Unmarshal(b []byte) error

type Property

+ func (*Property) Descriptor() ([]byte, []int)

+ func (*Property) ProtoMessage()

+ func (m *Property) GetKey() string

+ func (m *Property) GetValue() string

+ func (m *Property) Marshal() (dAtA []byte, err error)

+ func (m *Property) MarshalTo(dAtA []byte) (int, error)

+ func (m *Property) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Property) ProtoSize() (n int)

+ func (m *Property) Reset()

+ func (m *Property) String() string

+ func (m *Property) Unmarshal(dAtA []byte) error

+ func (m *Property) XXX_DiscardUnknown()

+ func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Property) XXX_Merge(src proto.Message)

+ func (m *Property) XXX_Size() int

+ func (m *Property) XXX_Unmarshal(b []byte) error

type RefChildTableDef

+ func (*RefChildTableDef) Descriptor() ([]byte, []int)

+ func (*RefChildTableDef) ProtoMessage()

+ func (def *RefChildTableDef) ToPBVersion() ConstraintPB

+ func (m *RefChildTableDef) GetTables() []uint64

+ func (m *RefChildTableDef) Marshal() (dAtA []byte, err error)

+ func (m *RefChildTableDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *RefChildTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RefChildTableDef) ProtoSize() (n int)

+ func (m *RefChildTableDef) Reset()

+ func (m *RefChildTableDef) String() string

+ func (m *RefChildTableDef) Unmarshal(dAtA []byte) error

+ func (m *RefChildTableDef) XXX_DiscardUnknown()

+ func (m *RefChildTableDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RefChildTableDef) XXX_Merge(src proto.Message)

+ func (m *RefChildTableDef) XXX_Size() int

+ func (m *RefChildTableDef) XXX_Unmarshal(b []byte) error

type Relation

+ AlterTable func(ctx context.Context, c *ConstraintDef, constraint [][]byte) error

+ ApplyRuntimeFilters func(context.Context, [][]byte, []*plan.Expr, []*pipeline.RuntimeFilter) ([][]byte, error)

+ GetColumMetadataScanInfo func(ctx context.Context, name string) ([]*plan.MetadataScanInfo, error)

+ GetDBID func(context.Context) uint64

+ GetEngineType func() EngineType

+ GetTableName func() string

+ PrimaryKeysMayBeModified func(ctx context.Context, from types.TS, to types.TS, keyVector *vector.Vector) (bool, error)

type TableDef

+ ToPBVersion func() TableDefPB

+ type TableDefPB struct

+ Def isTableDefPB_Def

+ func (*TableDefPB) Descriptor() ([]byte, []int)

+ func (*TableDefPB) ProtoMessage()

+ func (*TableDefPB) XXX_OneofWrappers() []interface{}

+ func (def *TableDefPB) FromPBVersion() TableDef

+ func (m *TableDefPB) GetAttributeDef() *AttributeDef

+ func (m *TableDefPB) GetClusterByDef() *ClusterByDef

+ func (m *TableDefPB) GetCommentDef() *CommentDef

+ func (m *TableDefPB) GetConstraintDefPB() *ConstraintDefPB

+ func (m *TableDefPB) GetDef() isTableDefPB_Def

+ func (m *TableDefPB) GetIndexTableDef() *IndexTableDef

+ func (m *TableDefPB) GetPartitionDef() *PartitionDef

+ func (m *TableDefPB) GetPropertiesDef() *PropertiesDef

+ func (m *TableDefPB) GetVersionDef() *VersionDef

+ func (m *TableDefPB) GetViewDef() *ViewDef

+ func (m *TableDefPB) Marshal() (dAtA []byte, err error)

+ func (m *TableDefPB) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB) ProtoSize() (n int)

+ func (m *TableDefPB) Reset()

+ func (m *TableDefPB) String() string

+ func (m *TableDefPB) Unmarshal(dAtA []byte) error

+ func (m *TableDefPB) XXX_DiscardUnknown()

+ func (m *TableDefPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TableDefPB) XXX_Merge(src proto.Message)

+ func (m *TableDefPB) XXX_Size() int

+ func (m *TableDefPB) XXX_Unmarshal(b []byte) error

+ type TableDefPB_AttributeDef struct

+ AttributeDef *AttributeDef

+ func (m *TableDefPB_AttributeDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_AttributeDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_AttributeDef) ProtoSize() (n int)

+ type TableDefPB_ClusterByDef struct

+ ClusterByDef *ClusterByDef

+ func (m *TableDefPB_ClusterByDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_ClusterByDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_ClusterByDef) ProtoSize() (n int)

+ type TableDefPB_CommentDef struct

+ CommentDef *CommentDef

+ func (m *TableDefPB_CommentDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_CommentDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_CommentDef) ProtoSize() (n int)

+ type TableDefPB_ConstraintDefPB struct

+ ConstraintDefPB *ConstraintDefPB

+ func (m *TableDefPB_ConstraintDefPB) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_ConstraintDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_ConstraintDefPB) ProtoSize() (n int)

+ type TableDefPB_IndexTableDef struct

+ IndexTableDef *IndexTableDef

+ func (m *TableDefPB_IndexTableDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_IndexTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_IndexTableDef) ProtoSize() (n int)

+ type TableDefPB_PartitionDef struct

+ PartitionDef *PartitionDef

+ func (m *TableDefPB_PartitionDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_PartitionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_PartitionDef) ProtoSize() (n int)

+ type TableDefPB_PropertiesDef struct

+ PropertiesDef *PropertiesDef

+ func (m *TableDefPB_PropertiesDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_PropertiesDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_PropertiesDef) ProtoSize() (n int)

+ type TableDefPB_VersionDef struct

+ VersionDef *VersionDef

+ func (m *TableDefPB_VersionDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_VersionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_VersionDef) ProtoSize() (n int)

+ type TableDefPB_ViewDef struct

+ ViewDef *ViewDef

+ func (m *TableDefPB_ViewDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDefPB_ViewDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDefPB_ViewDef) ProtoSize() (n int)

+ type VectorPool interface

+ GetVector func(typ types.Type) *vector.Vector

+ PutBatch func(bat *batch.Batch)

+ type VersionDef struct

+ Version uint32

+ func (*VersionDef) Descriptor() ([]byte, []int)

+ func (*VersionDef) ProtoMessage()

+ func (def *VersionDef) ToPBVersion() TableDefPB

+ func (m *VersionDef) GetVersion() uint32

+ func (m *VersionDef) Marshal() (dAtA []byte, err error)

+ func (m *VersionDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *VersionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VersionDef) ProtoSize() (n int)

+ func (m *VersionDef) Reset()

+ func (m *VersionDef) String() string

+ func (m *VersionDef) Unmarshal(dAtA []byte) error

+ func (m *VersionDef) XXX_DiscardUnknown()

+ func (m *VersionDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VersionDef) XXX_Merge(src proto.Message)

+ func (m *VersionDef) XXX_Size() int

+ func (m *VersionDef) XXX_Unmarshal(b []byte) error

type ViewDef

+ func (*ViewDef) Descriptor() ([]byte, []int)

+ func (*ViewDef) ProtoMessage()

+ func (def *ViewDef) ToPBVersion() TableDefPB

+ func (m *ViewDef) GetView() string

+ func (m *ViewDef) Marshal() (dAtA []byte, err error)

+ func (m *ViewDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ViewDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ViewDef) ProtoSize() (n int)

+ func (m *ViewDef) Reset()

+ func (m *ViewDef) String() string

+ func (m *ViewDef) Unmarshal(dAtA []byte) error

+ func (m *ViewDef) XXX_DiscardUnknown()

+ func (m *ViewDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ViewDef) XXX_Merge(src proto.Message)

+ func (m *ViewDef) XXX_Size() int

+ func (m *ViewDef) XXX_Unmarshal(b []byte) error

v0.7.0

Feb 18, 2023

Changes in this version

+ func GetTempTableName(DbName string, TblName string) string

type Attribute

+ ClusterBy bool

+ ID uint64

+ type ClusterByDef struct

+ Name string

+ type Constraint interface

+ type ConstraintDef struct

+ Cts []Constraint

+ func (c *ConstraintDef) GetPrimaryKeyDef() *PrimaryKeyDef

+ func (c *ConstraintDef) MarshalBinary() (data []byte, err error)

+ func (c *ConstraintDef) UnmarshalBinary(data []byte) error

+ type ConstraintType int8

+ const ForeignKey

+ const Index

+ const PrimaryKey

+ const RefChildTable

type Engine

+ GetNameById func(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, err error)

+ GetRelationById func(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, rel Relation, err error)

+ type EntireEngine struct

+ Engine Engine

+ TempEngine Engine

+ func (e *EntireEngine) Commit(ctx context.Context, op client.TxnOperator) error

+ func (e *EntireEngine) Create(ctx context.Context, databaseName string, op client.TxnOperator) error

+ func (e *EntireEngine) Database(ctx context.Context, databaseName string, op client.TxnOperator) (Database, error)

+ func (e *EntireEngine) Databases(ctx context.Context, op client.TxnOperator) (databaseNames []string, err error)

+ func (e *EntireEngine) Delete(ctx context.Context, databaseName string, op client.TxnOperator) error

+ func (e *EntireEngine) GetNameById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, err error)

+ func (e *EntireEngine) GetRelationById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, rel Relation, err error)

+ func (e *EntireEngine) Hints() Hints

+ func (e *EntireEngine) New(ctx context.Context, op client.TxnOperator) error

+ func (e *EntireEngine) NewBlockReader(ctx context.Context, num int, ts timestamp.Timestamp, expr *plan.Expr, ...) ([]Reader, error)

+ func (e *EntireEngine) Nodes() (cnNodes Nodes, err error)

+ func (e *EntireEngine) Rollback(ctx context.Context, op client.TxnOperator) error

+ type ForeignKeyDef struct

+ Fkeys []*plan.ForeignKeyDef

+ type IndexDef struct

+ Indexes []*plan.IndexDef

type Node

+ Rel Relation

+ type PrimaryKeyDef struct

+ Pkey *plan.PrimaryKeyDef

+ type RefChildTableDef struct

+ Tables []uint64

type Relation

+ MaxAndMinValues func(ctx context.Context) ([][2]any, []uint8, error)

+ UpdateConstraint func(context.Context, *ConstraintDef) error

type Statistics

+ Stats func(ctx context.Context, expr *plan.Expr) (*plan.Stats, error)

v0.6.0

Nov 29, 2022

Changes in this version

type Attribute

+ AutoIncrement bool

+ Comment string

+ IsHidden bool

+ IsRowId bool

+ OnUpdate *plan.OnUpdate

+ type ComputeIndexDef struct

+ Fields [][]string

+ IndexNames []string

+ TableNames []string

+ Uniques []bool

type Database

+ GetDatabaseId func(context.Context) string

+ Truncate func(context.Context, string) error

type Engine

+ Commit func(ctx context.Context, op client.TxnOperator) error

+ Hints func() Hints

+ New func(ctx context.Context, op client.TxnOperator) error

+ NewBlockReader func(ctx context.Context, num int, ts timestamp.Timestamp, expr *plan.Expr, ...) ([]Reader, error)

+ Nodes func() (cnNodes Nodes, err error)

+ Rollback func(ctx context.Context, op client.TxnOperator) error

+ type GetClusterDetailsFunc = func() (logservicepb.ClusterDetails, error)

+ type Hints struct

+ CommitOrRollbackTimeout time.Duration

type Node

+ Mcpu int

+ type PartitionDef struct

+ Partition string

type Reader

+ Close func() error

type Relation

+ GetHideKeys func(context.Context) ([]*Attribute, error)

+ GetTableID func(context.Context) string

+ Ranges func(context.Context, *plan.Expr) ([][]byte, error)

+ TableColumns func(ctx context.Context) ([]*Attribute, error)

+ type ViewDef struct

+ View string

v0.5.1

Aug 17, 2022

v0.5.0

Jul 14, 2022

Changes in this version

type Relation

+ Delete func(uint64, *vector.Vector, string, Snapshot) error

+ GetHideKey func(Snapshot) *Attribute

+ GetPrimaryKeys func(Snapshot) []*Attribute

+ Truncate func(Snapshot) (uint64, error)

+ Update func(uint64, *batch.Batch, Snapshot) error

+ type Snapshot []byte

v0.4.0

May 5, 2022

Changes in this version

+ var EmptyDefaultExpr = DefaultExpr

+ type Attribute struct

+ Alg compress.T

+ Default DefaultExpr

+ Name string

+ Primary bool

+ Type types.Type

+ func (node *Attribute) Format(buf *bytes.Buffer)

+ func (node Attribute) GetDefaultExpr() (interface{}, bool)

+ func (node Attribute) HasDefaultExpr() bool

+ type AttributeDef struct

+ Attr Attribute

+ func (node *AttributeDef) Format(buf *bytes.Buffer)

+ type CommentDef struct

+ Comment string

+ type Database interface

+ Create func(uint64, string, []TableDef) error

+ Delete func(uint64, string) error

+ Relation func(string) (Relation, error)

+ Relations func() []string

+ type DefaultExpr struct

+ Exist bool

+ IsNull bool

+ Value interface{}

+ func MakeDefaultExpr(exist bool, value interface{}, isNull bool) DefaultExpr

+ type Engine interface

+ Create func(uint64, string, int) error

+ Database func(string) (Database, error)

+ Databases func() []string

+ Delete func(uint64, string) error

+ Node func(string) *NodeInfo

+ type Filter interface

+ Btw func(string, interface{}, interface{}) (*roaring.Bitmap, error)

+ Eq func(string, interface{}) (*roaring.Bitmap, error)

+ Ge func(string, interface{}) (*roaring.Bitmap, error)

+ Gt func(string, interface{}) (*roaring.Bitmap, error)

+ Le func(string, interface{}) (*roaring.Bitmap, error)

+ Lt func(string, interface{}) (*roaring.Bitmap, error)

+ Ne func(string, interface{}) (*roaring.Bitmap, error)

+ type IndexT int

+ const BsiIndex

+ const Invalid

+ const ZoneMap

+ func (node IndexT) ToString() string

+ type IndexTableDef struct

+ ColNames []string

+ Name string

+ Typ IndexT

+ func (node *IndexTableDef) Format(buf *bytes.Buffer)

+ type ListPartition struct

+ Extends []extend.Extend

+ Name string

+ Subpartition *PartitionByDef

+ type Node struct

+ Addr string

+ Data []byte

+ Id string

+ func (n Node) String() string

+ type NodeInfo struct

+ Mcpu int

+ type Nodes []Node

+ type PartitionByDef struct

+ Fields []string

+ List []ListPartition

+ Range []RangePartition

+ type PrimaryIndexDef struct

+ Names []string

+ func (node *PrimaryIndexDef) Format(buf *bytes.Buffer)

+ type PropertiesDef struct

+ Properties []Property

+ type Property struct

+ Key string

+ Value string

+ type RangePartition struct

+ From []extend.Extend

+ Name string

+ Subpartition *PartitionByDef

+ To []extend.Extend

+ type Reader interface

+ Read func([]uint64, []string) (*batch.Batch, error)

+ type Relation interface

+ AddTableDef func(uint64, TableDef) error

+ Close func()

+ DelTableDef func(uint64, TableDef) error

+ GetPriKeyOrHideKey func() ([]Attribute, bool)

+ ID func() string

+ NewReader func(int, extend.Extend, []byte) []Reader

+ Nodes func() Nodes

+ TableDefs func() []TableDef

+ Write func(uint64, *batch.Batch) error

+ type SparseFilter interface

+ Btw func(string, interface{}, interface{}) (Reader, error)

+ Eq func(string, interface{}) (Reader, error)

+ Ge func(string, interface{}) (Reader, error)

+ Gt func(string, interface{}) (Reader, error)

+ Le func(string, interface{}) (Reader, error)

+ Lt func(string, interface{}) (Reader, error)

+ Ne func(string, interface{}) (Reader, error)

+ type Statistics interface

+ Rows func() int64

+ Size func(string) int64

+ type Summarizer interface

+ Count func(string, *roaring.Bitmap) (uint64, error)

+ Max func(string, *roaring.Bitmap) (interface{}, error)

+ Min func(string, *roaring.Bitmap) (interface{}, error)

+ NullCount func(string, *roaring.Bitmap) (uint64, error)

+ Sum func(string, *roaring.Bitmap) (int64, uint64, error)

+ type TableDef interface

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