memoryengine

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

Changes in this version

type CompilerContext

+ func (c *CompilerContext) GetLowerCaseTableNames() int64

v1.2.1-20240709

Jul 9, 2024

v1.2.0

May 17, 2024

Changes in this version

type BindedEngine

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

+ func (b *BindedEngine) TryToSubscribeTable(ctx context.Context, dbID, tbID uint64) error

+ func (b *BindedEngine) UnsubscribeTable(ctx context.Context, dbID, tbID uint64) error

type CompilerContext

+ func (c *CompilerContext) CheckTimeStampValid(ts int64) (bool, error)

+ func (c *CompilerContext) GetSnapshot() *plan.Snapshot

+ func (c *CompilerContext) GetViews() []string

+ func (c *CompilerContext) ReplacePlan(execPlan *planpb.Execute) (*planpb.Plan, tree.Statement, error)

+ func (c *CompilerContext) ResolveSnapshotWithSnapshotName(snapshotName string) (*plan.Snapshot, error)

+ func (c *CompilerContext) ResolveSubscriptionTableById(tableId uint64, pubmeta *plan.SubscriptionMeta) (*plan.ObjectRef, *plan.TableDef)

+ func (c *CompilerContext) SetSnapshot(snapshot *plan.Snapshot)

+ func (c *CompilerContext) SetViews(views []string)

type Engine

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

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

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

+ type ShardIdSlice []byte

+ func (s *ShardIdSlice) Append(bs []byte)

+ func (s *ShardIdSlice) Get(i int) uint64

+ func (s *ShardIdSlice) GetAllBytes() []byte

+ func (s *ShardIdSlice) GetBytes(i int) []byte

+ func (s *ShardIdSlice) Len() int

+ func (s *ShardIdSlice) SetBytes(bs []byte)

+ func (s *ShardIdSlice) Size() int

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

type Table

+ func (t *Table) ApproxObjectsNum(ctx context.Context) int

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

type TableReader

+ func (t *TableReader) GetOrderBy() []*plan.OrderBySpec

+ func (t *TableReader) SetFilterZM(objectio.ZoneMap)

+ func (t *TableReader) SetOrderBy([]*plan.OrderBySpec)

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

Changes in this version

type Table

+ func (t *Table) CopyTableDef(ctx context.Context) *plan.TableDef

v1.1.1

Feb 2, 2024

Changes in this version

type Table

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

v1.1.0

Dec 29, 2023

Changes in this version

type Table

+ func (t *Table) GetTableDef(ctx 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 Table

+ func (t *Table) UpdateObjectInfos(_ context.Context) error

type TableReader

+ func (t *TableReader) Count() *engine.ReaderCount

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 IDBytes

+ const LengthBytes

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

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

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

type AccessInfo

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

+ func (*AccessInfo) ProtoMessage()

+ func (m *AccessInfo) GetAccountID() uint32

+ func (m *AccessInfo) GetRoleID() uint32

+ func (m *AccessInfo) GetUserID() uint32

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

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

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

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

+ func (m *AccessInfo) Reset()

+ func (m *AccessInfo) String() string

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

+ func (m *AccessInfo) XXX_DiscardUnknown()

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

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

+ func (m *AccessInfo) XXX_Size() int

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

type AddTableDefReq

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

+ func (*AddTableDefReq) ProtoMessage()

+ func (m *AddTableDefReq) GetDatabaseName() string

+ func (m *AddTableDefReq) GetTableID() ID

+ func (m *AddTableDefReq) GetTableName() string

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

+ func (m *AddTableDefReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *AddTableDefReq) Reset()

+ func (m *AddTableDefReq) String() string

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

+ func (m *AddTableDefReq) UnmarshalBinary(data []byte) error

+ func (m *AddTableDefReq) XXX_DiscardUnknown()

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

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

+ func (m *AddTableDefReq) XXX_Size() int

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

type AddTableDefResp

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

+ func (*AddTableDefResp) ProtoMessage()

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

+ func (m *AddTableDefResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *AddTableDefResp) Reset()

+ func (m *AddTableDefResp) String() string

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

+ func (m *AddTableDefResp) UnmarshalBinary(data []byte) error

+ func (m *AddTableDefResp) XXX_DiscardUnknown()

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

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

+ func (m *AddTableDefResp) XXX_Size() int

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

type BindedEngine

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

type CloseTableIterReq

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

+ func (*CloseTableIterReq) ProtoMessage()

+ func (m *CloseTableIterReq) GetIterID() ID

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

+ func (m *CloseTableIterReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *CloseTableIterReq) Reset()

+ func (m *CloseTableIterReq) String() string

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

+ func (m *CloseTableIterReq) UnmarshalBinary(data []byte) error

+ func (m *CloseTableIterReq) XXX_DiscardUnknown()

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

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

+ func (m *CloseTableIterReq) XXX_Size() int

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

type CloseTableIterResp

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

+ func (*CloseTableIterResp) ProtoMessage()

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

+ func (m *CloseTableIterResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *CloseTableIterResp) Reset()

+ func (m *CloseTableIterResp) String() string

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

+ func (m *CloseTableIterResp) UnmarshalBinary(data []byte) error

+ func (m *CloseTableIterResp) XXX_DiscardUnknown()

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

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

+ func (m *CloseTableIterResp) XXX_Size() int

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

type CompilerContext

+ func (*CompilerContext) GetStatsCache() *plan.StatsCache

+ func (c *CompilerContext) CheckSubscriptionValid(subName, accName string, pubName string) error

+ func (c *CompilerContext) GetDatabaseId(dbName string) (uint64, error)

+ func (c *CompilerContext) GetQueryingSubscription() *plan.SubscriptionMeta

+ func (c *CompilerContext) GetSubscriptionMeta(dbName string) (*plan.SubscriptionMeta, error)

+ func (c *CompilerContext) IsPublishing(dbName string) (bool, error)

+ func (c *CompilerContext) ResolveUdf(name string, ast []*plan.Expr) (string, error)

+ func (c *CompilerContext) SetQueryingSubscription(meta *plan.SubscriptionMeta)

type CreateDatabaseReq

+ CreateSql string

+ Typ string

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

+ func (*CreateDatabaseReq) ProtoMessage()

+ func (m *CreateDatabaseReq) GetAccessInfo() AccessInfo

+ func (m *CreateDatabaseReq) GetID() ID

+ func (m *CreateDatabaseReq) GetName() string

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

+ func (m *CreateDatabaseReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *CreateDatabaseReq) Reset()

+ func (m *CreateDatabaseReq) String() string

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

+ func (m *CreateDatabaseReq) UnmarshalBinary(data []byte) error

+ func (m *CreateDatabaseReq) XXX_DiscardUnknown()

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

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

+ func (m *CreateDatabaseReq) XXX_Size() int

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

type CreateDatabaseResp

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

+ func (*CreateDatabaseResp) ProtoMessage()

+ func (m *CreateDatabaseResp) GetID() ID

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

+ func (m *CreateDatabaseResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *CreateDatabaseResp) Reset()

+ func (m *CreateDatabaseResp) String() string

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

+ func (m *CreateDatabaseResp) UnmarshalBinary(data []byte) error

+ func (m *CreateDatabaseResp) XXX_DiscardUnknown()

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

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

+ func (m *CreateDatabaseResp) XXX_Size() int

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

type CreateRelationReq

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

+ func (*CreateRelationReq) ProtoMessage()

+ func (m *CreateRelationReq) GetDatabaseID() ID

+ func (m *CreateRelationReq) GetDatabaseName() string

+ func (m *CreateRelationReq) GetID() ID

+ func (m *CreateRelationReq) GetName() string

+ func (m *CreateRelationReq) GetType() RelationType

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

+ func (m *CreateRelationReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *CreateRelationReq) Reset()

+ func (m *CreateRelationReq) String() string

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

+ func (m *CreateRelationReq) UnmarshalBinary(data []byte) error

+ func (m *CreateRelationReq) XXX_DiscardUnknown()

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

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

+ func (m *CreateRelationReq) XXX_Size() int

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

type CreateRelationResp

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

+ func (*CreateRelationResp) ProtoMessage()

+ func (m *CreateRelationResp) GetID() ID

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

+ func (m *CreateRelationResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *CreateRelationResp) Reset()

+ func (m *CreateRelationResp) String() string

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

+ func (m *CreateRelationResp) UnmarshalBinary(data []byte) error

+ func (m *CreateRelationResp) XXX_DiscardUnknown()

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

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

+ func (m *CreateRelationResp) XXX_Size() int

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

type Database

+ func (d *Database) GetCreateSql(ctx context.Context) string

+ func (d *Database) IsSubscription(ctx context.Context) bool

type DelTableDefReq

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

+ func (*DelTableDefReq) ProtoMessage()

+ func (m *DelTableDefReq) GetDatabaseName() string

+ func (m *DelTableDefReq) GetTableID() ID

+ func (m *DelTableDefReq) GetTableName() string

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

+ func (m *DelTableDefReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *DelTableDefReq) Reset()

+ func (m *DelTableDefReq) String() string

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

+ func (m *DelTableDefReq) UnmarshalBinary(data []byte) error

+ func (m *DelTableDefReq) XXX_DiscardUnknown()

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

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

+ func (m *DelTableDefReq) XXX_Size() int

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

type DelTableDefResp

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

+ func (*DelTableDefResp) ProtoMessage()

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

+ func (m *DelTableDefResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *DelTableDefResp) Reset()

+ func (m *DelTableDefResp) String() string

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

+ func (m *DelTableDefResp) UnmarshalBinary(data []byte) error

+ func (m *DelTableDefResp) XXX_DiscardUnknown()

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

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

+ func (m *DelTableDefResp) XXX_Size() int

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

type DeleteDatabaseReq

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

+ func (*DeleteDatabaseReq) ProtoMessage()

+ func (m *DeleteDatabaseReq) GetAccessInfo() AccessInfo

+ func (m *DeleteDatabaseReq) GetName() string

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

+ func (m *DeleteDatabaseReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *DeleteDatabaseReq) Reset()

+ func (m *DeleteDatabaseReq) String() string

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

+ func (m *DeleteDatabaseReq) UnmarshalBinary(data []byte) error

+ func (m *DeleteDatabaseReq) XXX_DiscardUnknown()

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

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

+ func (m *DeleteDatabaseReq) XXX_Size() int

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

type DeleteDatabaseResp

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

+ func (*DeleteDatabaseResp) ProtoMessage()

+ func (m *DeleteDatabaseResp) GetID() ID

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

+ func (m *DeleteDatabaseResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *DeleteDatabaseResp) Reset()

+ func (m *DeleteDatabaseResp) String() string

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

+ func (m *DeleteDatabaseResp) UnmarshalBinary(data []byte) error

+ func (m *DeleteDatabaseResp) XXX_DiscardUnknown()

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

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

+ func (m *DeleteDatabaseResp) XXX_Size() int

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

type DeleteRelationReq

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

+ func (*DeleteRelationReq) ProtoMessage()

+ func (m *DeleteRelationReq) GetDatabaseID() ID

+ func (m *DeleteRelationReq) GetDatabaseName() string

+ func (m *DeleteRelationReq) GetName() string

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

+ func (m *DeleteRelationReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *DeleteRelationReq) Reset()

+ func (m *DeleteRelationReq) String() string

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

+ func (m *DeleteRelationReq) UnmarshalBinary(data []byte) error

+ func (m *DeleteRelationReq) XXX_DiscardUnknown()

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

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

+ func (m *DeleteRelationReq) XXX_Size() int

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

type DeleteRelationResp

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

+ func (*DeleteRelationResp) ProtoMessage()

+ func (m *DeleteRelationResp) GetID() ID

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

+ func (m *DeleteRelationResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *DeleteRelationResp) Reset()

+ func (m *DeleteRelationResp) String() string

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

+ func (m *DeleteRelationResp) UnmarshalBinary(data []byte) error

+ func (m *DeleteRelationResp) XXX_DiscardUnknown()

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

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

+ func (m *DeleteRelationResp) XXX_Size() int

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

type DeleteReq

+ func (r *DeleteReq) MarshalBinary() ([]byte, error)

+ func (r *DeleteReq) UnmarshalBinary(data []byte) error

type DeleteResp

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

+ func (*DeleteResp) ProtoMessage()

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

+ func (m *DeleteResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *DeleteResp) Reset()

+ func (m *DeleteResp) String() string

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

+ func (m *DeleteResp) UnmarshalBinary(data []byte) error

+ func (m *DeleteResp) XXX_DiscardUnknown()

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

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

+ func (m *DeleteResp) XXX_Size() int

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

type Engine

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

type GetDatabasesReq

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

+ func (*GetDatabasesReq) ProtoMessage()

+ func (m *GetDatabasesReq) GetAccessInfo() AccessInfo

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

+ func (m *GetDatabasesReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetDatabasesReq) Reset()

+ func (m *GetDatabasesReq) String() string

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

+ func (m *GetDatabasesReq) UnmarshalBinary(data []byte) error

+ func (m *GetDatabasesReq) XXX_DiscardUnknown()

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

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

+ func (m *GetDatabasesReq) XXX_Size() int

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

type GetDatabasesResp

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

+ func (*GetDatabasesResp) ProtoMessage()

+ func (m *GetDatabasesResp) GetNames() []string

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

+ func (m *GetDatabasesResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetDatabasesResp) Reset()

+ func (m *GetDatabasesResp) String() string

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

+ func (m *GetDatabasesResp) UnmarshalBinary(data []byte) error

+ func (m *GetDatabasesResp) XXX_DiscardUnknown()

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

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

+ func (m *GetDatabasesResp) XXX_Size() int

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

type GetHiddenKeysReq

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

+ func (*GetHiddenKeysReq) ProtoMessage()

+ func (m *GetHiddenKeysReq) GetTableID() ID

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

+ func (m *GetHiddenKeysReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetHiddenKeysReq) Reset()

+ func (m *GetHiddenKeysReq) String() string

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

+ func (m *GetHiddenKeysReq) UnmarshalBinary(data []byte) error

+ func (m *GetHiddenKeysReq) XXX_DiscardUnknown()

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

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

+ func (m *GetHiddenKeysReq) XXX_Size() int

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

type GetHiddenKeysResp

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

+ func (*GetHiddenKeysResp) ProtoMessage()

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

+ func (m *GetHiddenKeysResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetHiddenKeysResp) Reset()

+ func (m *GetHiddenKeysResp) String() string

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

+ func (m *GetHiddenKeysResp) UnmarshalBinary(data []byte) error

+ func (m *GetHiddenKeysResp) XXX_DiscardUnknown()

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

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

+ func (m *GetHiddenKeysResp) XXX_Size() int

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

type GetPrimaryKeysReq

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

+ func (*GetPrimaryKeysReq) ProtoMessage()

+ func (m *GetPrimaryKeysReq) GetTableID() ID

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

+ func (m *GetPrimaryKeysReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetPrimaryKeysReq) Reset()

+ func (m *GetPrimaryKeysReq) String() string

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

+ func (m *GetPrimaryKeysReq) UnmarshalBinary(data []byte) error

+ func (m *GetPrimaryKeysReq) XXX_DiscardUnknown()

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

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

+ func (m *GetPrimaryKeysReq) XXX_Size() int

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

type GetPrimaryKeysResp

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

+ func (*GetPrimaryKeysResp) ProtoMessage()

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

+ func (m *GetPrimaryKeysResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetPrimaryKeysResp) Reset()

+ func (m *GetPrimaryKeysResp) String() string

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

+ func (m *GetPrimaryKeysResp) UnmarshalBinary(data []byte) error

+ func (m *GetPrimaryKeysResp) XXX_DiscardUnknown()

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

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

+ func (m *GetPrimaryKeysResp) XXX_Size() int

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

type GetRelationsReq

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

+ func (*GetRelationsReq) ProtoMessage()

+ func (m *GetRelationsReq) GetDatabaseID() ID

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

+ func (m *GetRelationsReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetRelationsReq) Reset()

+ func (m *GetRelationsReq) String() string

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

+ func (m *GetRelationsReq) UnmarshalBinary(data []byte) error

+ func (m *GetRelationsReq) XXX_DiscardUnknown()

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

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

+ func (m *GetRelationsReq) XXX_Size() int

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

type GetRelationsResp

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

+ func (*GetRelationsResp) ProtoMessage()

+ func (m *GetRelationsResp) GetNames() []string

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

+ func (m *GetRelationsResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetRelationsResp) Reset()

+ func (m *GetRelationsResp) String() string

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

+ func (m *GetRelationsResp) UnmarshalBinary(data []byte) error

+ func (m *GetRelationsResp) XXX_DiscardUnknown()

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

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

+ func (m *GetRelationsResp) XXX_Size() int

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

type GetTableColumnsReq

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

+ func (*GetTableColumnsReq) ProtoMessage()

+ func (m *GetTableColumnsReq) GetTableID() ID

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

+ func (m *GetTableColumnsReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetTableColumnsReq) Reset()

+ func (m *GetTableColumnsReq) String() string

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

+ func (m *GetTableColumnsReq) UnmarshalBinary(data []byte) error

+ func (m *GetTableColumnsReq) XXX_DiscardUnknown()

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

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

+ func (m *GetTableColumnsReq) XXX_Size() int

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

type GetTableColumnsResp

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

+ func (*GetTableColumnsResp) ProtoMessage()

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

+ func (m *GetTableColumnsResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetTableColumnsResp) Reset()

+ func (m *GetTableColumnsResp) String() string

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

+ func (m *GetTableColumnsResp) UnmarshalBinary(data []byte) error

+ func (m *GetTableColumnsResp) XXX_DiscardUnknown()

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

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

+ func (m *GetTableColumnsResp) XXX_Size() int

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

type GetTableDefsReq

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

+ func (*GetTableDefsReq) ProtoMessage()

+ func (m *GetTableDefsReq) GetTableID() ID

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

+ func (m *GetTableDefsReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetTableDefsReq) Reset()

+ func (m *GetTableDefsReq) String() string

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

+ func (m *GetTableDefsReq) UnmarshalBinary(data []byte) error

+ func (m *GetTableDefsReq) XXX_DiscardUnknown()

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

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

+ func (m *GetTableDefsReq) XXX_Size() int

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

type GetTableDefsResp

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

+ func (*GetTableDefsResp) ProtoMessage()

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

+ func (m *GetTableDefsResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *GetTableDefsResp) Reset()

+ func (m *GetTableDefsResp) String() string

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

+ func (m *GetTableDefsResp) UnmarshalBinary(data []byte) error

+ func (m *GetTableDefsResp) XXX_DiscardUnknown()

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

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

+ func (m *GetTableDefsResp) XXX_Size() int

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

type HakeeperIDGenerator

+ func (h *HakeeperIDGenerator) NewIDByKey(ctx context.Context, key string) (ID, error)

type IDGenerator

+ NewIDByKey func(ctx context.Context, key string) (ID, error)

type NewTableIterReq

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

+ func (*NewTableIterReq) ProtoMessage()

+ func (m *NewTableIterReq) GetExpr() *plan.Expr

+ func (m *NewTableIterReq) GetTableID() ID

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

+ func (m *NewTableIterReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *NewTableIterReq) Reset()

+ func (m *NewTableIterReq) String() string

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

+ func (m *NewTableIterReq) UnmarshalBinary(data []byte) error

+ func (m *NewTableIterReq) XXX_DiscardUnknown()

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

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

+ func (m *NewTableIterReq) XXX_Size() int

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

type NewTableIterResp

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

+ func (*NewTableIterResp) ProtoMessage()

+ func (m *NewTableIterResp) GetIterID() ID

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

+ func (m *NewTableIterResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *NewTableIterResp) Reset()

+ func (m *NewTableIterResp) String() string

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

+ func (m *NewTableIterResp) UnmarshalBinary(data []byte) error

+ func (m *NewTableIterResp) XXX_DiscardUnknown()

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

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

+ func (m *NewTableIterResp) XXX_Size() int

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

type OpenDatabaseReq

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

+ func (*OpenDatabaseReq) ProtoMessage()

+ func (m *OpenDatabaseReq) GetAccessInfo() AccessInfo

+ func (m *OpenDatabaseReq) GetName() string

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

+ func (m *OpenDatabaseReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *OpenDatabaseReq) Reset()

+ func (m *OpenDatabaseReq) String() string

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

+ func (m *OpenDatabaseReq) UnmarshalBinary(data []byte) error

+ func (m *OpenDatabaseReq) XXX_DiscardUnknown()

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

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

+ func (m *OpenDatabaseReq) XXX_Size() int

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

type OpenDatabaseResp

+ CreateSql string

+ DatTyp string

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

+ func (*OpenDatabaseResp) ProtoMessage()

+ func (m *OpenDatabaseResp) GetID() ID

+ func (m *OpenDatabaseResp) GetName() string

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

+ func (m *OpenDatabaseResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *OpenDatabaseResp) Reset()

+ func (m *OpenDatabaseResp) String() string

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

+ func (m *OpenDatabaseResp) UnmarshalBinary(data []byte) error

+ func (m *OpenDatabaseResp) XXX_DiscardUnknown()

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

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

+ func (m *OpenDatabaseResp) XXX_Size() int

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

type OpenRelationReq

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

+ func (*OpenRelationReq) ProtoMessage()

+ func (m *OpenRelationReq) GetDatabaseID() ID

+ func (m *OpenRelationReq) GetDatabaseName() string

+ func (m *OpenRelationReq) GetName() string

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

+ func (m *OpenRelationReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *OpenRelationReq) Reset()

+ func (m *OpenRelationReq) String() string

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

+ func (m *OpenRelationReq) UnmarshalBinary(data []byte) error

+ func (m *OpenRelationReq) XXX_DiscardUnknown()

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

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

+ func (m *OpenRelationReq) XXX_Size() int

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

type OpenRelationResp

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

+ func (*OpenRelationResp) ProtoMessage()

+ func (m *OpenRelationResp) GetDatabaseName() string

+ func (m *OpenRelationResp) GetID() ID

+ func (m *OpenRelationResp) GetRelationName() string

+ func (m *OpenRelationResp) GetType() RelationType

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

+ func (m *OpenRelationResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *OpenRelationResp) Reset()

+ func (m *OpenRelationResp) String() string

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

+ func (m *OpenRelationResp) UnmarshalBinary(data []byte) error

+ func (m *OpenRelationResp) XXX_DiscardUnknown()

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

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

+ func (m *OpenRelationResp) XXX_Size() int

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

type ReadReq

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

+ func (*ReadReq) ProtoMessage()

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

+ func (m *ReadReq) GetIterID() ID

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

+ func (m *ReadReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *ReadReq) Reset()

+ func (m *ReadReq) String() string

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

+ func (m *ReadReq) UnmarshalBinary(data []byte) error

+ func (m *ReadReq) XXX_DiscardUnknown()

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

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

+ func (m *ReadReq) XXX_Size() int

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

type ReadResp

+ func (r *ReadResp) MarshalBinary() ([]byte, error)

+ func (r *ReadResp) UnmarshalBinary(data []byte) error

type Table

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

+ func (t *Table) ApplyRuntimeFilters(_ context.Context, ranges [][]byte, _ []*plan.Expr, ...) ([][]byte, error)

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

+ func (t *Table) GetDBID(ctx context.Context) uint64

+ func (t *Table) GetEngineType() engine.EngineType

+ func (t *Table) GetTableName() string

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

type TableStatsReq

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

+ func (*TableStatsReq) ProtoMessage()

+ func (m *TableStatsReq) GetTableID() ID

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

+ func (m *TableStatsReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *TableStatsReq) Reset()

+ func (m *TableStatsReq) String() string

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

+ func (m *TableStatsReq) UnmarshalBinary(data []byte) error

+ func (m *TableStatsReq) XXX_DiscardUnknown()

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

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

+ func (m *TableStatsReq) XXX_Size() int

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

type TableStatsResp

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

+ func (*TableStatsResp) ProtoMessage()

+ func (m *TableStatsResp) GetRows() int

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

+ func (m *TableStatsResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *TableStatsResp) Reset()

+ func (m *TableStatsResp) String() string

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

+ func (m *TableStatsResp) UnmarshalBinary(data []byte) error

+ func (m *TableStatsResp) XXX_DiscardUnknown()

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

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

+ func (m *TableStatsResp) XXX_Size() int

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

type TruncateRelationReq

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

+ func (*TruncateRelationReq) ProtoMessage()

+ func (m *TruncateRelationReq) GetDatabaseID() ID

+ func (m *TruncateRelationReq) GetDatabaseName() string

+ func (m *TruncateRelationReq) GetName() string

+ func (m *TruncateRelationReq) GetNewTableID() ID

+ func (m *TruncateRelationReq) GetOldTableID() ID

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

+ func (m *TruncateRelationReq) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *TruncateRelationReq) Reset()

+ func (m *TruncateRelationReq) String() string

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

+ func (m *TruncateRelationReq) UnmarshalBinary(data []byte) error

+ func (m *TruncateRelationReq) XXX_DiscardUnknown()

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

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

+ func (m *TruncateRelationReq) XXX_Size() int

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

type TruncateRelationResp

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

+ func (*TruncateRelationResp) ProtoMessage()

+ func (m *TruncateRelationResp) GetID() ID

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

+ func (m *TruncateRelationResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *TruncateRelationResp) Reset()

+ func (m *TruncateRelationResp) String() string

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

+ func (m *TruncateRelationResp) UnmarshalBinary(data []byte) error

+ func (m *TruncateRelationResp) XXX_DiscardUnknown()

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

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

+ func (m *TruncateRelationResp) XXX_Size() int

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

type UpdateReq

+ func (r *UpdateReq) MarshalBinary() ([]byte, error)

+ func (r *UpdateReq) UnmarshalBinary(data []byte) error

type UpdateResp

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

+ func (*UpdateResp) ProtoMessage()

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

+ func (m *UpdateResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *UpdateResp) Reset()

+ func (m *UpdateResp) String() string

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

+ func (m *UpdateResp) UnmarshalBinary(data []byte) error

+ func (m *UpdateResp) XXX_DiscardUnknown()

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

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

