tidbclient

package
v0.0.0-...-c2c101f Latest Latest
Warning

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

Go to latest
Published: Sep 30, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

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 GetInsertGcMapSql(num int) (sqltext string)

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 GetSegmentInfoSql(maxNum int) (sqltext string)

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 GetSegsLeaderSql(maxNum int) (sqltext string)

func InsertOrUpdateSegInfo

func InsertOrUpdateSegInfo(ctx context.Context, seg *types.NewGcSegment, sqlTx *sql.Tx) (err error)

func InsertOrUpdateSegZone

func InsertOrUpdateSegZone(ctx context.Context, newSeg *types.NewGcSegment, sqlTx *sql.Tx) (err error)

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

type TidbClient struct {
	Client *sql.DB
}

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 (t *TidbClient) CheckFsIsExisted(ctx context.Context, fsid string) (flag bool, err error)

func (*TidbClient) CheckGcFile

func (t *TidbClient) CheckGcFile(ctx context.Context, file *types.DeleteFileMsg) (isDelete bool, err error)

func (*TidbClient) CheckGcFs

func (t *TidbClient) CheckGcFs(ctx context.Context, fsid string) (isDelete bool, err error)

func (*TidbClient) CheckGcFsHasNoSeg

func (t *TidbClient) CheckGcFsHasNoSeg(ctx context.Context, fsid string) (flag bool, err error)

func (*TidbClient) CheckGcFsIsDeleted

func (t *TidbClient) CheckGcFsIsDeleted(ctx context.Context, fsid string) (flag bool, err error)

func (*TidbClient) CheckSegExistsInGcFs

func (t *TidbClient) CheckSegExistsInGcFs(ctx context.Context, fsid string) (flag bool, err error)

func (*TidbClient) CheckSegInGcFs

func (t *TidbClient) CheckSegInGcFs(ctx context.Context, fsid string, segId0, segId1 uint64) (flag bool, segSize, unitSize uint64, err error)

func (*TidbClient) CheckSegmentIsDeleted

func (t *TidbClient) CheckSegmentIsDeleted(ctx context.Context, fsid string, segId0, segId1 uint64) (flag bool, segSize, unitSize uint64, err error)

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 (t *TidbClient) DeleteGcMapSegs(ctx context.Context, segs map[string][]int) (err error)

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 (t *TidbClient) GetAllGcFs(ctx context.Context, checkTime int64) (fsids []string, nextCheckTime int64, err error)

func (*TidbClient) GetAllIsNotDeletingFsIds

func (t *TidbClient) GetAllIsNotDeletingFsIds(ctx context.Context, checkTime int64) (fsInfos []*types.FsStatusStore, nextCheckTime int64, err error)

func (*TidbClient) GetAndCheckSegsLeader

func (t *TidbClient) GetAndCheckSegsLeader(ctx context.Context, fsid, zoneId, machine string, segs []*types.SegmentId) (err error)

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 (t *TidbClient) GetFileSystemInfo(ctx context.Context, fsId string) (resp *types.StoreInfo, err error)

func (*TidbClient) GetFilesForGcMapTree

func (t *TidbClient) GetFilesForGcMapTree(ctx context.Context, offset uint64) (files []*types.FileTime, err error)

func (*TidbClient) GetFsInfoByFsIds

func (t *TidbClient) GetFsInfoByFsIds(ctx context.Context, fsids []string) (fsInfo []*types.FsInfo, err error)

func (*TidbClient) GetFsInfoFromGcFs

func (t *TidbClient) GetFsInfoFromGcFs(ctx context.Context, fsId string) (resp *types.StoreInfo, err error)

func (*TidbClient) GetFsMonitorIndexes

func (t *TidbClient) GetFsMonitorIndexes(ctx context.Context, fsid string) (indexes []*types.FsIndex, err error)

func (*TidbClient) GetFsNameAndUid

func (t *TidbClient) GetFsNameAndUid(ctx context.Context, fsid string) (fsName string, uid int, err error)

func (*TidbClient) GetFsStatus

func (t *TidbClient) GetFsStatus(ctx context.Context, fsid string) (status int, err error)

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 (t *TidbClient) GetSegIdsFromFileBlocks(ctx context.Context, file *types.FileIno, offset uint64) (segIds map[[2]uint64]struct{}, nextOffset uint64, blockNum int, err error)

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 (t *TidbClient) SetFileSystem(ctx context.Context, store *types.StoreInfo, fsCapacity uint64) (err error)

func (*TidbClient) UnlockBlocks

func (t *TidbClient) UnlockBlocks(ctx context.Context, tx *sql.Tx) (err error)

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL