memoryengine

package
v1.0.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2023 License: Apache-2.0 Imports: 38 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 (b *BindedEngine) New(ctx context.Context, _ client.TxnOperator) error

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

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) (string, 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 (e *Engine) New(_ context.Context, _ client.TxnOperator) error

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 ReadRequest 

type ReadRequest interface {
	OpenDatabaseReq |
		GetDatabasesReq |
		OpenRelationReq |
		GetRelationsReq |
		GetPrimaryKeysReq |
		GetTableColumnsReq |
		GetTableDefsReq |
		GetHiddenKeysReq |
		NewTableIterReq |
		ReadReq |
		CloseTableIterReq |
		TableStatsReq |
		apipb.SyncLogTailReq
}

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 Response 

type Response interface {
	CreateDatabaseResp |
		OpenDatabaseResp |
		GetDatabasesResp |
		DeleteDatabaseResp |
		CreateRelationResp |
		DeleteRelationResp |
		TruncateRelationResp |
		OpenRelationResp |
		GetRelationsResp |
		AddTableDefResp |
		DelTableDefResp |
		DeleteResp |
		GetPrimaryKeysResp |
		GetTableColumnsResp |
		GetTableDefsResp |
		GetHiddenKeysResp |
		UpdateResp |
		WriteResp |
		NewTableIterResp |
		ReadResp |
		CloseTableIterResp |
		TableStatsResp |
		apipb.SyncLogTailResp
}

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) 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) 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) Update 

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

func (*Table) UpdateBlockInfos 

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

func (*Table) UpdateConstraint added in v0.7.0 

func (t *Table) UpdateConstraint(context.Context, *engine.ConstraintDef) 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 WriteReqeust 

type WriteReqeust interface {
	CreateDatabaseReq |
		DeleteDatabaseReq |
		CreateRelationReq |
		DeleteRelationReq |
		TruncateRelationReq |
		AddTableDefReq |
		DelTableDefReq |
		DeleteReq |
		UpdateReq |
		WriteReq
}

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.