+ func (m *UpdateResp) XXX_Size() int

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

type WriteReq

+ func (r *WriteReq) MarshalBinary() ([]byte, error)

+ func (r *WriteReq) UnmarshalBinary(data []byte) error

type WriteResp

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

+ func (*WriteResp) ProtoMessage()

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

+ func (m *WriteResp) MarshalBinary() ([]byte, error)

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

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

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

+ func (m *WriteResp) Reset()

+ func (m *WriteResp) String() string

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

+ func (m *WriteResp) UnmarshalBinary(data []byte) error

+ func (m *WriteResp) XXX_DiscardUnknown()

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

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

+ func (m *WriteResp) XXX_Size() int

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

v0.7.0

Feb 18, 2023

Changes in this version

type BindedEngine

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

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

type CompilerContext

+ func (*CompilerContext) Stats(obj *plan.ObjectRef, e *plan.Expr) *plan.Stats

+ func (c *CompilerContext) GetBuildingAlterView() (bool, string, string)

+ func (c *CompilerContext) GetContext() context.Context

+ func (c *CompilerContext) GetProcess() *process.Process

+ func (c *CompilerContext) GetQueryResultMeta(uuid string) ([]*plan.ColDef, string, error)

+ func (c *CompilerContext) ResolveAccountIds(accountNames []string) ([]uint32, error)

