cmd_util

package
v0.0.0-debug-20260702 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OpPreCommit  = uint32(apipb.OpCode_OpPreCommit)
	OpGetLogTail = uint32(apipb.OpCode_OpGetLogTail)
)
View Source 
const (
	EnableFaultInjection  = "enable_fault_injection"
	DisableFaultInjection = "disable_fault_injection"
)
View Source 
const (
	InspectNormal = 0
	InspectCata   = 1
	InspectJSON   = 2
)
View Source 
const (
	CheckerKeyTTL    = "ttl"
	CheckerKeyMinTS  = "min_ts"
	CheckerKeyBackup = "backup"

	AddChecker    = "add_checker"
	RemoveChecker = "remove_checker"

	StopGC  = "stop_gc"
	StartGC = "start_gc"

	ForceGC = "force_gc"

	GCDetails = "details"
	GCVerify  = "verify"

	// Sync protection operations for cross-cluster sync
	RegisterSyncProtection   = "register_sync_protection"
	RenewSyncProtection      = "renew_sync_protection"
	UnregisterSyncProtection = "unregister_sync_protection"
)
View Source 
const AllowPruneDuration = 24 * time.Hour

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 ChangedListType_name = map[int32]string{
	0: "CheckChanged",
	1: "CollectChanged",
}
View Source 
var ChangedListType_value = map[string]int32{
	"CheckChanged":   0,
	"CollectChanged": 1,
}

Functions

This section is empty.

Types

type AccessInfo 

type AccessInfo struct {
	AccountID uint32
	UserID    uint32
	RoleID    uint32
}

func (*AccessInfo) Descriptor 

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

func (*AccessInfo) GetAccountID 

func (m *AccessInfo) GetAccountID() uint32

func (*AccessInfo) GetRoleID 

func (m *AccessInfo) GetRoleID() uint32

func (*AccessInfo) GetUserID 

func (m *AccessInfo) GetUserID() uint32

func (*AccessInfo) Marshal 

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

func (*AccessInfo) MarshalTo 

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

func (*AccessInfo) MarshalToSizedBuffer 

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

func (*AccessInfo) ProtoMessage 

func (*AccessInfo) ProtoMessage()

func (*AccessInfo) ProtoSize 

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

func (*AccessInfo) Reset 

func (m *AccessInfo) Reset()

func (*AccessInfo) String 

func (m *AccessInfo) String() string

func (*AccessInfo) Unmarshal 

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

func (*AccessInfo) XXX_DiscardUnknown 

func (m *AccessInfo) XXX_DiscardUnknown()

func (*AccessInfo) XXX_Marshal 

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

func (*AccessInfo) XXX_Merge 

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

func (*AccessInfo) XXX_Size 

func (m *AccessInfo) XXX_Size() int

func (*AccessInfo) XXX_Unmarshal 

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

type BlockMetaInfo 

type BlockMetaInfo struct {
	Info []uint64
}

func (*BlockMetaInfo) Descriptor 

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

func (*BlockMetaInfo) GetInfo 

func (m *BlockMetaInfo) GetInfo() []uint64

func (*BlockMetaInfo) Marshal 

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

func (*BlockMetaInfo) MarshalBinary 

func (b *BlockMetaInfo) MarshalBinary() ([]byte, error)

func (*BlockMetaInfo) MarshalTo 

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

func (*BlockMetaInfo) MarshalToSizedBuffer 

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

func (*BlockMetaInfo) ProtoMessage 

func (*BlockMetaInfo) ProtoMessage()

func (*BlockMetaInfo) ProtoSize 

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

func (*BlockMetaInfo) Reset 

func (m *BlockMetaInfo) Reset()

func (*BlockMetaInfo) String 

func (m *BlockMetaInfo) String() string

func (*BlockMetaInfo) Unmarshal 

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

func (*BlockMetaInfo) UnmarshalBinary 

func (b *BlockMetaInfo) UnmarshalBinary(data []byte) error

func (*BlockMetaInfo) XXX_DiscardUnknown 

func (m *BlockMetaInfo) XXX_DiscardUnknown()

func (*BlockMetaInfo) XXX_Marshal 

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

func (*BlockMetaInfo) XXX_Merge 

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

func (*BlockMetaInfo) XXX_Size 

func (m *BlockMetaInfo) XXX_Size() int

func (*BlockMetaInfo) XXX_Unmarshal 

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

type CatalogResp 

type CatalogResp struct {
	Item string         `json:"Item,omitempty"`
	Sub  []*CatalogResp `json:"Sub,omitempty"`
}

func (*CatalogResp) Descriptor 

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

func (*CatalogResp) GetItem 

func (m *CatalogResp) GetItem() string

func (*CatalogResp) GetSub 

func (m *CatalogResp) GetSub() []*CatalogResp

func (*CatalogResp) Marshal 

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

func (*CatalogResp) MarshalBinary 

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

func (*CatalogResp) MarshalTo 

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

func (*CatalogResp) MarshalToSizedBuffer 

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

func (*CatalogResp) ProtoMessage 

func (*CatalogResp) ProtoMessage()

func (*CatalogResp) ProtoSize 

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

func (*CatalogResp) Reset 

func (m *CatalogResp) Reset()

func (*CatalogResp) String 

func (m *CatalogResp) String() string

func (*CatalogResp) Unmarshal 

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

func (*CatalogResp) UnmarshalBinary 

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

func (*CatalogResp) XXX_DiscardUnknown 

func (m *CatalogResp) XXX_DiscardUnknown()

func (*CatalogResp) XXX_Marshal 

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

func (*CatalogResp) XXX_Merge 

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

func (*CatalogResp) XXX_Size 

func (m *CatalogResp) XXX_Size() int

