Documentation ¶
Index ¶
- Constants
- func CheckDirHasFilesSql() (sqltext string)
- func CheckSegAlreadyBeGcSql() (sqltext string)
- func CreateGcSegmentInfoSql() (sqltext string)
- func CreateOrUpdateFileLeaderSql() (sqltext string)
- func CreateOrUpdateZoneSql() (sqltext string)
- func CreateSegmentZoneSql() (sqltext string)
- func DeleteDirSql() (sqltext string)
- func DeleteFileLeaderSql() (sqltext string)
- func DeleteFileSql() (sqltext string)
- func DeleteSegSql() (sqltext string)
- func DeleteSegmentInfoSql() (sqltext string)
- func DeleteSegmentZoneSql() (sqltext string)
- func GetAllExistedFileSql() (sqltext string)
- func GetDirFileInfoSql() (sqltext string)
- func GetDirFileInoSql() (sqltext string)
- func GetDirInfoSql() (sqltext string)
- func GetFileExistedSql() (sqltext string)
- func GetFileInfoSql() (sqltext string)
- func GetFileSizeSql() (sqltext string)
- func GetGcMapSegExistedSql() (sqltext string)
- func GetGcSegZoneSql() (sqltext string)
- func GetGcSegmentInfoSql() (sqltext string)
- func GetGcSegmentZoneSql() (sqltext string)
- func GetInsertGcMapSql(num int) (sqltext string)
- func GetLeaderSql() (sqltext string)
- func GetSegAge(ctx context.Context, seg *types.GcSegmentInfo, t *TidbClient) (err error)
- func GetSegAgeSql() (sqltext string)
- func GetSegDeletedSizeSql() (sqltext string)
- func GetSegExistedSql() (sqltext string)
- func GetSegmentInfoSql(maxNum int) (sqltext string)
- func GetSegmentLeaderSql() (sqltext string)
- func GetSegmentZone(ctx context.Context, seg *types.GcSegmentInfo, t *TidbClient) (err error)
- func GetSegmentsByLeaderSql() (sqltext string)
- func GetSegsByGcSql() (sqltext string)
- func GetSegsByTimeSql() (sqltext string)
- func GetSegsLeaderSql(maxNum int) (sqltext string)
- func InsertOrUpdateSegInfo(ctx context.Context, seg *types.NewGcSegment, sqlTx *sql.Tx) (err error)
- func InsertOrUpdateSegZone(ctx context.Context, newSeg *types.NewGcSegment, sqlTx *sql.Tx) (err error)
- func InsertOrUpdateSegZoneSql() (sqltext string)
- func RecoverSegGcStatusSql() (sqltext string)
- func SelectFileParentSql() (sqltext string)
- func UpdateFileSizeSql() (sqltext string)
- func UpdateSegCompletedGcSql() (sqltext string)
- func UpdateSegDeletedSizeSql() (sqltext string)
- func UpdateSegGcStatusSql() (sqltext string)
- func UpdateSegmentInfoSql() (sqltext string)
- type TidbClient
- func (t *TidbClient) CheckAndDeleteGcFile(ctx context.Context, file *types.DeleteFileMsg) (err error)
- func (t *TidbClient) CheckDirInfo(ctx context.Context, dir *types.DeleteDirStore) (resp *types.GetDirInfoRet, err error)
- func (t *TidbClient) CheckFsIsExisted(ctx context.Context, fsid string) (flag bool, err error)
- func (t *TidbClient) CheckGcFile(ctx context.Context, file *types.DeleteFileMsg) (isDelete bool, err error)
- func (t *TidbClient) CheckGcFs(ctx context.Context, fsid string) (isDelete bool, err error)
- func (t *TidbClient) CheckGcFsHasNoSeg(ctx context.Context, fsid string) (flag bool, err error)
- func (t *TidbClient) CheckGcFsIsDeleted(ctx context.Context, fsid string) (flag bool, err error)
- func (t *TidbClient) CheckSegExistsInGcFs(ctx context.Context, fsid string) (flag bool, err error)
- func (t *TidbClient) CheckSegInGcFs(ctx context.Context, fsid string, segId0, segId1 uint64) (flag bool, segSize, unitSize uint64, err error)
- func (t *TidbClient) CheckSegmentIsDeleted(ctx context.Context, fsid string, segId0, segId1 uint64) (flag bool, segSize, unitSize uint64, err error)
- func (t *TidbClient) CheckSegsLeader(ctx context.Context, segs *types.CheckSegsStore) (segIds []*types.SegmentId, err error)
- func (t *TidbClient) CheckTheSeg(ctx context.Context, seg *types.GcDeleteSeg) (isDeleted bool, err error)
- func (t *TidbClient) CloseFile(ctx context.Context, file *types.FileTimeStore) (err error)
- func (t *TidbClient) CreateFile(ctx context.Context, file *types.CreateFileStore) (err error)
- func (t *TidbClient) CreateNewFile(ctx context.Context, file *types.CreateFileStore) (ino, generation uint64, ctime, mtime, atime int64, err error)
- func (t *TidbClient) CreateOrUpdateFileLeader(ctx context.Context, leader *types.GetLeaderStore) (err error)
- func (t *TidbClient) CreateOrUpdateZone(ctx context.Context, zone *types.MountStore) (err error)
- func (t *TidbClient) DeleteFile(ctx context.Context, file *types.DeleteFileStore) (err error)
- func (t *TidbClient) DeleteFileBlocks(ctx context.Context, req *types.DeleteBlocksInfo, tx *sql.Tx) (err error)
- func (t *TidbClient) DeleteFileTime(ctx context.Context, file *types.DeleteFileStore) (err error)
- func (t *TidbClient) DeleteGcFile(ctx context.Context, file *types.DeleteFileStore) (err error)
- func (t *TidbClient) DeleteGcFs(ctx context.Context, fsid string) (err error)
- func (t *TidbClient) DeleteGcMapSegs(ctx context.Context, segs map[string][]int) (err error)
- func (t *TidbClient) DeleteLock(ctx context.Context, lock *types.LockInfoStore) (err error)
- func (t *TidbClient) DeleteSegZoneAndInfo(ctx context.Context, seg *types.GcDeleteSeg) (err error)
- func (t *TidbClient) DeleteSegsByNewSegId(ctx context.Context, seg *types.GcDeleteSeg) (deleteSegs []string, err error)
- func (t *TidbClient) GetAllExistedBlocksInfo(ctx context.Context, seg *types.DestGcSegment) (blocks []*types.GcBlockInfo, gcInfo []*types.GcMigrateInfo, err error)
- func (t *TidbClient) GetAllExistedFiles(ctx context.Context, checkOffset uint64) (files []*types.FileSizeStore, nextOffset uint64, err error)
- func (t *TidbClient) GetAllGcFiles(ctx context.Context, checkTime int64) (files []*types.DeleteFileStore, nextCheckTime int64, err error)
- func (t *TidbClient) GetAllGcFs(ctx context.Context, checkTime int64) (fsids []string, nextCheckTime int64, err error)
- func (t *TidbClient) GetAllIsNotDeletingFsIds(ctx context.Context, checkTime int64) (fsInfos []*types.FsStatusStore, nextCheckTime int64, err error)
- func (t *TidbClient) GetAndCheckSegsLeader(ctx context.Context, fsid, zoneId, machine string, segs []*types.SegmentId) (err error)
- func (t *TidbClient) GetAndCreateSegmentId(ctx context.Context) (err error)
- func (t *TidbClient) GetAndUpdateSegmentId(ctx context.Context) (segId uint64, err error)
- func (t *TidbClient) GetAvailableSegment(ctx context.Context, seg *types.GetSegmentsStore) (resp *types.SegmentInfo, err error)
- func (t *TidbClient) GetDeletedSegsInfo(ctx context.Context, fsId string, segs []*types.GcDeleteSeg) (resp []*types.GcDeleteSeg, err error)
- func (t *TidbClient) GetDirFileInfo(ctx context.Context, file *types.GetDirFileInfoStore) (resp *types.FileInfo, err error)
- func (t *TidbClient) GetDirLeaderInfo(ctx context.Context, dir *types.GetDirInfoRet) (err error)
- func (t *TidbClient) GetDirsAndFiles(ctx context.Context, fsid string, checkIno uint64) (files *types.DirsAndFiles, nextIno uint64, err error)
- func (t *TidbClient) GetFileInfo(ctx context.Context, file *types.GetFileAttrStore) (resp *types.FileInfo, err error)
- func (t *TidbClient) GetFileLeaderInfo(ctx context.Context, leader *types.GetLeaderStore) (resp *types.GetLeaderRet, err error)
- func (t *TidbClient) GetFileSegs(ctx context.Context, seg *types.GetSegmentsStore) (resp map[interface{}]*types.SegmentInfo, segIds [][2]uint64, nextOffset uint64, ...)
- func (t *TidbClient) GetFileSize(ctx context.Context, file *types.FileSizeStore) (resp *types.FileSizeStore, err error)
- func (t *TidbClient) GetFileSystemInfo(ctx context.Context, fsId string) (resp *types.StoreInfo, err error)
- func (t *TidbClient) GetFilesForGcMapTree(ctx context.Context, offset uint64) (files []*types.FileTime, err error)
- func (t *TidbClient) GetFsInfoByFsIds(ctx context.Context, fsids []string) (fsInfo []*types.FsInfo, err error)
- func (t *TidbClient) GetFsInfoFromGcFs(ctx context.Context, fsId string) (resp *types.StoreInfo, err error)
- func (t *TidbClient) GetFsMonitorIndexes(ctx context.Context, fsid string) (indexes []*types.FsIndex, err error)
- func (t *TidbClient) GetFsNameAndUid(ctx context.Context, fsid string) (fsName string, uid int, err error)
- func (t *TidbClient) GetFsStatus(ctx context.Context, fsid string) (status int, err error)
- func (t *TidbClient) GetGcCreateSegs(ctx context.Context) (segs []*types.NewGcSegInfo, err error)
- func (t *TidbClient) GetGcMap(ctx context.Context, req *types.GetGcMapReq) (resp map[string][]*types.GetGcMapResp, lastId uint64, err error)
- func (t *TidbClient) GetGcMapOfSegment(ctx context.Context, req *types.GetGcMapReq) (resp []*types.GetGcMapResp, lastId uint64, err error)
- func (t *TidbClient) GetIncompleteUploadSegs(ctx context.Context, segInfo *types.GetIncompleteUploadSegsStore, ...) (segsResp []*types.IncompleteUploadSegInfo, err error)
- func (t *TidbClient) GetMachineInfo(ctx context.Context, zone *types.GetLeaderStore) (resp *types.GetMachineInfoResp, err error)
- func (t *TidbClient) GetOneUpMachine(ctx context.Context, zone *types.GetLeaderStore) (leader string, err error)
- func (t *TidbClient) GetParentUGOPerm(ctx context.Context, file *types.FileOrDirInfo) (perm *types.UGOPermission, err error)
- func (t *TidbClient) GetSegIdsFromFileBlocks(ctx context.Context, file *types.FileIno, offset uint64) (segIds map[[2]uint64]struct{}, nextOffset uint64, blockNum int, err error)
- func (t *TidbClient) GetSegInfo(ctx context.Context, gcExecuting, gcCompleted int) (segs []*types.GcSegmentInfo, ages []int64, deletedSegs []*types.GcDeleteSeg, ...)
- func (t *TidbClient) GetSegSize(ctx context.Context, seg *types.DestGcSegment) (resp *types.GetSizeResp, err error)
- func (t *TidbClient) GetSegSizeAndUnitSize(ctx context.Context, seg *types.DeleteFileMsg) (segSize, unitSize uint64, err error)
- func (t *TidbClient) GetSegmentInfo(ctx context.Context, seg *types.GcDeleteSeg) (segSize, unitSize uint64, err error)
- func (t *TidbClient) GetSegmentLeader(ctx context.Context, segment *types.GetSegLeaderReq) (resp *types.LeaderInfo, err error)
- func (t *TidbClient) GetSegmentsFromGcMap(ctx context.Context, file *types.FileTime) (segs []*types.FileSegment, err error)
- func (t *TidbClient) GetSegsAndDeleteFileBlocks(ctx context.Context, offset uint64, file *types.DeleteFileStore) (segBlocks []*types.SegBlock, nextOffset uint64, err error)
- func (t *TidbClient) GetSegsBlockInfo(ctx context.Context, seg *types.GetSegmentsStore, ...) (err error)
- func (t *TidbClient) GetSegsByLeader(ctx context.Context, seg *types.GetIncompleteUploadSegsStore) (segsResp []*types.IncompleteUploadSegInfo, err error)
- func (t *TidbClient) GetSegsInfo(ctx context.Context, file *types.DeleteFileStore, segId *types.SegId) (addrs []uint64, nextOffset uint64, err error)
- func (t *TidbClient) GetSegsInfoForHeartBeat(ctx context.Context, segs *types.CheckSegsStore) (ret []*types.CheckSegsRet, err error)
- func (t *TidbClient) GetTheSlowestGrowingSeg(ctx context.Context, segReq *types.GetSegmentsStore, ...) (isExisted bool, resp *types.SegmentInfo, err error)
- func (t *TidbClient) GetUGOPerm(ctx context.Context, file *types.FileOrDirInfo) (perm *types.UGOPermission, err error)
- func (t *TidbClient) HandleFileDeleted(ctx context.Context, file *types.DeleteFileStore) (err error)
- func (t *TidbClient) HandleFsDeleted(ctx context.Context, fsid string) (err error)
- func (t *TidbClient) HandleMetaDataForDeletedSeg(ctx context.Context, seg *types.DeleteFileMsg, offset uint64, ...) (nextOffset uint64, deleteDone bool, blockNum int, err error)
- func (t *TidbClient) InitRootDirs(ctx context.Context, rootDir *types.MountStore) (err error)
- func (t *TidbClient) InsertGcCreateSegInfo(ctx context.Context, seg *types.NewGcSegment) (err error)
- func (t *TidbClient) InsertLock(ctx context.Context, lock *types.LockInfoStore) (err error)
- func (t *TidbClient) IsFileHasSegments(ctx context.Context, seg *types.GetSegmentsStore) (isExisted bool, err error)
- func (t *TidbClient) IsFileLeaderDown(ctx context.Context, file *types.FileTimeStore) (flag bool, err error)
- func (t *TidbClient) ListDirFiles(ctx context.Context, dir *types.GetDirFilesStore) (dirFilesResp []*types.DirFileInfoStore, offset uint64, err error)
- func (t *TidbClient) LockSegment(ctx context.Context, seg *types.FileSegment) (txn *sql.Tx, err error)
- func (t *TidbClient) MarkSegInfoAndDelSegZone(ctx context.Context, seg *types.DeleteFileMsg) (err error)
- func (t *TidbClient) RenameFile(ctx context.Context, file *types.RenameFileStore) (err error)
- func (t *TidbClient) SetFileAttr(ctx context.Context, file *types.SetFileAttrStore) (err error)
- func (t *TidbClient) SetFileSystem(ctx context.Context, store *types.StoreInfo, fsCapacity uint64) (err error)
- func (t *TidbClient) UnlockBlocks(ctx context.Context, tx *sql.Tx) (err error)
- func (t *TidbClient) UpdateFileAndSegBlocks(ctx context.Context, blocks []*types.FileBlockInfo, tx *sql.Tx) (err error)
- func (t *TidbClient) UpdateFileBlocksNum(ctx context.Context, file *types.GetFileAttrStore) (err error)
- func (t *TidbClient) UpdateFileInfo(ctx context.Context, file *types.FileSizeStore) (err error)
- func (t *TidbClient) UpdateFileOpenTime(ctx context.Context, file *types.FileTimeStore) (err error)
- func (t *TidbClient) UpdateFileSize(ctx context.Context, file *types.FileSizeStore) (err error)
- func (t *TidbClient) UpdateFsFileNum(ctx context.Context, file *types.FsFileNumStat) (err error)
- func (t *TidbClient) UpdateFsStatus(ctx context.Context, req *types.FsStatusStore) (err error)
- func (t *TidbClient) UpdateFsUsage(ctx context.Context, file *types.FsUsageStat) (err error)
- func (t *TidbClient) UpdateGcCreateSegs(ctx context.Context, segs []*types.NewGcSegInfo) (err error)
- func (t *TidbClient) UpdateGcSegStatus(ctx context.Context, seg *types.NewGcSegInfo) (err error)
- func (t *TidbClient) UpdateGcSegmentInfo(ctx context.Context, blocks map[string][]*types.GcBlockInfo, ...) (deletedSize uint64, err error)
- func (t *TidbClient) UpdateMachineStatus(ctx context.Context, zone *types.GetIncompleteUploadSegsStore, status int) (err error)
- func (t *TidbClient) UpdateMetaDataForSeqWrite(ctx context.Context, blocks *types.FileBlocks, ...) (err error)
- func (t *TidbClient) UpdateMonitorMetrics(ctx context.Context, metric *types.StoreIndexes) (err error)
- func (t *TidbClient) UpdateSegBlockInfo(ctx context.Context, seg *types.UpdateSegBlockInfoStore) (err error)
- func (t *TidbClient) UpdateSegCompletedGc(ctx context.Context, seg *types.GcDeleteSeg) (err error)
- func (t *TidbClient) UpdateSegDeletedSize(ctx context.Context, seg *types.DeleteFileMsg) (err error)
- func (t *TidbClient) UpdateSegInGc(ctx context.Context, segs []*types.DestGcSegment) (err error)
- func (t *TidbClient) UpdateSegZoneAndInfo(ctx context.Context, req *types.UpdateZoneAndInfoReq, tx *sql.Tx) (err error)
Constants ¶
View Source
const MAX_OPEN_CONNS = 8196
Variables ¶
This section is empty.
Functions ¶
func CheckDirHasFilesSql ¶
func CheckDirHasFilesSql() (sqltext string)
func CheckSegAlreadyBeGcSql ¶
func CheckSegAlreadyBeGcSql() (sqltext string)
func CreateGcSegmentInfoSql ¶
func CreateGcSegmentInfoSql() (sqltext string)
func CreateOrUpdateFileLeaderSql ¶
func CreateOrUpdateFileLeaderSql() (sqltext string)
func CreateOrUpdateZoneSql ¶
func CreateOrUpdateZoneSql() (sqltext string)
func CreateSegmentZoneSql ¶
func CreateSegmentZoneSql() (sqltext string)
func DeleteDirSql ¶
func DeleteDirSql() (sqltext string)
func DeleteFileLeaderSql ¶
func DeleteFileLeaderSql() (sqltext string)
func DeleteFileSql ¶
func DeleteFileSql() (sqltext string)
func DeleteSegSql ¶
func DeleteSegSql() (sqltext string)
func DeleteSegmentInfoSql ¶
func DeleteSegmentInfoSql() (sqltext string)
func DeleteSegmentZoneSql ¶
func DeleteSegmentZoneSql() (sqltext string)
func GetAllExistedFileSql ¶
func GetAllExistedFileSql() (sqltext string)
func GetDirFileInfoSql ¶
func GetDirFileInfoSql() (sqltext string)
func GetDirFileInoSql ¶
func GetDirFileInoSql() (sqltext string)
func GetDirInfoSql ¶
func GetDirInfoSql() (sqltext string)
func GetFileExistedSql ¶
func GetFileExistedSql() (sqltext string)
func GetFileInfoSql ¶
func GetFileInfoSql() (sqltext string)
func GetFileSizeSql ¶
func GetFileSizeSql() (sqltext string)
func GetGcMapSegExistedSql ¶
func GetGcMapSegExistedSql() (sqltext string)
func GetGcSegZoneSql ¶
func GetGcSegZoneSql() (sqltext string)
func GetGcSegmentInfoSql ¶
func GetGcSegmentInfoSql() (sqltext string)
func GetGcSegmentZoneSql ¶
func GetGcSegmentZoneSql() (sqltext string)
func GetInsertGcMapSql ¶
func GetLeaderSql ¶
func GetLeaderSql() (sqltext string)
func GetSegAge ¶
func GetSegAge(ctx context.Context, seg *types.GcSegmentInfo, t *TidbClient) (err error)
func GetSegAgeSql ¶
func GetSegAgeSql() (sqltext string)
func GetSegDeletedSizeSql ¶
func GetSegDeletedSizeSql() (sqltext string)
func GetSegExistedSql ¶
func GetSegExistedSql() (sqltext string)
func GetSegmentInfoSql ¶
func GetSegmentLeaderSql ¶
func GetSegmentLeaderSql() (sqltext string)
func GetSegmentZone ¶
func GetSegmentZone(ctx context.Context, seg *types.GcSegmentInfo, t *TidbClient) (err error)
func GetSegmentsByLeaderSql ¶
func GetSegmentsByLeaderSql() (sqltext string)
func GetSegsByGcSql ¶
func GetSegsByGcSql() (sqltext string)
func GetSegsByTimeSql ¶
func GetSegsByTimeSql() (sqltext string)
func GetSegsLeaderSql ¶
func InsertOrUpdateSegInfo ¶
func InsertOrUpdateSegZone ¶
func InsertOrUpdateSegZoneSql ¶
func InsertOrUpdateSegZoneSql() (sqltext string)
func RecoverSegGcStatusSql ¶
func RecoverSegGcStatusSql() (sqltext string)
func SelectFileParentSql ¶
func SelectFileParentSql() (sqltext string)
func UpdateFileSizeSql ¶
func UpdateFileSizeSql() (sqltext string)
func UpdateSegCompletedGcSql ¶
func UpdateSegCompletedGcSql() (sqltext string)
func UpdateSegDeletedSizeSql ¶
func UpdateSegDeletedSizeSql() (sqltext string)
func UpdateSegGcStatusSql ¶
func UpdateSegGcStatusSql() (sqltext string)
func UpdateSegmentInfoSql ¶
func UpdateSegmentInfoSql() (sqltext string)
Types ¶
type TidbClient ¶
func NewTidbClient ¶
func NewTidbClient(tidbInfo string) *TidbClient
func (*TidbClient) CheckAndDeleteGcFile ¶
func (t *TidbClient) CheckAndDeleteGcFile(ctx context.Context, file *types.DeleteFileMsg) (err error)
func (*TidbClient) CheckDirInfo ¶
func (t *TidbClient) CheckDirInfo(ctx context.Context, dir *types.DeleteDirStore) (resp *types.GetDirInfoRet, err error)
func (*TidbClient) CheckFsIsExisted ¶
func (*TidbClient) CheckGcFile ¶
func (t *TidbClient) CheckGcFile(ctx context.Context, file *types.DeleteFileMsg) (isDelete bool, err error)
func (*TidbClient) CheckGcFsHasNoSeg ¶
func (*TidbClient) CheckGcFsIsDeleted ¶
func (*TidbClient) CheckSegExistsInGcFs ¶
func (*TidbClient) CheckSegInGcFs ¶
func (*TidbClient) CheckSegmentIsDeleted ¶
func (*TidbClient) CheckSegsLeader ¶
func (t *TidbClient) CheckSegsLeader(ctx context.Context, segs *types.CheckSegsStore) (segIds []*types.SegmentId, err error)
func (*TidbClient) CheckTheSeg ¶
func (t *TidbClient) CheckTheSeg(ctx context.Context, seg *types.GcDeleteSeg) (isDeleted bool, err error)
func (*TidbClient) CloseFile ¶
func (t *TidbClient) CloseFile(ctx context.Context, file *types.FileTimeStore) (err error)
func (*TidbClient) CreateFile ¶
func (t *TidbClient) CreateFile(ctx context.Context, file *types.CreateFileStore) (err error)
func (*TidbClient) CreateNewFile ¶
func (t *TidbClient) CreateNewFile(ctx context.Context, file *types.CreateFileStore) (ino, generation uint64, ctime, mtime, atime int64, err error)
func (*TidbClient) CreateOrUpdateFileLeader ¶
func (t *TidbClient) CreateOrUpdateFileLeader(ctx context.Context, leader *types.GetLeaderStore) (err error)
func (*TidbClient) CreateOrUpdateZone ¶
func (t *TidbClient) CreateOrUpdateZone(ctx context.Context, zone *types.MountStore) (err error)
func (*TidbClient) DeleteFile ¶
func (t *TidbClient) DeleteFile(ctx context.Context, file *types.DeleteFileStore) (err error)
func (*TidbClient) DeleteFileBlocks ¶
func (t *TidbClient) DeleteFileBlocks(ctx context.Context, req *types.DeleteBlocksInfo, tx *sql.Tx) (err error)
func (*TidbClient) DeleteFileTime ¶
func (t *TidbClient) DeleteFileTime(ctx context.Context, file *types.DeleteFileStore) (err error)
func (*TidbClient) DeleteGcFile ¶
func (t *TidbClient) DeleteGcFile(ctx context.Context, file *types.DeleteFileStore) (err error)
func (*TidbClient) DeleteGcFs ¶
func (t *TidbClient) DeleteGcFs(ctx context.Context, fsid string) (err error)
func (*TidbClient) DeleteGcMapSegs ¶
func (*TidbClient) DeleteLock ¶
func (t *TidbClient) DeleteLock(ctx context.Context, lock *types.LockInfoStore) (err error)
func (*TidbClient) DeleteSegZoneAndInfo ¶
func (t *TidbClient) DeleteSegZoneAndInfo(ctx context.Context, seg *types.GcDeleteSeg) (err error)
func (*TidbClient) DeleteSegsByNewSegId ¶
func (t *TidbClient) DeleteSegsByNewSegId(ctx context.Context, seg *types.GcDeleteSeg) (deleteSegs []string, err error)
func (*TidbClient) GetAllExistedBlocksInfo ¶
func (t *TidbClient) GetAllExistedBlocksInfo(ctx context.Context, seg *types.DestGcSegment) (blocks []*types.GcBlockInfo, gcInfo []*types.GcMigrateInfo, err error)
func (*TidbClient) GetAllExistedFiles ¶
func (t *TidbClient) GetAllExistedFiles(ctx context.Context, checkOffset uint64) (files []*types.FileSizeStore, nextOffset uint64, err error)
func (*TidbClient) GetAllGcFiles ¶
func (t *TidbClient) GetAllGcFiles(ctx context.Context, checkTime int64) (files []*types.DeleteFileStore, nextCheckTime int64, err error)
func (*TidbClient) GetAllGcFs ¶
func (*TidbClient) GetAllIsNotDeletingFsIds ¶
func (t *TidbClient) GetAllIsNotDeletingFsIds(ctx context.Context, checkTime int64) (fsInfos []*types.FsStatusStore, nextCheckTime int64, err error)
func (*TidbClient) GetAndCheckSegsLeader ¶
func (*TidbClient) GetAndCreateSegmentId ¶
func (t *TidbClient) GetAndCreateSegmentId(ctx context.Context) (err error)
func (*TidbClient) GetAndUpdateSegmentId ¶
func (t *TidbClient) GetAndUpdateSegmentId(ctx context.Context) (segId uint64, err error)
func (*TidbClient) GetAvailableSegment ¶
func (t *TidbClient) GetAvailableSegment(ctx context.Context, seg *types.GetSegmentsStore) (resp *types.SegmentInfo, err error)
func (*TidbClient) GetDeletedSegsInfo ¶
func (t *TidbClient) GetDeletedSegsInfo(ctx context.Context, fsId string, segs []*types.GcDeleteSeg) (resp []*types.GcDeleteSeg, err error)
func (*TidbClient) GetDirFileInfo ¶
func (t *TidbClient) GetDirFileInfo(ctx context.Context, file *types.GetDirFileInfoStore) (resp *types.FileInfo, err error)
func (*TidbClient) GetDirLeaderInfo ¶
func (t *TidbClient) GetDirLeaderInfo(ctx context.Context, dir *types.GetDirInfoRet) (err error)
func (*TidbClient) GetDirsAndFiles ¶
func (t *TidbClient) GetDirsAndFiles(ctx context.Context, fsid string, checkIno uint64) (files *types.DirsAndFiles, nextIno uint64, err error)
func (*TidbClient) GetFileInfo ¶
func (t *TidbClient) GetFileInfo(ctx context.Context, file *types.GetFileAttrStore) (resp *types.FileInfo, err error)
func (*TidbClient) GetFileLeaderInfo ¶
func (t *TidbClient) GetFileLeaderInfo(ctx context.Context, leader *types.GetLeaderStore) (resp *types.GetLeaderRet, err error)
func (*TidbClient) GetFileSegs ¶
func (t *TidbClient) GetFileSegs(ctx context.Context, seg *types.GetSegmentsStore) (resp map[interface{}]*types.SegmentInfo, segIds [][2]uint64, nextOffset uint64, err error)
func (*TidbClient) GetFileSize ¶
func (t *TidbClient) GetFileSize(ctx context.Context, file *types.FileSizeStore) (resp *types.FileSizeStore, err error)
func (*TidbClient) GetFileSystemInfo ¶
func (*TidbClient) GetFilesForGcMapTree ¶
func (*TidbClient) GetFsInfoByFsIds ¶
func (*TidbClient) GetFsInfoFromGcFs ¶
func (*TidbClient) GetFsMonitorIndexes ¶
func (*TidbClient) GetFsNameAndUid ¶
func (*TidbClient) GetFsStatus ¶
func (*TidbClient) GetGcCreateSegs ¶
func (t *TidbClient) GetGcCreateSegs(ctx context.Context) (segs []*types.NewGcSegInfo, err error)
func (*TidbClient) GetGcMap ¶
func (t *TidbClient) GetGcMap(ctx context.Context, req *types.GetGcMapReq) (resp map[string][]*types.GetGcMapResp, lastId uint64, err error)
func (*TidbClient) GetGcMapOfSegment ¶
func (t *TidbClient) GetGcMapOfSegment(ctx context.Context, req *types.GetGcMapReq) (resp []*types.GetGcMapResp, lastId uint64, err error)
func (*TidbClient) GetIncompleteUploadSegs ¶
func (t *TidbClient) GetIncompleteUploadSegs(ctx context.Context, segInfo *types.GetIncompleteUploadSegsStore, segs []*types.IncompleteUploadSegInfo) (segsResp []*types.IncompleteUploadSegInfo, err error)
func (*TidbClient) GetMachineInfo ¶
func (t *TidbClient) GetMachineInfo(ctx context.Context, zone *types.GetLeaderStore) (resp *types.GetMachineInfoResp, err error)
func (*TidbClient) GetOneUpMachine ¶
func (t *TidbClient) GetOneUpMachine(ctx context.Context, zone *types.GetLeaderStore) (leader string, err error)
func (*TidbClient) GetParentUGOPerm ¶
func (t *TidbClient) GetParentUGOPerm(ctx context.Context, file *types.FileOrDirInfo) (perm *types.UGOPermission, err error)
func (*TidbClient) GetSegIdsFromFileBlocks ¶
func (*TidbClient) GetSegInfo ¶
func (t *TidbClient) GetSegInfo(ctx context.Context, gcExecuting, gcCompleted int) (segs []*types.GcSegmentInfo, ages []int64, deletedSegs []*types.GcDeleteSeg, gcFsSegs []*types.GcDeleteSeg, err error)
func (*TidbClient) GetSegSize ¶
func (t *TidbClient) GetSegSize(ctx context.Context, seg *types.DestGcSegment) (resp *types.GetSizeResp, err error)
func (*TidbClient) GetSegSizeAndUnitSize ¶
func (t *TidbClient) GetSegSizeAndUnitSize(ctx context.Context, seg *types.DeleteFileMsg) (segSize, unitSize uint64, err error)
func (*TidbClient) GetSegmentInfo ¶
func (t *TidbClient) GetSegmentInfo(ctx context.Context, seg *types.GcDeleteSeg) (segSize, unitSize uint64, err error)
func (*TidbClient) GetSegmentLeader ¶
func (t *TidbClient) GetSegmentLeader(ctx context.Context, segment *types.GetSegLeaderReq) (resp *types.LeaderInfo, err error)
func (*TidbClient) GetSegmentsFromGcMap ¶
func (t *TidbClient) GetSegmentsFromGcMap(ctx context.Context, file *types.FileTime) (segs []*types.FileSegment, err error)
func (*TidbClient) GetSegsAndDeleteFileBlocks ¶
func (t *TidbClient) GetSegsAndDeleteFileBlocks(ctx context.Context, offset uint64, file *types.DeleteFileStore) (segBlocks []*types.SegBlock, nextOffset uint64, err error)
func (*TidbClient) GetSegsBlockInfo ¶
func (t *TidbClient) GetSegsBlockInfo(ctx context.Context, seg *types.GetSegmentsStore, segs map[interface{}]*types.SegmentInfo, segsId [][2]uint64) (err error)
func (*TidbClient) GetSegsByLeader ¶
func (t *TidbClient) GetSegsByLeader(ctx context.Context, seg *types.GetIncompleteUploadSegsStore) (segsResp []*types.IncompleteUploadSegInfo, err error)
func (*TidbClient) GetSegsInfo ¶
func (t *TidbClient) GetSegsInfo(ctx context.Context, file *types.DeleteFileStore, segId *types.SegId) (addrs []uint64, nextOffset uint64, err error)
func (*TidbClient) GetSegsInfoForHeartBeat ¶
func (t *TidbClient) GetSegsInfoForHeartBeat(ctx context.Context, segs *types.CheckSegsStore) (ret []*types.CheckSegsRet, err error)
func (*TidbClient) GetTheSlowestGrowingSeg ¶
func (t *TidbClient) GetTheSlowestGrowingSeg(ctx context.Context, segReq *types.GetSegmentsStore, segIds []*types.IncompleteUploadSegInfo) (isExisted bool, resp *types.SegmentInfo, err error)
func (*TidbClient) GetUGOPerm ¶
func (t *TidbClient) GetUGOPerm(ctx context.Context, file *types.FileOrDirInfo) (perm *types.UGOPermission, err error)
func (*TidbClient) HandleFileDeleted ¶
func (t *TidbClient) HandleFileDeleted(ctx context.Context, file *types.DeleteFileStore) (err error)
func (*TidbClient) HandleFsDeleted ¶
func (t *TidbClient) HandleFsDeleted(ctx context.Context, fsid string) (err error)
func (*TidbClient) HandleMetaDataForDeletedSeg ¶
func (t *TidbClient) HandleMetaDataForDeletedSeg(ctx context.Context, seg *types.DeleteFileMsg, offset uint64, msgBus helper.MsgBusConfig) (nextOffset uint64, deleteDone bool, blockNum int, err error)
func (*TidbClient) InitRootDirs ¶
func (t *TidbClient) InitRootDirs(ctx context.Context, rootDir *types.MountStore) (err error)
func (*TidbClient) InsertGcCreateSegInfo ¶
func (t *TidbClient) InsertGcCreateSegInfo(ctx context.Context, seg *types.NewGcSegment) (err error)
func (*TidbClient) InsertLock ¶
func (t *TidbClient) InsertLock(ctx context.Context, lock *types.LockInfoStore) (err error)
func (*TidbClient) IsFileHasSegments ¶
func (t *TidbClient) IsFileHasSegments(ctx context.Context, seg *types.GetSegmentsStore) (isExisted bool, err error)
func (*TidbClient) IsFileLeaderDown ¶
func (t *TidbClient) IsFileLeaderDown(ctx context.Context, file *types.FileTimeStore) (flag bool, err error)
func (*TidbClient) ListDirFiles ¶
func (t *TidbClient) ListDirFiles(ctx context.Context, dir *types.GetDirFilesStore) (dirFilesResp []*types.DirFileInfoStore, offset uint64, err error)
func (*TidbClient) LockSegment ¶
func (t *TidbClient) LockSegment(ctx context.Context, seg *types.FileSegment) (txn *sql.Tx, err error)
func (*TidbClient) MarkSegInfoAndDelSegZone ¶
func (t *TidbClient) MarkSegInfoAndDelSegZone(ctx context.Context, seg *types.DeleteFileMsg) (err error)
func (*TidbClient) RenameFile ¶
func (t *TidbClient) RenameFile(ctx context.Context, file *types.RenameFileStore) (err error)
func (*TidbClient) SetFileAttr ¶
func (t *TidbClient) SetFileAttr(ctx context.Context, file *types.SetFileAttrStore) (err error)
func (*TidbClient) SetFileSystem ¶
func (*TidbClient) UnlockBlocks ¶
func (*TidbClient) UpdateFileAndSegBlocks ¶
func (t *TidbClient) UpdateFileAndSegBlocks(ctx context.Context, blocks []*types.FileBlockInfo, tx *sql.Tx) (err error)
func (*TidbClient) UpdateFileBlocksNum ¶
func (t *TidbClient) UpdateFileBlocksNum(ctx context.Context, file *types.GetFileAttrStore) (err error)
func (*TidbClient) UpdateFileInfo ¶
func (t *TidbClient) UpdateFileInfo(ctx context.Context, file *types.FileSizeStore) (err error)
func (*TidbClient) UpdateFileOpenTime ¶
func (t *TidbClient) UpdateFileOpenTime(ctx context.Context, file *types.FileTimeStore) (err error)
func (*TidbClient) UpdateFileSize ¶
func (t *TidbClient) UpdateFileSize(ctx context.Context, file *types.FileSizeStore) (err error)
func (*TidbClient) UpdateFsFileNum ¶
func (t *TidbClient) UpdateFsFileNum(ctx context.Context, file *types.FsFileNumStat) (err error)
func (*TidbClient) UpdateFsStatus ¶
func (t *TidbClient) UpdateFsStatus(ctx context.Context, req *types.FsStatusStore) (err error)
func (*TidbClient) UpdateFsUsage ¶
func (t *TidbClient) UpdateFsUsage(ctx context.Context, file *types.FsUsageStat) (err error)
func (*TidbClient) UpdateGcCreateSegs ¶
func (t *TidbClient) UpdateGcCreateSegs(ctx context.Context, segs []*types.NewGcSegInfo) (err error)
func (*TidbClient) UpdateGcSegStatus ¶
func (t *TidbClient) UpdateGcSegStatus(ctx context.Context, seg *types.NewGcSegInfo) (err error)
func (*TidbClient) UpdateGcSegmentInfo ¶
func (t *TidbClient) UpdateGcSegmentInfo(ctx context.Context, blocks map[string][]*types.GcBlockInfo, segId *types.GcSegIdInfo, newSeg *types.NewGcSegment) (deletedSize uint64, err error)
func (*TidbClient) UpdateMachineStatus ¶
func (t *TidbClient) UpdateMachineStatus(ctx context.Context, zone *types.GetIncompleteUploadSegsStore, status int) (err error)
func (*TidbClient) UpdateMetaDataForSeqWrite ¶
func (t *TidbClient) UpdateMetaDataForSeqWrite(ctx context.Context, blocks *types.FileBlocks, zoneAndInfo *types.ZoneAndInfoStore) (err error)
func (*TidbClient) UpdateMonitorMetrics ¶
func (t *TidbClient) UpdateMonitorMetrics(ctx context.Context, metric *types.StoreIndexes) (err error)
func (*TidbClient) UpdateSegBlockInfo ¶
func (t *TidbClient) UpdateSegBlockInfo(ctx context.Context, seg *types.UpdateSegBlockInfoStore) (err error)
func (*TidbClient) UpdateSegCompletedGc ¶
func (t *TidbClient) UpdateSegCompletedGc(ctx context.Context, seg *types.GcDeleteSeg) (err error)
func (*TidbClient) UpdateSegDeletedSize ¶
func (t *TidbClient) UpdateSegDeletedSize(ctx context.Context, seg *types.DeleteFileMsg) (err error)
func (*TidbClient) UpdateSegInGc ¶
func (t *TidbClient) UpdateSegInGc(ctx context.Context, segs []*types.DestGcSegment) (err error)
func (*TidbClient) UpdateSegZoneAndInfo ¶
func (t *TidbClient) UpdateSegZoneAndInfo(ctx context.Context, req *types.UpdateZoneAndInfoReq, tx *sql.Tx) (err error)
Click to show internal directories.
Click to hide internal directories.