+ func (c *CompilerContext) ResolveById(tableId uint64) (objRef *plan.ObjectRef, tableDef *plan.TableDef)

+ func (c *CompilerContext) SetBuildingAlterView(yesOrNo bool, dbName, viewName string)

type Engine

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

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

type Table

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

+ func (t *Table) Stats(ctx context.Context, e *plan2.Expr) (*plan.Stats, error)

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

v0.6.0

Nov 29, 2022

Changes in this version

+ const OpAddTableDef

+ const OpCloseTableIter

+ const OpCreateDatabase

+ const OpCreateRelation

+ const OpDelTableDef

+ const OpDelete

+ const OpDeleteDatabase

+ const OpDeleteRelation

+ const OpGetDatabases

+ const OpGetHiddenKeys

+ const OpGetLogTail

+ const OpGetPrimaryKeys

+ const OpGetRelations

+ const OpGetTableColumns

+ const OpGetTableDefs

+ const OpNewTableIter

+ const OpOpenDatabase

+ const OpOpenRelation

+ const OpPreCommit

+ const OpRead

+ const OpTableStats

+ const OpTruncateRelation

+ const OpUpdate

+ const OpWrite

+ var RandomIDGenerator = new(randomIDGenerator)

+ func DoTxnRequest(ctx context.Context, txnOperator client.TxnOperator, isRead bool, ...) (resps []Resp, err error)

