memoryengine

package
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 2, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source
const (
	LengthBytes = 4
	IDBytes     = 8
)
View Source
const (
	OpCreateDatabase = iota + 64
	OpOpenDatabase
	OpGetDatabases
	OpDeleteDatabase
	OpCreateRelation
	OpDeleteRelation
	OpTruncateRelation
	OpOpenRelation
	OpGetRelations
	OpAddTableDef
	OpDelTableDef
	OpDelete
	OpGetPrimaryKeys
	OpGetTableColumns
	OpGetTableDefs
	OpGetHiddenKeys
	OpUpdate
	OpWrite
	OpNewTableIter
	OpRead
	OpCloseTableIter
	OpTableStats
	OpPreCommit  = uint32(apipb.OpCode_OpPreCommit)
	OpGetLogTail = uint32(apipb.OpCode_OpGetLogTail)
)

Variables

View Source
var (
	ErrInvalidLengthOperations        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOperations          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOperations = fmt.Errorf("proto: unexpected end of group")
)
View Source
var RandomIDGenerator = new(randomIDGenerator)

Functions

func DoTxnRequest

func DoTxnRequest[
	Resp any, PResp interface {
		// anonymous constraint
		encoding.BinaryUnmarshaler

		*Resp
	},
	Req any, PReq interface {
		// anonymous constraint
		encoding.BinaryMarshaler

		*Req
	},
](
	ctx context.Context,
	txnOperator client.TxnOperator,
	isRead bool,
	shardsFunc shardsFunc,
	op uint32,
	preq PReq,
) (
	resps []Resp,
	err error,
)

Types

type AccessInfo

type AccessInfo struct {
	AccountID uint32
	UserID    uint32
	RoleID    uint32
}

func (*AccessInfo) Descriptor added in v0.8.0

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

func (*AccessInfo) GetAccountID added in v0.8.0

func (m *AccessInfo) GetAccountID() uint32

func (*AccessInfo) GetRoleID added in v0.8.0

func (m *AccessInfo) GetRoleID() uint32

func (*AccessInfo) GetUserID added in v0.8.0

func (m *AccessInfo) GetUserID() uint32

func (*AccessInfo) Marshal added in v0.8.0

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

func (*AccessInfo) MarshalTo added in v0.8.0

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

func (*AccessInfo) MarshalToSizedBuffer added in v0.8.0

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

func (*AccessInfo) ProtoMessage added in v0.8.0

func (*AccessInfo) ProtoMessage()

func (*AccessInfo) ProtoSize added in v0.8.0

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

func (*AccessInfo) Reset added in v0.8.0

func (m *AccessInfo) Reset()

func (*AccessInfo) String added in v0.8.0

func (m *AccessInfo) String() string

func (*AccessInfo) Unmarshal added in v0.8.0

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

func (*AccessInfo) XXX_DiscardUnknown added in v0.8.0

func (m *AccessInfo) XXX_DiscardUnknown()

func (*AccessInfo) XXX_Marshal added in v0.8.0

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

func (*AccessInfo) XXX_Merge added in v0.8.0

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

func (*AccessInfo) XXX_Size added in v0.8.0

func (m *AccessInfo) XXX_Size() int

func (*AccessInfo) XXX_Unmarshal added in v0.8.0

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

type AddTableDefReq

type AddTableDefReq struct {
	TableID ID
	Def     engine.TableDefPB

	DatabaseName string
	TableName    string
}

func (*AddTableDefReq) Descriptor added in v0.8.0

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

func (*AddTableDefReq) GetDatabaseName added in v0.8.0

func (m *AddTableDefReq) GetDatabaseName() string

func (*AddTableDefReq) GetTableID added in v0.8.0

func (m *AddTableDefReq) GetTableID() ID

func (*AddTableDefReq) GetTableName added in v0.8.0

func (m *AddTableDefReq) GetTableName() string

func (*AddTableDefReq) Marshal added in v0.8.0

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

func (*AddTableDefReq) MarshalBinary added in v0.8.0

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

func (*AddTableDefReq) MarshalTo added in v0.8.0

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

func (*AddTableDefReq) MarshalToSizedBuffer added in v0.8.0

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

func (*AddTableDefReq) ProtoMessage added in v0.8.0

func (*AddTableDefReq) ProtoMessage()

func (*AddTableDefReq) ProtoSize added in v0.8.0

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

func (*AddTableDefReq) Reset added in v0.8.0

func (m *AddTableDefReq) Reset()

func (*AddTableDefReq) String added in v0.8.0

func (m *AddTableDefReq) String() string

func (*AddTableDefReq) Unmarshal added in v0.8.0

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

func (*AddTableDefReq) UnmarshalBinary added in v0.8.0

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

func (*AddTableDefReq) XXX_DiscardUnknown added in v0.8.0

func (m *AddTableDefReq) XXX_DiscardUnknown()

func (*AddTableDefReq) XXX_Marshal added in v0.8.0

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

func (*AddTableDefReq) XXX_Merge added in v0.8.0

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

func (*AddTableDefReq) XXX_Size added in v0.8.0

func (m *AddTableDefReq) XXX_Size() int

func (*AddTableDefReq) XXX_Unmarshal added in v0.8.0

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

type AddTableDefResp

type AddTableDefResp struct {
}

func (*AddTableDefResp) Descriptor added in v0.8.0

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

func (*AddTableDefResp) Marshal added in v0.8.0

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

func (*AddTableDefResp) MarshalBinary added in v0.8.0

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

func (*AddTableDefResp) MarshalTo added in v0.8.0

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

func (*AddTableDefResp) MarshalToSizedBuffer added in v0.8.0

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

func (*AddTableDefResp) ProtoMessage added in v0.8.0

func (*AddTableDefResp) ProtoMessage()

func (*AddTableDefResp) ProtoSize added in v0.8.0

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

func (*AddTableDefResp) Reset added in v0.8.0

func (m *AddTableDefResp) Reset()

func (*AddTableDefResp) String added in v0.8.0

func (m *AddTableDefResp) String() string

func (*AddTableDefResp) Unmarshal added in v0.8.0

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

func (*AddTableDefResp) UnmarshalBinary added in v0.8.0

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

func (*AddTableDefResp) XXX_DiscardUnknown added in v0.8.0

func (m *AddTableDefResp) XXX_DiscardUnknown()

func (*AddTableDefResp) XXX_Marshal added in v0.8.0

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

func (*AddTableDefResp) XXX_Merge added in v0.8.0

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

func (*AddTableDefResp) XXX_Size added in v0.8.0

func (m *AddTableDefResp) XXX_Size() int

func (*AddTableDefResp) XXX_Unmarshal added in v0.8.0

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

type BindedEngine

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

func (*BindedEngine) AllocateIDByKey added in v0.8.0

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

func (*BindedEngine) Commit

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

func (*BindedEngine) Create

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

func (*BindedEngine) Database

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

func (*BindedEngine) Databases

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

func (*BindedEngine) Delete

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

func (*BindedEngine) GetNameById added in v0.7.0

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

func (*BindedEngine) GetRelationById added in v0.7.0

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

func (*BindedEngine) Hints

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

func (*BindedEngine) New

func (*BindedEngine) NewBlockReader

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

func (*BindedEngine) Nodes

func (b *BindedEngine) Nodes(isInternal bool, tenant string, username string, cnLabel map[string]string) (cnNodes engine.Nodes, err error)

func (*BindedEngine) Rollback

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

type CloseTableIterReq

type CloseTableIterReq struct {
	IterID ID
}

func (*CloseTableIterReq) Descriptor added in v0.8.0

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

func (*CloseTableIterReq) GetIterID added in v0.8.0

func (m *CloseTableIterReq) GetIterID() ID

func (*CloseTableIterReq) Marshal added in v0.8.0

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

func (*CloseTableIterReq) MarshalBinary added in v0.8.0

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

func (*CloseTableIterReq) MarshalTo added in v0.8.0

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

func (*CloseTableIterReq) MarshalToSizedBuffer added in v0.8.0

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

func (*CloseTableIterReq) ProtoMessage added in v0.8.0

func (*CloseTableIterReq) ProtoMessage()

func (*CloseTableIterReq) ProtoSize added in v0.8.0

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

func (*CloseTableIterReq) Reset added in v0.8.0

func (m *CloseTableIterReq) Reset()

func (*CloseTableIterReq) String added in v0.8.0

func (m *CloseTableIterReq) String() string

func (*CloseTableIterReq) Unmarshal added in v0.8.0

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

func (*CloseTableIterReq) UnmarshalBinary added in v0.8.0

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

func (*CloseTableIterReq) XXX_DiscardUnknown added in v0.8.0

func (m *CloseTableIterReq) XXX_DiscardUnknown()

func (*CloseTableIterReq) XXX_Marshal added in v0.8.0

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

func (*CloseTableIterReq) XXX_Merge added in v0.8.0

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

func (*CloseTableIterReq) XXX_Size added in v0.8.0

func (m *CloseTableIterReq) XXX_Size() int

func (*CloseTableIterReq) XXX_Unmarshal added in v0.8.0

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

type CloseTableIterResp

type CloseTableIterResp struct {
}

func (*CloseTableIterResp) Descriptor added in v0.8.0

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

func (*CloseTableIterResp) Marshal added in v0.8.0

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

func (*CloseTableIterResp) MarshalBinary added in v0.8.0

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

func (*CloseTableIterResp) MarshalTo added in v0.8.0

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

func (*CloseTableIterResp) MarshalToSizedBuffer added in v0.8.0

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

func (*CloseTableIterResp) ProtoMessage added in v0.8.0

func (*CloseTableIterResp) ProtoMessage()

func (*CloseTableIterResp) ProtoSize added in v0.8.0

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

func (*CloseTableIterResp) Reset added in v0.8.0

func (m *CloseTableIterResp) Reset()

func (*CloseTableIterResp) String added in v0.8.0

func (m *CloseTableIterResp) String() string

func (*CloseTableIterResp) Unmarshal added in v0.8.0

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

func (*CloseTableIterResp) UnmarshalBinary added in v0.8.0

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

func (*CloseTableIterResp) XXX_DiscardUnknown added in v0.8.0

func (m *CloseTableIterResp) XXX_DiscardUnknown()

func (*CloseTableIterResp) XXX_Marshal added in v0.8.0

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

func (*CloseTableIterResp) XXX_Merge added in v0.8.0

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

func (*CloseTableIterResp) XXX_Size added in v0.8.0

func (m *CloseTableIterResp) XXX_Size() int

func (*CloseTableIterResp) XXX_Unmarshal added in v0.8.0

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

type CompilerContext

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

func (*CompilerContext) CheckSubscriptionValid added in v0.8.0

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

func (*CompilerContext) DatabaseExists

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

func (*CompilerContext) DefaultDatabase

func (c *CompilerContext) DefaultDatabase() string

func (*CompilerContext) GetAccountId

func (c *CompilerContext) GetAccountId() (uint32, error)

func (*CompilerContext) GetBuildingAlterView added in v0.7.0

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

func (*CompilerContext) GetContext added in v0.7.0

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

func (*CompilerContext) GetDatabaseId added in v0.8.0

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

func (*CompilerContext) GetPrimaryKeyDef

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

func (*CompilerContext) GetProcess added in v0.7.0

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

func (*CompilerContext) GetQueryResultMeta added in v0.7.0

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

func (*CompilerContext) GetQueryingSubscription added in v0.8.0

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

func (*CompilerContext) GetRootSql

func (*CompilerContext) GetRootSql() string

func (*CompilerContext) GetStatsCache added in v0.8.0

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

func (*CompilerContext) GetSubscriptionMeta added in v0.8.0

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

func (*CompilerContext) GetUserName

func (*CompilerContext) GetUserName() string

func (*CompilerContext) IsPublishing added in v0.8.0

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

func (*CompilerContext) Resolve

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

func (*CompilerContext) ResolveAccountIds added in v0.7.0

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

func (*CompilerContext) ResolveById added in v0.7.0

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

func (*CompilerContext) ResolveUdf added in v0.8.0

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

func (*CompilerContext) ResolveVariable

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

func (*CompilerContext) SetBuildingAlterView added in v0.7.0

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

func (*CompilerContext) SetQueryingSubscription added in v0.8.0

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

func (*CompilerContext) Stats added in v0.7.0

func (*CompilerContext) Stats(obj *plan.ObjectRef) bool

type CreateDatabaseReq

type CreateDatabaseReq struct {
	ID         ID
	AccessInfo AccessInfo
	Name       string
	Typ        string
	CreateSql  string
}

func (*CreateDatabaseReq) Descriptor added in v0.8.0

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

func (*CreateDatabaseReq) GetAccessInfo added in v0.8.0

func (m *CreateDatabaseReq) GetAccessInfo() AccessInfo

func (*CreateDatabaseReq) GetID added in v0.8.0

func (m *CreateDatabaseReq) GetID() ID

func (*CreateDatabaseReq) GetName added in v0.8.0

func (m *CreateDatabaseReq) GetName() string

func (*CreateDatabaseReq) Marshal added in v0.8.0

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

func (*CreateDatabaseReq) MarshalBinary added in v0.8.0

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

func (*CreateDatabaseReq) MarshalTo added in v0.8.0

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

func (*CreateDatabaseReq) MarshalToSizedBuffer added in v0.8.0

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

func (*CreateDatabaseReq) ProtoMessage added in v0.8.0

func (*CreateDatabaseReq) ProtoMessage()

func (*CreateDatabaseReq) ProtoSize added in v0.8.0

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

func (*CreateDatabaseReq) Reset added in v0.8.0

func (m *CreateDatabaseReq) Reset()

func (*CreateDatabaseReq) String added in v0.8.0

func (m *CreateDatabaseReq) String() string

func (*CreateDatabaseReq) Unmarshal added in v0.8.0

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

func (*CreateDatabaseReq) UnmarshalBinary added in v0.8.0

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

func (*CreateDatabaseReq) XXX_DiscardUnknown added in v0.8.0

func (m *CreateDatabaseReq) XXX_DiscardUnknown()

func (*CreateDatabaseReq) XXX_Marshal added in v0.8.0

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

func (*CreateDatabaseReq) XXX_Merge added in v0.8.0

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

func (*CreateDatabaseReq) XXX_Size added in v0.8.0

func (m *CreateDatabaseReq) XXX_Size() int

func (*CreateDatabaseReq) XXX_Unmarshal added in v0.8.0

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

type CreateDatabaseResp

type CreateDatabaseResp struct {
	ID ID
}

func (*CreateDatabaseResp) Descriptor added in v0.8.0

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

func (*CreateDatabaseResp) GetID added in v0.8.0

func (m *CreateDatabaseResp) GetID() ID

func (*CreateDatabaseResp) Marshal added in v0.8.0

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

func (*CreateDatabaseResp) MarshalBinary added in v0.8.0

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

func (*CreateDatabaseResp) MarshalTo added in v0.8.0

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

func (*CreateDatabaseResp) MarshalToSizedBuffer added in v0.8.0

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

func (*CreateDatabaseResp) ProtoMessage added in v0.8.0

func (*CreateDatabaseResp) ProtoMessage()

func (*CreateDatabaseResp) ProtoSize added in v0.8.0

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

func (*CreateDatabaseResp) Reset added in v0.8.0

func (m *CreateDatabaseResp) Reset()

func (*CreateDatabaseResp) String added in v0.8.0

func (m *CreateDatabaseResp) String() string

func (*CreateDatabaseResp) Unmarshal added in v0.8.0

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

func (*CreateDatabaseResp) UnmarshalBinary added in v0.8.0

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

func (*CreateDatabaseResp) XXX_DiscardUnknown added in v0.8.0

func (m *CreateDatabaseResp) XXX_DiscardUnknown()

func (*CreateDatabaseResp) XXX_Marshal added in v0.8.0

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

func (*CreateDatabaseResp) XXX_Merge added in v0.8.0

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

func (*CreateDatabaseResp) XXX_Size added in v0.8.0

func (m *CreateDatabaseResp) XXX_Size() int

func (*CreateDatabaseResp) XXX_Unmarshal added in v0.8.0

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

type CreateRelationReq

type CreateRelationReq struct {
	ID           ID
	DatabaseID   ID
	DatabaseName string
	Name         string
	Type         RelationType
	Defs         []engine.TableDefPB
}

func (*CreateRelationReq) Descriptor added in v0.8.0

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

func (*CreateRelationReq) GetDatabaseID added in v0.8.0

func (m *CreateRelationReq) GetDatabaseID() ID

func (*CreateRelationReq) GetDatabaseName added in v0.8.0

func (m *CreateRelationReq) GetDatabaseName() string

func (*CreateRelationReq) GetID added in v0.8.0

func (m *CreateRelationReq) GetID() ID

func (*CreateRelationReq) GetName added in v0.8.0

func (m *CreateRelationReq) GetName() string

func (*CreateRelationReq) GetType added in v0.8.0

func (m *CreateRelationReq) GetType() RelationType

func (*CreateRelationReq) Marshal added in v0.8.0

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

func (*CreateRelationReq) MarshalBinary added in v0.8.0

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

func (*CreateRelationReq) MarshalTo added in v0.8.0

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

func (*CreateRelationReq) MarshalToSizedBuffer added in v0.8.0

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

func (*CreateRelationReq) ProtoMessage added in v0.8.0

func (*CreateRelationReq) ProtoMessage()

func (*CreateRelationReq) ProtoSize added in v0.8.0

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

func (*CreateRelationReq) Reset added in v0.8.0

func (m *CreateRelationReq) Reset()

func (*CreateRelationReq) String added in v0.8.0

func (m *CreateRelationReq) String() string

func (*CreateRelationReq) Unmarshal added in v0.8.0

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

func (*CreateRelationReq) UnmarshalBinary added in v0.8.0

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

func (*CreateRelationReq) XXX_DiscardUnknown added in v0.8.0

func (m *CreateRelationReq) XXX_DiscardUnknown()

func (*CreateRelationReq) XXX_Marshal added in v0.8.0

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

func (*CreateRelationReq) XXX_Merge added in v0.8.0

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

func (*CreateRelationReq) XXX_Size added in v0.8.0

func (m *CreateRelationReq) XXX_Size() int

func (*CreateRelationReq) XXX_Unmarshal added in v0.8.0

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

type CreateRelationResp

type CreateRelationResp struct {
	ID ID
}

func (*CreateRelationResp) Descriptor added in v0.8.0

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

func (*CreateRelationResp) GetID added in v0.8.0

func (m *CreateRelationResp) GetID() ID

func (*CreateRelationResp) Marshal added in v0.8.0

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

func (*CreateRelationResp) MarshalBinary added in v0.8.0

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

func (*CreateRelationResp) MarshalTo added in v0.8.0

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

func (*CreateRelationResp) MarshalToSizedBuffer added in v0.8.0

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

func (*CreateRelationResp) ProtoMessage added in v0.8.0

func (*CreateRelationResp) ProtoMessage()

func (*CreateRelationResp) ProtoSize added in v0.8.0

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

func (*CreateRelationResp) Reset added in v0.8.0

func (m *CreateRelationResp) Reset()

func (*CreateRelationResp) String added in v0.8.0

func (m *CreateRelationResp) String() string

func (*CreateRelationResp) Unmarshal added in v0.8.0

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

func (*CreateRelationResp) UnmarshalBinary added in v0.8.0

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

func (*CreateRelationResp) XXX_DiscardUnknown added in v0.8.0

func (m *CreateRelationResp) XXX_DiscardUnknown()

func (*CreateRelationResp) XXX_Marshal added in v0.8.0

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

func (*CreateRelationResp) XXX_Merge added in v0.8.0

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

func (*CreateRelationResp) XXX_Size added in v0.8.0

func (m *CreateRelationResp) XXX_Size() int

func (*CreateRelationResp) XXX_Unmarshal added in v0.8.0

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

type Database

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

func (*Database) Create

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

func (*Database) Delete

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

func (*Database) GetCreateSql added in v0.8.0

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

func (*Database) GetDatabaseId

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

func (*Database) IsSubscription added in v0.8.0

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

func (*Database) Relation

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

func (*Database) Relations

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

func (*Database) Truncate

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

type DelTableDefReq

type DelTableDefReq struct {
	TableID      ID
	DatabaseName string
	TableName    string
	Def          engine.TableDefPB
}

func (*DelTableDefReq) Descriptor added in v0.8.0

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

func (*DelTableDefReq) GetDatabaseName added in v0.8.0

func (m *DelTableDefReq) GetDatabaseName() string

func (*DelTableDefReq) GetTableID added in v0.8.0

func (m *DelTableDefReq) GetTableID() ID

func (*DelTableDefReq) GetTableName added in v0.8.0

func (m *DelTableDefReq) GetTableName() string

func (*DelTableDefReq) Marshal added in v0.8.0

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

func (*DelTableDefReq) MarshalBinary added in v0.8.0

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

func (*DelTableDefReq) MarshalTo added in v0.8.0

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

func (*DelTableDefReq) MarshalToSizedBuffer added in v0.8.0

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

func (*DelTableDefReq) ProtoMessage added in v0.8.0

func (*DelTableDefReq) ProtoMessage()

func (*DelTableDefReq) ProtoSize added in v0.8.0

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

func (*DelTableDefReq) Reset added in v0.8.0

func (m *DelTableDefReq) Reset()

func (*DelTableDefReq) String added in v0.8.0

func (m *DelTableDefReq) String() string

func (*DelTableDefReq) Unmarshal added in v0.8.0

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

func (*DelTableDefReq) UnmarshalBinary added in v0.8.0

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

func (*DelTableDefReq) XXX_DiscardUnknown added in v0.8.0

func (m *DelTableDefReq) XXX_DiscardUnknown()

func (*DelTableDefReq) XXX_Marshal added in v0.8.0

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

func (*DelTableDefReq) XXX_Merge added in v0.8.0

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

func (*DelTableDefReq) XXX_Size added in v0.8.0

func (m *DelTableDefReq) XXX_Size() int

func (*DelTableDefReq) XXX_Unmarshal added in v0.8.0

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

type DelTableDefResp

type DelTableDefResp struct {
}

func (*DelTableDefResp) Descriptor added in v0.8.0

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

func (*DelTableDefResp) Marshal added in v0.8.0

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

func (*DelTableDefResp) MarshalBinary added in v0.8.0

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

func (*DelTableDefResp) MarshalTo added in v0.8.0

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

func (*DelTableDefResp) MarshalToSizedBuffer added in v0.8.0

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

func (*DelTableDefResp) ProtoMessage added in v0.8.0

func (*DelTableDefResp) ProtoMessage()

func (*DelTableDefResp) ProtoSize added in v0.8.0

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

func (*DelTableDefResp) Reset added in v0.8.0

func (m *DelTableDefResp) Reset()

func (*DelTableDefResp) String added in v0.8.0

func (m *DelTableDefResp) String() string

func (*DelTableDefResp) Unmarshal added in v0.8.0

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

func (*DelTableDefResp) UnmarshalBinary added in v0.8.0

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

func (*DelTableDefResp) XXX_DiscardUnknown added in v0.8.0

func (m *DelTableDefResp) XXX_DiscardUnknown()

func (*DelTableDefResp) XXX_Marshal added in v0.8.0

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

func (*DelTableDefResp) XXX_Merge added in v0.8.0

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

func (*DelTableDefResp) XXX_Size added in v0.8.0

func (m *DelTableDefResp) XXX_Size() int

func (*DelTableDefResp) XXX_Unmarshal added in v0.8.0

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

type DeleteDatabaseReq

type DeleteDatabaseReq struct {
	AccessInfo AccessInfo
	Name       string
}

func (*DeleteDatabaseReq) Descriptor added in v0.8.0

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

func (*DeleteDatabaseReq) GetAccessInfo added in v0.8.0

func (m *DeleteDatabaseReq) GetAccessInfo() AccessInfo

func (*DeleteDatabaseReq) GetName added in v0.8.0

func (m *DeleteDatabaseReq) GetName() string

func (*DeleteDatabaseReq) Marshal added in v0.8.0

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

func (*DeleteDatabaseReq) MarshalBinary added in v0.8.0

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

func (*DeleteDatabaseReq) MarshalTo added in v0.8.0

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

func (*DeleteDatabaseReq) MarshalToSizedBuffer added in v0.8.0

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

func (*DeleteDatabaseReq) ProtoMessage added in v0.8.0

func (*DeleteDatabaseReq) ProtoMessage()

func (*DeleteDatabaseReq) ProtoSize added in v0.8.0

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

func (*DeleteDatabaseReq) Reset added in v0.8.0

func (m *DeleteDatabaseReq) Reset()

func (*DeleteDatabaseReq) String added in v0.8.0

func (m *DeleteDatabaseReq) String() string

func (*DeleteDatabaseReq) Unmarshal added in v0.8.0

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

func (*DeleteDatabaseReq) UnmarshalBinary added in v0.8.0

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

func (*DeleteDatabaseReq) XXX_DiscardUnknown added in v0.8.0

func (m *DeleteDatabaseReq) XXX_DiscardUnknown()

func (*DeleteDatabaseReq) XXX_Marshal added in v0.8.0

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

func (*DeleteDatabaseReq) XXX_Merge added in v0.8.0

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

func (*DeleteDatabaseReq) XXX_Size added in v0.8.0

func (m *DeleteDatabaseReq) XXX_Size() int

func (*DeleteDatabaseReq) XXX_Unmarshal added in v0.8.0

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

type DeleteDatabaseResp

type DeleteDatabaseResp struct {
	ID ID
}

func (*DeleteDatabaseResp) Descriptor added in v0.8.0

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

func (*DeleteDatabaseResp) GetID added in v0.8.0

func (m *DeleteDatabaseResp) GetID() ID

func (*DeleteDatabaseResp) Marshal added in v0.8.0

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

func (*DeleteDatabaseResp) MarshalBinary added in v0.8.0

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

func (*DeleteDatabaseResp) MarshalTo added in v0.8.0

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

func (*DeleteDatabaseResp) MarshalToSizedBuffer added in v0.8.0

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

func (*DeleteDatabaseResp) ProtoMessage added in v0.8.0

func (*DeleteDatabaseResp) ProtoMessage()

func (*DeleteDatabaseResp) ProtoSize added in v0.8.0

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

func (*DeleteDatabaseResp) Reset added in v0.8.0

func (m *DeleteDatabaseResp) Reset()

func (*DeleteDatabaseResp) String added in v0.8.0

func (m *DeleteDatabaseResp) String() string

func (*DeleteDatabaseResp) Unmarshal added in v0.8.0

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

func (*DeleteDatabaseResp) UnmarshalBinary added in v0.8.0

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

func (*DeleteDatabaseResp) XXX_DiscardUnknown added in v0.8.0

func (m *DeleteDatabaseResp) XXX_DiscardUnknown()

func (*DeleteDatabaseResp) XXX_Marshal added in v0.8.0

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

func (*DeleteDatabaseResp) XXX_Merge added in v0.8.0

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

func (*DeleteDatabaseResp) XXX_Size added in v0.8.0

func (m *DeleteDatabaseResp) XXX_Size() int

func (*DeleteDatabaseResp) XXX_Unmarshal added in v0.8.0

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

type DeleteRelationReq

type DeleteRelationReq struct {
	DatabaseID   ID
	DatabaseName string
	Name         string
}

func (*DeleteRelationReq) Descriptor added in v0.8.0

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

func (*DeleteRelationReq) GetDatabaseID added in v0.8.0

func (m *DeleteRelationReq) GetDatabaseID() ID

func (*DeleteRelationReq) GetDatabaseName added in v0.8.0

func (m *DeleteRelationReq) GetDatabaseName() string

func (*DeleteRelationReq) GetName added in v0.8.0

func (m *DeleteRelationReq) GetName() string

func (*DeleteRelationReq) Marshal added in v0.8.0

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

func (*DeleteRelationReq) MarshalBinary added in v0.8.0

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

func (*DeleteRelationReq) MarshalTo added in v0.8.0

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

func (*DeleteRelationReq) MarshalToSizedBuffer added in v0.8.0

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

func (*DeleteRelationReq) ProtoMessage added in v0.8.0

func (*DeleteRelationReq) ProtoMessage()

func (*DeleteRelationReq) ProtoSize added in v0.8.0

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

func (*DeleteRelationReq) Reset added in v0.8.0

func (m *DeleteRelationReq) Reset()

func (*DeleteRelationReq) String added in v0.8.0

func (m *DeleteRelationReq) String() string

func (*DeleteRelationReq) Unmarshal added in v0.8.0

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

func (*DeleteRelationReq) UnmarshalBinary added in v0.8.0

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

func (*DeleteRelationReq) XXX_DiscardUnknown added in v0.8.0

func (m *DeleteRelationReq) XXX_DiscardUnknown()

func (*DeleteRelationReq) XXX_Marshal added in v0.8.0

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

func (*DeleteRelationReq) XXX_Merge added in v0.8.0

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

func (*DeleteRelationReq) XXX_Size added in v0.8.0

func (m *DeleteRelationReq) XXX_Size() int

func (*DeleteRelationReq) XXX_Unmarshal added in v0.8.0

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

type DeleteRelationResp

type DeleteRelationResp struct {
	ID ID
}

func (*DeleteRelationResp) Descriptor added in v0.8.0

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

func (*DeleteRelationResp) GetID added in v0.8.0

func (m *DeleteRelationResp) GetID() ID

func (*DeleteRelationResp) Marshal added in v0.8.0

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

func (*DeleteRelationResp) MarshalBinary added in v0.8.0

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

func (*DeleteRelationResp) MarshalTo added in v0.8.0

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

func (*DeleteRelationResp) MarshalToSizedBuffer added in v0.8.0

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

func (*DeleteRelationResp) ProtoMessage added in v0.8.0

func (*DeleteRelationResp) ProtoMessage()

func (*DeleteRelationResp) ProtoSize added in v0.8.0

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

func (*DeleteRelationResp) Reset added in v0.8.0

func (m *DeleteRelationResp) Reset()

func (*DeleteRelationResp) String added in v0.8.0

func (m *DeleteRelationResp) String() string

func (*DeleteRelationResp) Unmarshal added in v0.8.0

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

func (*DeleteRelationResp) UnmarshalBinary added in v0.8.0

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

func (*DeleteRelationResp) XXX_DiscardUnknown added in v0.8.0

func (m *DeleteRelationResp) XXX_DiscardUnknown()

func (*DeleteRelationResp) XXX_Marshal added in v0.8.0

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

func (*DeleteRelationResp) XXX_Merge added in v0.8.0

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

func (*DeleteRelationResp) XXX_Size added in v0.8.0

func (m *DeleteRelationResp) XXX_Size() int

func (*DeleteRelationResp) XXX_Unmarshal added in v0.8.0

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

type DeleteReq

type DeleteReq struct {
	TableID      ID
	DatabaseName string
	TableName    string
	ColumnName   string
	Vector       *vector.Vector
}

func (*DeleteReq) MarshalBinary added in v0.8.0

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

func (*DeleteReq) UnmarshalBinary added in v0.8.0

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

type DeleteResp

type DeleteResp struct {
}

func (*DeleteResp) Descriptor added in v0.8.0

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

func (*DeleteResp) Marshal added in v0.8.0

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

func (*DeleteResp) MarshalBinary added in v0.8.0

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

func (*DeleteResp) MarshalTo added in v0.8.0

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

func (*DeleteResp) MarshalToSizedBuffer added in v0.8.0

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

func (*DeleteResp) ProtoMessage added in v0.8.0

