Documentation ¶
Index ¶
- Constants
- Variables
- func NewDBScanner(db *DB, errHandler ErrHandler) *dbScanner
- func ScopeConflictCheck(oldScope, newScope *common.ID) (err error)
- func TaeMetricsTask(ctx context.Context)
- type AccessInfo
- func (*AccessInfo) Descriptor() ([]byte, []int)
- func (m *AccessInfo) GetAccountID() uint32
- func (m *AccessInfo) GetRoleID() uint32
- func (m *AccessInfo) GetUserID() uint32
- func (m *AccessInfo) Marshal() (dAtA []byte, err error)
- func (m *AccessInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *AccessInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccessInfo) ProtoMessage()
- func (m *AccessInfo) ProtoSize() (n int)
- func (m *AccessInfo) Reset()
- func (m *AccessInfo) String() string
- func (m *AccessInfo) Unmarshal(dAtA []byte) error
- func (m *AccessInfo) XXX_DiscardUnknown()
- func (m *AccessInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccessInfo) XXX_Merge(src proto.Message)
- func (m *AccessInfo) XXX_Size() int
- func (m *AccessInfo) XXX_Unmarshal(b []byte) error
- type BlockMetaInfo
- func (*BlockMetaInfo) Descriptor() ([]byte, []int)
- func (m *BlockMetaInfo) GetInfo() []uint64
- func (m *BlockMetaInfo) Marshal() (dAtA []byte, err error)
- func (b *BlockMetaInfo) MarshalBinary() ([]byte, error)
- func (m *BlockMetaInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *BlockMetaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BlockMetaInfo) ProtoMessage()
- func (m *BlockMetaInfo) ProtoSize() (n int)
- func (m *BlockMetaInfo) Reset()
- func (m *BlockMetaInfo) String() string
- func (m *BlockMetaInfo) Unmarshal(dAtA []byte) error
- func (b *BlockMetaInfo) UnmarshalBinary(data []byte) error
- func (m *BlockMetaInfo) XXX_DiscardUnknown()
- func (m *BlockMetaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BlockMetaInfo) XXX_Merge(src proto.Message)
- func (m *BlockMetaInfo) XXX_Size() int
- func (m *BlockMetaInfo) XXX_Unmarshal(b []byte) error
- type CatalogResp
- func (*CatalogResp) Descriptor() ([]byte, []int)
- func (m *CatalogResp) GetItem() string
- func (m *CatalogResp) GetSub() []*CatalogResp
- func (m *CatalogResp) Marshal() (dAtA []byte, err error)
- func (m *CatalogResp) MarshalBinary() ([]byte, error)
- func (m *CatalogResp) MarshalTo(dAtA []byte) (int, error)
- func (m *CatalogResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CatalogResp) ProtoMessage()
- func (m *CatalogResp) ProtoSize() (n int)
- func (m *CatalogResp) Reset()
- func (m *CatalogResp) String() string
- func (m *CatalogResp) Unmarshal(dAtA []byte) error
- func (m *CatalogResp) UnmarshalBinary(data []byte) error
- func (m *CatalogResp) XXX_DiscardUnknown()
- func (m *CatalogResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CatalogResp) XXX_Merge(src proto.Message)
- func (m *CatalogResp) XXX_Size() int
- func (m *CatalogResp) XXX_Unmarshal(b []byte) error
- type Checkpoint
- func (*Checkpoint) Descriptor() ([]byte, []int)
- func (m *Checkpoint) GetEnable() bool
- func (m *Checkpoint) GetFlushDuration() time.Duration
- func (m *Checkpoint) Marshal() (dAtA []byte, err error)
- func (m *Checkpoint) MarshalBinary() ([]byte, error)
- func (m *Checkpoint) MarshalTo(dAtA []byte) (int, error)
- func (m *Checkpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Checkpoint) ProtoMessage()
- func (m *Checkpoint) ProtoSize() (n int)
- func (m *Checkpoint) Reset()
- func (m *Checkpoint) String() string
- func (m *Checkpoint) Unmarshal(dAtA []byte) error
- func (m *Checkpoint) UnmarshalBinary(data []byte) error
- func (m *Checkpoint) XXX_DiscardUnknown()
- func (m *Checkpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Checkpoint) XXX_Merge(src proto.Message)
- func (m *Checkpoint) XXX_Size() int
- func (m *Checkpoint) XXX_Unmarshal(b []byte) error
- type CkpMetaInfo
- func (*CkpMetaInfo) Descriptor() ([]byte, []int)
- func (m *CkpMetaInfo) GetLocation() []byte
- func (m *CkpMetaInfo) GetVersion() uint32
- func (m *CkpMetaInfo) Marshal() (dAtA []byte, err error)
- func (c *CkpMetaInfo) MarshalBinary() ([]byte, error)
- func (m *CkpMetaInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *CkpMetaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CkpMetaInfo) ProtoMessage()
- func (m *CkpMetaInfo) ProtoSize() (n int)
- func (m *CkpMetaInfo) Reset()
- func (m *CkpMetaInfo) String() string
- func (m *CkpMetaInfo) Unmarshal(dAtA []byte) error
- func (c *CkpMetaInfo) UnmarshalBinary(data []byte) error
- func (m *CkpMetaInfo) XXX_DiscardUnknown()
- func (m *CkpMetaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CkpMetaInfo) XXX_Merge(src proto.Message)
- func (m *CkpMetaInfo) XXX_Size() int
- func (m *CkpMetaInfo) XXX_Unmarshal(b []byte) error
- type DB
- func (db *DB) AddFaultPoint(ctx context.Context, name string, freq string, action string, iarg int64, ...) error
- func (db *DB) Close() error
- func (db *DB) CommitTxn(txn txnif.AsyncTxn) (err error)
- func (db *DB) FlushTable(ctx context.Context, tenantID uint32, dbId, tableId uint64, ts types.TS) (err error)
- func (db *DB) ForceCheckpoint(ctx context.Context, ts types.TS, flushDuration time.Duration) (err error)
- func (db *DB) ForceCheckpointForBackup(ctx context.Context, ts types.TS, flushDuration time.Duration) (location string, err error)
- func (db *DB) ForceGlobalCheckpoint(ctx context.Context, ts types.TS, flushDuration time.Duration) (err error)
- func (db *DB) GetOrCreateTxnWithMeta(info []byte, id []byte, ts types.TS) (txn txnif.AsyncTxn, err error)
- func (db *DB) GetTxnByID(id []byte) (txn txnif.AsyncTxn, err error)
- func (db *DB) GetUsageMemo() *logtail.TNUsageMemo
- func (db *DB) Replay(dataFactory *tables.DataFactory, maxTs types.TS, lsn uint64, valid bool)
- func (db *DB) RollbackTxn(txn txnif.AsyncTxn) error
- func (db *DB) StartTxn(info []byte) (txnif.AsyncTxn, error)
- func (db *DB) StartTxnWithStartTSAndSnapshotTS(info []byte, ts types.TS) (txn txnif.AsyncTxn, err error)
- type DBScanner
- type DiskCleaner
- func (*DiskCleaner) Descriptor() ([]byte, []int)
- func (m *DiskCleaner) GetKey() string
- func (m *DiskCleaner) GetOp() string
- func (m *DiskCleaner) GetValue() string
- func (m *DiskCleaner) Marshal() (dAtA []byte, err error)
- func (m *DiskCleaner) MarshalBinary() ([]byte, error)
- func (m *DiskCleaner) MarshalTo(dAtA []byte) (int, error)
- func (m *DiskCleaner) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DiskCleaner) ProtoMessage()
- func (m *DiskCleaner) ProtoSize() (n int)
- func (m *DiskCleaner) Reset()
- func (m *DiskCleaner) String() string
- func (m *DiskCleaner) Unmarshal(dAtA []byte) error
- func (m *DiskCleaner) UnmarshalBinary(data []byte) error
- func (m *DiskCleaner) XXX_DiscardUnknown()
- func (m *DiskCleaner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiskCleaner) XXX_Merge(src proto.Message)
- func (m *DiskCleaner) XXX_Size() int
- func (m *DiskCleaner) XXX_Unmarshal(b []byte) error
- type EntryType
- type ErrHandler
- type FaultPoint
- func (*FaultPoint) Descriptor() ([]byte, []int)
- func (m *FaultPoint) GetAction() string
- func (m *FaultPoint) GetFreq() string
- func (m *FaultPoint) GetIarg() int64
- func (m *FaultPoint) GetName() string
- func (m *FaultPoint) GetSarg() string
- func (m *FaultPoint) Marshal() (dAtA []byte, err error)
- func (m *FaultPoint) MarshalBinary() ([]byte, error)
- func (m *FaultPoint) MarshalTo(dAtA []byte) (int, error)
- func (m *FaultPoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FaultPoint) ProtoMessage()
- func (m *FaultPoint) ProtoSize() (n int)
- func (m *FaultPoint) Reset()
- func (m *FaultPoint) String() string
- func (m *FaultPoint) Unmarshal(dAtA []byte) error
- func (m *FaultPoint) UnmarshalBinary(data []byte) error
- func (m *FaultPoint) XXX_DiscardUnknown()
- func (m *FaultPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FaultPoint) XXX_Merge(src proto.Message)
- func (m *FaultPoint) XXX_Size() int
- func (m *FaultPoint) XXX_Unmarshal(b []byte) error
- type FlushTable
- func (*FlushTable) Descriptor() ([]byte, []int)
- func (m *FlushTable) GetAccessInfo() AccessInfo
- func (m *FlushTable) GetDatabaseID() uint64
- func (m *FlushTable) GetTableID() uint64
- func (m *FlushTable) Marshal() (dAtA []byte, err error)
- func (m *FlushTable) MarshalBinary() ([]byte, error)
- func (m *FlushTable) MarshalTo(dAtA []byte) (int, error)
- func (m *FlushTable) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FlushTable) ProtoMessage()
- func (m *FlushTable) ProtoSize() (n int)
- func (m *FlushTable) Reset()
- func (m *FlushTable) String() string
- func (m *FlushTable) Unmarshal(dAtA []byte) error
- func (m *FlushTable) UnmarshalBinary(data []byte) error
- func (m *FlushTable) XXX_DiscardUnknown()
- func (m *FlushTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FlushTable) XXX_Merge(src proto.Message)
- func (m *FlushTable) XXX_Size() int
- func (m *FlushTable) XXX_Unmarshal(b []byte) error
- type InspectResp
- func (m *InspectResp) ConsoleString() string
- func (*InspectResp) Descriptor() ([]byte, []int)
- func (m *InspectResp) GetMessage() string
- func (m *InspectResp) GetPayload() []byte
- func (m *InspectResp) GetResponse() any
- func (m *InspectResp) GetTyp() int
- func (m *InspectResp) Marshal() (dAtA []byte, err error)
- func (m *InspectResp) MarshalBinary() ([]byte, error)
- func (m *InspectResp) MarshalTo(dAtA []byte) (int, error)
- func (m *InspectResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InspectResp) ProtoMessage()
- func (m *InspectResp) ProtoSize() (n int)
- func (m *InspectResp) Reset()
- func (m *InspectResp) String() string
- func (m *InspectResp) Unmarshal(dAtA []byte) error
- func (m *InspectResp) UnmarshalBinary(data []byte) error
- func (m *InspectResp) XXX_DiscardUnknown()
- func (m *InspectResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectResp) XXX_Merge(src proto.Message)
- func (m *InspectResp) XXX_Size() int
- func (m *InspectResp) XXX_Unmarshal(b []byte) error
- type InspectTN
- func (*InspectTN) Descriptor() ([]byte, []int)
- func (m *InspectTN) GetAccessInfo() AccessInfo
- func (m *InspectTN) GetOperation() string
- func (m *InspectTN) Marshal() (dAtA []byte, err error)
- func (m *InspectTN) MarshalBinary() ([]byte, error)
- func (m *InspectTN) MarshalTo(dAtA []byte) (int, error)
- func (m *InspectTN) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InspectTN) ProtoMessage()
- func (m *InspectTN) ProtoSize() (n int)
- func (m *InspectTN) Reset()
- func (m *InspectTN) String() string
- func (m *InspectTN) Unmarshal(dAtA []byte) error
- func (m *InspectTN) UnmarshalBinary(data []byte) error
- func (m *InspectTN) XXX_DiscardUnknown()
- func (m *InspectTN) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectTN) XXX_Merge(src proto.Message)
- func (m *InspectTN) XXX_Size() int
- func (m *InspectTN) XXX_Unmarshal(b []byte) error
- type InterceptCommit
- func (*InterceptCommit) Descriptor() ([]byte, []int)
- func (m *InterceptCommit) GetTableName() string
- func (m *InterceptCommit) Marshal() (dAtA []byte, err error)
- func (m *InterceptCommit) MarshalBinary() ([]byte, error)
- func (m *InterceptCommit) MarshalTo(dAtA []byte) (int, error)
- func (m *InterceptCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InterceptCommit) ProtoMessage()
- func (m *InterceptCommit) ProtoSize() (n int)
- func (m *InterceptCommit) Reset()
- func (m *InterceptCommit) String() string
- func (m *InterceptCommit) Unmarshal(dAtA []byte) error
- func (m *InterceptCommit) UnmarshalBinary(data []byte) error
- func (m *InterceptCommit) XXX_DiscardUnknown()
- func (m *InterceptCommit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InterceptCommit) XXX_Merge(src proto.Message)
- func (m *InterceptCommit) XXX_Size() int
- func (m *InterceptCommit) XXX_Unmarshal(b []byte) error
- type LocationKey
- type MergeTaskBuilder
- type NoopErrHandler
- type PKCheckType
- type RelationType
- type Replayer
- func (replayer *Replayer) GetMaxTS() types.TS
- func (replayer *Replayer) OnReplayEntry(group uint32, lsn uint64, payload []byte, typ uint16, info any)
- func (replayer *Replayer) OnReplayTxn(cmd txnif.TxnCmd, lsn uint64)
- func (replayer *Replayer) OnTimeStamp(ts types.TS)
- func (replayer *Replayer) PreReplayWal()
- func (replayer *Replayer) Replay()
- type ScannerOp
- type ScheduledTxnTask
- type StorageUsageReq
- func (*StorageUsageReq) Descriptor() ([]byte, []int)
- func (m *StorageUsageReq) GetAccIds() []int64
- func (m *StorageUsageReq) Marshal() (dAtA []byte, err error)
- func (s *StorageUsageReq) MarshalBinary() ([]byte, error)
- func (m *StorageUsageReq) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageUsageReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageUsageReq) ProtoMessage()
- func (m *StorageUsageReq) ProtoSize() (n int)
- func (m *StorageUsageReq) Reset()
- func (m *StorageUsageReq) String() string
- func (m *StorageUsageReq) Unmarshal(dAtA []byte) error
- func (s *StorageUsageReq) UnmarshalBinary(data []byte) error
- func (m *StorageUsageReq) XXX_DiscardUnknown()
- func (m *StorageUsageReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageUsageReq) XXX_Merge(src proto.Message)
- func (m *StorageUsageReq) XXX_Size() int
- func (m *StorageUsageReq) XXX_Unmarshal(b []byte) error
- type StorageUsageResp_V0
- func (*StorageUsageResp_V0) Descriptor() ([]byte, []int)
- func (m *StorageUsageResp_V0) GetBlockEntries() []*BlockMetaInfo
- func (m *StorageUsageResp_V0) GetCkpEntries() []*CkpMetaInfo
- func (m *StorageUsageResp_V0) GetSucceed() bool
- func (m *StorageUsageResp_V0) Marshal() (dAtA []byte, err error)
- func (m *StorageUsageResp_V0) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageUsageResp_V0) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageUsageResp_V0) ProtoMessage()
- func (m *StorageUsageResp_V0) ProtoSize() (n int)
- func (m *StorageUsageResp_V0) Reset()
- func (m *StorageUsageResp_V0) String() string
- func (m *StorageUsageResp_V0) Unmarshal(dAtA []byte) error
- func (m *StorageUsageResp_V0) XXX_DiscardUnknown()
- func (m *StorageUsageResp_V0) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageUsageResp_V0) XXX_Merge(src proto.Message)
- func (m *StorageUsageResp_V0) XXX_Size() int
- func (m *StorageUsageResp_V0) XXX_Unmarshal(b []byte) error
- type StorageUsageResp_V1
- func (*StorageUsageResp_V1) Descriptor() ([]byte, []int)
- func (m *StorageUsageResp_V1) GetAccIds() []int64
- func (m *StorageUsageResp_V1) GetMagic() uint64
- func (m *StorageUsageResp_V1) GetSizes() []uint64
- func (m *StorageUsageResp_V1) GetSucceed() bool
- func (m *StorageUsageResp_V1) Marshal() (dAtA []byte, err error)
- func (s *StorageUsageResp_V1) MarshalBinary() ([]byte, error)
- func (m *StorageUsageResp_V1) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageUsageResp_V1) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageUsageResp_V1) ProtoMessage()
- func (m *StorageUsageResp_V1) ProtoSize() (n int)
- func (m *StorageUsageResp_V1) Reset()
- func (m *StorageUsageResp_V1) String() string
- func (m *StorageUsageResp_V1) Unmarshal(dAtA []byte) error
- func (s *StorageUsageResp_V1) UnmarshalBinary(data []byte) error
- func (m *StorageUsageResp_V1) XXX_DiscardUnknown()
- func (m *StorageUsageResp_V1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageUsageResp_V1) XXX_Merge(src proto.Message)
- func (m *StorageUsageResp_V1) XXX_Size() int
- func (m *StorageUsageResp_V1) XXX_Unmarshal(b []byte) error
- type StorageUsageResp_V2
- func (*StorageUsageResp_V2) Descriptor() ([]byte, []int)
- func (m *StorageUsageResp_V2) GetAccIds() []int64
- func (m *StorageUsageResp_V2) GetBlkCnts() []uint64
- func (m *StorageUsageResp_V2) GetMagic() uint64
- func (m *StorageUsageResp_V2) GetObjCnts() []uint64
- func (m *StorageUsageResp_V2) GetRowCnts() []uint64
- func (m *StorageUsageResp_V2) GetSizes() []uint64
- func (m *StorageUsageResp_V2) GetSucceed() bool
- func (m *StorageUsageResp_V2) Marshal() (dAtA []byte, err error)
- func (s *StorageUsageResp_V2) MarshalBinary() ([]byte, error)
- func (m *StorageUsageResp_V2) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageUsageResp_V2) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageUsageResp_V2) ProtoMessage()
- func (m *StorageUsageResp_V2) ProtoSize() (n int)
- func (m *StorageUsageResp_V2) Reset()
- func (m *StorageUsageResp_V2) String() string
- func (m *StorageUsageResp_V2) Unmarshal(dAtA []byte) error
- func (s *StorageUsageResp_V2) UnmarshalBinary(data []byte) error
- func (m *StorageUsageResp_V2) XXX_DiscardUnknown()
- func (m *StorageUsageResp_V2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageUsageResp_V2) XXX_Merge(src proto.Message)
- func (m *StorageUsageResp_V2) XXX_Size() int
- func (m *StorageUsageResp_V2) XXX_Unmarshal(b []byte) error
- type TraceSpan
- func (*TraceSpan) Descriptor() ([]byte, []int)
- func (m *TraceSpan) GetCmd() string
- func (m *TraceSpan) GetSpans() string
- func (m *TraceSpan) GetThreshold() int64
- func (m *TraceSpan) Marshal() (dAtA []byte, err error)
- func (t *TraceSpan) MarshalBinary() ([]byte, error)
- func (m *TraceSpan) MarshalTo(dAtA []byte) (int, error)
- func (m *TraceSpan) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TraceSpan) ProtoMessage()
- func (m *TraceSpan) ProtoSize() (n int)
- func (m *TraceSpan) Reset()
- func (m *TraceSpan) String() string
- func (m *TraceSpan) Unmarshal(dAtA []byte) error
- func (t *TraceSpan) UnmarshalBinary(data []byte) error
- func (m *TraceSpan) XXX_DiscardUnknown()
- func (m *TraceSpan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TraceSpan) XXX_Merge(src proto.Message)
- func (m *TraceSpan) XXX_Size() int
- func (m *TraceSpan) XXX_Unmarshal(b []byte) error
- type WriteReq
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 )
View Source
const (
LockName string = "TAE"
)
View Source
const (
WALDir = "wal"
)
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 ( ErrTaskDuplicated = moerr.NewInternalErrorNoCtx("tae task: duplicated task found") ErrTaskNotFound = moerr.NewInternalErrorNoCtx("tae task: task not found") )
View Source
var (
ErrClosed = moerr.NewInternalErrorNoCtx("tae: closed")
)
Functions ¶
func NewDBScanner ¶
func NewDBScanner(db *DB, errHandler ErrHandler) *dbScanner
func ScopeConflictCheck ¶
func TaeMetricsTask ¶ added in v1.0.0
Types ¶
type AccessInfo ¶ added in v0.6.0
func (*AccessInfo) Descriptor ¶ added in v0.8.0
func (*AccessInfo) Descriptor() ([]byte, []int)
func (*AccessInfo) GetAccountID ¶ added in v0.8.0
func (m *AccessInfo) GetAccountID() uint32
func (*AccessInfo) GetRoleID ¶ added in v0.8.0
func (m *AccessInfo) GetRoleID() uint32
func (*AccessInfo) GetUserID ¶ added in v0.8.0
func (m *AccessInfo) GetUserID() uint32
func (*AccessInfo) Marshal ¶ added in v0.8.0
func (m *AccessInfo) Marshal() (dAtA []byte, err error)
func (*AccessInfo) MarshalTo ¶ added in v0.8.0
func (m *AccessInfo) MarshalTo(dAtA []byte) (int, error)
func (*AccessInfo) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *AccessInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AccessInfo) ProtoMessage ¶ added in v0.8.0
func (*AccessInfo) ProtoMessage()
func (*AccessInfo) ProtoSize ¶ added in v0.8.0
func (m *AccessInfo) ProtoSize() (n int)
func (*AccessInfo) Reset ¶ added in v0.8.0
func (m *AccessInfo) Reset()
func (*AccessInfo) String ¶ added in v0.8.0
func (m *AccessInfo) String() string
func (*AccessInfo) Unmarshal ¶ added in v0.8.0
func (m *AccessInfo) Unmarshal(dAtA []byte) error
func (*AccessInfo) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *AccessInfo) XXX_DiscardUnknown()
func (*AccessInfo) XXX_Marshal ¶ added in v0.8.0
func (m *AccessInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AccessInfo) XXX_Merge ¶ added in v0.8.0
func (m *AccessInfo) XXX_Merge(src proto.Message)
func (*AccessInfo) XXX_Size ¶ added in v0.8.0
func (m *AccessInfo) XXX_Size() int
func (*AccessInfo) XXX_Unmarshal ¶ added in v0.8.0
func (m *AccessInfo) XXX_Unmarshal(b []byte) error
type BlockMetaInfo ¶ added in v1.0.1
type BlockMetaInfo struct {
Info []uint64
}
func (*BlockMetaInfo) Descriptor ¶ added in v1.0.1
func (*BlockMetaInfo) Descriptor() ([]byte, []int)
func (*BlockMetaInfo) GetInfo ¶ added in v1.0.1
func (m *BlockMetaInfo) GetInfo() []uint64
func (*BlockMetaInfo) Marshal ¶ added in v1.0.1
func (m *BlockMetaInfo) Marshal() (dAtA []byte, err error)
func (*BlockMetaInfo) MarshalBinary ¶ added in v1.0.1
func (b *BlockMetaInfo) MarshalBinary() ([]byte, error)
func (*BlockMetaInfo) MarshalTo ¶ added in v1.0.1
func (m *BlockMetaInfo) MarshalTo(dAtA []byte) (int, error)
func (*BlockMetaInfo) MarshalToSizedBuffer ¶ added in v1.0.1
func (m *BlockMetaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BlockMetaInfo) ProtoMessage ¶ added in v1.0.1
func (*BlockMetaInfo) ProtoMessage()
func (*BlockMetaInfo) ProtoSize ¶ added in v1.0.1
func (m *BlockMetaInfo) ProtoSize() (n int)
func (*BlockMetaInfo) Reset ¶ added in v1.0.1
func (m *BlockMetaInfo) Reset()
func (*BlockMetaInfo) String ¶ added in v1.0.1
func (m *BlockMetaInfo) String() string
func (*BlockMetaInfo) Unmarshal ¶ added in v1.0.1
func (m *BlockMetaInfo) Unmarshal(dAtA []byte) error
func (*BlockMetaInfo) UnmarshalBinary ¶ added in v1.0.1
func (b *BlockMetaInfo) UnmarshalBinary(data []byte) error
func (*BlockMetaInfo) XXX_DiscardUnknown ¶ added in v1.0.1
func (m *BlockMetaInfo) XXX_DiscardUnknown()
func (*BlockMetaInfo) XXX_Marshal ¶ added in v1.0.1
func (m *BlockMetaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BlockMetaInfo) XXX_Merge ¶ added in v1.0.1
func (m *BlockMetaInfo) XXX_Merge(src proto.Message)
func (*BlockMetaInfo) XXX_Size ¶ added in v1.0.1
func (m *BlockMetaInfo) XXX_Size() int
func (*BlockMetaInfo) XXX_Unmarshal ¶ added in v1.0.1
func (m *BlockMetaInfo) XXX_Unmarshal(b []byte) error
type CatalogResp ¶ added in v0.7.0
type CatalogResp struct { Item string `json:"Item,omitempty"` Sub []*CatalogResp `json:"Sub,omitempty"` }
func (*CatalogResp) Descriptor ¶ added in v0.8.0
func (*CatalogResp) Descriptor() ([]byte, []int)
func (*CatalogResp) GetItem ¶ added in v0.8.0
func (m *CatalogResp) GetItem() string
func (*CatalogResp) GetSub ¶ added in v0.8.0
func (m *CatalogResp) GetSub() []*CatalogResp
func (*CatalogResp) Marshal ¶ added in v0.8.0
func (m *CatalogResp) Marshal() (dAtA []byte, err error)
func (*CatalogResp) MarshalBinary ¶ added in v0.8.0
func (m *CatalogResp) MarshalBinary() ([]byte, error)
func (*CatalogResp) MarshalTo ¶ added in v0.8.0
func (m *CatalogResp) MarshalTo(dAtA []byte) (int, error)
func (*CatalogResp) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *CatalogResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CatalogResp) ProtoMessage ¶ added in v0.8.0
func (*CatalogResp) ProtoMessage()
func (*CatalogResp) ProtoSize ¶ added in v0.8.0
func (m *CatalogResp) ProtoSize() (n int)
func (*CatalogResp) Reset ¶ added in v0.8.0
func (m *CatalogResp) Reset()
func (*CatalogResp) String ¶ added in v0.8.0
func (m *CatalogResp) String() string
func (*CatalogResp) Unmarshal ¶ added in v0.8.0
func (m *CatalogResp) Unmarshal(dAtA []byte) error
func (*CatalogResp) UnmarshalBinary ¶ added in v0.8.0
func (m *CatalogResp) UnmarshalBinary(data []byte) error
func (*CatalogResp) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *CatalogResp) XXX_DiscardUnknown()
func (*CatalogResp) XXX_Marshal ¶ added in v0.8.0
func (m *CatalogResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CatalogResp) XXX_Merge ¶ added in v0.8.0
func (m *CatalogResp) XXX_Merge(src proto.Message)
func (*CatalogResp) XXX_Size ¶ added in v0.8.0
func (m *CatalogResp) XXX_Size() int
func (*CatalogResp) XXX_Unmarshal ¶ added in v0.8.0
func (m *CatalogResp) XXX_Unmarshal(b []byte) error
type Checkpoint ¶ added in v0.7.0
func (*Checkpoint) Descriptor ¶ added in v0.8.0
func (*Checkpoint) Descriptor() ([]byte, []int)
func (*Checkpoint) GetEnable ¶ added in v1.2.1
func (m *Checkpoint) GetEnable() bool
func (*Checkpoint) GetFlushDuration ¶ added in v0.8.0
func (m *Checkpoint) GetFlushDuration() time.Duration
func (*Checkpoint) Marshal ¶ added in v0.8.0
func (m *Checkpoint) Marshal() (dAtA []byte, err error)
func (*Checkpoint) MarshalBinary ¶ added in v0.8.0
func (m *Checkpoint) MarshalBinary() ([]byte, error)
func (*Checkpoint) MarshalTo ¶ added in v0.8.0
func (m *Checkpoint) MarshalTo(dAtA []byte) (int, error)
func (*Checkpoint) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *Checkpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Checkpoint) ProtoMessage ¶ added in v0.8.0
func (*Checkpoint) ProtoMessage()
func (*Checkpoint) ProtoSize ¶ added in v0.8.0
func (m *Checkpoint) ProtoSize() (n int)
func (*Checkpoint) Reset ¶ added in v0.8.0
func (m *Checkpoint) Reset()
func (*Checkpoint) String ¶ added in v0.8.0
func (m *Checkpoint) String() string
func (*Checkpoint) Unmarshal ¶ added in v0.8.0
func (m *Checkpoint) Unmarshal(dAtA []byte) error
func (*Checkpoint) UnmarshalBinary ¶ added in v0.8.0
func (m *Checkpoint) UnmarshalBinary(data []byte) error
func (*Checkpoint) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *Checkpoint) XXX_DiscardUnknown()
func (*Checkpoint) XXX_Marshal ¶ added in v0.8.0
func (m *Checkpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Checkpoint) XXX_Merge ¶ added in v0.8.0
func (m *Checkpoint) XXX_Merge(src proto.Message)
func (*Checkpoint) XXX_Size ¶ added in v0.8.0
func (m *Checkpoint) XXX_Size() int
func (*Checkpoint) XXX_Unmarshal ¶ added in v0.8.0
func (m *Checkpoint) XXX_Unmarshal(b []byte) error
type CkpMetaInfo ¶ added in v1.0.1
func (*CkpMetaInfo) Descriptor ¶ added in v1.0.1
func (*CkpMetaInfo) Descriptor() ([]byte, []int)
func (*CkpMetaInfo) GetLocation ¶ added in v1.0.1
func (m *CkpMetaInfo) GetLocation() []byte
func (*CkpMetaInfo) GetVersion ¶ added in v1.0.1
func (m *CkpMetaInfo) GetVersion() uint32
func (*CkpMetaInfo) Marshal ¶ added in v1.0.1
func (m *CkpMetaInfo) Marshal() (dAtA []byte, err error)
func (*CkpMetaInfo) MarshalBinary ¶ added in v1.0.1
func (c *CkpMetaInfo) MarshalBinary() ([]byte, error)
func (*CkpMetaInfo) MarshalTo ¶ added in v1.0.1
func (m *CkpMetaInfo) MarshalTo(dAtA []byte) (int, error)
func (*CkpMetaInfo) MarshalToSizedBuffer ¶ added in v1.0.1
func (m *CkpMetaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CkpMetaInfo) ProtoMessage ¶ added in v1.0.1
func (*CkpMetaInfo) ProtoMessage()
func (*CkpMetaInfo) ProtoSize ¶ added in v1.0.1
func (m *CkpMetaInfo) ProtoSize() (n int)
func (*CkpMetaInfo) Reset ¶ added in v1.0.1
func (m *CkpMetaInfo) Reset()
func (*CkpMetaInfo) String ¶ added in v1.0.1
func (m *CkpMetaInfo) String() string
func (*CkpMetaInfo) Unmarshal ¶ added in v1.0.1
func (m *CkpMetaInfo) Unmarshal(dAtA []byte) error
func (*CkpMetaInfo) UnmarshalBinary ¶ added in v1.0.1
func (c *CkpMetaInfo) UnmarshalBinary(data []byte) error
func (*CkpMetaInfo) XXX_DiscardUnknown ¶ added in v1.0.1
func (m *CkpMetaInfo) XXX_DiscardUnknown()
func (*CkpMetaInfo) XXX_Marshal ¶ added in v1.0.1
func (m *CkpMetaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CkpMetaInfo) XXX_Merge ¶ added in v1.0.1
func (m *CkpMetaInfo) XXX_Merge(src proto.Message)
func (*CkpMetaInfo) XXX_Size ¶ added in v1.0.1
func (m *CkpMetaInfo) XXX_Size() int
func (*CkpMetaInfo) XXX_Unmarshal ¶ added in v1.0.1
func (m *CkpMetaInfo) XXX_Unmarshal(b []byte) error
type DB ¶
type DB struct { Dir string Opts *options.Options Catalog *catalog.Catalog TxnMgr *txnbase.TxnManager LogtailMgr *logtail.Manager Wal wal.Driver GCManager *gc.Manager BGScanner wb.IHeartbeater BGCheckpointRunner checkpoint.Runner MergeHandle *MergeTaskBuilder DiskCleaner *gc2.DiskCleaner Runtime *dbutils.Runtime DBLocker io.Closer CNMergeSched merge.CNMergeScheduler Closed *atomic.Value // contains filtered or unexported fields }
func (*DB) AddFaultPoint ¶ added in v1.0.0
func (*DB) FlushTable ¶ added in v0.6.0
func (*DB) ForceCheckpoint ¶ added in v0.8.0
func (*DB) ForceCheckpointForBackup ¶ added in v1.1.0
func (*DB) ForceGlobalCheckpoint ¶ added in v1.1.2
func (*DB) GetOrCreateTxnWithMeta ¶ added in v0.6.0
func (*DB) GetTxnByID ¶ added in v0.8.0
func (*DB) GetUsageMemo ¶ added in v1.1.0
func (db *DB) GetUsageMemo() *logtail.TNUsageMemo
type DiskCleaner ¶ added in v1.2.1
func (*DiskCleaner) Descriptor ¶ added in v1.2.1
func (*DiskCleaner) Descriptor() ([]byte, []int)
func (*DiskCleaner) GetKey ¶ added in v1.2.1
func (m *DiskCleaner) GetKey() string
func (*DiskCleaner) GetOp ¶ added in v1.2.1
func (m *DiskCleaner) GetOp() string
func (*DiskCleaner) GetValue ¶ added in v1.2.1
func (m *DiskCleaner) GetValue() string
func (*DiskCleaner) Marshal ¶ added in v1.2.1
func (m *DiskCleaner) Marshal() (dAtA []byte, err error)
func (*DiskCleaner) MarshalBinary ¶ added in v1.2.1
func (m *DiskCleaner) MarshalBinary() ([]byte, error)
func (*DiskCleaner) MarshalTo ¶ added in v1.2.1
func (m *DiskCleaner) MarshalTo(dAtA []byte) (int, error)
func (*DiskCleaner) MarshalToSizedBuffer ¶ added in v1.2.1
func (m *DiskCleaner) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DiskCleaner) ProtoMessage ¶ added in v1.2.1
func (*DiskCleaner) ProtoMessage()
func (*DiskCleaner) ProtoSize ¶ added in v1.2.1
func (m *DiskCleaner) ProtoSize() (n int)
func (*DiskCleaner) Reset ¶ added in v1.2.1
func (m *DiskCleaner) Reset()
func (*DiskCleaner) String ¶ added in v1.2.1
func (m *DiskCleaner) String() string
func (*DiskCleaner) Unmarshal ¶ added in v1.2.1
func (m *DiskCleaner) Unmarshal(dAtA []byte) error
func (*DiskCleaner) UnmarshalBinary ¶ added in v1.2.1
func (m *DiskCleaner) UnmarshalBinary(data []byte) error
func (*DiskCleaner) XXX_DiscardUnknown ¶ added in v1.2.1
func (m *DiskCleaner) XXX_DiscardUnknown()
func (*DiskCleaner) XXX_Marshal ¶ added in v1.2.1
func (m *DiskCleaner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiskCleaner) XXX_Merge ¶ added in v1.2.1
func (m *DiskCleaner) XXX_Merge(src proto.Message)
func (*DiskCleaner) XXX_Size ¶ added in v1.2.1
func (m *DiskCleaner) XXX_Size() int
func (*DiskCleaner) XXX_Unmarshal ¶ added in v1.2.1
func (m *DiskCleaner) XXX_Unmarshal(b []byte) error
type ErrHandler ¶
type FaultPoint ¶ added in v1.0.0
func (*FaultPoint) Descriptor ¶ added in v1.0.0
func (*FaultPoint) Descriptor() ([]byte, []int)
func (*FaultPoint) GetAction ¶ added in v1.0.0
func (m *FaultPoint) GetAction() string
func (*FaultPoint) GetFreq ¶ added in v1.0.0
func (m *FaultPoint) GetFreq() string
func (*FaultPoint) GetIarg ¶ added in v1.0.0
func (m *FaultPoint) GetIarg() int64
func (*FaultPoint) GetName ¶ added in v1.0.0
func (m *FaultPoint) GetName() string
func (*FaultPoint) GetSarg ¶ added in v1.0.0
func (m *FaultPoint) GetSarg() string
func (*FaultPoint) Marshal ¶ added in v1.0.0
func (m *FaultPoint) Marshal() (dAtA []byte, err error)
func (*FaultPoint) MarshalBinary ¶ added in v1.0.0
func (m *FaultPoint) MarshalBinary() ([]byte, error)
func (*FaultPoint) MarshalTo ¶ added in v1.0.0
func (m *FaultPoint) MarshalTo(dAtA []byte) (int, error)
func (*FaultPoint) MarshalToSizedBuffer ¶ added in v1.0.0
func (m *FaultPoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FaultPoint) ProtoMessage ¶ added in v1.0.0
func (*FaultPoint) ProtoMessage()
func (*FaultPoint) ProtoSize ¶ added in v1.0.0
func (m *FaultPoint) ProtoSize() (n int)
func (*FaultPoint) Reset ¶ added in v1.0.0
func (m *FaultPoint) Reset()
func (*FaultPoint) String ¶ added in v1.0.0
func (m *FaultPoint) String() string
func (*FaultPoint) Unmarshal ¶ added in v1.0.0
func (m *FaultPoint) Unmarshal(dAtA []byte) error
func (*FaultPoint) UnmarshalBinary ¶ added in v1.0.0
func (m *FaultPoint) UnmarshalBinary(data []byte) error
func (*FaultPoint) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *FaultPoint) XXX_DiscardUnknown()
func (*FaultPoint) XXX_Marshal ¶ added in v1.0.0
func (m *FaultPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FaultPoint) XXX_Merge ¶ added in v1.0.0
func (m *FaultPoint) XXX_Merge(src proto.Message)
func (*FaultPoint) XXX_Size ¶ added in v1.0.0
func (m *FaultPoint) XXX_Size() int
func (*FaultPoint) XXX_Unmarshal ¶ added in v1.0.0
func (m *FaultPoint) XXX_Unmarshal(b []byte) error
type FlushTable ¶ added in v0.6.0
type FlushTable struct { AccessInfo AccessInfo DatabaseID uint64 TableID uint64 }
func (*FlushTable) Descriptor ¶ added in v0.8.0
func (*FlushTable) Descriptor() ([]byte, []int)
func (*FlushTable) GetAccessInfo ¶ added in v0.8.0
func (m *FlushTable) GetAccessInfo() AccessInfo
func (*FlushTable) GetDatabaseID ¶ added in v0.8.0
func (m *FlushTable) GetDatabaseID() uint64
func (*FlushTable) GetTableID ¶ added in v0.8.0
func (m *FlushTable) GetTableID() uint64
func (*FlushTable) Marshal ¶ added in v0.8.0
func (m *FlushTable) Marshal() (dAtA []byte, err error)
func (*FlushTable) MarshalBinary ¶ added in v0.8.0
func (m *FlushTable) MarshalBinary() ([]byte, error)
func (*FlushTable) MarshalTo ¶ added in v0.8.0
func (m *FlushTable) MarshalTo(dAtA []byte) (int, error)
func (*FlushTable) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *FlushTable) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FlushTable) ProtoMessage ¶ added in v0.8.0
func (*FlushTable) ProtoMessage()
func (*FlushTable) ProtoSize ¶ added in v0.8.0
func (m *FlushTable) ProtoSize() (n int)
func (*FlushTable) Reset ¶ added in v0.8.0
func (m *FlushTable) Reset()
func (*FlushTable) String ¶ added in v0.8.0
func (m *FlushTable) String() string
func (*FlushTable) Unmarshal ¶ added in v0.8.0
func (m *FlushTable) Unmarshal(dAtA []byte) error
func (*FlushTable) UnmarshalBinary ¶ added in v0.8.0
func (m *FlushTable) UnmarshalBinary(data []byte) error
func (*FlushTable) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *FlushTable) XXX_DiscardUnknown()
func (*FlushTable) XXX_Marshal ¶ added in v0.8.0
func (m *FlushTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FlushTable) XXX_Merge ¶ added in v0.8.0
func (m *FlushTable) XXX_Merge(src proto.Message)
func (*FlushTable) XXX_Size ¶ added in v0.8.0
func (m *FlushTable) XXX_Size() int
func (*FlushTable) XXX_Unmarshal ¶ added in v0.8.0
func (m *FlushTable) XXX_Unmarshal(b []byte) error
type InspectResp ¶ added in v0.7.0
type InspectResp struct { Typ int `json:"-"` Message string `json:"msg"` Payload []byte `json:"-"` }
func (*InspectResp) ConsoleString ¶ added in v1.0.0
func (m *InspectResp) ConsoleString() string
func (*InspectResp) Descriptor ¶ added in v0.8.0
func (*InspectResp) Descriptor() ([]byte, []int)
func (*InspectResp) GetMessage ¶ added in v0.8.0
func (m *InspectResp) GetMessage() string
func (*InspectResp) GetPayload ¶ added in v0.8.0
func (m *InspectResp) GetPayload() []byte
func (*InspectResp) GetResponse ¶ added in v0.7.0
func (m *InspectResp) GetResponse() any
func (*InspectResp) GetTyp ¶ added in v0.8.0
func (m *InspectResp) GetTyp() int
func (*InspectResp) Marshal ¶ added in v0.8.0
func (m *InspectResp) Marshal() (dAtA []byte, err error)
func (*InspectResp) MarshalBinary ¶ added in v0.8.0
func (m *InspectResp) MarshalBinary() ([]byte, error)
func (*InspectResp) MarshalTo ¶ added in v0.8.0
func (m *InspectResp) MarshalTo(dAtA []byte) (int, error)
func (*InspectResp) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *InspectResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InspectResp) ProtoMessage ¶ added in v0.8.0
func (*InspectResp) ProtoMessage()
func (*InspectResp) ProtoSize ¶ added in v0.8.0
func (m *InspectResp) ProtoSize() (n int)
func (*InspectResp) Reset ¶ added in v0.8.0
func (m *InspectResp) Reset()
func (*InspectResp) String ¶ added in v0.8.0
func (m *InspectResp) String() string
func (*InspectResp) Unmarshal ¶ added in v0.8.0
func (m *InspectResp) Unmarshal(dAtA []byte) error
func (*InspectResp) UnmarshalBinary ¶ added in v0.8.0
func (m *InspectResp) UnmarshalBinary(data []byte) error
func (*InspectResp) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *InspectResp) XXX_DiscardUnknown()
func (*InspectResp) XXX_Marshal ¶ added in v0.8.0
func (m *InspectResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InspectResp) XXX_Merge ¶ added in v0.8.0
func (m *InspectResp) XXX_Merge(src proto.Message)
func (*InspectResp) XXX_Size ¶ added in v0.8.0
func (m *InspectResp) XXX_Size() int
func (*InspectResp) XXX_Unmarshal ¶ added in v0.8.0
func (m *InspectResp) XXX_Unmarshal(b []byte) error
type InspectTN ¶ added in v1.0.0
type InspectTN struct { AccessInfo AccessInfo Operation string }
func (*InspectTN) Descriptor ¶ added in v1.0.0
func (*InspectTN) GetAccessInfo ¶ added in v1.0.0
func (m *InspectTN) GetAccessInfo() AccessInfo
func (*InspectTN) GetOperation ¶ added in v1.0.0
func (*InspectTN) MarshalBinary ¶ added in v1.0.0
func (*InspectTN) MarshalToSizedBuffer ¶ added in v1.0.0
func (*InspectTN) ProtoMessage ¶ added in v1.0.0
func (*InspectTN) ProtoMessage()
func (*InspectTN) UnmarshalBinary ¶ added in v1.0.0
func (*InspectTN) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *InspectTN) XXX_DiscardUnknown()
func (*InspectTN) XXX_Marshal ¶ added in v1.0.0
func (*InspectTN) XXX_Unmarshal ¶ added in v1.0.0
type InterceptCommit ¶ added in v1.2.0
type InterceptCommit struct {
TableName string
}
func (*InterceptCommit) Descriptor ¶ added in v1.2.0
func (*InterceptCommit) Descriptor() ([]byte, []int)
func (*InterceptCommit) GetTableName ¶ added in v1.2.0
func (m *InterceptCommit) GetTableName() string
func (*InterceptCommit) Marshal ¶ added in v1.2.0
func (m *InterceptCommit) Marshal() (dAtA []byte, err error)
func (*InterceptCommit) MarshalBinary ¶ added in v1.2.0
func (m *InterceptCommit) MarshalBinary() ([]byte, error)
func (*InterceptCommit) MarshalTo ¶ added in v1.2.0
func (m *InterceptCommit) MarshalTo(dAtA []byte) (int, error)
func (*InterceptCommit) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *InterceptCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InterceptCommit) ProtoMessage ¶ added in v1.2.0
func (*InterceptCommit) ProtoMessage()
func (*InterceptCommit) ProtoSize ¶ added in v1.2.0
func (m *InterceptCommit) ProtoSize() (n int)
func (*InterceptCommit) Reset ¶ added in v1.2.0
func (m *InterceptCommit) Reset()
func (*InterceptCommit) String ¶ added in v1.2.0
func (m *InterceptCommit) String() string
func (*InterceptCommit) Unmarshal ¶ added in v1.2.0
func (m *InterceptCommit) Unmarshal(dAtA []byte) error
func (*InterceptCommit) UnmarshalBinary ¶ added in v1.2.0
func (m *InterceptCommit) UnmarshalBinary(data []byte) error
func (*InterceptCommit) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *InterceptCommit) XXX_DiscardUnknown()
func (*InterceptCommit) XXX_Marshal ¶ added in v1.2.0
func (m *InterceptCommit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InterceptCommit) XXX_Merge ¶ added in v1.2.0
func (m *InterceptCommit) XXX_Merge(src proto.Message)
func (*InterceptCommit) XXX_Size ¶ added in v1.2.0
func (m *InterceptCommit) XXX_Size() int
func (*InterceptCommit) XXX_Unmarshal ¶ added in v1.2.0
func (m *InterceptCommit) XXX_Unmarshal(b []byte) error
type LocationKey ¶ added in v0.7.0
type LocationKey struct{}
type MergeTaskBuilder ¶ added in v0.7.0
type MergeTaskBuilder struct { *catalog.LoopProcessor // contains filtered or unexported fields }
func (*MergeTaskBuilder) ConfigPolicy ¶ added in v1.0.0
func (s *MergeTaskBuilder) ConfigPolicy(tbl *catalog.TableEntry, c any)
func (*MergeTaskBuilder) GetPolicy ¶ added in v1.0.0
func (s *MergeTaskBuilder) GetPolicy(tbl *catalog.TableEntry) any
func (*MergeTaskBuilder) PostExecute ¶ added in v0.7.0
func (s *MergeTaskBuilder) PostExecute() error
func (*MergeTaskBuilder) PreExecute ¶ added in v0.7.0
func (s *MergeTaskBuilder) PreExecute() error
type NoopErrHandler ¶
type NoopErrHandler struct{}
func (*NoopErrHandler) OnDatabaseErr ¶
func (h *NoopErrHandler) OnDatabaseErr(entry *catalog.DBEntry, err error) error
func (*NoopErrHandler) OnObjectErr ¶ added in v1.1.0
func (h *NoopErrHandler) OnObjectErr(entry *catalog.ObjectEntry, err error) error
func (*NoopErrHandler) OnTableErr ¶
func (h *NoopErrHandler) OnTableErr(entry *catalog.TableEntry, err error) error
type PKCheckType ¶ added in v0.8.0
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 )
type RelationType ¶ added in v0.6.0
type RelationType uint8
const ( RelationTable RelationType = iota + 1 RelationView )
type Replayer ¶
type Replayer struct { DataFactory *tables.DataFactory // contains filtered or unexported fields }
func (*Replayer) OnReplayEntry ¶
func (*Replayer) OnReplayTxn ¶ added in v0.6.0
func (*Replayer) OnTimeStamp ¶
func (*Replayer) PreReplayWal ¶
func (replayer *Replayer) PreReplayWal()
type ScheduledTxnTask ¶
func NewScheduledTxnTask ¶
func NewScheduledTxnTask(ctx *tasks.Context, db *DB, taskType tasks.TaskType, scopes []common.ID, factory tasks.TxnTaskFactory) (task *ScheduledTxnTask)
func (*ScheduledTxnTask) Execute ¶
func (task *ScheduledTxnTask) Execute(ctx context.Context) (err error)
func (*ScheduledTxnTask) Scope ¶
func (task *ScheduledTxnTask) Scope() *common.ID
func (*ScheduledTxnTask) Scopes ¶
func (task *ScheduledTxnTask) Scopes() []common.ID
type StorageUsageReq ¶ added in v1.1.0
type StorageUsageReq struct {
AccIds []int64
}
func (*StorageUsageReq) Descriptor ¶ added in v1.1.0
func (*StorageUsageReq) Descriptor() ([]byte, []int)
func (*StorageUsageReq) GetAccIds ¶ added in v1.1.0
func (m *StorageUsageReq) GetAccIds() []int64
func (*StorageUsageReq) Marshal ¶ added in v1.1.0
func (m *StorageUsageReq) Marshal() (dAtA []byte, err error)
func (*StorageUsageReq) MarshalBinary ¶ added in v1.1.0
func (s *StorageUsageReq) MarshalBinary() ([]byte, error)
func (*StorageUsageReq) MarshalTo ¶ added in v1.1.0
func (m *StorageUsageReq) MarshalTo(dAtA []byte) (int, error)
func (*StorageUsageReq) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *StorageUsageReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageUsageReq) ProtoMessage ¶ added in v1.1.0
func (*StorageUsageReq) ProtoMessage()
func (*StorageUsageReq) ProtoSize ¶ added in v1.1.0
func (m *StorageUsageReq) ProtoSize() (n int)
func (*StorageUsageReq) Reset ¶ added in v1.1.0
func (m *StorageUsageReq) Reset()
func (*StorageUsageReq) String ¶ added in v1.1.0
func (m *StorageUsageReq) String() string
func (*StorageUsageReq) Unmarshal ¶ added in v1.1.0
func (m *StorageUsageReq) Unmarshal(dAtA []byte) error
func (*StorageUsageReq) UnmarshalBinary ¶ added in v1.1.0
func (s *StorageUsageReq) UnmarshalBinary(data []byte) error
func (*StorageUsageReq) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *StorageUsageReq) XXX_DiscardUnknown()
func (*StorageUsageReq) XXX_Marshal ¶ added in v1.1.0
func (m *StorageUsageReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageUsageReq) XXX_Merge ¶ added in v1.1.0
func (m *StorageUsageReq) XXX_Merge(src proto.Message)
func (*StorageUsageReq) XXX_Size ¶ added in v1.1.0
func (m *StorageUsageReq) XXX_Size() int
func (*StorageUsageReq) XXX_Unmarshal ¶ added in v1.1.0
func (m *StorageUsageReq) XXX_Unmarshal(b []byte) error
type StorageUsageResp_V0 ¶ added in v1.1.1
type StorageUsageResp_V0 struct { Succeed bool CkpEntries []*CkpMetaInfo BlockEntries []*BlockMetaInfo }
func (*StorageUsageResp_V0) Descriptor ¶ added in v1.1.1
func (*StorageUsageResp_V0) Descriptor() ([]byte, []int)
func (*StorageUsageResp_V0) GetBlockEntries ¶ added in v1.1.1
func (m *StorageUsageResp_V0) GetBlockEntries() []*BlockMetaInfo
func (*StorageUsageResp_V0) GetCkpEntries ¶ added in v1.1.1
func (m *StorageUsageResp_V0) GetCkpEntries() []*CkpMetaInfo
func (*StorageUsageResp_V0) GetSucceed ¶ added in v1.1.1
func (m *StorageUsageResp_V0) GetSucceed() bool
func (*StorageUsageResp_V0) Marshal ¶ added in v1.1.1
func (m *StorageUsageResp_V0) Marshal() (dAtA []byte, err error)
func (*StorageUsageResp_V0) MarshalTo ¶ added in v1.1.1
func (m *StorageUsageResp_V0) MarshalTo(dAtA []byte) (int, error)
func (*StorageUsageResp_V0) MarshalToSizedBuffer ¶ added in v1.1.1
func (m *StorageUsageResp_V0) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageUsageResp_V0) ProtoMessage ¶ added in v1.1.1
func (*StorageUsageResp_V0) ProtoMessage()
func (*StorageUsageResp_V0) ProtoSize ¶ added in v1.1.1
func (m *StorageUsageResp_V0) ProtoSize() (n int)
func (*StorageUsageResp_V0) Reset ¶ added in v1.1.1
func (m *StorageUsageResp_V0) Reset()
func (*StorageUsageResp_V0) String ¶ added in v1.1.1
func (m *StorageUsageResp_V0) String() string
func (*StorageUsageResp_V0) Unmarshal ¶ added in v1.1.1
func (m *StorageUsageResp_V0) Unmarshal(dAtA []byte) error
func (*StorageUsageResp_V0) XXX_DiscardUnknown ¶ added in v1.1.1
func (m *StorageUsageResp_V0) XXX_DiscardUnknown()
func (*StorageUsageResp_V0) XXX_Marshal ¶ added in v1.1.1
func (m *StorageUsageResp_V0) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageUsageResp_V0) XXX_Merge ¶ added in v1.1.1
func (m *StorageUsageResp_V0) XXX_Merge(src proto.Message)
func (*StorageUsageResp_V0) XXX_Size ¶ added in v1.1.1
func (m *StorageUsageResp_V0) XXX_Size() int
func (*StorageUsageResp_V0) XXX_Unmarshal ¶ added in v1.1.1
func (m *StorageUsageResp_V0) XXX_Unmarshal(b []byte) error
type StorageUsageResp_V1 ¶ added in v1.2.3
func (*StorageUsageResp_V1) Descriptor ¶ added in v1.2.3
func (*StorageUsageResp_V1) Descriptor() ([]byte, []int)
func (*StorageUsageResp_V1) GetAccIds ¶ added in v1.2.3
func (m *StorageUsageResp_V1) GetAccIds() []int64
func (*StorageUsageResp_V1) GetMagic ¶ added in v1.2.3
func (m *StorageUsageResp_V1) GetMagic() uint64
func (*StorageUsageResp_V1) GetSizes ¶ added in v1.2.3
func (m *StorageUsageResp_V1) GetSizes() []uint64
func (*StorageUsageResp_V1) GetSucceed ¶ added in v1.2.3
func (m *StorageUsageResp_V1) GetSucceed() bool
func (*StorageUsageResp_V1) Marshal ¶ added in v1.2.3
func (m *StorageUsageResp_V1) Marshal() (dAtA []byte, err error)
func (*StorageUsageResp_V1) MarshalBinary ¶ added in v1.2.3
func (s *StorageUsageResp_V1) MarshalBinary() ([]byte, error)
func (*StorageUsageResp_V1) MarshalTo ¶ added in v1.2.3
func (m *StorageUsageResp_V1) MarshalTo(dAtA []byte) (int, error)
func (*StorageUsageResp_V1) MarshalToSizedBuffer ¶ added in v1.2.3
func (m *StorageUsageResp_V1) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageUsageResp_V1) ProtoMessage ¶ added in v1.2.3
func (*StorageUsageResp_V1) ProtoMessage()
func (*StorageUsageResp_V1) ProtoSize ¶ added in v1.2.3
func (m *StorageUsageResp_V1) ProtoSize() (n int)
func (*StorageUsageResp_V1) Reset ¶ added in v1.2.3
func (m *StorageUsageResp_V1) Reset()
func (*StorageUsageResp_V1) String ¶ added in v1.2.3
func (m *StorageUsageResp_V1) String() string
func (*StorageUsageResp_V1) Unmarshal ¶ added in v1.2.3
func (m *StorageUsageResp_V1) Unmarshal(dAtA []byte) error
func (*StorageUsageResp_V1) UnmarshalBinary ¶ added in v1.2.3
func (s *StorageUsageResp_V1) UnmarshalBinary(data []byte) error
func (*StorageUsageResp_V1) XXX_DiscardUnknown ¶ added in v1.2.3
func (m *StorageUsageResp_V1) XXX_DiscardUnknown()
func (*StorageUsageResp_V1) XXX_Marshal ¶ added in v1.2.3
func (m *StorageUsageResp_V1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageUsageResp_V1) XXX_Merge ¶ added in v1.2.3
func (m *StorageUsageResp_V1) XXX_Merge(src proto.Message)
func (*StorageUsageResp_V1) XXX_Size ¶ added in v1.2.3
func (m *StorageUsageResp_V1) XXX_Size() int
func (*StorageUsageResp_V1) XXX_Unmarshal ¶ added in v1.2.3
func (m *StorageUsageResp_V1) XXX_Unmarshal(b []byte) error
type StorageUsageResp_V2 ¶ added in v1.2.3
type StorageUsageResp_V2 struct { Succeed bool AccIds []int64 Sizes []uint64 Magic uint64 ObjCnts []uint64 BlkCnts []uint64 RowCnts []uint64 }
func (*StorageUsageResp_V2) Descriptor ¶ added in v1.2.3
func (*StorageUsageResp_V2) Descriptor() ([]byte, []int)
func (*StorageUsageResp_V2) GetAccIds ¶ added in v1.2.3
func (m *StorageUsageResp_V2) GetAccIds() []int64
func (*StorageUsageResp_V2) GetBlkCnts ¶ added in v1.2.3
func (m *StorageUsageResp_V2) GetBlkCnts() []uint64
func (*StorageUsageResp_V2) GetMagic ¶ added in v1.2.3
func (m *StorageUsageResp_V2) GetMagic() uint64
func (*StorageUsageResp_V2) GetObjCnts ¶ added in v1.2.3
func (m *StorageUsageResp_V2) GetObjCnts() []uint64
func (*StorageUsageResp_V2) GetRowCnts ¶ added in v1.2.3
func (m *StorageUsageResp_V2) GetRowCnts() []uint64
func (*StorageUsageResp_V2) GetSizes ¶ added in v1.2.3
func (m *StorageUsageResp_V2) GetSizes() []uint64
func (*StorageUsageResp_V2) GetSucceed ¶ added in v1.2.3
func (m *StorageUsageResp_V2) GetSucceed() bool
func (*StorageUsageResp_V2) Marshal ¶ added in v1.2.3
func (m *StorageUsageResp_V2) Marshal() (dAtA []byte, err error)
func (*StorageUsageResp_V2) MarshalBinary ¶ added in v1.2.3
func (s *StorageUsageResp_V2) MarshalBinary() ([]byte, error)
func (*StorageUsageResp_V2) MarshalTo ¶ added in v1.2.3
func (m *StorageUsageResp_V2) MarshalTo(dAtA []byte) (int, error)
func (*StorageUsageResp_V2) MarshalToSizedBuffer ¶ added in v1.2.3
func (m *StorageUsageResp_V2) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageUsageResp_V2) ProtoMessage ¶ added in v1.2.3
func (*StorageUsageResp_V2) ProtoMessage()
func (*StorageUsageResp_V2) ProtoSize ¶ added in v1.2.3
func (m *StorageUsageResp_V2) ProtoSize() (n int)
func (*StorageUsageResp_V2) Reset ¶ added in v1.2.3
func (m *StorageUsageResp_V2) Reset()
func (*StorageUsageResp_V2) String ¶ added in v1.2.3
func (m *StorageUsageResp_V2) String() string
func (*StorageUsageResp_V2) Unmarshal ¶ added in v1.2.3
func (m *StorageUsageResp_V2) Unmarshal(dAtA []byte) error
func (*StorageUsageResp_V2) UnmarshalBinary ¶ added in v1.2.3
func (s *StorageUsageResp_V2) UnmarshalBinary(data []byte) error
func (*StorageUsageResp_V2) XXX_DiscardUnknown ¶ added in v1.2.3
func (m *StorageUsageResp_V2) XXX_DiscardUnknown()
func (*StorageUsageResp_V2) XXX_Marshal ¶ added in v1.2.3
func (m *StorageUsageResp_V2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageUsageResp_V2) XXX_Merge ¶ added in v1.2.3
func (m *StorageUsageResp_V2) XXX_Merge(src proto.Message)
func (*StorageUsageResp_V2) XXX_Size ¶ added in v1.2.3
func (m *StorageUsageResp_V2) XXX_Size() int
func (*StorageUsageResp_V2) XXX_Unmarshal ¶ added in v1.2.3
func (m *StorageUsageResp_V2) XXX_Unmarshal(b []byte) error
type TraceSpan ¶ added in v1.0.0
func (*TraceSpan) Descriptor ¶ added in v1.0.0
func (*TraceSpan) GetThreshold ¶ added in v1.0.0
func (*TraceSpan) MarshalBinary ¶ added in v1.0.0
func (*TraceSpan) MarshalToSizedBuffer ¶ added in v1.0.0
func (*TraceSpan) ProtoMessage ¶ added in v1.0.0
func (*TraceSpan) ProtoMessage()
func (*TraceSpan) UnmarshalBinary ¶ added in v1.0.0
func (*TraceSpan) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *TraceSpan) XXX_DiscardUnknown()
func (*TraceSpan) XXX_Marshal ¶ added in v1.0.0
func (*TraceSpan) XXX_Unmarshal ¶ added in v1.0.0
type WriteReq ¶ added in v0.6.0
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 MetaLocs []string //for delete on S3 DeltaLocs []string //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 ¶
Click to show internal directories.
Click to hide internal directories.