api

package
v0.8.0 Latest Latest
Warning

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

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

Documentation

Overview

Copyright 2021 - 2022 Matrix Origin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

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 AlterKind_name = map[int32]string{
	0: "Invalid",
	1: "AddColumn",
	2: "DropColumn",
	3: "RenameTable",
	4: "UpdateComment",
	5: "UpdateConstraint",
}
View Source 
var AlterKind_value = map[string]int32{
	"Invalid":          0,
	"AddColumn":        1,
	"DropColumn":       2,
	"RenameTable":      3,
	"UpdateComment":    4,
	"UpdateConstraint": 5,
}
View Source 
var Entry_EntryType_name = map[int32]string{
	0: "Insert",
	1: "Delete",
	2: "Update",
	3: "Alter",
}
View Source 
var Entry_EntryType_value = map[string]int32{
	"Insert": 0,
	"Delete": 1,
	"Update": 2,
	"Alter":  3,
}
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 AlterKind added in v0.8.0 

type AlterKind int32
const (
	AlterKind_Invalid          AlterKind = 0
	AlterKind_AddColumn        AlterKind = 1
	AlterKind_DropColumn       AlterKind = 2
	AlterKind_RenameTable      AlterKind = 3
	AlterKind_UpdateComment    AlterKind = 4
	AlterKind_UpdateConstraint AlterKind = 5
)

func (AlterKind) EnumDescriptor added in v0.8.0 

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

func (AlterKind) String added in v0.8.0 

func (x AlterKind) String() string

type AlterTableAddColumn added in v0.8.0 

type AlterTableAddColumn struct {
	Column               *plan.ColDef `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	InsertPosition       int32        `protobuf:"varint,2,opt,name=insert_position,json=insertPosition,proto3" json:"insert_position,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*AlterTableAddColumn) Descriptor added in v0.8.0 

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

func (*AlterTableAddColumn) GetColumn added in v0.8.0 

func (m *AlterTableAddColumn) GetColumn() *plan.ColDef

func (*AlterTableAddColumn) GetInsertPosition added in v0.8.0 

func (m *AlterTableAddColumn) GetInsertPosition() int32

func (*AlterTableAddColumn) Marshal added in v0.8.0 

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

func (*AlterTableAddColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableAddColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableAddColumn) ProtoMessage added in v0.8.0 

func (*AlterTableAddColumn) ProtoMessage()

func (*AlterTableAddColumn) ProtoSize added in v0.8.0 

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

func (*AlterTableAddColumn) Reset added in v0.8.0 

func (m *AlterTableAddColumn) Reset()

func (*AlterTableAddColumn) String added in v0.8.0 

func (m *AlterTableAddColumn) String() string

func (*AlterTableAddColumn) Unmarshal added in v0.8.0 

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

func (*AlterTableAddColumn) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableAddColumn) XXX_DiscardUnknown()

func (*AlterTableAddColumn) XXX_Marshal added in v0.8.0 

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

func (*AlterTableAddColumn) XXX_Merge added in v0.8.0 

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

func (*AlterTableAddColumn) XXX_Size added in v0.8.0 

func (m *AlterTableAddColumn) XXX_Size() int

func (*AlterTableAddColumn) XXX_Unmarshal added in v0.8.0 

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

type AlterTableComment added in v0.8.0 