func (*DeleteResp) ProtoMessage()

func (*DeleteResp) ProtoSize added in v0.8.0

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

func (*DeleteResp) Reset added in v0.8.0

func (m *DeleteResp) Reset()

func (*DeleteResp) String added in v0.8.0

func (m *DeleteResp) String() string

func (*DeleteResp) Unmarshal added in v0.8.0

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

func (*DeleteResp) UnmarshalBinary added in v0.8.0

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

func (*DeleteResp) XXX_DiscardUnknown added in v0.8.0

func (m *DeleteResp) XXX_DiscardUnknown()

func (*DeleteResp) XXX_Marshal added in v0.8.0

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

func (*DeleteResp) XXX_Merge added in v0.8.0

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

func (*DeleteResp) XXX_Size added in v0.8.0

func (m *DeleteResp) XXX_Size() int

func (*DeleteResp) XXX_Unmarshal added in v0.8.0

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

type Engine

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

Engine is an engine.Engine impl

func New

func New(
	ctx context.Context,
	shardPolicy ShardPolicy,
	idGenerator IDGenerator,
	cluster clusterservice.MOCluster,
) *Engine

func (*Engine) AllocateIDByKey added in v0.8.0

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

func (*Engine) Bind

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

func (*Engine) Commit

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

func (*Engine) Create

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

func (*Engine) Database

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

func (*Engine) Databases

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

func (*Engine) Delete

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

func (*Engine) GetNameById added in v0.7.0

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

func (*Engine) GetRelationById added in v0.7.0

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

func (*Engine) Hints

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

func (*Engine) New

func (*Engine) NewBlockReader

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

func (*Engine) NewCompilerContext

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

func (*Engine) Nodes

func (e *Engine) Nodes(isInternal bool, tenant string, _ string, cnLabel map[string]string) (engine.Nodes, error)

func (*Engine) Rollback

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

type FallbackShard

type FallbackShard []ShardPolicy

func (FallbackShard) Batch

func (f FallbackShard) Batch(
	ctx context.Context,
	tableID ID,
	getDefs func(context.Context) ([]engine.TableDef, error),
	batch *batch.Batch,
	nodes []metadata.TNService) (sharded []*ShardedBatch, err error)

func (FallbackShard) Vector

func (f FallbackShard) Vector(
	ctx context.Context,
	tableID ID,
	getDefs func(context.Context) ([]engine.TableDef, error),
	colName string,
	vec *vector.Vector,
	nodes []metadata.TNService) (sharded []*ShardedVector, err error)

type GetDatabasesReq

type GetDatabasesReq struct {
	AccessInfo AccessInfo
}

func (*GetDatabasesReq) Descriptor added in v0.8.0

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

func (*GetDatabasesReq) GetAccessInfo added in v0.8.0

func (m *GetDatabasesReq) GetAccessInfo() AccessInfo

func (*GetDatabasesReq) Marshal added in v0.8.0

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

func (*GetDatabasesReq) MarshalBinary added in v0.8.0

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

func (*GetDatabasesReq) MarshalTo added in v0.8.0

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

func (*GetDatabasesReq) MarshalToSizedBuffer added in v0.8.0

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

func (*GetDatabasesReq) ProtoMessage added in v0.8.0

func (*GetDatabasesReq) ProtoMessage()

func (*GetDatabasesReq) ProtoSize added in v0.8.0

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

func (*GetDatabasesReq) Reset added in v0.8.0

func (m *GetDatabasesReq) Reset()

func (*GetDatabasesReq) String added in v0.8.0

func (m *GetDatabasesReq) String() string

func (*GetDatabasesReq) Unmarshal added in v0.8.0

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

func (*GetDatabasesReq) UnmarshalBinary added in v0.8.0

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

func (*GetDatabasesReq) XXX_DiscardUnknown added in v0.8.0

func (m *GetDatabasesReq) XXX_DiscardUnknown()

func (*GetDatabasesReq) XXX_Marshal added in v0.8.0

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

func (*GetDatabasesReq) XXX_Merge added in v0.8.0

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

func (*GetDatabasesReq) XXX_Size added in v0.8.0

func (m *GetDatabasesReq) XXX_Size() int

func (*GetDatabasesReq) XXX_Unmarshal added in v0.8.0

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

type GetDatabasesResp

type GetDatabasesResp struct {
	Names []string
}

func (*GetDatabasesResp) Descriptor added in v0.8.0

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

func (*GetDatabasesResp) GetNames added in v0.8.0

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

func (*GetDatabasesResp) Marshal added in v0.8.0

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

func (*GetDatabasesResp) MarshalBinary added in v0.8.0

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

func (*GetDatabasesResp) MarshalTo added in v0.8.0

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

func (*GetDatabasesResp) MarshalToSizedBuffer added in v0.8.0

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

func (*GetDatabasesResp) ProtoMessage added in v0.8.0

func (*GetDatabasesResp) ProtoMessage()

func (*GetDatabasesResp) ProtoSize added in v0.8.0

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

func (*GetDatabasesResp) Reset added in v0.8.0

func (m *GetDatabasesResp) Reset()

func (*GetDatabasesResp) String added in v0.8.0

func (m *GetDatabasesResp) String() string

func (*GetDatabasesResp) Unmarshal added in v0.8.0

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

func (*GetDatabasesResp) UnmarshalBinary added in v0.8.0

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

func (*GetDatabasesResp) XXX_DiscardUnknown added in v0.8.0

func (m *GetDatabasesResp) XXX_DiscardUnknown()

func (*GetDatabasesResp) XXX_Marshal added in v0.8.0

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

func (*GetDatabasesResp) XXX_Merge added in v0.8.0

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

func (*GetDatabasesResp) XXX_Size added in v0.8.0

func (m *GetDatabasesResp) XXX_Size() int

func (*GetDatabasesResp) XXX_Unmarshal added in v0.8.0

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

type GetHiddenKeysReq

type GetHiddenKeysReq struct {
	TableID ID
}

func (*GetHiddenKeysReq) Descriptor added in v0.8.0

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

func (*GetHiddenKeysReq) GetTableID added in v0.8.0

func (m *GetHiddenKeysReq) GetTableID() ID

func (*GetHiddenKeysReq) Marshal added in v0.8.0

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

func (*GetHiddenKeysReq) MarshalBinary added in v0.8.0

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

func (*GetHiddenKeysReq) MarshalTo added in v0.8.0

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

func (*GetHiddenKeysReq) MarshalToSizedBuffer added in v0.8.0

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

func (*GetHiddenKeysReq) ProtoMessage added in v0.8.0

func (*GetHiddenKeysReq) ProtoMessage()

func (*GetHiddenKeysReq) ProtoSize added in v0.8.0

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

func (*GetHiddenKeysReq) Reset added in v0.8.0

func (m *GetHiddenKeysReq) Reset()

func (*GetHiddenKeysReq) String added in v0.8.0

func (m *GetHiddenKeysReq) String() string

func (*GetHiddenKeysReq) Unmarshal added in v0.8.0

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

func (*GetHiddenKeysReq) UnmarshalBinary added in v0.8.0

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

func (*GetHiddenKeysReq) XXX_DiscardUnknown added in v0.8.0

func (m *GetHiddenKeysReq) XXX_DiscardUnknown()

func (*GetHiddenKeysReq) XXX_Marshal added in v0.8.0

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

func (*GetHiddenKeysReq) XXX_Merge added in v0.8.0

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

func (*GetHiddenKeysReq) XXX_Size added in v0.8.0

func (m *GetHiddenKeysReq) XXX_Size() int

func (*GetHiddenKeysReq) XXX_Unmarshal added in v0.8.0

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

type GetHiddenKeysResp

type GetHiddenKeysResp struct {
	Attrs []engine.Attribute
}

func (*GetHiddenKeysResp) Descriptor added in v0.8.0

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

func (*GetHiddenKeysResp) Marshal added in v0.8.0

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

func (*GetHiddenKeysResp) MarshalBinary added in v0.8.0

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

func (*GetHiddenKeysResp) MarshalTo added in v0.8.0

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

func (*GetHiddenKeysResp) MarshalToSizedBuffer added in v0.8.0

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

func (*GetHiddenKeysResp) ProtoMessage added in v0.8.0

func (*GetHiddenKeysResp) ProtoMessage()

func (*GetHiddenKeysResp) ProtoSize added in v0.8.0

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

func (*GetHiddenKeysResp) Reset added in v0.8.0

func (m *GetHiddenKeysResp) Reset()

func (*GetHiddenKeysResp) String added in v0.8.0

func (m *GetHiddenKeysResp) String() string

func (*GetHiddenKeysResp) Unmarshal added in v0.8.0

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

func (*GetHiddenKeysResp) UnmarshalBinary added in v0.8.0

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

func (*GetHiddenKeysResp) XXX_DiscardUnknown added in v0.8.0

func (m *GetHiddenKeysResp) XXX_DiscardUnknown()

func (*GetHiddenKeysResp) XXX_Marshal added in v0.8.0

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

func (*GetHiddenKeysResp) XXX_Merge added in v0.8.0

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

func (*GetHiddenKeysResp) XXX_Size added in v0.8.0

func (m *GetHiddenKeysResp) XXX_Size() int

func (*GetHiddenKeysResp) XXX_Unmarshal added in v0.8.0

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

type GetPrimaryKeysReq

type GetPrimaryKeysReq struct {
	TableID ID
}

func (*GetPrimaryKeysReq) Descriptor added in v0.8.0

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

func (*GetPrimaryKeysReq) GetTableID added in v0.8.0

func (m *GetPrimaryKeysReq) GetTableID() ID

func (*GetPrimaryKeysReq) Marshal added in v0.8.0

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

func (*GetPrimaryKeysReq) MarshalBinary added in v0.8.0

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

func (*GetPrimaryKeysReq) MarshalTo added in v0.8.0

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

func (*GetPrimaryKeysReq) MarshalToSizedBuffer added in v0.8.0

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

func (*GetPrimaryKeysReq) ProtoMessage added in v0.8.0

func (*GetPrimaryKeysReq) ProtoMessage()

func (*GetPrimaryKeysReq) ProtoSize added in v0.8.0

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

func (*GetPrimaryKeysReq) Reset added in v0.8.0

func (m *GetPrimaryKeysReq) Reset()

func (*GetPrimaryKeysReq) String added in v0.8.0

func (m *GetPrimaryKeysReq) String() string

func (*GetPrimaryKeysReq) Unmarshal added in v0.8.0

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

func (*GetPrimaryKeysReq) UnmarshalBinary added in v0.8.0

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

func (*GetPrimaryKeysReq) XXX_DiscardUnknown added in v0.8.0

func (m *GetPrimaryKeysReq) XXX_DiscardUnknown()

func (*GetPrimaryKeysReq) XXX_Marshal added in v0.8.0

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

func (*GetPrimaryKeysReq) XXX_Merge added in v0.8.0

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

func (*GetPrimaryKeysReq) XXX_Size added in v0.8.0

func (m *GetPrimaryKeysReq) XXX_Size() int

func (*GetPrimaryKeysReq) XXX_Unmarshal added in v0.8.0

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

type GetPrimaryKeysResp

type GetPrimaryKeysResp struct {
	Attrs []engine.Attribute
}

func (*GetPrimaryKeysResp) Descriptor added in v0.8.0

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

func (*GetPrimaryKeysResp) Marshal added in v0.8.0

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

func (*GetPrimaryKeysResp) MarshalBinary added in v0.8.0

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

func (*GetPrimaryKeysResp) MarshalTo added in v0.8.0

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

func (*GetPrimaryKeysResp) MarshalToSizedBuffer added in v0.8.0

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

func (*GetPrimaryKeysResp) ProtoMessage added in v0.8.0

func (*GetPrimaryKeysResp) ProtoMessage()

func (*GetPrimaryKeysResp) ProtoSize added in v0.8.0

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

func (*GetPrimaryKeysResp) Reset added in v0.8.0

func (m *GetPrimaryKeysResp) Reset()

func (*GetPrimaryKeysResp) String added in v0.8.0

func (m *GetPrimaryKeysResp) String() string

func (*GetPrimaryKeysResp) Unmarshal added in v0.8.0

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

func (*GetPrimaryKeysResp) UnmarshalBinary added in v0.8.0

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

func (*GetPrimaryKeysResp) XXX_DiscardUnknown added in v0.8.0

func (m *GetPrimaryKeysResp) XXX_DiscardUnknown()

func (*GetPrimaryKeysResp) XXX_Marshal added in v0.8.0

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

func (*GetPrimaryKeysResp) XXX_Merge added in v0.8.0

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

func (*GetPrimaryKeysResp) XXX_Size added in v0.8.0

func (m *GetPrimaryKeysResp) XXX_Size() int

func (*GetPrimaryKeysResp) XXX_Unmarshal added in v0.8.0

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

type GetRelationsReq

type GetRelationsReq struct {
	DatabaseID ID
}

func (*GetRelationsReq) Descriptor added in v0.8.0

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

func (*GetRelationsReq) GetDatabaseID added in v0.8.0

func (m *GetRelationsReq) GetDatabaseID() ID

func (*GetRelationsReq) Marshal added in v0.8.0

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

func (*GetRelationsReq) MarshalBinary added in v0.8.0

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

func (*GetRelationsReq) MarshalTo added in v0.8.0

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

func (*GetRelationsReq) MarshalToSizedBuffer added in v0.8.0

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

func (*GetRelationsReq) ProtoMessage added in v0.8.0

func (*GetRelationsReq) ProtoMessage()

func (*GetRelationsReq) ProtoSize added in v0.8.0

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

func (*GetRelationsReq) Reset added in v0.8.0

func (m *GetRelationsReq) Reset()

func (*GetRelationsReq) String added in v0.8.0

func (m *GetRelationsReq) String() string

func (*GetRelationsReq) Unmarshal added in v0.8.0

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

func (*GetRelationsReq) UnmarshalBinary added in v0.8.0

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

func (*GetRelationsReq) XXX_DiscardUnknown added in v0.8.0

func (m *GetRelationsReq) XXX_DiscardUnknown()

func (*GetRelationsReq) XXX_Marshal added in v0.8.0

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

func (*GetRelationsReq) XXX_Merge added in v0.8.0

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

func (*GetRelationsReq) XXX_Size added in v0.8.0

func (m *GetRelationsReq) XXX_Size() int

func (*GetRelationsReq) XXX_Unmarshal added in v0.8.0

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

type GetRelationsResp

type GetRelationsResp struct {
	Names []string
}

func (*GetRelationsResp) Descriptor added in v0.8.0

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

func (*GetRelationsResp) GetNames added in v0.8.0

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

func (*GetRelationsResp) Marshal added in v0.8.0

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

func (*GetRelationsResp) MarshalBinary added in v0.8.0

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

func (*GetRelationsResp) MarshalTo added in v0.8.0

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

func (*GetRelationsResp) MarshalToSizedBuffer added in v0.8.0

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

func (*GetRelationsResp) ProtoMessage added in v0.8.0

func (*GetRelationsResp) ProtoMessage()

func (*GetRelationsResp) ProtoSize added in v0.8.0

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

func (*GetRelationsResp) Reset added in v0.8.0

func (m *GetRelationsResp) Reset()

func (*GetRelationsResp) String added in v0.8.0

func (m *GetRelationsResp) String() string

func (*GetRelationsResp) Unmarshal added in v0.8.0

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

func (*GetRelationsResp) UnmarshalBinary added in v0.8.0

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

func (*GetRelationsResp) XXX_DiscardUnknown added in v0.8.0

func (m *GetRelationsResp) XXX_DiscardUnknown()

func (*GetRelationsResp) XXX_Marshal added in v0.8.0

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

func (*GetRelationsResp) XXX_Merge added in v0.8.0

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

func (*GetRelationsResp) XXX_Size added in v0.8.0

func (m *GetRelationsResp) XXX_Size() int

func (*GetRelationsResp) XXX_Unmarshal added in v0.8.0

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

type GetTableColumnsReq

type GetTableColumnsReq struct {
	TableID ID
}

func (*GetTableColumnsReq) Descriptor added in v0.8.0

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

func (*GetTableColumnsReq) GetTableID added in v0.8.0

func (m *GetTableColumnsReq) GetTableID() ID

func (*GetTableColumnsReq) Marshal added in v0.8.0

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

func (*GetTableColumnsReq) MarshalBinary added in v0.8.0

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

func (*GetTableColumnsReq) MarshalTo added in v0.8.0

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

func (*GetTableColumnsReq) MarshalToSizedBuffer added in v0.8.0

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

func (*GetTableColumnsReq) ProtoMessage added in v0.8.0

func (*GetTableColumnsReq) ProtoMessage()

func (*GetTableColumnsReq) ProtoSize added in v0.8.0

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

func (*GetTableColumnsReq) Reset added in v0.8.0

func (m *GetTableColumnsReq) Reset()

func (*GetTableColumnsReq) String added in v0.8.0

func (m *GetTableColumnsReq) String() string

func (*GetTableColumnsReq) Unmarshal added in v0.8.0

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

func (*GetTableColumnsReq) UnmarshalBinary added in v0.8.0

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

func (*GetTableColumnsReq) XXX_DiscardUnknown added in v0.8.0

func (m *GetTableColumnsReq) XXX_DiscardUnknown()

func (*GetTableColumnsReq) XXX_Marshal added in v0.8.0

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

func (*GetTableColumnsReq) XXX_Merge added in v0.8.0

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

func (*GetTableColumnsReq) XXX_Size added in v0.8.0

func (m *GetTableColumnsReq) XXX_Size() int

func (*GetTableColumnsReq) XXX_Unmarshal added in v0.8.0

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

type GetTableColumnsResp

type GetTableColumnsResp struct {
	Attrs []engine.Attribute
}

func (*GetTableColumnsResp) Descriptor added in v0.8.0

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

func (*GetTableColumnsResp) Marshal added in v0.8.0

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

func (*GetTableColumnsResp) MarshalBinary added in v0.8.0

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

func (*GetTableColumnsResp) MarshalTo added in v0.8.0

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

func (*GetTableColumnsResp) MarshalToSizedBuffer added in v0.8.0

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

func (*GetTableColumnsResp) ProtoMessage added in v0.8.0

func (*GetTableColumnsResp) ProtoMessage()

func (*GetTableColumnsResp) ProtoSize added in v0.8.0

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

func (*GetTableColumnsResp) Reset added in v0.8.0

func (m *GetTableColumnsResp) Reset()

func (*GetTableColumnsResp) String added in v0.8.0

func (m *GetTableColumnsResp) String() string

func (*GetTableColumnsResp) Unmarshal added in v0.8.0

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

func (*GetTableColumnsResp) UnmarshalBinary added in v0.8.0

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

func (*GetTableColumnsResp) XXX_DiscardUnknown added in v0.8.0

func (m *GetTableColumnsResp) XXX_DiscardUnknown()

func (*GetTableColumnsResp) XXX_Marshal added in v0.8.0

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

func (*GetTableColumnsResp) XXX_Merge added in v0.8.0

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

func (*GetTableColumnsResp) XXX_Size added in v0.8.0

func (m *GetTableColumnsResp) XXX_Size() int

func (*GetTableColumnsResp) XXX_Unmarshal added in v0.8.0

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

type GetTableDefsReq

type GetTableDefsReq struct {
	TableID ID
}

func (*GetTableDefsReq) Descriptor added in v0.8.0

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

func (*GetTableDefsReq) GetTableID added in v0.8.0

func (m *GetTableDefsReq) GetTableID() ID

func (*GetTableDefsReq) Marshal added in v0.8.0

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

func (*GetTableDefsReq) MarshalBinary added in v0.8.0

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

func (*GetTableDefsReq) MarshalTo added in v0.8.0

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

func (*GetTableDefsReq) MarshalToSizedBuffer added in v0.8.0

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

func (*GetTableDefsReq) ProtoMessage added in v0.8.0

func (*GetTableDefsReq) ProtoMessage()

func (*GetTableDefsReq) ProtoSize added in v0.8.0

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

func (*GetTableDefsReq) Reset added in v0.8.0

func (m *GetTableDefsReq) Reset()

func (*GetTableDefsReq) String added in v0.8.0

func (m *GetTableDefsReq) String() string

func (*GetTableDefsReq) Unmarshal added in v0.8.0

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

func (*GetTableDefsReq) UnmarshalBinary added in v0.8.0

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

func (*GetTableDefsReq) XXX_DiscardUnknown added in v0.8.0

func (m *GetTableDefsReq) XXX_DiscardUnknown()

func (*GetTableDefsReq) XXX_Marshal added in v0.8.0

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

func (*GetTableDefsReq) XXX_Merge added in v0.8.0

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

func (*GetTableDefsReq) XXX_Size added in v0.8.0

func (m *GetTableDefsReq) XXX_Size() int

func (*GetTableDefsReq) XXX_Unmarshal added in v0.8.0

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

type GetTableDefsResp

type GetTableDefsResp struct {
	Defs []engine.TableDefPB
}

func (*GetTableDefsResp) Descriptor added in v0.8.0

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

func (*GetTableDefsResp) Marshal added in v0.8.0

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

func (*GetTableDefsResp) MarshalBinary added in v0.8.0

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

func (*GetTableDefsResp) MarshalTo added in v0.8.0

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

func (*GetTableDefsResp) MarshalToSizedBuffer added in v0.8.0

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

func (*GetTableDefsResp) ProtoMessage added in v0.8.0

func (*GetTableDefsResp) ProtoMessage()

func (*GetTableDefsResp) ProtoSize added in v0.8.0

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

func (*GetTableDefsResp) Reset added in v0.8.0

func (m *GetTableDefsResp) Reset()

func (*GetTableDefsResp) String added in v0.8.0

func (m *GetTableDefsResp) String() string

func (*GetTableDefsResp) Unmarshal added in v0.8.0

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

func (*GetTableDefsResp) UnmarshalBinary added in v0.8.0

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

func (*GetTableDefsResp) XXX_DiscardUnknown added in v0.8.0

func (m *GetTableDefsResp) XXX_DiscardUnknown()

func (*GetTableDefsResp) XXX_Marshal added in v0.8.0

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

func (*GetTableDefsResp) XXX_Merge added in v0.8.0

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

func (*GetTableDefsResp) XXX_Size added in v0.8.0

func (m *GetTableDefsResp) XXX_Size() int

func (*GetTableDefsResp) XXX_Unmarshal added in v0.8.0

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

type HakeeperIDGenerator

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

func NewHakeeperIDGenerator

func NewHakeeperIDGenerator(
	generator hakeeperIDGenerator,
) *HakeeperIDGenerator

func (*HakeeperIDGenerator) NewID

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

func (*HakeeperIDGenerator) NewIDByKey added in v0.8.0

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

type HashShard

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

func NewHashShard

func NewHashShard(mp *mpool.MPool) *HashShard

func (*HashShard) Batch

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

func (*HashShard) Vector

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

type ID

type ID uint64

func (ID) IsEmpty

func (i ID) IsEmpty() bool

func (ID) Less

func (i ID) Less(than ID) bool

func (ID) ToRowID

func (i ID) ToRowID() types.Rowid

type IDGenerator

type IDGenerator interface {
	NewID(context.Context) (ID, error)
	NewIDByKey(ctx context.Context, key string) (ID, error)
}

type IterInfo

type IterInfo struct {
	Shard  Shard
	IterID ID
}

type NewTableIterReq

type NewTableIterReq struct {
	TableID ID
	Expr    *plan.Expr
}

func (*NewTableIterReq) Descriptor added in v0.8.0

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

func (*NewTableIterReq) GetExpr added in v0.8.0

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

func (*NewTableIterReq) GetTableID added in v0.8.0

func (m *NewTableIterReq) GetTableID() ID

func (*NewTableIterReq) Marshal added in v0.8.0

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

func (*NewTableIterReq) MarshalBinary added in v0.8.0

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

func (*NewTableIterReq) MarshalTo added in v0.8.0

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

func (*NewTableIterReq) MarshalToSizedBuffer added in v0.8.0

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

func (*NewTableIterReq) ProtoMessage added in v0.8.0

func (*NewTableIterReq) ProtoMessage()

func (*NewTableIterReq) ProtoSize added in v0.8.0

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

func (*NewTableIterReq) Reset added in v0.8.0

func (m *NewTableIterReq) Reset()

func (*NewTableIterReq) String added in v0.8.0

func (m *NewTableIterReq) String() string

func (*NewTableIterReq) Unmarshal added in v0.8.0

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

func (*NewTableIterReq) UnmarshalBinary added in v0.8.0

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

func (*NewTableIterReq) XXX_DiscardUnknown added in v0.8.0

func (m *NewTableIterReq) XXX_DiscardUnknown()

func (*NewTableIterReq) XXX_Marshal added in v0.8.0

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

func (*NewTableIterReq) XXX_Merge added in v0.8.0

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

func (*NewTableIterReq) XXX_Size added in v0.8.0

func (m *NewTableIterReq) XXX_Size() int

func (*NewTableIterReq) XXX_Unmarshal added in v0.8.0

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

type NewTableIterResp

type NewTableIterResp struct {
	IterID ID
}

func (*NewTableIterResp) Descriptor added in v0.8.0

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

func (*NewTableIterResp) GetIterID added in v0.8.0

func (m *NewTableIterResp) GetIterID() ID

func (*NewTableIterResp) Marshal added in v0.8.0

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

func (*NewTableIterResp) MarshalBinary added in v0.8.0

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

func (*NewTableIterResp) MarshalTo added in v0.8.0

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

func (*NewTableIterResp) MarshalToSizedBuffer added in v0.8.0

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

func (*NewTableIterResp) ProtoMessage added in v0.8.0

func (*NewTableIterResp) ProtoMessage()

func (*NewTableIterResp) ProtoSize added in v0.8.0

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

func (*NewTableIterResp) Reset added in v0.8.0

func (m *NewTableIterResp) Reset()

func (*NewTableIterResp) String added in v0.8.0

func (m *NewTableIterResp) String() string

func (*NewTableIterResp) Unmarshal added in v0.8.0

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

func (*NewTableIterResp) UnmarshalBinary added in v0.8.0

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

func (*NewTableIterResp) XXX_DiscardUnknown added in v0.8.0

func (m *NewTableIterResp) XXX_DiscardUnknown()

func (*NewTableIterResp) XXX_Marshal added in v0.8.0

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

func (*NewTableIterResp) XXX_Merge added in v0.8.0

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

func (*NewTableIterResp) XXX_Size added in v0.8.0

func (m *NewTableIterResp) XXX_Size() int

func (*NewTableIterResp) XXX_Unmarshal added in v0.8.0

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

type NoShard

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

NoShard doesn't do sharding at all

func (*NoShard) Batch

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

func (*NoShard) Vector

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

type Nullable

type Nullable struct {
	IsNull bool
	Value  any
}

type OpenDatabaseReq

type OpenDatabaseReq struct {
	AccessInfo AccessInfo
	Name       string
}

func (*OpenDatabaseReq) Descriptor added in v0.8.0

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

func (*OpenDatabaseReq) GetAccessInfo added in v0.8.0

func (m *OpenDatabaseReq) GetAccessInfo() AccessInfo

func (*OpenDatabaseReq) GetName added in v0.8.0

func (m *OpenDatabaseReq) GetName() string

func (*OpenDatabaseReq) Marshal added in v0.8.0

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

func (*OpenDatabaseReq) MarshalBinary added in v0.8.0

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

func (*OpenDatabaseReq) MarshalTo added in v0.8.0

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

func (*OpenDatabaseReq) MarshalToSizedBuffer added in v0.8.0

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

func (*OpenDatabaseReq) ProtoMessage added in v0.8.0

func (*OpenDatabaseReq) ProtoMessage()

func (*OpenDatabaseReq) ProtoSize added in v0.8.0

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

func (*OpenDatabaseReq) Reset added in v0.8.0

func (m *OpenDatabaseReq) Reset()

func (*OpenDatabaseReq) String added in v0.8.0

func (m *OpenDatabaseReq) String() string

func (*OpenDatabaseReq) Unmarshal added in v0.8.0

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

func (*OpenDatabaseReq) UnmarshalBinary added in v0.8.0

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

func (*OpenDatabaseReq) XXX_DiscardUnknown added in v0.8.0

func (m *OpenDatabaseReq) XXX_DiscardUnknown()

func (*OpenDatabaseReq) XXX_Marshal added in v0.8.0

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

func (*OpenDatabaseReq) XXX_Merge added in v0.8.0

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

func (*OpenDatabaseReq) XXX_Size added in v0.8.0

func (m *OpenDatabaseReq) XXX_Size() int

func (*OpenDatabaseReq) XXX_Unmarshal added in v0.8.0

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

type OpenDatabaseResp

type OpenDatabaseResp struct {
	ID        ID
	Name      string
	DatTyp    string
	CreateSql string
}

func (*OpenDatabaseResp) Descriptor added in v0.8.0

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

func (*OpenDatabaseResp) GetID added in v0.8.0

func (m *OpenDatabaseResp) GetID() ID

func (*OpenDatabaseResp) GetName added in v0.8.0

func (m *OpenDatabaseResp) GetName() string

func (*OpenDatabaseResp) Marshal added in v0.8.0

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

func (*OpenDatabaseResp) MarshalBinary added in v0.8.0

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

func (*OpenDatabaseResp) MarshalTo added in v0.8.0

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

func (*OpenDatabaseResp) MarshalToSizedBuffer added in v0.8.0

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

func (*OpenDatabaseResp) ProtoMessage added in v0.8.0

func (*OpenDatabaseResp) ProtoMessage()

func (*OpenDatabaseResp) ProtoSize added in v0.8.0

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

func (*OpenDatabaseResp) Reset added in v0.8.0

func (m *OpenDatabaseResp) Reset()

func (*OpenDatabaseResp) String added in v0.8.0

func (m *OpenDatabaseResp) String() string

func (*OpenDatabaseResp) Unmarshal added in v0.8.0

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

func (*OpenDatabaseResp) UnmarshalBinary added in v0.8.0

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

func (*OpenDatabaseResp) XXX_DiscardUnknown added in v0.8.0

func (m *OpenDatabaseResp) XXX_DiscardUnknown()

func (*OpenDatabaseResp) XXX_Marshal added in v0.8.0

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

func (*OpenDatabaseResp) XXX_Merge added in v0.8.0

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

func (*OpenDatabaseResp) XXX_Size added in v0.8.0

func (m *OpenDatabaseResp) XXX_Size() int

func (*OpenDatabaseResp) XXX_Unmarshal added in v0.8.0

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

type OpenRelationReq

type OpenRelationReq struct {
	DatabaseID   ID
	DatabaseName string
	Name         string
}

func (*OpenRelationReq) Descriptor added in v0.8.0

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

func (*OpenRelationReq) GetDatabaseID added in v0.8.0

func (m *OpenRelationReq) GetDatabaseID() ID

func (*OpenRelationReq) GetDatabaseName added in v0.8.0

func (m *OpenRelationReq) GetDatabaseName() string

func (*OpenRelationReq) GetName added in v0.8.0

func (m *OpenRelationReq) GetName() string

func (*OpenRelationReq) Marshal added in v0.8.0

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

func (*OpenRelationReq) MarshalBinary added in v0.8.0

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

func (*OpenRelationReq) MarshalTo added in v0.8.0

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

func (*OpenRelationReq) MarshalToSizedBuffer added in v0.8.0

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

func (*OpenRelationReq) ProtoMessage added in v0.8.0

func (*OpenRelationReq) ProtoMessage()

func (*OpenRelationReq) ProtoSize added in v0.8.0

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

func (*OpenRelationReq) Reset added in v0.8.0

func (m *OpenRelationReq) Reset()

func (*OpenRelationReq) String added in v0.8.0

func (m *OpenRelationReq) String() string

func (*OpenRelationReq) Unmarshal added in v0.8.0

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

func (*OpenRelationReq) UnmarshalBinary added in v0.8.0

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

func (*OpenRelationReq) XXX_DiscardUnknown added in v0.8.0

func (m *OpenRelationReq) XXX_DiscardUnknown()

func (*OpenRelationReq) XXX_Marshal added in v0.8.0

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

func (*OpenRelationReq) XXX_Merge added in v0.8.0

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

func (*OpenRelationReq) XXX_Size added in v0.8.0

func (m *OpenRelationReq) XXX_Size() int

func (*OpenRelationReq) XXX_Unmarshal added in v0.8.0

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

type OpenRelationResp

type OpenRelationResp struct {
	ID           ID
	Type         RelationType
	DatabaseName string
	RelationName string
}

func (*OpenRelationResp) Descriptor added in v0.8.0

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

func (*OpenRelationResp) GetDatabaseName added in v0.8.0

func (m *OpenRelationResp) GetDatabaseName() string

func (*OpenRelationResp) GetID added in v0.8.0

func (m *OpenRelationResp) GetID() ID

func (*OpenRelationResp) GetRelationName added in v0.8.0

func (m *OpenRelationResp) GetRelationName() string

func (*OpenRelationResp) GetType added in v0.8.0

func (m *OpenRelationResp) GetType() RelationType

func (*OpenRelationResp) Marshal added in v0.8.0

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

func (*OpenRelationResp) MarshalBinary added in v0.8.0

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

func (*OpenRelationResp) MarshalTo added in v0.8.0

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

func (*OpenRelationResp) MarshalToSizedBuffer added in v0.8.0

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

func (*OpenRelationResp) ProtoMessage added in v0.8.0

func (*OpenRelationResp) ProtoMessage()

func (*OpenRelationResp) ProtoSize added in v0.8.0

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

func (*OpenRelationResp) Reset added in v0.8.0

func (m *OpenRelationResp) Reset()

func (*OpenRelationResp) String added in v0.8.0

func (m *OpenRelationResp) String() string

func (*OpenRelationResp) Unmarshal added in v0.8.0

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

func (*OpenRelationResp) UnmarshalBinary added in v0.8.0

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

func (*OpenRelationResp) XXX_DiscardUnknown added in v0.8.0

func (m *OpenRelationResp) XXX_DiscardUnknown()

func (*OpenRelationResp) XXX_Marshal added in v0.8.0

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

func (*OpenRelationResp) XXX_Merge added in v0.8.0

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

func (*OpenRelationResp) XXX_Size added in v0.8.0

func (m *OpenRelationResp) XXX_Size() int

func (*OpenRelationResp) XXX_Unmarshal added in v0.8.0

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

type OperationHandler

