api

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Entry_EntryType_name = map[int32]string{
	0: "Insert",
	1: "Delete",
	2: "Update",
}
View Source 
var Entry_EntryType_value = map[string]int32{
	"Insert": 0,
	"Delete": 1,
	"Update": 2,
}
View Source 
var OpCode_name = map[int32]string{
	0:    "Nop",
	1000: "OpGetLogTail",
	1001: "OpWrite",
	1002: "OpPreCommit",
}
View Source 
var OpCode_value = map[string]int32{
	"Nop":          0,
	"OpGetLogTail": 1000,
	"OpWrite":      1001,
	"OpPreCommit":  1002,
}

Functions

This section is empty.

Types

type Batch 

type Batch struct {
	Attrs                []string  `protobuf:"bytes,1,rep,name=attrs,proto3" json:"attrs,omitempty"`
	Vecs                 []*Vector `protobuf:"bytes,2,rep,name=vecs,proto3" json:"vecs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Batch) Descriptor 

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

func (*Batch) GetAttrs 

func (m *Batch) GetAttrs() []string

func (*Batch) GetVecs 

func (m *Batch) GetVecs() []*Vector

func (*Batch) Marshal 

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

func (*Batch) MarshalTo 

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

func (*Batch) MarshalToSizedBuffer 

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

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) ProtoSize 

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

func (*Batch) Reset 

func (m *Batch) Reset()

func (*Batch) String 

func (m *Batch) String() string

func (*Batch) Unmarshal 

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

func (*Batch) XXX_DiscardUnknown 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal 

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

func (*Batch) XXX_Merge 

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

func (*Batch) XXX_Size 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal 

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

type CatalogCkp 

type CatalogCkp struct {
	MinTs                *timestamp.Timestamp `protobuf:"bytes,1,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	MaxTs                *timestamp.Timestamp `protobuf:"bytes,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	Bat                  *Batch               `protobuf:"bytes,3,opt,name=bat,proto3" json:"bat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

catalog checkpoint: one Batch represents a table, such as : mo_databases, mo_tables, mo_columns,... etc. knowing more about system tables, pls ref to pkg/vm/engine/tae/catalog/model.go

func (*CatalogCkp) Descriptor 

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

func (*CatalogCkp) GetBat 

func (m *CatalogCkp) GetBat() *Batch

func (*CatalogCkp) GetMaxTs 

func (m *CatalogCkp) GetMaxTs() *timestamp.Timestamp

func (*CatalogCkp) GetMinTs 

func (m *CatalogCkp) GetMinTs() *timestamp.Timestamp

func (*CatalogCkp) Marshal 

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

func (*CatalogCkp) MarshalTo 

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

func (*CatalogCkp) MarshalToSizedBuffer 

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

func (*CatalogCkp) ProtoMessage 

func (*CatalogCkp) ProtoMessage()

func (*CatalogCkp) ProtoSize 

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

func (*CatalogCkp) Reset 

func (m *CatalogCkp) Reset()

func (*CatalogCkp) String 

func (m *CatalogCkp) String() string

func (*CatalogCkp) Unmarshal 

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

func (*CatalogCkp) XXX_DiscardUnknown 

func (m *CatalogCkp) XXX_DiscardUnknown()

func (*CatalogCkp) XXX_Marshal 

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

func (*CatalogCkp) XXX_Merge 

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

func (*CatalogCkp) XXX_Size 

func (m *CatalogCkp) XXX_Size() int

func (*CatalogCkp) XXX_Unmarshal 

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

type Checkpoint 

type Checkpoint struct {
	//min_ts DN is the lower bounds of the checkpoint
	// CN maybe don't care about it.
	MinTs *timestamp.Timestamp `protobuf:"bytes,1,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	//max_ts is the upper bounds of the checkpoint.
	// CN maybe don't care about it.
	MaxTs                *timestamp.Timestamp `protobuf:"bytes,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	Bat                  *Batch               `protobuf:"bytes,3,opt,name=bat,proto3" json:"bat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CatalogCkp contains information about database and tables in the system,and MetadataCkp contains information about blocks.

func (*Checkpoint) Descriptor 

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

func (*Checkpoint) GetBat 

func (m *Checkpoint) GetBat() *Batch

func (*Checkpoint) GetMaxTs 

func (m *Checkpoint) GetMaxTs() *timestamp.Timestamp

func (*Checkpoint) GetMinTs 

func (m *Checkpoint) GetMinTs() *timestamp.Timestamp

func (*Checkpoint) Marshal 

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

func (*Checkpoint) MarshalTo 

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

func (*Checkpoint) MarshalToSizedBuffer 

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

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoSize 

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

func (*Checkpoint) Reset 

func (m *Checkpoint) Reset()

func (*Checkpoint) String 

func (m *Checkpoint) String() string

func (*Checkpoint) Unmarshal 

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

func (*Checkpoint) XXX_DiscardUnknown 

func (m *Checkpoint) XXX_DiscardUnknown()

func (*Checkpoint) XXX_Marshal 

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

func (*Checkpoint) XXX_Merge 

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

func (*Checkpoint) XXX_Size 

func (m *Checkpoint) XXX_Size() int

func (*Checkpoint) XXX_Unmarshal 

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

type Entry 

type Entry struct {
	EntryType            Entry_EntryType `protobuf:"varint,1,opt,name=entry_type,json=entryType,proto3,enum=api.Entry_EntryType" json:"entry_type,omitempty"`
	TableId              uint64          `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	DatabaseId           uint64          `protobuf:"varint,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	TableName            string          `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	DatabaseName         string          `protobuf:"bytes,5,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	FileName             string          `protobuf:"bytes,6,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Bat                  *Batch          `protobuf:"bytes,8,opt,name=bat,proto3" json:"bat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Entry) Descriptor 

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

func (*Entry) GetBat 

func (m *Entry) GetBat() *Batch

func (*Entry) GetDatabaseId 

func (m *Entry) GetDatabaseId() uint64

func (*Entry) GetDatabaseName 

func (m *Entry) GetDatabaseName() string

func (*Entry) GetEntryType 

func (m *Entry) GetEntryType() Entry_EntryType

func (*Entry) GetFileName 

func (m *Entry) GetFileName() string

func (*Entry) GetTableId 

func (m *Entry) GetTableId() uint64

func (*Entry) GetTableName 

func (m *Entry) GetTableName() string

func (*Entry) Marshal 

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

func (*Entry) MarshalTo 

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

func (*Entry) MarshalToSizedBuffer 

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

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoSize 

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

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) Unmarshal 

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

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

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

func (*Entry) XXX_Merge 

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

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

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

type Entry_EntryType 

type Entry_EntryType int32
const (
	Entry_Insert Entry_EntryType = 0
	Entry_Delete Entry_EntryType = 1
	Entry_Update Entry_EntryType = 2
)

func (Entry_EntryType) EnumDescriptor 

func (Entry_EntryType) EnumDescriptor() ([]byte, []int)

func (Entry_EntryType) String 

func (x Entry_EntryType) String() string

type MetadataCkp 

type MetadataCkp struct {
	MinTs *timestamp.Timestamp `protobuf:"bytes,1,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	MaxTs *timestamp.Timestamp `protobuf:"bytes,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	//block meta data for a table;
	Bat                  *Batch   `protobuf:"bytes,3,opt,name=bat,proto3" json:"bat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

metadata checkpoint: Batch is a batch of block metadata for a table, one row of Batch represents a block meta data. TODO:: knowing more about block meta data , pls ref to ...

func (*MetadataCkp) Descriptor 

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

func (*MetadataCkp) GetBat 

func (m *MetadataCkp) GetBat() *Batch

func (*MetadataCkp) GetMaxTs 

func (m *MetadataCkp) GetMaxTs() *timestamp.Timestamp

func (*MetadataCkp) GetMinTs 

func (m *MetadataCkp) GetMinTs() *timestamp.Timestamp

func (*MetadataCkp) Marshal 

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

func (*MetadataCkp) MarshalTo 

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

func (*MetadataCkp) MarshalToSizedBuffer 

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

func (*MetadataCkp) ProtoMessage 

func (*MetadataCkp) ProtoMessage()

func (*MetadataCkp) ProtoSize 

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

func (*MetadataCkp) Reset 

func (m *MetadataCkp) Reset()

func (*MetadataCkp) String 

func (m *MetadataCkp) String() string

func (*MetadataCkp) Unmarshal 

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

func (*MetadataCkp) XXX_DiscardUnknown 

func (m *MetadataCkp) XXX_DiscardUnknown()

func (*MetadataCkp) XXX_Marshal 

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

func (*MetadataCkp) XXX_Merge 

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

func (*MetadataCkp) XXX_Size 

func (m *MetadataCkp) XXX_Size() int

func (*MetadataCkp) XXX_Unmarshal 

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

type OpCode 

type OpCode int32
const (
	OpCode_Nop          OpCode = 0
	OpCode_OpGetLogTail OpCode = 1000
	OpCode_OpWrite      OpCode = 1001
	OpCode_OpPreCommit  OpCode = 1002
)

func (OpCode) EnumDescriptor 

func (OpCode) EnumDescriptor() ([]byte, []int)

func (OpCode) String 

func (x OpCode) String() string

type PrecommitWriteCmd 

type PrecommitWriteCmd struct {
	UserId               uint32   `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	RoleId               uint32   `protobuf:"varint,2,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	AccountId            uint32   `protobuf:"varint,3,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	EntryList            []*Entry `protobuf:"bytes,4,rep,name=entry_list,json=entryList,proto3" json:"entry_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

How to parse and handle PrecommiWriteCmd , pls ref to tae/rpc/handle.go/HandlePreCommit function

func (*PrecommitWriteCmd) Descriptor 

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

func (*PrecommitWriteCmd) GetAccountId 

func (m *PrecommitWriteCmd) GetAccountId() uint32

func (*PrecommitWriteCmd) GetEntryList 

func (m *PrecommitWriteCmd) GetEntryList() []*Entry

func (*PrecommitWriteCmd) GetRoleId 

func (m *PrecommitWriteCmd) GetRoleId() uint32

func (*PrecommitWriteCmd) GetUserId 

func (m *PrecommitWriteCmd) GetUserId() uint32

func (*PrecommitWriteCmd) Marshal 

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

func (*PrecommitWriteCmd) MarshalTo 

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

func (*PrecommitWriteCmd) MarshalToSizedBuffer 

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

func (*PrecommitWriteCmd) ProtoMessage 

func (*PrecommitWriteCmd) ProtoMessage()

func (*PrecommitWriteCmd) ProtoSize 

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

func (*PrecommitWriteCmd) Reset 

func (m *PrecommitWriteCmd) Reset()

func (*PrecommitWriteCmd) String 

func (m *PrecommitWriteCmd) String() string

func (*PrecommitWriteCmd) Unmarshal 

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

func (*PrecommitWriteCmd) XXX_DiscardUnknown 

func (m *PrecommitWriteCmd) XXX_DiscardUnknown()

func (*PrecommitWriteCmd) XXX_Marshal 

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

func (*PrecommitWriteCmd) XXX_Merge 

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

func (*PrecommitWriteCmd) XXX_Size 

func (m *PrecommitWriteCmd) XXX_Size() int

func (*PrecommitWriteCmd) XXX_Unmarshal 

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

type SyncLogTailReq 

type SyncLogTailReq struct {
	CnHave               *timestamp.Timestamp `protobuf:"bytes,1,opt,name=cn_have,json=cnHave,proto3" json:"cn_have,omitempty"`
	CnWant               *timestamp.Timestamp `protobuf:"bytes,2,opt,name=cn_want,json=cnWant,proto3" json:"cn_want,omitempty"`
	Table                *TableID             `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CN pull the log tail of table from DN.

func (*SyncLogTailReq) Descriptor 

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

func (*SyncLogTailReq) GetCnHave 

func (m *SyncLogTailReq) GetCnHave() *timestamp.Timestamp

func (*SyncLogTailReq) GetCnWant 

func (m *SyncLogTailReq) GetCnWant() *timestamp.Timestamp

func (*SyncLogTailReq) GetTable 

func (m *SyncLogTailReq) GetTable() *TableID

func (*SyncLogTailReq) Marshal 

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

func (*SyncLogTailReq) MarshalTo 

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

func (*SyncLogTailReq) MarshalToSizedBuffer 

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

func (*SyncLogTailReq) ProtoMessage 

func (*SyncLogTailReq) ProtoMessage()

func (*SyncLogTailReq) ProtoSize 

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

func (*SyncLogTailReq) Reset 

func (m *SyncLogTailReq) Reset()

func (*SyncLogTailReq) String 

func (m *SyncLogTailReq) String() string

func (*SyncLogTailReq) Unmarshal 

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

func (*SyncLogTailReq) XXX_DiscardUnknown 

func (m *SyncLogTailReq) XXX_DiscardUnknown()

func (*SyncLogTailReq) XXX_Marshal 

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

func (*SyncLogTailReq) XXX_Merge 

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

func (*SyncLogTailReq) XXX_Size 

func (m *SyncLogTailReq) XXX_Size() int

func (*SyncLogTailReq) XXX_Unmarshal 

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

type SyncLogTailResp 

type SyncLogTailResp struct {
	// ckp_location is a checkpoint location list.
	// How to get checkpoint data on S3 by the ckp_location ,
	// pls ref to disttae/logtail.go/consumeLogTail function.
	CkpLocation string `protobuf:"bytes,1,opt,name=ckp_location,json=ckpLocation,proto3" json:"ckp_location,omitempty"`
	// commands is log tail for a system or user table,
	// pls ref to tae/logtail/handle.go/HandleSyncLogTailReq function.
	Commands             []*Entry `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncLogTailResp) Descriptor 

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

func (*SyncLogTailResp) GetCkpLocation 

func (m *SyncLogTailResp) GetCkpLocation() string

func (*SyncLogTailResp) GetCommands 

func (m *SyncLogTailResp) GetCommands() []*Entry

func (*SyncLogTailResp) Marshal 

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

func (*SyncLogTailResp) MarshalTo 

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

func (*SyncLogTailResp) MarshalToSizedBuffer 

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

func (*SyncLogTailResp) ProtoMessage 

func (*SyncLogTailResp) ProtoMessage()

func (*SyncLogTailResp) ProtoSize 

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

func (*SyncLogTailResp) Reset 

func (m *SyncLogTailResp) Reset()

func (*SyncLogTailResp) String 

func (m *SyncLogTailResp) String() string

func (*SyncLogTailResp) Unmarshal 

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

func (*SyncLogTailResp) XXX_DiscardUnknown 

func (m *SyncLogTailResp) XXX_DiscardUnknown()

func (*SyncLogTailResp) XXX_Marshal 

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

func (*SyncLogTailResp) XXX_Merge 

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

func (*SyncLogTailResp) XXX_Size 

func (m *SyncLogTailResp) XXX_Size() int

func (*SyncLogTailResp) XXX_Unmarshal 

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

type TableID 

type TableID struct {
	DbId                 uint64   `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TbId                 uint64   `protobuf:"varint,2,opt,name=tb_id,json=tbId,proto3" json:"tb_id,omitempty"`
	PartitionId          uint64   `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TableID) Descriptor 

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

func (*TableID) GetDbId 

func (m *TableID) GetDbId() uint64

func (*TableID) GetPartitionId added in v0.7.0 

func (m *TableID) GetPartitionId() uint64

func (*TableID) GetTbId 

func (m *TableID) GetTbId() uint64

func (*TableID) Marshal 

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

func (*TableID) MarshalTo 

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

func (*TableID) MarshalToSizedBuffer 

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

func (*TableID) ProtoMessage 

func (*TableID) ProtoMessage()

func (*TableID) ProtoSize 

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

func (*TableID) Reset 

func (m *TableID) Reset()

func (*TableID) String 

func (m *TableID) String() string

func (*TableID) Unmarshal 

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

func (*TableID) XXX_DiscardUnknown 

func (m *TableID) XXX_DiscardUnknown()

func (*TableID) XXX_Marshal 

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

func (*TableID) XXX_Merge 

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

func (*TableID) XXX_Size 

func (m *TableID) XXX_Size() int

func (*TableID) XXX_Unmarshal 

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

type Vector 

type Vector struct {
	Data                 []byte     `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Type                 *plan.Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Nullable             bool       `protobuf:"varint,3,opt,name=nullable,proto3" json:"nullable,omitempty"`
	Nsp                  []byte     `protobuf:"bytes,4,opt,name=nsp,proto3" json:"nsp,omitempty"`
	IsConst              bool       `protobuf:"varint,5,opt,name=is_const,json=isConst,proto3" json:"is_const,omitempty"`
	Len                  uint32     `protobuf:"varint,6,opt,name=len,proto3" json:"len,omitempty"`
	Area                 []byte     `protobuf:"bytes,7,opt,name=area,proto3" json:"area,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Vector) Descriptor 

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

func (*Vector) GetArea 

func (m *Vector) GetArea() []byte

func (*Vector) GetData 

func (m *Vector) GetData() []byte

func (*Vector) GetIsConst 

func (m *Vector) GetIsConst() bool

func (*Vector) GetLen 

func (m *Vector) GetLen() uint32

func (*Vector) GetNsp 

func (m *Vector) GetNsp() []byte

func (*Vector) GetNullable 

func (m *Vector) GetNullable() bool

func (*Vector) GetType 

func (m *Vector) GetType() *plan.Type

func (*Vector) Marshal 

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

func (*Vector) MarshalTo 

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

func (*Vector) MarshalToSizedBuffer 

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

func (*Vector) ProtoMessage 

func (*Vector) ProtoMessage()

func (*Vector) ProtoSize 

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

func (*Vector) Reset 

func (m *Vector) Reset()

func (*Vector) String 

func (m *Vector) String() string

func (*Vector) Unmarshal 

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

func (*Vector) XXX_DiscardUnknown 

func (m *Vector) XXX_DiscardUnknown()

func (*Vector) XXX_Marshal 

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

func (*Vector) XXX_Merge 

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

func (*Vector) XXX_Size 

func (m *Vector) XXX_Size() int

func (*Vector) XXX_Unmarshal 

func (m *Vector) 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.