type AlterTableComment struct {
	Comment              string   `protobuf:"bytes,1,opt,name=comment,proto3" json:"comment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableComment) Descriptor added in v0.8.0 

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

func (*AlterTableComment) GetComment added in v0.8.0 

func (m *AlterTableComment) GetComment() string

func (*AlterTableComment) Marshal added in v0.8.0 

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

func (*AlterTableComment) MarshalTo added in v0.8.0 

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

func (*AlterTableComment) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableComment) ProtoMessage added in v0.8.0 

func (*AlterTableComment) ProtoMessage()

func (*AlterTableComment) ProtoSize added in v0.8.0 

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

func (*AlterTableComment) Reset added in v0.8.0 

func (m *AlterTableComment) Reset()

func (*AlterTableComment) String added in v0.8.0 

func (m *AlterTableComment) String() string

func (*AlterTableComment) Unmarshal added in v0.8.0 

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

func (*AlterTableComment) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableComment) XXX_DiscardUnknown()

func (*AlterTableComment) XXX_Marshal added in v0.8.0 

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

func (*AlterTableComment) XXX_Merge added in v0.8.0 

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

func (*AlterTableComment) XXX_Size added in v0.8.0 

func (m *AlterTableComment) XXX_Size() int

func (*AlterTableComment) XXX_Unmarshal added in v0.8.0 

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

type AlterTableConstraint added in v0.8.0 

type AlterTableConstraint struct {
	Constraints          []byte   `protobuf:"bytes,1,opt,name=constraints,proto3" json:"constraints,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableConstraint) Descriptor added in v0.8.0 

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

func (*AlterTableConstraint) GetConstraints added in v0.8.0 

func (m *AlterTableConstraint) GetConstraints() []byte

func (*AlterTableConstraint) Marshal added in v0.8.0 

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

func (*AlterTableConstraint) MarshalTo added in v0.8.0 

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

func (*AlterTableConstraint) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableConstraint) ProtoMessage added in v0.8.0 

func (*AlterTableConstraint) ProtoMessage()

func (*AlterTableConstraint) ProtoSize added in v0.8.0 

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

func (*AlterTableConstraint) Reset added in v0.8.0 

func (m *AlterTableConstraint) Reset()

func (*AlterTableConstraint) String added in v0.8.0 

func (m *AlterTableConstraint) String() string

func (*AlterTableConstraint) Unmarshal added in v0.8.0 

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

func (*AlterTableConstraint) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableConstraint) XXX_DiscardUnknown()

func (*AlterTableConstraint) XXX_Marshal added in v0.8.0 

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

func (*AlterTableConstraint) XXX_Merge added in v0.8.0 

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

func (*AlterTableConstraint) XXX_Size added in v0.8.0 

func (m *AlterTableConstraint) XXX_Size() int

func (*AlterTableConstraint) XXX_Unmarshal added in v0.8.0 

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

type AlterTableDropColumn added in v0.8.0 

type AlterTableDropColumn struct {
	LogicalIdx           uint32   `protobuf:"varint,1,opt,name=logical_idx,json=logicalIdx,proto3" json:"logical_idx,omitempty"`
	SequenceNum          uint32   `protobuf:"varint,2,opt,name=sequence_num,json=sequenceNum,proto3" json:"sequence_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableDropColumn) Descriptor added in v0.8.0 

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

func (*AlterTableDropColumn) GetLogicalIdx added in v0.8.0 

func (m *AlterTableDropColumn) GetLogicalIdx() uint32

func (*AlterTableDropColumn) GetSequenceNum added in v0.8.0 

func (m *AlterTableDropColumn) GetSequenceNum() uint32

func (*AlterTableDropColumn) Marshal added in v0.8.0 

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

func (*AlterTableDropColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableDropColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableDropColumn) ProtoMessage added in v0.8.0 

func (*AlterTableDropColumn) ProtoMessage()

func (*AlterTableDropColumn) ProtoSize added in v0.8.0 

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

func (*AlterTableDropColumn) Reset added in v0.8.0 

func (m *AlterTableDropColumn) Reset()

func (*AlterTableDropColumn) String added in v0.8.0 

func (m *AlterTableDropColumn) String() string

func (*AlterTableDropColumn) Unmarshal added in v0.8.0 

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

func (*AlterTableDropColumn) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableDropColumn) XXX_DiscardUnknown()

func (*AlterTableDropColumn) XXX_Marshal added in v0.8.0 

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

func (*AlterTableDropColumn) XXX_Merge added in v0.8.0 

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

func (*AlterTableDropColumn) XXX_Size added in v0.8.0 

func (m *AlterTableDropColumn) XXX_Size() int

func (*AlterTableDropColumn) XXX_Unmarshal added in v0.8.0 

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

type AlterTableRenameTable added in v0.8.0 

type AlterTableRenameTable struct {
	OldName              string   `protobuf:"bytes,1,opt,name=old_name,json=oldName,proto3" json:"old_name,omitempty"`
	NewName              string   `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableRenameTable) Descriptor added in v0.8.0 

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

func (*AlterTableRenameTable) GetNewName added in v0.8.0 

func (m *AlterTableRenameTable) GetNewName() string