+ func GetClusterDetailsFromHAKeeper(ctx context.Context, client logservice.CNHAKeeperClient) (get engine.GetClusterDetailsFunc)

+ type AccessInfo struct

+ AccountID uint32

+ RoleID uint32

+ UserID uint32

+ type AddTableDefReq struct

+ DatabaseName string

+ Def engine.TableDef

+ TableID ID

+ TableName string

+ type AddTableDefResp struct

+ type BindedEngine struct

+ func (b *BindedEngine) Commit(ctx context.Context, _ client.TxnOperator) error

+ func (b *BindedEngine) Create(ctx context.Context, databaseName string, _ client.TxnOperator) error

+ func (b *BindedEngine) Database(ctx context.Context, databaseName string, _ client.TxnOperator) (engine.Database, error)

+ func (b *BindedEngine) Databases(ctx context.Context, _ client.TxnOperator) (databaseNames []string, err error)

+ func (b *BindedEngine) Delete(ctx context.Context, databaseName string, _ client.TxnOperator) error

+ func (b *BindedEngine) Hints() engine.Hints

+ func (b *BindedEngine) New(ctx context.Context, _ client.TxnOperator) error

+ func (b *BindedEngine) NewBlockReader(_ context.Context, _ int, _ timestamp.Timestamp, _ *plan.Expr, _ [][]byte, ...) ([]engine.Reader, error)

+ func (b *BindedEngine) Nodes() (cnNodes engine.Nodes, err error)

+ func (b *BindedEngine) Rollback(ctx context.Context, _ client.TxnOperator) error

+ type CloseTableIterReq struct

+ IterID ID

+ type CloseTableIterResp struct

+ type CompilerContext struct

+ func (*CompilerContext) Cost(obj *plan.ObjectRef, e *plan.Expr) *plan.Cost

+ func (*CompilerContext) GetRootSql() string

+ func (*CompilerContext) GetUserName() string

+ func (*CompilerContext) ResolveVariable(varName string, isSystemVar bool, isGlobalVar bool) (interface{}, error)

+ func (c *CompilerContext) DatabaseExists(name string) bool

+ func (c *CompilerContext) DefaultDatabase() string

+ func (c *CompilerContext) GetAccountId() uint32

+ func (c *CompilerContext) GetHideKeyDef(dbName string, tableName string) *plan.ColDef

+ func (c *CompilerContext) GetPrimaryKeyDef(dbName string, tableName string) (defs []*plan.ColDef)

+ func (c *CompilerContext) Resolve(schemaName string, tableName string) (objRef *plan.ObjectRef, tableDef *plan.TableDef)

+ type CreateDatabaseReq struct

+ AccessInfo AccessInfo

+ ID ID

+ Name string

+ type CreateDatabaseResp struct

+ ID ID

+ type CreateRelationReq struct

+ DatabaseID ID

+ DatabaseName string

+ Defs []engine.TableDef

+ ID ID

+ Name string

+ Type RelationType

+ type CreateRelationResp struct

+ ID ID

+ type Database struct

+ func (d *Database) Create(ctx context.Context, relName string, defs []engine.TableDef) error

+ func (d *Database) Delete(ctx context.Context, relName string) error

+ func (d *Database) GetDatabaseId(ctx context.Context) string

+ func (d *Database) Relation(ctx context.Context, relName string) (engine.Relation, error)

+ func (d *Database) Relations(ctx context.Context) ([]string, error)

+ func (d *Database) Truncate(ctx context.Context, relName string) error

+ type DelTableDefReq struct

+ DatabaseName string

+ Def engine.TableDef

+ TableID ID

+ TableName string

+ type DelTableDefResp struct

+ type DeleteDatabaseReq struct

+ AccessInfo AccessInfo

+ Name string

+ type DeleteDatabaseResp struct

+ ID ID

+ type DeleteRelationReq struct

+ DatabaseID ID

+ DatabaseName string

+ Name string

+ type DeleteRelationResp struct