func (*CatalogResp) XXX_Unmarshal 

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

type ChangedListType 

type ChangedListType int32
const (
	CheckChanged   ChangedListType = 0
	CollectChanged ChangedListType = 1
)

func (ChangedListType) EnumDescriptor 

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

func (ChangedListType) String 

func (x ChangedListType) String() string

type Checkpoint 

type Checkpoint struct {
	FlushDuration time.Duration
}

func (*Checkpoint) Descriptor 

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

func (*Checkpoint) GetFlushDuration 

func (m *Checkpoint) GetFlushDuration() time.Duration

func (*Checkpoint) Marshal 

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

func (*Checkpoint) MarshalBinary 

func (m *Checkpoint) MarshalBinary() ([]byte, 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) UnmarshalBinary 

func (m *Checkpoint) UnmarshalBinary(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 CheckpointEntryResp 

type CheckpointEntryResp struct {
	Start     *timestamp.Timestamp
	End       *timestamp.Timestamp
	Location1 []byte
	Location2 []byte
	EntryType int32
	Version   uint32
}

func (*CheckpointEntryResp) Descriptor 

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

func (*CheckpointEntryResp) GetEnd 

func (m *CheckpointEntryResp) GetEnd() *timestamp.Timestamp

func (*CheckpointEntryResp) GetEntryType 

func (m *CheckpointEntryResp) GetEntryType() int32

func (*CheckpointEntryResp) GetLocation1 

func (m *CheckpointEntryResp) GetLocation1() []byte

func (*CheckpointEntryResp) GetLocation2 

func (m *CheckpointEntryResp) GetLocation2() []byte

func (*CheckpointEntryResp) GetStart 

func (m *CheckpointEntryResp) GetStart() *timestamp.Timestamp

func (*CheckpointEntryResp) GetVersion 

func (m *CheckpointEntryResp) GetVersion() uint32

func (*CheckpointEntryResp) Marshal 

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

func (*CheckpointEntryResp) MarshalBinary 

func (c *CheckpointEntryResp) MarshalBinary() ([]byte, error)

func (*CheckpointEntryResp) MarshalTo 

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

func (*CheckpointEntryResp) MarshalToSizedBuffer 

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

func (*CheckpointEntryResp) ProtoMessage 

func (*CheckpointEntryResp) ProtoMessage()

func (*CheckpointEntryResp) ProtoSize 

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

func (*CheckpointEntryResp) Reset 

func (m *CheckpointEntryResp) Reset()

func (*CheckpointEntryResp) String 

func (m *CheckpointEntryResp) String() string

func (*CheckpointEntryResp) Unmarshal 

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

func (*CheckpointEntryResp) UnmarshalBinary 

func (c *CheckpointEntryResp) UnmarshalBinary(data []byte) error

func (*CheckpointEntryResp) XXX_DiscardUnknown 

func (m *CheckpointEntryResp) XXX_DiscardUnknown()

func (*CheckpointEntryResp) XXX_Marshal 

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

func (*CheckpointEntryResp) XXX_Merge 

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

func (*CheckpointEntryResp) XXX_Size 

func (m *CheckpointEntryResp) XXX_Size() int

func (*CheckpointEntryResp) XXX_Unmarshal 

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

type CkpMetaInfo 

type CkpMetaInfo struct {
	Version  uint32
	Location []byte
}

func (*CkpMetaInfo) Descriptor 

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

func (*CkpMetaInfo) GetLocation 

func (m *CkpMetaInfo) GetLocation() []byte

func (*CkpMetaInfo) GetVersion 

func (m *CkpMetaInfo) GetVersion() uint32

func (*CkpMetaInfo) Marshal 

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

func (*CkpMetaInfo) MarshalBinary 

func (c *CkpMetaInfo) MarshalBinary() ([]byte, error)

func (*CkpMetaInfo) MarshalTo 

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

func (*CkpMetaInfo) MarshalToSizedBuffer 

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

func (*CkpMetaInfo) ProtoMessage 

func (*CkpMetaInfo) ProtoMessage()

func (*CkpMetaInfo) ProtoSize 

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

func (*CkpMetaInfo) Reset 

func (m *CkpMetaInfo) Reset()

func (*CkpMetaInfo) String 

func (m *CkpMetaInfo) String() string

func (*CkpMetaInfo) Unmarshal 

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

func (*CkpMetaInfo) UnmarshalBinary 

func (c *CkpMetaInfo) UnmarshalBinary(data []byte) error

func (*CkpMetaInfo) XXX_DiscardUnknown 

func (m *CkpMetaInfo) XXX_DiscardUnknown()

func (*CkpMetaInfo) XXX_Marshal 

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

func (*CkpMetaInfo) XXX_Merge 

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

func (*CkpMetaInfo) XXX_Size 

func (m *CkpMetaInfo) XXX_Size() int

func (*CkpMetaInfo) XXX_Unmarshal 

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

type DiskCleaner 

type DiskCleaner struct {
	Op    string
	Key   string
	Value string
}

func (*DiskCleaner) Descriptor 

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

func (*DiskCleaner) GetKey 

func (m *DiskCleaner) GetKey() string

func (*DiskCleaner) GetOp 

func (m *DiskCleaner) GetOp() string

func (*DiskCleaner) GetValue 

func (m *DiskCleaner) GetValue() string

func (*DiskCleaner) Marshal 

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

func (*DiskCleaner) MarshalBinary 

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

func (*DiskCleaner) MarshalTo 

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

func (*DiskCleaner) MarshalToSizedBuffer 

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

func (*DiskCleaner) ProtoMessage 

func (*DiskCleaner) ProtoMessage()

func (*DiskCleaner) ProtoSize 

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

func (*DiskCleaner) Reset 

func (m *DiskCleaner) Reset()

func (*DiskCleaner) String 

func (m *DiskCleaner) String() string

func (*DiskCleaner) Unmarshal 

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

func (*DiskCleaner) UnmarshalBinary 

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

func (*DiskCleaner) XXX_DiscardUnknown 

func (m *DiskCleaner) XXX_DiscardUnknown()

func (*DiskCleaner) XXX_Marshal 

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

func (*DiskCleaner) XXX_Merge 

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

func (*DiskCleaner) XXX_Size 

func (m *DiskCleaner) XXX_Size() int

func (*DiskCleaner) XXX_Unmarshal 

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

type EntryType 

type EntryType int32
const (
	EntryInsert           EntryType = 0
	EntryDelete           EntryType = 1
	EntrySoftDeleteObject EntryType = 2
)

type FaultInjectReq 

type FaultInjectReq struct {
	Method    string
	Parameter string
}

func (*FaultInjectReq) Descriptor 

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

func (*FaultInjectReq) GetMethod 

func (m *FaultInjectReq) GetMethod() string

func (*FaultInjectReq) GetParameter 

func (m *FaultInjectReq) GetParameter() string

func (*FaultInjectReq) Marshal 

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

func (*FaultInjectReq) MarshalBinary 

func (f *FaultInjectReq) MarshalBinary() ([]byte, error)

func (*FaultInjectReq) MarshalTo 

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

func (*FaultInjectReq) MarshalToSizedBuffer 

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

func (*FaultInjectReq) ProtoMessage 

func (*FaultInjectReq) ProtoMessage()

func (*FaultInjectReq) ProtoSize 

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

func (*FaultInjectReq) Reset 

func (m *FaultInjectReq) Reset()

func (*FaultInjectReq) String 

func (m *FaultInjectReq) String() string

func (*FaultInjectReq) Unmarshal 

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

func (*FaultInjectReq) UnmarshalBinary 

func (f *FaultInjectReq) UnmarshalBinary(data []byte) error

func (*FaultInjectReq) XXX_DiscardUnknown 

func (m *FaultInjectReq) XXX_DiscardUnknown()

func (*FaultInjectReq) XXX_Marshal 

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

func (*FaultInjectReq) XXX_Merge 

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

func (*FaultInjectReq) XXX_Size 

func (m *FaultInjectReq) XXX_Size() int

func (*FaultInjectReq) XXX_Unmarshal 

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

type FaultPoint 

type FaultPoint struct {
	Name     string
	Freq     string
	Action   string
	Iarg     int64
	Sarg     string
	Constant bool
}

func (*FaultPoint) Descriptor 

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

func (*FaultPoint) GetAction 

func (m *FaultPoint) GetAction() string

func (*FaultPoint) GetConstant 

func (m *FaultPoint) GetConstant() bool

func (*FaultPoint) GetFreq 

func (m *FaultPoint) GetFreq() string

func (*FaultPoint) GetIarg 

func (m *FaultPoint) GetIarg() int64

func (*FaultPoint) GetName 

func (m *FaultPoint) GetName() string

func (*FaultPoint) GetSarg 

func (m *FaultPoint) GetSarg() string

func (*FaultPoint) Marshal 

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

func (*FaultPoint) MarshalBinary 

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

func (*FaultPoint) MarshalTo 

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

func (*FaultPoint) MarshalToSizedBuffer 

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

func (*FaultPoint) ProtoMessage 

func (*FaultPoint) ProtoMessage()

func (*FaultPoint) ProtoSize 

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

func (*FaultPoint) Reset 

func (m *FaultPoint) Reset()

func (*FaultPoint) String 

func (m *FaultPoint) String() string

func (*FaultPoint) Unmarshal 

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

func (*FaultPoint) UnmarshalBinary 

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

func (*FaultPoint) XXX_DiscardUnknown 

func (m *FaultPoint) XXX_DiscardUnknown()

func (*FaultPoint) XXX_Marshal 

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

func (*FaultPoint) XXX_Merge 

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

func (*FaultPoint) XXX_Size 

func (m *FaultPoint) XXX_Size() int

func (*FaultPoint) XXX_Unmarshal 

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

type FlushTable 

type FlushTable struct {
	AccessInfo AccessInfo
	DatabaseID uint64
	TableID    uint64
}

func (*FlushTable) Descriptor 

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

func (*FlushTable) GetAccessInfo 

func (m *FlushTable) GetAccessInfo() AccessInfo

func (*FlushTable) GetDatabaseID 

func (m *FlushTable) GetDatabaseID() uint64

func (*FlushTable) GetTableID 

func (m *FlushTable) GetTableID() uint64

func (*FlushTable) Marshal 

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

func (*FlushTable) MarshalBinary 

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

func (*FlushTable) MarshalTo 

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

func (*FlushTable) MarshalToSizedBuffer 

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

func (*FlushTable) ProtoMessage 

func (*FlushTable) ProtoMessage()

func (*FlushTable) ProtoSize 

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

func (*FlushTable) Reset 

func (m *FlushTable) Reset()

func (*FlushTable) String 

func (m *FlushTable) String() string

func (*FlushTable) Unmarshal 

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

func (*FlushTable) UnmarshalBinary 

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

func (*FlushTable) XXX_DiscardUnknown 

func (m *FlushTable) XXX_DiscardUnknown()

func (*FlushTable) XXX_Marshal 

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

func (*FlushTable) XXX_Merge 

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

func (*FlushTable) XXX_Size 

func (m *FlushTable) XXX_Size() int

func (*FlushTable) XXX_Unmarshal 

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

type GetChangedTableListReq 

type GetChangedTableListReq struct {
	TS          []*timestamp.Timestamp
	AccIds      []uint64
	DatabaseIds []uint64
	TableIds    []uint64
	Extra       []byte
	Type        ChangedListType
}

func (*GetChangedTableListReq) Descriptor 

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

func (*GetChangedTableListReq) GetAccIds 

func (m *GetChangedTableListReq) GetAccIds() []uint64

func (*GetChangedTableListReq) GetDatabaseIds 

func (m *GetChangedTableListReq) GetDatabaseIds() []uint64

func (*GetChangedTableListReq) GetExtra 

func (m *GetChangedTableListReq) GetExtra() []byte

func (*GetChangedTableListReq) GetTS 

func (m *GetChangedTableListReq) GetTS() []*timestamp.Timestamp

func (*GetChangedTableListReq) GetTableIds 

func (m *GetChangedTableListReq) GetTableIds() []uint64

func (*GetChangedTableListReq) GetType 

func (m *GetChangedTableListReq) GetType() ChangedListType

func (*GetChangedTableListReq) Marshal 

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

func (*GetChangedTableListReq) MarshalBinary 

func (tlreq *GetChangedTableListReq) MarshalBinary() ([]byte, error)

func (*GetChangedTableListReq) MarshalTo 

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

func (*GetChangedTableListReq) MarshalToSizedBuffer 

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

func (*GetChangedTableListReq) ProtoMessage 

func (*GetChangedTableListReq) ProtoMessage()

func (*GetChangedTableListReq) ProtoSize 

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

func (*GetChangedTableListReq) Reset 

func (m *GetChangedTableListReq) Reset()

func (*GetChangedTableListReq) String 

func (m *GetChangedTableListReq) String() string

func (*GetChangedTableListReq) Unmarshal 

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

func (*GetChangedTableListReq) UnmarshalBinary 

func (tlreq *GetChangedTableListReq) UnmarshalBinary(data []byte) error

func (*GetChangedTableListReq) XXX_DiscardUnknown 

func (m *GetChangedTableListReq) XXX_DiscardUnknown()

func (*GetChangedTableListReq) XXX_Marshal 

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

func (*GetChangedTableListReq) XXX_Merge 

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

func (*GetChangedTableListReq) XXX_Size 

func (m *GetChangedTableListReq) XXX_Size() int

func (*GetChangedTableListReq) XXX_Unmarshal 

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

type GetChangedTableListResp 

type GetChangedTableListResp struct {
	Newest      *timestamp.Timestamp
	AccIds      []uint64
	DatabaseIds []uint64
	TableIds    []uint64
	Extra       []byte
	Oldest      *timestamp.Timestamp
}

func (*GetChangedTableListResp) Descriptor 

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

func (*GetChangedTableListResp) GetAccIds 

func (m *GetChangedTableListResp) GetAccIds() []uint64

func (*GetChangedTableListResp) GetDatabaseIds 

func (m *GetChangedTableListResp) GetDatabaseIds() []uint64

func (*GetChangedTableListResp) GetExtra 

func (m *GetChangedTableListResp) GetExtra() []byte

func (*GetChangedTableListResp) GetNewest 

func (m *GetChangedTableListResp) GetNewest() *timestamp.Timestamp

func (*GetChangedTableListResp) GetOldest 

func (m *GetChangedTableListResp) GetOldest() *timestamp.Timestamp

func (*GetChangedTableListResp) GetTableIds 

func (m *GetChangedTableListResp) GetTableIds() []uint64

func (*GetChangedTableListResp) Marshal 

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

func (*GetChangedTableListResp) MarshalBinary 

func (tlresp *GetChangedTableListResp) MarshalBinary() ([]byte, error)

func (*GetChangedTableListResp) MarshalTo 

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

func (*GetChangedTableListResp) MarshalToSizedBuffer 

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

func (*GetChangedTableListResp) ProtoMessage 

func (*GetChangedTableListResp) ProtoMessage()

func (*GetChangedTableListResp) ProtoSize 

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

func (*GetChangedTableListResp) Reset 

func (m *GetChangedTableListResp) Reset()

func (*GetChangedTableListResp) String 

func (m *GetChangedTableListResp) String() string

func (*GetChangedTableListResp) Unmarshal 

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

func (*GetChangedTableListResp) UnmarshalBinary 

func (tlresp *GetChangedTableListResp) UnmarshalBinary(data []byte) error

func (*GetChangedTableListResp) XXX_DiscardUnknown 

func (m *GetChangedTableListResp) XXX_DiscardUnknown()

func (*GetChangedTableListResp) XXX_Marshal 

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

func (*GetChangedTableListResp) XXX_Merge 

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

func (*GetChangedTableListResp) XXX_Size 

func (m *GetChangedTableListResp) XXX_Size() int

func (*GetChangedTableListResp) XXX_Unmarshal 

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

type InspectResp 

type InspectResp struct {
	Typ     int    `json:"-"`
	Message string `json:"msg"`
	Payload []byte `json:"-"`
}

func (*InspectResp) ConsoleString 

func (m *InspectResp) ConsoleString() string

func (*InspectResp) Descriptor 

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

func (*InspectResp) GetMessage 

func (m *InspectResp) GetMessage() string

func (*InspectResp) GetPayload 

func (m *InspectResp) GetPayload() []byte

func (*InspectResp) GetResponse 

func (m *InspectResp) GetResponse() any

func (*InspectResp) GetTyp 

func (m *InspectResp) GetTyp() int

func (*InspectResp) Marshal 

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

func (*InspectResp) MarshalBinary 

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

func (*InspectResp) MarshalTo 

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

func (*InspectResp) MarshalToSizedBuffer 

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

func (*InspectResp) ProtoMessage 

func (*InspectResp) ProtoMessage()

func (*InspectResp) ProtoSize 

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

func (*InspectResp) Reset 

func (m *InspectResp) Reset()

func (*InspectResp) String 

func (m *InspectResp) String() string

func (*InspectResp) Unmarshal 

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

func (*InspectResp) UnmarshalBinary 

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

func (*InspectResp) XXX_DiscardUnknown 

func (m *InspectResp) XXX_DiscardUnknown()

func (*InspectResp) XXX_Marshal 

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

func (*InspectResp) XXX_Merge 

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

func (*InspectResp) XXX_Size 

func (m *InspectResp) XXX_Size() int

func (*InspectResp) XXX_Unmarshal 

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

type InspectTN 

type InspectTN struct {
	AccessInfo AccessInfo
	Operation  string
}

func (*InspectTN) Descriptor 

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

func (*InspectTN) GetAccessInfo 

func (m *InspectTN) GetAccessInfo() AccessInfo

func (*InspectTN) GetOperation 

func (m *InspectTN) GetOperation() string

func (*InspectTN) Marshal 

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

func (*InspectTN) MarshalBinary 

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

func (*InspectTN) MarshalTo 

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

func (*InspectTN) MarshalToSizedBuffer 

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

func (*InspectTN) ProtoMessage 

func (*InspectTN) ProtoMessage()

func (*InspectTN) ProtoSize 

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

func (*InspectTN) Reset 

func (m *InspectTN) Reset()

func (*InspectTN) String 

func (m *InspectTN) String() string

func (*InspectTN) Unmarshal 

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

func (*InspectTN) UnmarshalBinary 

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

func (*InspectTN) XXX_DiscardUnknown 

func (m *InspectTN) XXX_DiscardUnknown()

func (*InspectTN) XXX_Marshal 

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

func (*InspectTN) XXX_Merge 

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

func (*InspectTN) XXX_Size 

func (m *InspectTN) XXX_Size() int

func (*InspectTN) XXX_Unmarshal 

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

type InterceptCommit 

type InterceptCommit struct {
	TableName string
}

func (*InterceptCommit) Descriptor 

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

func (*InterceptCommit) GetTableName 

func (m *InterceptCommit) GetTableName() string

func (*InterceptCommit) Marshal 

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

func (*InterceptCommit) MarshalBinary 

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

func (*InterceptCommit) MarshalTo 

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

func (*InterceptCommit) MarshalToSizedBuffer 

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

func (*InterceptCommit) ProtoMessage 

func (*InterceptCommit) ProtoMessage()

func (*InterceptCommit) ProtoSize 

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

func (*InterceptCommit) Reset 

func (m *InterceptCommit) Reset()

func (*InterceptCommit) String 

func (m *InterceptCommit) String() string

func (*InterceptCommit) Unmarshal 

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

func (*InterceptCommit) UnmarshalBinary 

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

func (*InterceptCommit) XXX_DiscardUnknown 

func (m *InterceptCommit) XXX_DiscardUnknown()

func (*InterceptCommit) XXX_Marshal 

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

func (*InterceptCommit) XXX_Merge 

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

func (*InterceptCommit) XXX_Size 

func (m *InterceptCommit) XXX_Size() int

func (*InterceptCommit) XXX_Unmarshal 

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

type LocationKey 

type LocationKey struct{}

type PKCheckType 

type PKCheckType int32
const (
	//IncrementalDedup do not check uniqueness of PK before txn's snapshot TS.
	IncrementalDedup PKCheckType = 0
	//FullSkipWorkspaceDedup do not check uniqueness of PK against txn's workspace.
	FullSkipWorkspaceDedup PKCheckType = 1
	FullDedup              PKCheckType = 2
	//SkipAllDedup skip all deduplication checks including workspace, committed data, and persisted source.
	SkipAllDedup PKCheckType = 3
)

type RelationType 

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

type SnapshotReadReq 

type SnapshotReadReq struct {
	Snapshot *timestamp.Timestamp
}

func (*SnapshotReadReq) Descriptor 

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

func (*SnapshotReadReq) GetSnapshot 

func (m *SnapshotReadReq) GetSnapshot() *timestamp.Timestamp

func (*SnapshotReadReq) Marshal 

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

func (*SnapshotReadReq) MarshalBinary 

func (s *SnapshotReadReq) MarshalBinary() ([]byte, error)

func (*SnapshotReadReq) MarshalTo 

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

func (*SnapshotReadReq) MarshalToSizedBuffer 

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

func (*SnapshotReadReq) ProtoMessage 

func (*SnapshotReadReq) ProtoMessage()

func (*SnapshotReadReq) ProtoSize 

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

func (*SnapshotReadReq) Reset 

func (m *SnapshotReadReq) Reset()

func (*SnapshotReadReq) String 

func (m *SnapshotReadReq) String() string

func (*SnapshotReadReq) Unmarshal 

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

func (*SnapshotReadReq) UnmarshalBinary 

func (s *SnapshotReadReq) UnmarshalBinary(data []byte) error

func (*SnapshotReadReq) XXX_DiscardUnknown 

func (m *SnapshotReadReq) XXX_DiscardUnknown()

func (*SnapshotReadReq) XXX_Marshal 

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

func (*SnapshotReadReq) XXX_Merge 

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

func (*SnapshotReadReq) XXX_Size 

func (m *SnapshotReadReq) XXX_Size() int

func (*SnapshotReadReq) XXX_Unmarshal 

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

type SnapshotReadResp 

type SnapshotReadResp struct {
	Succeed bool
	Entries []*CheckpointEntryResp
}

func (*SnapshotReadResp) Descriptor 

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

func (*SnapshotReadResp) GetEntries 

func (m *SnapshotReadResp) GetEntries() []*CheckpointEntryResp

func (*SnapshotReadResp) GetSucceed 

func (m *SnapshotReadResp) GetSucceed() bool

func (*SnapshotReadResp) Marshal 

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

func (*SnapshotReadResp) MarshalBinary 

func (s *SnapshotReadResp) MarshalBinary() ([]byte, error)

func (*SnapshotReadResp) MarshalTo 

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

func (*SnapshotReadResp) MarshalToSizedBuffer 

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

func (*SnapshotReadResp) ProtoMessage 

func (*SnapshotReadResp) ProtoMessage()

func (*SnapshotReadResp) ProtoSize 

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

func (*SnapshotReadResp) Reset 

func (m *SnapshotReadResp) Reset()

func (*SnapshotReadResp) String 

func (m *SnapshotReadResp) String() string

func (*SnapshotReadResp) Unmarshal 

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

func (*SnapshotReadResp) UnmarshalBinary 

func (s *SnapshotReadResp) UnmarshalBinary(data []byte) error

func (*SnapshotReadResp) XXX_DiscardUnknown 

func (m *SnapshotReadResp) XXX_DiscardUnknown()

func (*SnapshotReadResp) XXX_Marshal 

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

func (*SnapshotReadResp) XXX_Merge 

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

func (*SnapshotReadResp) XXX_Size 

func (m *SnapshotReadResp) XXX_Size() int

func (*SnapshotReadResp) XXX_Unmarshal 

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

type StorageUsageReq 

type StorageUsageReq struct {
	AccIds []int64
}

func (*StorageUsageReq) Descriptor 

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

func (*StorageUsageReq) GetAccIds 

func (m *StorageUsageReq) GetAccIds() []int64

func (*StorageUsageReq) Marshal 

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

func (*StorageUsageReq) MarshalBinary 

func (s *StorageUsageReq) MarshalBinary() ([]byte, error)

func (*StorageUsageReq) MarshalTo 

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

func (*StorageUsageReq) MarshalToSizedBuffer 

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

func (*StorageUsageReq) ProtoMessage 

func (*StorageUsageReq) ProtoMessage()

func (*StorageUsageReq) ProtoSize 

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

func (*StorageUsageReq) Reset 

func (m *StorageUsageReq) Reset()

func (*StorageUsageReq) String 

func (m *StorageUsageReq) String() string

func (*StorageUsageReq) Unmarshal 

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

func (*StorageUsageReq) UnmarshalBinary 

func (s *StorageUsageReq) UnmarshalBinary(data []byte) error

func (*StorageUsageReq) XXX_DiscardUnknown 

func (m *StorageUsageReq) XXX_DiscardUnknown()

func (*StorageUsageReq) XXX_Marshal 

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

func (*StorageUsageReq) XXX_Merge 

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

func (*StorageUsageReq) XXX_Size 

func (m *StorageUsageReq) XXX_Size() int

func (*StorageUsageReq) XXX_Unmarshal 

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

type StorageUsageResp_V0 

type StorageUsageResp_V0 struct {
	Succeed      bool
	CkpEntries   []*CkpMetaInfo
	BlockEntries []*BlockMetaInfo
}

func (*StorageUsageResp_V0) Descriptor 

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

func (*StorageUsageResp_V0) GetBlockEntries 

func (m *StorageUsageResp_V0) GetBlockEntries() []*BlockMetaInfo

func (*StorageUsageResp_V0) GetCkpEntries 

func (m *StorageUsageResp_V0) GetCkpEntries() []*CkpMetaInfo

func (*StorageUsageResp_V0) GetSucceed 

func (m *StorageUsageResp_V0) GetSucceed() bool

func (*StorageUsageResp_V0) Marshal 

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

func (*StorageUsageResp_V0) MarshalTo 

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

func (*StorageUsageResp_V0) MarshalToSizedBuffer 

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

func (*StorageUsageResp_V0) ProtoMessage 

func (*StorageUsageResp_V0) ProtoMessage()

func (*StorageUsageResp_V0) ProtoSize 

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

func (*StorageUsageResp_V0) Reset 

func (m *StorageUsageResp_V0) Reset()

func (*StorageUsageResp_V0) String 

func (m *StorageUsageResp_V0) String() string

func (*StorageUsageResp_V0) Unmarshal 

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

func (*StorageUsageResp_V0) XXX_DiscardUnknown 

func (m *StorageUsageResp_V0) XXX_DiscardUnknown()

func (*StorageUsageResp_V0) XXX_Marshal 

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

func (*StorageUsageResp_V0) XXX_Merge 

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

func (*StorageUsageResp_V0) XXX_Size 

func (m *StorageUsageResp_V0) XXX_Size() int

func (*StorageUsageResp_V0) XXX_Unmarshal 

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

type StorageUsageResp_V1 

type StorageUsageResp_V1 struct {
	Succeed bool
	AccIds  []int64
	Sizes   []uint64
	Magic   uint64
}

func (*StorageUsageResp_V1) Descriptor 

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

func (*StorageUsageResp_V1) GetAccIds 

func (m *StorageUsageResp_V1) GetAccIds() []int64

func (*StorageUsageResp_V1) GetMagic 

func (m *StorageUsageResp_V1) GetMagic() uint64

func (*StorageUsageResp_V1) GetSizes 

func (m *StorageUsageResp_V1) GetSizes() []uint64

func (*StorageUsageResp_V1) GetSucceed 

func (m *StorageUsageResp_V1) GetSucceed() bool

func (*StorageUsageResp_V1) Marshal 

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

func (*StorageUsageResp_V1) MarshalBinary 

func (s *StorageUsageResp_V1) MarshalBinary() ([]byte, error)

func (*StorageUsageResp_V1) MarshalTo 

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

func (*StorageUsageResp_V1) MarshalToSizedBuffer 

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

func (*StorageUsageResp_V1) ProtoMessage 

func (*StorageUsageResp_V1) ProtoMessage()

func (*StorageUsageResp_V1) ProtoSize 

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

func (*StorageUsageResp_V1) Reset 

func (m *StorageUsageResp_V1) Reset()

func (*StorageUsageResp_V1) String 

func (m *StorageUsageResp_V1) String() string

func (*StorageUsageResp_V1) Unmarshal 

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

func (*StorageUsageResp_V1) UnmarshalBinary 

func (s *StorageUsageResp_V1) UnmarshalBinary(data []byte) error

func (*StorageUsageResp_V1) XXX_DiscardUnknown 

func (m *StorageUsageResp_V1) XXX_DiscardUnknown()

func (*StorageUsageResp_V1) XXX_Marshal 

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

func (*StorageUsageResp_V1) XXX_Merge 

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

func (*StorageUsageResp_V1) XXX_Size 

func (m *StorageUsageResp_V1) XXX_Size() int

func (*StorageUsageResp_V1) XXX_Unmarshal 

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

type StorageUsageResp_V2 

type StorageUsageResp_V2 struct {
	Succeed bool
	AccIds  []int64
	Sizes   []uint64
	Magic   uint64

	ObjCnts []uint64
	BlkCnts []uint64
	RowCnts []uint64
}

func (*StorageUsageResp_V2) Descriptor 

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

func (*StorageUsageResp_V2) GetAccIds 

func (m *StorageUsageResp_V2) GetAccIds() []int64

func (*StorageUsageResp_V2) GetBlkCnts 

func (m *StorageUsageResp_V2) GetBlkCnts() []uint64

func (*StorageUsageResp_V2) GetMagic 

func (m *StorageUsageResp_V2) GetMagic() uint64

func (*StorageUsageResp_V2) GetObjCnts 

func (m *StorageUsageResp_V2) GetObjCnts() []uint64

func (*StorageUsageResp_V2) GetRowCnts 

func (m *StorageUsageResp_V2) GetRowCnts() []uint64

func (*StorageUsageResp_V2) GetSizes 

func (m *StorageUsageResp_V2) GetSizes() []uint64

func (*StorageUsageResp_V2) GetSucceed 

func (m *StorageUsageResp_V2) GetSucceed() bool

func (*StorageUsageResp_V2) Marshal 

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

func (*StorageUsageResp_V2) MarshalBinary 

func (s *StorageUsageResp_V2) MarshalBinary() ([]byte, error)

func (*StorageUsageResp_V2) MarshalTo 

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

func (*StorageUsageResp_V2) MarshalToSizedBuffer 

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

func (*StorageUsageResp_V2) ProtoMessage 

func (*StorageUsageResp_V2) ProtoMessage()

func (*StorageUsageResp_V2) ProtoSize 

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

func (*StorageUsageResp_V2) Reset 

func (m *StorageUsageResp_V2) Reset()

func (*StorageUsageResp_V2) String 

func (m *StorageUsageResp_V2) String() string

func (*StorageUsageResp_V2) Unmarshal 

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

func (*StorageUsageResp_V2) UnmarshalBinary 

func (s *StorageUsageResp_V2) UnmarshalBinary(data []byte) error

func (*StorageUsageResp_V2) XXX_DiscardUnknown 

func (m *StorageUsageResp_V2) XXX_DiscardUnknown()

func (*StorageUsageResp_V2) XXX_Marshal 

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

func (*StorageUsageResp_V2) XXX_Merge 

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

func (*StorageUsageResp_V2) XXX_Size 

func (m *StorageUsageResp_V2) XXX_Size() int

func (*StorageUsageResp_V2) XXX_Unmarshal 

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

type StorageUsageResp_V3 

type StorageUsageResp_V3 struct {
	Succeed bool
	AccIds  []int64
	Sizes   []uint64
	Magic   uint64

	ObjCnts       []uint64
	BlkCnts       []uint64
	RowCnts       []uint64
	SnapshotSizes []uint64
}

func (*StorageUsageResp_V3) Descriptor 

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

func (*StorageUsageResp_V3) GetAccIds 

func (m *StorageUsageResp_V3) GetAccIds() []int64

func (*StorageUsageResp_V3) GetBlkCnts 

func (m *StorageUsageResp_V3) GetBlkCnts() []uint64

func (*StorageUsageResp_V3) GetMagic 

func (m *StorageUsageResp_V3) GetMagic() uint64

func (*StorageUsageResp_V3) GetObjCnts 

func (m *StorageUsageResp_V3) GetObjCnts() []uint64

func (*StorageUsageResp_V3) GetRowCnts 

func (m *StorageUsageResp_V3) GetRowCnts() []uint64

func (*StorageUsageResp_V3) GetSizes 

func (m *StorageUsageResp_V3) GetSizes() []uint64

func (*StorageUsageResp_V3) GetSnapshotSizes 

func (m *StorageUsageResp_V3) GetSnapshotSizes() []uint64

func (*StorageUsageResp_V3) GetSucceed 

func (m *StorageUsageResp_V3) GetSucceed() bool

func (*StorageUsageResp_V3) Marshal 

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

func (*StorageUsageResp_V3) MarshalBinary 

func (s *StorageUsageResp_V3) MarshalBinary() ([]byte, error)

func (*StorageUsageResp_V3) MarshalTo 

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

func (*StorageUsageResp_V3) MarshalToSizedBuffer 

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

func (*StorageUsageResp_V3) ProtoMessage 

func (*StorageUsageResp_V3) ProtoMessage()

func (*StorageUsageResp_V3) ProtoSize 

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

func (*StorageUsageResp_V3) Reset 

func (m *StorageUsageResp_V3) Reset()

func (*StorageUsageResp_V3) String 

func (m *StorageUsageResp_V3) String() string

func (*StorageUsageResp_V3) Unmarshal 

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

func (*StorageUsageResp_V3) UnmarshalBinary 

func (s *StorageUsageResp_V3) UnmarshalBinary(data []byte) error

func (*StorageUsageResp_V3) XXX_DiscardUnknown 

func (m *StorageUsageResp_V3) XXX_DiscardUnknown()

func (*StorageUsageResp_V3) XXX_Marshal 

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

func (*StorageUsageResp_V3) XXX_Merge 

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

func (*StorageUsageResp_V3) XXX_Size 

func (m *StorageUsageResp_V3) XXX_Size() int

func (*StorageUsageResp_V3) XXX_Unmarshal 

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

type SyncProtection 

type SyncProtection struct {
	JobID      string `json:"job_id"`      // Sync job ID
	BF         string `json:"bf"`          // Base64 encoded BloomFilter data (for register)
	ValidTS    int64  `json:"valid_ts"`    // Valid timestamp in nanoseconds (for register and renew)
	TestObject string `json:"test_object"` // Test object name for debugging (optional)
	TaskID     string `json:"task_id"`     // CCPR iteration task ID with LSN (e.g., "taskID-123")
}

SyncProtection is the request for sync protection operations

func (*SyncProtection) Descriptor 

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

func (*SyncProtection) GetBF 

func (m *SyncProtection) GetBF() string

func (*SyncProtection) GetJobID 

func (m *SyncProtection) GetJobID() string

func (*SyncProtection) GetTestObject 

func (m *SyncProtection) GetTestObject() string

func (*SyncProtection) GetValidTS 

func (m *SyncProtection) GetValidTS() int64

func (*SyncProtection) Marshal 

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

func (*SyncProtection) MarshalTo 

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

func (*SyncProtection) MarshalToSizedBuffer 

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

func (*SyncProtection) ProtoMessage 

func (*SyncProtection) ProtoMessage()

func (*SyncProtection) ProtoSize 

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

func (*SyncProtection) Reset 

func (m *SyncProtection) Reset()

func (*SyncProtection) String 

func (m *SyncProtection) String() string

func (*SyncProtection) Unmarshal 

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

func (*SyncProtection) XXX_DiscardUnknown 

func (m *SyncProtection) XXX_DiscardUnknown()

func (*SyncProtection) XXX_Marshal 

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

func (*SyncProtection) XXX_Merge 

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

func (*SyncProtection) XXX_Size 

func (m *SyncProtection) XXX_Size() int

func (*SyncProtection) XXX_Unmarshal 

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

type TraceSpan 

type TraceSpan struct {
	Cmd       string
	Spans     string
	Threshold int64
}

func (*TraceSpan) Descriptor 

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

func (*TraceSpan) GetCmd 

func (m *TraceSpan) GetCmd() string

func (*TraceSpan) GetSpans 

func (m *TraceSpan) GetSpans() string

func (*TraceSpan) GetThreshold 

func (m *TraceSpan) GetThreshold() int64

func (*TraceSpan) Marshal 

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

func (*TraceSpan) MarshalBinary 

func (t *TraceSpan) MarshalBinary() ([]byte, error)

func (*TraceSpan) MarshalTo 

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

func (*TraceSpan) MarshalToSizedBuffer 

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

func (*TraceSpan) ProtoMessage 

func (*TraceSpan) ProtoMessage()

func (*TraceSpan) ProtoSize 

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

func (*TraceSpan) Reset 

func (m *TraceSpan) Reset()

func (*TraceSpan) String 

func (m *TraceSpan) String() string

func (*TraceSpan) Unmarshal 

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

func (*TraceSpan) UnmarshalBinary 

func (t *TraceSpan) UnmarshalBinary(data []byte) error

func (*TraceSpan) XXX_DiscardUnknown 

func (m *TraceSpan) XXX_DiscardUnknown()

func (*TraceSpan) XXX_Marshal 

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

func (*TraceSpan) XXX_Merge 

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

func (*TraceSpan) XXX_Size 

func (m *TraceSpan) XXX_Size() int

func (*TraceSpan) XXX_Unmarshal 

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

type WriteReq 

type WriteReq struct {
	Type         EntryType
	DatabaseId   uint64
	TableID      uint64
	DatabaseName string
	TableName    string
	Schema       *catalog2.Schema
	Batch        *batch.Batch
	//[IncrementalDedup|FullSkipWorkspaceDedup|FullDedup], default is IncrementalDedup.
	//If incremental-dedup in dn.toml is false, IncrementalDedup will be treated as FullSkipWorkspaceDedup.
	//IncrementalDedup do not check uniqueness of PK before txn's snapshot TS.
	//FullSkipWorkspaceDedup do not check uniqueness of PK against txn's workspace.
	PkCheck PKCheckType
	//S3 object file name
	FileName string
	// cn flushed data object stats
	DataObjectStats []objectio.ObjectStats
	//for delete on S3
	TombstoneStats []objectio.ObjectStats
	//for soft delete object: object ID to delete
	ObjectID *objectio.ObjectId
	//for soft delete object: whether it's a tombstone object
	IsTombstone bool
	//tasks for loading primary keys or deleted row ids
	Jobs []*tasks.Job
	//loaded sorted primary keys or deleted row ids.
	JobRes []*tasks.JobResult
	//load context cancel function
	Cancel context.CancelFunc
}

writeReq responds to entry

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.