func (*AlterTableRenameTable) GetOldName added in v0.8.0 

func (m *AlterTableRenameTable) GetOldName() string

func (*AlterTableRenameTable) Marshal added in v0.8.0 

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

func (*AlterTableRenameTable) MarshalTo added in v0.8.0 

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

func (*AlterTableRenameTable) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableRenameTable) ProtoMessage added in v0.8.0 

func (*AlterTableRenameTable) ProtoMessage()

func (*AlterTableRenameTable) ProtoSize added in v0.8.0 

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

func (*AlterTableRenameTable) Reset added in v0.8.0 

func (m *AlterTableRenameTable) Reset()

func (*AlterTableRenameTable) String added in v0.8.0 

func (m *AlterTableRenameTable) String() string

func (*AlterTableRenameTable) Unmarshal added in v0.8.0 

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

func (*AlterTableRenameTable) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableRenameTable) XXX_DiscardUnknown()

func (*AlterTableRenameTable) XXX_Marshal added in v0.8.0 

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

func (*AlterTableRenameTable) XXX_Merge added in v0.8.0 

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

func (*AlterTableRenameTable) XXX_Size added in v0.8.0 

func (m *AlterTableRenameTable) XXX_Size() int

func (*AlterTableRenameTable) XXX_Unmarshal added in v0.8.0 

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

type AlterTableReq added in v0.8.0 

type AlterTableReq struct {
	TableId uint64    `protobuf:"varint,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	DbId    uint64    `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	Kind    AlterKind `protobuf:"varint,3,opt,name=kind,proto3,enum=api.AlterKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Operation:
	//	*AlterTableReq_AddColumn
	//	*AlterTableReq_DropColumn
	//	*AlterTableReq_RenameTable
	//	*AlterTableReq_UpdateComment
	//	*AlterTableReq_UpdateCstr
	Operation            isAlterTableReq_Operation `protobuf_oneof:"operation"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func NewAddColumnReq added in v0.8.0 

func NewAddColumnReq(did, tid uint64, name string, typ *plan.Type, insertAt int32) *AlterTableReq

func NewRemoveColumnReq added in v0.8.0 

func NewRemoveColumnReq(did, tid uint64, idx, seqnum uint32) *AlterTableReq

func NewRenameTableReq added in v0.8.0 

func NewRenameTableReq(did, tid uint64, old, new string) *AlterTableReq

func NewUpdateCommentReq added in v0.8.0 

func NewUpdateCommentReq(did, tid uint64, comment string) *AlterTableReq

func NewUpdateConstraintReq added in v0.8.0 

func NewUpdateConstraintReq(did, tid uint64, cstr string) *AlterTableReq

func (*AlterTableReq) Descriptor added in v0.8.0 

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

func (*AlterTableReq) GetAddColumn added in v0.8.0 

func (m *AlterTableReq) GetAddColumn() *AlterTableAddColumn

func (*AlterTableReq) GetDbId added in v0.8.0 

func (m *AlterTableReq) GetDbId() uint64

func (*AlterTableReq) GetDropColumn added in v0.8.0 

func (m *AlterTableReq) GetDropColumn() *AlterTableDropColumn

func (*AlterTableReq) GetKind added in v0.8.0 

func (m *AlterTableReq) GetKind() AlterKind

func (*AlterTableReq) GetOperation added in v0.8.0 

func (m *AlterTableReq) GetOperation() isAlterTableReq_Operation

func (*AlterTableReq) GetRenameTable added in v0.8.0 

func (m *AlterTableReq) GetRenameTable() *AlterTableRenameTable

func (*AlterTableReq) GetTableId added in v0.8.0 

func (m *AlterTableReq) GetTableId() uint64

func (*AlterTableReq) GetUpdateComment added in v0.8.0 

func (m *AlterTableReq) GetUpdateComment() *AlterTableComment

func (*AlterTableReq) GetUpdateCstr added in v0.8.0 

func (m *AlterTableReq) GetUpdateCstr() *AlterTableConstraint

func (*AlterTableReq) Marshal added in v0.8.0 

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

func (*AlterTableReq) MarshalTo added in v0.8.0 

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

func (*AlterTableReq) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq) ProtoMessage added in v0.8.0 

func (*AlterTableReq) ProtoMessage()