type OperationHandler interface {
	HandleOpenDatabase(
		ctx context.Context,
		meta txn.TxnMeta,
		req *OpenDatabaseReq,
		resp *OpenDatabaseResp,
	) error

	HandleGetDatabases(
		ctx context.Context,
		meta txn.TxnMeta,
		req *GetDatabasesReq,
		resp *GetDatabasesResp,
	) error

	HandleOpenRelation(
		ctx context.Context,
		meta txn.TxnMeta,
		req *OpenRelationReq,
		resp *OpenRelationResp,
	) error

	HandleGetRelations(
		ctx context.Context,
		meta txn.TxnMeta,
		req *GetRelationsReq,
		resp *GetRelationsResp,
	) error

	HandleGetPrimaryKeys(
		ctx context.Context,
		meta txn.TxnMeta,
		req *GetPrimaryKeysReq,
		resp *GetPrimaryKeysResp,
	) error

	HandleGetTableColumns(
		ctx context.Context,
		meta txn.TxnMeta,
		req *GetTableColumnsReq,
		resp *GetTableColumnsResp,
	) error

	HandleGetTableDefs(
		ctx context.Context,
		meta txn.TxnMeta,
		req *GetTableDefsReq,
		resp *GetTableDefsResp,
	) error

	HandleGetHiddenKeys(
		ctx context.Context,
		meta txn.TxnMeta,
		req *GetHiddenKeysReq,
		resp *GetHiddenKeysResp,
	) error

	HandleNewTableIter(
		ctx context.Context,
		meta txn.TxnMeta,
		req *NewTableIterReq,
		resp *NewTableIterResp,
	) error

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

	HandleCloseTableIter(
		ctx context.Context,
		meta txn.TxnMeta,
		req *CloseTableIterReq,
		resp *CloseTableIterResp,
	) error

	HandleCreateDatabase(
		ctx context.Context,
		meta txn.TxnMeta,
		req *CreateDatabaseReq,
		resp *CreateDatabaseResp,
	) error

	HandleDeleteDatabase(
		ctx context.Context,
		meta txn.TxnMeta,
		req *DeleteDatabaseReq,
		resp *DeleteDatabaseResp,
	) error

	HandleCreateRelation(
		ctx context.Context,
		meta txn.TxnMeta,
		req *CreateRelationReq,
		resp *CreateRelationResp,
	) error

	HandleDeleteRelation(
		ctx context.Context,
		meta txn.TxnMeta,
		req *DeleteRelationReq,
		resp *DeleteRelationResp,
	) error

	HandleTruncateRelation(
		ctx context.Context,
		meta txn.TxnMeta,
		req *TruncateRelationReq,
		resp *TruncateRelationResp,
	) error

	HandleAddTableDef(
		ctx context.Context,
		meta txn.TxnMeta,
		req *AddTableDefReq,
		resp *AddTableDefResp,
	) error

	HandleDelTableDef(
		ctx context.Context,
		meta txn.TxnMeta,
		req *DelTableDefReq,
		resp *DelTableDefResp,
	) error

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

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

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

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

type OperationHandlerProvider

type OperationHandlerProvider interface {
	GetOperationHandler(shard Shard) (OperationHandler, txn.TxnMeta)
}

type ReadReq

type ReadReq struct {
	IterID   ID
	ColNames []string
}

func (*ReadReq) Descriptor added in v0.8.0

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

func (*ReadReq) GetColNames added in v0.8.0

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

func (*ReadReq) GetIterID added in v0.8.0

func (m *ReadReq) GetIterID() ID

func (*ReadReq) Marshal added in v0.8.0

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

func (*ReadReq) MarshalBinary added in v0.8.0

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

func (*ReadReq) MarshalTo added in v0.8.0

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

func (*ReadReq) MarshalToSizedBuffer added in v0.8.0

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

func (*ReadReq) ProtoMessage added in v0.8.0

func (*ReadReq) ProtoMessage()

func (*ReadReq) ProtoSize added in v0.8.0

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

func (*ReadReq) Reset added in v0.8.0

func (m *ReadReq) Reset()

func (*ReadReq) String added in v0.8.0

func (m *ReadReq) String() string

func (*ReadReq) Unmarshal added in v0.8.0

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

func (*ReadReq) UnmarshalBinary added in v0.8.0

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

func (*ReadReq) XXX_DiscardUnknown added in v0.8.0

func (m *ReadReq) XXX_DiscardUnknown()

func (*ReadReq) XXX_Marshal added in v0.8.0

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

func (*ReadReq) XXX_Merge added in v0.8.0

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

func (*ReadReq) XXX_Size added in v0.8.0

func (m *ReadReq) XXX_Size() int

func (*ReadReq) XXX_Unmarshal added in v0.8.0

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

type ReadResp

type ReadResp struct {
	Batch *batch.Batch
	// contains filtered or unexported fields
}

func (*ReadResp) Close

func (r *ReadResp) Close() error

func (*ReadResp) MarshalBinary added in v0.8.0

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

func (*ReadResp) SetHeap

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

func (*ReadResp) UnmarshalBinary added in v0.8.0

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

type RelationType

type RelationType uint8
const (
	RelationTable RelationType = iota + 1
	RelationView
)

type Request

type Request interface {
	ReadRequest | WriteReqeust
}

type Shard

type Shard = metadata.TNShard

type ShardPolicy

type ShardPolicy interface {
	Vector(
		ctx context.Context,
		tableID ID,
		getDefs getDefsFunc,
		colName string,
		vec *vector.Vector,
		nodes []metadata.TNService,
	) (
		sharded []*ShardedVector,
		err error,
	)

	Batch(
		ctx context.Context,
		tableID ID,
		getDefs getDefsFunc,
		batch *batch.Batch,
		nodes []metadata.TNService,
	) (
		sharded []*ShardedBatch,
		err error,
	)
}

func NewDefaultShardPolicy

func NewDefaultShardPolicy(mp *mpool.MPool) ShardPolicy

type ShardedBatch

type ShardedBatch struct {
	Shard Shard
	Batch *batch.Batch
}

type ShardedVector

type ShardedVector struct {
	Shard  Shard
	Vector *vector.Vector
}

type Table

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

func (*Table) AddTableDef

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

func (*Table) AlterTable added in v0.8.0

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

func (*Table) CopyTableDef added in v1.1.2

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

func (*Table) DelTableDef

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

func (*Table) Delete

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

func (*Table) GetColumMetadataScanInfo added in v0.8.0

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

func (*Table) GetDBID added in v0.8.0

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

func (*Table) GetEngineType added in v0.8.0

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

func (*Table) GetHideKey

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

func (*Table) GetHideKeys

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

func (*Table) GetLogTail

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

func (*Table) GetPriKeyOrHideKey

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

func (*Table) GetPrimaryKeys

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

func (*Table) GetTableDef added in v1.1.0

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

func (*Table) GetTableID

func (t *Table) GetTableID(ctx context.Context) uint64

func (*Table) GetTableName added in v0.8.0

func (t *Table) GetTableName() string

GetTableName implements the engine.Relation interface.

func (*Table) MaxAndMinValues added in v0.7.0

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

func (*Table) NewReader

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

func (*Table) PrimaryKeysMayBeModified added in v0.8.0

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

func (*Table) Ranges

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

func (*Table) Rows

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

func (*Table) Size

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

func (*Table) Stats added in v0.7.0

func (t *Table) Stats(ctx context.Context, partitionTables []any, statsInfoMap any) bool

func (*Table) TableColumns

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

func (*Table) TableDefs

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

func (*Table) TableRenameInTxn added in v1.1.1

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

func (*Table) Update

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

func (*Table) UpdateConstraint added in v0.7.0

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

func (*Table) UpdateObjectInfos added in v1.0.0

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

func (*Table) Write

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

type TableReader

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

func (*TableReader) Close

func (t *TableReader) Close() error

func (*TableReader) Read

func (t *TableReader) Read(ctx context.Context, colNames []string, plan *plan.Expr, mp *mpool.MPool, _ engine.VectorPool) (*batch.Batch, error)

type TableStatsReq

type TableStatsReq struct {
	TableID ID
}

func (*TableStatsReq) Descriptor added in v0.8.0

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

func (*TableStatsReq) GetTableID added in v0.8.0

func (m *TableStatsReq) GetTableID() ID

func (*TableStatsReq) Marshal added in v0.8.0

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

func (*TableStatsReq) MarshalBinary added in v0.8.0

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

func (*TableStatsReq) MarshalTo added in v0.8.0

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

func (*TableStatsReq) MarshalToSizedBuffer added in v0.8.0

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

func (*TableStatsReq) ProtoMessage added in v0.8.0

func (*TableStatsReq) ProtoMessage()

func (*TableStatsReq) ProtoSize added in v0.8.0

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

func (*TableStatsReq) Reset added in v0.8.0

func (m *TableStatsReq) Reset()

func (*TableStatsReq) String added in v0.8.0

func (m *TableStatsReq) String() string

func (*TableStatsReq) Unmarshal added in v0.8.0

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

func (*TableStatsReq) UnmarshalBinary added in v0.8.0

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

func (*TableStatsReq) XXX_DiscardUnknown added in v0.8.0

func (m *TableStatsReq) XXX_DiscardUnknown()

func (*TableStatsReq) XXX_Marshal added in v0.8.0

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

func (*TableStatsReq) XXX_Merge added in v0.8.0

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

func (*TableStatsReq) XXX_Size added in v0.8.0

func (m *TableStatsReq) XXX_Size() int

func (*TableStatsReq) XXX_Unmarshal added in v0.8.0

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

type TableStatsResp

type TableStatsResp struct {
	Rows int
}

func (*TableStatsResp) Descriptor added in v0.8.0

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

func (*TableStatsResp) GetRows added in v0.8.0

func (m *TableStatsResp) GetRows() int

func (*TableStatsResp) Marshal added in v0.8.0

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

func (*TableStatsResp) MarshalBinary added in v0.8.0

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

func (*TableStatsResp) MarshalTo added in v0.8.0

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

func (*TableStatsResp) MarshalToSizedBuffer added in v0.8.0

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

func (*TableStatsResp) ProtoMessage added in v0.8.0

func (*TableStatsResp) ProtoMessage()

func (*TableStatsResp) ProtoSize added in v0.8.0

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

func (*TableStatsResp) Reset added in v0.8.0

func (m *TableStatsResp) Reset()

func (*TableStatsResp) String added in v0.8.0

func (m *TableStatsResp) String() string

func (*TableStatsResp) Unmarshal added in v0.8.0

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

func (*TableStatsResp) UnmarshalBinary added in v0.8.0

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

func (*TableStatsResp) XXX_DiscardUnknown added in v0.8.0

func (m *TableStatsResp) XXX_DiscardUnknown()

func (*TableStatsResp) XXX_Marshal added in v0.8.0

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

func (*TableStatsResp) XXX_Merge added in v0.8.0

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

func (*TableStatsResp) XXX_Size added in v0.8.0

func (m *TableStatsResp) XXX_Size() int

func (*TableStatsResp) XXX_Unmarshal added in v0.8.0

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

type TruncateRelationReq

type TruncateRelationReq struct {
	NewTableID   ID
	OldTableID   ID
	DatabaseID   ID
	DatabaseName string
	Name         string
}

func (*TruncateRelationReq) Descriptor added in v0.8.0

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

func (*TruncateRelationReq) GetDatabaseID added in v0.8.0

func (m *TruncateRelationReq) GetDatabaseID() ID

func (*TruncateRelationReq) GetDatabaseName added in v0.8.0

func (m *TruncateRelationReq) GetDatabaseName() string

func (*TruncateRelationReq) GetName added in v0.8.0

func (m *TruncateRelationReq) GetName() string

func (*TruncateRelationReq) GetNewTableID added in v0.8.0

func (m *TruncateRelationReq) GetNewTableID() ID

func (*TruncateRelationReq) GetOldTableID added in v0.8.0

func (m *TruncateRelationReq) GetOldTableID() ID

func (*TruncateRelationReq) Marshal added in v0.8.0

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

func (*TruncateRelationReq) MarshalBinary added in v0.8.0

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

func (*TruncateRelationReq) MarshalTo added in v0.8.0

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

func (*TruncateRelationReq) MarshalToSizedBuffer added in v0.8.0

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

func (*TruncateRelationReq) ProtoMessage added in v0.8.0

func (*TruncateRelationReq) ProtoMessage()

func (*TruncateRelationReq) ProtoSize added in v0.8.0

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

func (*TruncateRelationReq) Reset added in v0.8.0

func (m *TruncateRelationReq) Reset()

func (*TruncateRelationReq) String added in v0.8.0

func (m *TruncateRelationReq) String() string

func (*TruncateRelationReq) Unmarshal added in v0.8.0

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

func (*TruncateRelationReq) UnmarshalBinary added in v0.8.0

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

func (*TruncateRelationReq) XXX_DiscardUnknown added in v0.8.0

func (m *TruncateRelationReq) XXX_DiscardUnknown()

func (*TruncateRelationReq) XXX_Marshal added in v0.8.0

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

func (*TruncateRelationReq) XXX_Merge added in v0.8.0

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

func (*TruncateRelationReq) XXX_Size added in v0.8.0

func (m *TruncateRelationReq) XXX_Size() int

func (*TruncateRelationReq) XXX_Unmarshal added in v0.8.0

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

type TruncateRelationResp

type TruncateRelationResp struct {
	ID ID
}

func (*TruncateRelationResp) Descriptor added in v0.8.0

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

func (*TruncateRelationResp) GetID added in v0.8.0

func (m *TruncateRelationResp) GetID() ID

func (*TruncateRelationResp) Marshal added in v0.8.0

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

func (*TruncateRelationResp) MarshalBinary added in v0.8.0

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

func (*TruncateRelationResp) MarshalTo added in v0.8.0

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

func (*TruncateRelationResp) MarshalToSizedBuffer added in v0.8.0

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

func (*TruncateRelationResp) ProtoMessage added in v0.8.0

func (*TruncateRelationResp) ProtoMessage()

func (*TruncateRelationResp) ProtoSize added in v0.8.0

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

func (*TruncateRelationResp) Reset added in v0.8.0

func (m *TruncateRelationResp) Reset()

func (*TruncateRelationResp) String added in v0.8.0

func (m *TruncateRelationResp) String() string

func (*TruncateRelationResp) Unmarshal added in v0.8.0

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

func (*TruncateRelationResp) UnmarshalBinary added in v0.8.0

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

func (*TruncateRelationResp) XXX_DiscardUnknown added in v0.8.0

func (m *TruncateRelationResp) XXX_DiscardUnknown()

func (*TruncateRelationResp) XXX_Marshal added in v0.8.0

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

func (*TruncateRelationResp) XXX_Merge added in v0.8.0

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

func (*TruncateRelationResp) XXX_Size added in v0.8.0

func (m *TruncateRelationResp) XXX_Size() int

func (*TruncateRelationResp) XXX_Unmarshal added in v0.8.0

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

type UpdateReq

type UpdateReq struct {
	TableID      ID
	DatabaseName string
	TableName    string
	Batch        *batch.Batch
}

func (*UpdateReq) MarshalBinary added in v0.8.0

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

func (*UpdateReq) UnmarshalBinary added in v0.8.0

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

type UpdateResp

type UpdateResp struct {
}

func (*UpdateResp) Descriptor added in v0.8.0

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

func (*UpdateResp) Marshal added in v0.8.0

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

func (*UpdateResp) MarshalBinary added in v0.8.0

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

func (*UpdateResp) MarshalTo added in v0.8.0

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

func (*UpdateResp) MarshalToSizedBuffer added in v0.8.0

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

func (*UpdateResp) ProtoMessage added in v0.8.0

func (*UpdateResp) ProtoMessage()

func (*UpdateResp) ProtoSize added in v0.8.0

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

func (*UpdateResp) Reset added in v0.8.0

func (m *UpdateResp) Reset()

func (*UpdateResp) String added in v0.8.0

func (m *UpdateResp) String() string

func (*UpdateResp) Unmarshal added in v0.8.0

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

func (*UpdateResp) UnmarshalBinary added in v0.8.0

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

func (*UpdateResp) XXX_DiscardUnknown added in v0.8.0

func (m *UpdateResp) XXX_DiscardUnknown()

func (*UpdateResp) XXX_Marshal added in v0.8.0

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

func (*UpdateResp) XXX_Merge added in v0.8.0

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

func (*UpdateResp) XXX_Size added in v0.8.0

func (m *UpdateResp) XXX_Size() int

func (*UpdateResp) XXX_Unmarshal added in v0.8.0

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

type WriteReq

type WriteReq struct {
	TableID      ID
	DatabaseName string
	TableName    string
	Batch        *batch.Batch
}

func (*WriteReq) MarshalBinary added in v0.8.0

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

func (*WriteReq) UnmarshalBinary added in v0.8.0

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

type WriteResp

type WriteResp struct {
}

func (*WriteResp) Descriptor added in v0.8.0

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

func (*WriteResp) Marshal added in v0.8.0

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

func (*WriteResp) MarshalBinary added in v0.8.0

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

func (*WriteResp) MarshalTo added in v0.8.0

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

func (*WriteResp) MarshalToSizedBuffer added in v0.8.0

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

func (*WriteResp) ProtoMessage added in v0.8.0

func (*WriteResp) ProtoMessage()

func (*WriteResp) ProtoSize added in v0.8.0

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

func (*WriteResp) Reset added in v0.8.0

func (m *WriteResp) Reset()

func (*WriteResp) String added in v0.8.0

func (m *WriteResp) String() string

func (*WriteResp) Unmarshal added in v0.8.0

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

func (*WriteResp) UnmarshalBinary added in v0.8.0

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

func (*WriteResp) XXX_DiscardUnknown added in v0.8.0

func (m *WriteResp) XXX_DiscardUnknown()

func (*WriteResp) XXX_Marshal added in v0.8.0

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

func (*WriteResp) XXX_Merge added in v0.8.0

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

func (*WriteResp) XXX_Size added in v0.8.0

func (m *WriteResp) XXX_Size() int

func (*WriteResp) XXX_Unmarshal added in v0.8.0

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

Jump to

Keyboard shortcuts

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