+ ID ID

+ type DeleteReq struct

+ ColumnName string

+ DatabaseName string

+ TableID ID

+ TableName string

+ Vector *vector.Vector

+ type DeleteResp struct

+ type Engine struct

+ func New(ctx context.Context, shardPolicy ShardPolicy, ...) *Engine

+ func (e *Engine) Bind(txnOp client.TxnOperator) *BindedEngine

+ func (e *Engine) Commit(_ context.Context, _ client.TxnOperator) error

+ func (e *Engine) Create(ctx context.Context, dbName string, txnOperator client.TxnOperator) error

+ func (e *Engine) Database(ctx context.Context, dbName string, txnOperator client.TxnOperator) (engine.Database, error)

+ func (e *Engine) Databases(ctx context.Context, txnOperator client.TxnOperator) ([]string, error)

+ func (e *Engine) Delete(ctx context.Context, dbName string, txnOperator client.TxnOperator) error

+ func (e *Engine) Hints() (h engine.Hints)

+ func (e *Engine) New(_ context.Context, _ client.TxnOperator) error

+ func (e *Engine) NewBlockReader(_ context.Context, _ int, _ timestamp.Timestamp, _ *plan.Expr, _ [][]byte, ...) ([]engine.Reader, error)

+ func (e *Engine) NewCompilerContext(ctx context.Context, defaultDB string, txnOp client.TxnOperator) *CompilerContext

+ func (e *Engine) Nodes() (engine.Nodes, error)

+ func (e *Engine) Rollback(_ context.Context, _ client.TxnOperator) error

+ type FallbackShard []ShardPolicy

+ func (f FallbackShard) Batch(ctx context.Context, tableID ID, ...) (sharded []*ShardedBatch, err error)

+ func (f FallbackShard) Vector(ctx context.Context, tableID ID, ...) (sharded []*ShardedVector, err error)

+ type GetDatabasesReq struct

+ AccessInfo AccessInfo

+ type GetDatabasesResp struct

+ Names []string

+ type GetHiddenKeysReq struct

+ TableID ID

+ type GetHiddenKeysResp struct

+ Attrs []*engine.Attribute

+ type GetPrimaryKeysReq struct

+ TableID ID

+ type GetPrimaryKeysResp struct

+ Attrs []*engine.Attribute

+ type GetRelationsReq struct

+ DatabaseID ID

+ type GetRelationsResp struct

+ Names []string

+ type GetTableColumnsReq struct

+ TableID ID

+ type GetTableColumnsResp struct

+ Attrs []*engine.Attribute

+ type GetTableDefsReq struct

+ TableID ID

+ type GetTableDefsResp struct

+ Defs []engine.TableDef

+ type HakeeperIDGenerator struct

+ func NewHakeeperIDGenerator(generator hakeeperIDGenerator) *HakeeperIDGenerator

+ func (h *HakeeperIDGenerator) NewID(ctx context.Context) (ID, error)

+ type HashShard struct

+ func NewHashShard(mp *mpool.MPool) *HashShard

+ func (*HashShard) Batch(ctx context.Context, tableID ID, getDefs getDefsFunc, bat *batch.Batch, ...) (sharded []*ShardedBatch, err error)

+ func (h *HashShard) Vector(ctx context.Context, tableID ID, getDefs getDefsFunc, colName string, ...) (sharded []*ShardedVector, err error)

+ type ID uint64

+ func (i ID) IsEmpty() bool

+ func (i ID) Less(than ID) bool

+ func (i ID) ToRowID() types.Rowid

+ type IDGenerator interface

+ NewID func(context.Context) (ID, error)

+ type IterInfo struct

+ IterID ID

+ Shard Shard

+ type NewTableIterReq struct

+ Expr *plan.Expr

+ TableID ID

+ type NewTableIterResp struct

+ IterID ID

+ type NoShard struct

+ func (s *NoShard) Batch(ctx context.Context, tableID ID, getDefs getDefsFunc, bat *batch.Batch, ...) (sharded []*ShardedBatch, err error)

+ func (s *NoShard) Vector(ctx context.Context, tableID ID, getDefs getDefsFunc, colName string, ...) (sharded []*ShardedVector, err error)

+ type Nullable struct

+ IsNull bool

+ Value any

+ type OpenDatabaseReq struct

+ AccessInfo AccessInfo

+ Name string

+ type OpenDatabaseResp struct

+ ID ID

+ Name string

+ type OpenRelationReq struct

+ DatabaseID ID

+ DatabaseName string

+ Name string

+ type OpenRelationResp struct

+ DatabaseName string

+ ID ID

+ RelationName string

+ Type RelationType

+ type OperationHandler interface

+ HandleAddTableDef func(ctx context.Context, meta txn.TxnMeta, req AddTableDefReq, ...) error

+ HandleCloseTableIter func(ctx context.Context, meta txn.TxnMeta, req CloseTableIterReq, ...) error

+ HandleCreateDatabase func(ctx context.Context, meta txn.TxnMeta, req CreateDatabaseReq, ...) error

+ HandleCreateRelation func(ctx context.Context, meta txn.TxnMeta, req CreateRelationReq, ...) error

+ HandleDelTableDef func(ctx context.Context, meta txn.TxnMeta, req DelTableDefReq, ...) error

+ HandleDelete func(ctx context.Context, meta txn.TxnMeta, req DeleteReq, resp *DeleteResp) error

+ HandleDeleteDatabase func(ctx context.Context, meta txn.TxnMeta, req DeleteDatabaseReq, ...) error

+ HandleDeleteRelation func(ctx context.Context, meta txn.TxnMeta, req DeleteRelationReq, ...) error

+ HandleGetDatabases func(ctx context.Context, meta txn.TxnMeta, req GetDatabasesReq, ...) error

+ HandleGetHiddenKeys func(ctx context.Context, meta txn.TxnMeta, req GetHiddenKeysReq, ...) error

+ HandleGetLogTail func(ctx context.Context, meta txn.TxnMeta, req apipb.SyncLogTailReq, ...) error

+ HandleGetPrimaryKeys func(ctx context.Context, meta txn.TxnMeta, req GetPrimaryKeysReq, ...) error

+ HandleGetRelations func(ctx context.Context, meta txn.TxnMeta, req GetRelationsReq, ...) error

+ HandleGetTableColumns func(ctx context.Context, meta txn.TxnMeta, req GetTableColumnsReq, ...) error

+ HandleGetTableDefs func(ctx context.Context, meta txn.TxnMeta, req GetTableDefsReq, ...) error

+ HandleNewTableIter func(ctx context.Context, meta txn.TxnMeta, req NewTableIterReq, ...) error

+ HandleOpenDatabase func(ctx context.Context, meta txn.TxnMeta, req OpenDatabaseReq, ...) error

+ HandleOpenRelation func(ctx context.Context, meta txn.TxnMeta, req OpenRelationReq, ...) error

+ HandlePreCommit func(ctx context.Context, meta txn.TxnMeta, req apipb.PrecommitWriteCmd, ...) error

+ HandleRead func(ctx context.Context, meta txn.TxnMeta, req ReadReq, resp *ReadResp) error

+ HandleTableStats func(ctx context.Context, meta txn.TxnMeta, req TableStatsReq, resp *TableStatsResp) error

+ HandleTruncateRelation func(ctx context.Context, meta txn.TxnMeta, req TruncateRelationReq, ...) error

+ HandleUpdate func(ctx context.Context, meta txn.TxnMeta, req UpdateReq, resp *UpdateResp) error

+ HandleWrite func(ctx context.Context, meta txn.TxnMeta, req WriteReq, resp *WriteResp) error

+ type OperationHandlerProvider interface

+ GetOperationHandler func(shard Shard) (OperationHandler, txn.TxnMeta)

+ type ReadReq struct

+ ColNames []string

+ IterID ID

+ type ReadRequest interface

+ type ReadResp struct

+ Batch *batch.Batch

+ func (r *ReadResp) Close() error

+ func (r *ReadResp) SetHeap(mp *mpool.MPool)

+ type RelationType uint8

+ const RelationTable

+ const RelationView

+ type Request interface

+ type Response interface

+ type Shard = metadata.DNShard

+ type ShardPolicy interface

+ Batch func(ctx context.Context, tableID ID, getDefs getDefsFunc, batch *batch.Batch, ...) (sharded []*ShardedBatch, err error)

+ Vector func(ctx context.Context, tableID ID, getDefs getDefsFunc, colName string, ...) (sharded []*ShardedVector, err error)

+ func NewDefaultShardPolicy(mp *mpool.MPool) ShardPolicy

+ type ShardedBatch struct

+ Batch *batch.Batch

+ Shard Shard

+ type ShardedVector struct

+ Shard Shard

+ Vector *vector.Vector

+ type Table struct

+ func (*Table) GetHideKey() *engine.Attribute

+ func (*Table) GetPriKeyOrHideKey() ([]engine.Attribute, bool)

+ func (t *Table) AddTableDef(ctx context.Context, def engine.TableDef) error

+ func (t *Table) DelTableDef(ctx context.Context, def engine.TableDef) error

+ func (t *Table) Delete(ctx context.Context, bat *batch.Batch, colName string) error

+ func (t *Table) GetHideKeys(ctx context.Context) (attrs []*engine.Attribute, err error)

+ func (t *Table) GetLogTail(ctx context.Context, from *timestamp.Timestamp, to *timestamp.Timestamp, ...) (resp *apipb.SyncLogTailResp, err error)

+ func (t *Table) GetPrimaryKeys(ctx context.Context) ([]*engine.Attribute, error)

+ func (t *Table) GetTableID(ctx context.Context) string

+ func (t *Table) NewReader(ctx context.Context, parallel int, expr *plan.Expr, shardIDs [][]byte) (readers []engine.Reader, err error)

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

+ func (t *Table) Rows(ctx context.Context) (int64, error)

+ func (t *Table) Size(ctx context.Context, columnName string) (int64, error)

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

+ func (t *Table) TableDefs(ctx context.Context) ([]engine.TableDef, error)

+ func (t *Table) Update(ctx context.Context, data *batch.Batch) error

+ func (t *Table) Write(ctx context.Context, data *batch.Batch) error

+ type TableReader struct

+ func (t *TableReader) Close() error

+ func (t *TableReader) Read(colNames []string, plan *plan.Expr, mp *mpool.MPool) (*batch.Batch, error)

+ type TableStatsReq struct

+ TableID ID

+ type TableStatsResp struct

+ Rows int

+ type TruncateRelationReq struct

+ DatabaseID ID

+ DatabaseName string

+ Name string

+ NewTableID ID

+ OldTableID ID

+ type TruncateRelationResp struct

+ ID ID

+ type UpdateReq struct

+ Batch *batch.Batch

+ DatabaseName string

+ TableID ID

+ TableName string

+ type UpdateResp struct

+ type WriteReq struct

+ Batch *batch.Batch

+ DatabaseName string

+ TableID ID

+ TableName string

+ type WriteReqeust interface

+ type WriteResp struct

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