func (*AlterTableReq) ProtoSize added in v0.8.0 

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

func (*AlterTableReq) Reset added in v0.8.0 

func (m *AlterTableReq) Reset()

func (*AlterTableReq) String added in v0.8.0 

func (m *AlterTableReq) String() string

func (*AlterTableReq) Unmarshal added in v0.8.0 

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

func (*AlterTableReq) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableReq) XXX_DiscardUnknown()

func (*AlterTableReq) XXX_Marshal added in v0.8.0 

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

func (*AlterTableReq) XXX_Merge added in v0.8.0 

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

func (*AlterTableReq) XXX_OneofWrappers added in v0.8.0 

func (*AlterTableReq) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AlterTableReq) XXX_Size added in v0.8.0 

func (m *AlterTableReq) XXX_Size() int

func (*AlterTableReq) XXX_Unmarshal added in v0.8.0 

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

type AlterTableReq_AddColumn added in v0.8.0 

type AlterTableReq_AddColumn struct {
	AddColumn *AlterTableAddColumn `protobuf:"bytes,4,opt,name=add_column,json=addColumn,proto3,oneof" json:"add_column,omitempty"`
}

func (*AlterTableReq_AddColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_AddColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_AddColumn) ProtoSize added in v0.8.0 

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

type AlterTableReq_DropColumn added in v0.8.0 

type AlterTableReq_DropColumn struct {
	DropColumn *AlterTableDropColumn `protobuf:"bytes,5,opt,name=drop_column,json=dropColumn,proto3,oneof" json:"drop_column,omitempty"`
}

func (*AlterTableReq_DropColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_DropColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_DropColumn) ProtoSize added in v0.8.0 

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

type AlterTableReq_RenameTable added in v0.8.0 

type AlterTableReq_RenameTable struct {
	RenameTable *AlterTableRenameTable `protobuf:"bytes,6,opt,name=rename_table,json=renameTable,proto3,oneof" json:"rename_table,omitempty"`
}

func (*AlterTableReq_RenameTable) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_RenameTable) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_RenameTable) ProtoSize added in v0.8.0 

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

type AlterTableReq_UpdateComment added in v0.8.0 

type AlterTableReq_UpdateComment struct {
	UpdateComment *AlterTableComment `protobuf:"bytes,7,opt,name=update_comment,json=updateComment,proto3,oneof" json:"update_comment,omitempty"`
}

func (*AlterTableReq_UpdateComment) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_UpdateComment) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_UpdateComment) ProtoSize added in v0.8.0 

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

type AlterTableReq_UpdateCstr added in v0.8.0 

type AlterTableReq_UpdateCstr struct {
	UpdateCstr *AlterTableConstraint `protobuf:"bytes,8,opt,name=update_cstr,json=updateCstr,proto3,oneof" json:"update_cstr,omitempty"`
}

func (*AlterTableReq_UpdateCstr) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_UpdateCstr) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_UpdateCstr) ProtoSize added in v0.8.0 

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

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,7,opt,name=bat,proto3" json:"bat,omitempty"`
	// whether DN do the PK uniqueness check against txn's workspace or not.
	PkCheckByDn          int32    `protobuf:"varint,8,opt,name=pk_check_by_dn,json=pkCheckByDn,proto3" json:"pk_check_by_dn,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) GetPkCheckByDn added in v0.8.0 

func (m *Entry) GetPkCheckByDn() int32

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
	Entry_Alter  Entry_EntryType = 3
)

func (Entry_EntryType) EnumDescriptor 

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

func (Entry_EntryType) String 

func (x Entry_EntryType) String() string

type Int64Map added in v0.8.0 

type Int64Map struct {
	M                    map[int64]int64 `` /* 145-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Int64Map mainly used in unit test

func (*Int64Map) Descriptor added in v0.8.0 

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

func (*Int64Map) GetM added in v0.8.0 

func (m *Int64Map) GetM() map[int64]int64

func (*Int64Map) Marshal added in v0.8.0 

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

func (*Int64Map) MarshalTo added in v0.8.0 

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

func (*Int64Map) MarshalToSizedBuffer added in v0.8.0 

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

func (*Int64Map) ProtoMessage added in v0.8.0 

func (*Int64Map) ProtoMessage()

func (*Int64Map) ProtoSize added in v0.8.0 

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

func (*Int64Map) Reset added in v0.8.0 

func (m *Int64Map) Reset()

func (*Int64Map) String added in v0.8.0 

func (m *Int64Map) String() string

func (*Int64Map) Unmarshal added in v0.8.0 

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

func (*Int64Map) XXX_DiscardUnknown added in v0.8.0 

func (m *Int64Map) XXX_DiscardUnknown()

func (*Int64Map) XXX_Marshal added in v0.8.0 

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

func (*Int64Map) XXX_Merge added in v0.8.0 

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

func (*Int64Map) XXX_Size added in v0.8.0 

func (m *Int64Map) XXX_Size() int

func (*Int64Map) XXX_Unmarshal added in v0.8.0 

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

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 {
	EntryList            []*Entry `protobuf:"bytes,1,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) GetEntryList 

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

func (*PrecommitWriteCmd) Marshal 

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

func (*PrecommitWriteCmd) MarshalBinary added in v0.8.0 

func (m *PrecommitWriteCmd) MarshalBinary() ([]byte, 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) UnmarshalBinary added in v0.8.0 

func (m *PrecommitWriteCmd) UnmarshalBinary(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 SchemaExtra added in v0.8.0 

type SchemaExtra struct {
	NextColSeqnum uint32 `protobuf:"varint,1,opt,name=next_col_seqnum,json=nextColSeqnum,proto3" json:"next_col_seqnum,omitempty"`
	// sending mo_columns deletes according to this.
	DroppedAttrs  []string `protobuf:"bytes,2,rep,name=dropped_attrs,json=droppedAttrs,proto3" json:"dropped_attrs,omitempty"`
	ColumnChanged bool     `protobuf:"varint,3,opt,name=column_changed,json=columnChanged,proto3" json:"column_changed,omitempty"`
	// sending mo_tables deletes by this.
	OldName              string   `protobuf:"bytes,4,opt,name=old_name,json=oldName,proto3" json:"old_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchemaExtra) Descriptor added in v0.8.0 

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

func (*SchemaExtra) GetColumnChanged added in v0.8.0 

func (m *SchemaExtra) GetColumnChanged() bool

func (*SchemaExtra) GetDroppedAttrs added in v0.8.0 

func (m *SchemaExtra) GetDroppedAttrs() []string

func (*SchemaExtra) GetNextColSeqnum added in v0.8.0 

func (m *SchemaExtra) GetNextColSeqnum() uint32

func (*SchemaExtra) GetOldName added in v0.8.0 

func (m *SchemaExtra) GetOldName() string

func (*SchemaExtra) Marshal added in v0.8.0 

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

func (*SchemaExtra) MarshalTo added in v0.8.0 

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

func (*SchemaExtra) MarshalToSizedBuffer added in v0.8.0 

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

func (*SchemaExtra) ProtoMessage added in v0.8.0 

func (*SchemaExtra) ProtoMessage()

func (*SchemaExtra) ProtoSize added in v0.8.0 

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

func (*SchemaExtra) Reset added in v0.8.0 

func (m *SchemaExtra) Reset()

func (*SchemaExtra) String added in v0.8.0 

func (m *SchemaExtra) String() string

func (*SchemaExtra) Unmarshal added in v0.8.0 

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

func (*SchemaExtra) XXX_DiscardUnknown added in v0.8.0 

func (m *SchemaExtra) XXX_DiscardUnknown()

func (*SchemaExtra) XXX_Marshal added in v0.8.0 

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

func (*SchemaExtra) XXX_Merge added in v0.8.0 

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

func (*SchemaExtra) XXX_Size added in v0.8.0 

func (m *SchemaExtra) XXX_Size() int

func (*SchemaExtra) XXX_Unmarshal added in v0.8.0 

func (m *SchemaExtra) 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) MarshalBinary added in v0.8.0 

func (m *SyncLogTailReq) MarshalBinary() ([]byte, 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) UnmarshalBinary added in v0.8.0 

func (m *SyncLogTailReq) UnmarshalBinary(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) MarshalBinary added in v0.8.0 

func (m *SyncLogTailResp) MarshalBinary() ([]byte, 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) UnmarshalBinary added in v0.8.0 

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