gfsptask

package
v0.2.3-alpha.11 Latest Latest
Warning

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

Go to latest
Published: Jul 25, 2023 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Delimiter                               = "-"
	KeyPrefixGfSpCreateBucketApprovalTask   = "CreateBucketApproval"
	KeyPrefixGfSpMigrateBucketApprovalTask  = "MigrateBucketApproval"
	KeyPrefixGfSpCreateObjectApprovalTask   = "CreateObjectApproval"
	KeyPrefixGfSpReplicatePieceApprovalTask = "ReplicatePieceApproval"
	KeyPrefixGfSpDownloadObjectTask         = "DownloadObject"
	KeyPrefixGfSpDownloadPieceTask          = "DownloadPiece"
	KeyPrefixGfSpChallengeTask              = "ChallengePiece"
	KeyPrefixGfSpUploadObjectTask           = "Uploading"
	KeyPrefixGfSpReplicatePieceTask         = "Uploading"
	KeyPrefixGfSpSealObjectTask             = "Uploading"
	KeyPrefixGfSpResumableUploadObjectTask  = "ResumableUploading"
	KeyPrefixGfSpRecoverPieceTask           = "Recovering"
	KeyPrefixGfSpReceivePieceTask           = "ReceivePiece"
	KeyPrefixGfSpGCObjectTask               = "GCObject"
	KeyPrefixGfSpGCZombiePieceTask          = "GCZombiePiece"
	KeyPrefixGfSpGfSpGCMetaTask             = "GCMeta"
	KeyPrefixGfSpMigrateGVGTask             = "MigrateGVG"
	KeyPrefixGfSpMigratePieceTask           = "MigratePiece"
)

Variables

View Source
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)

Functions

func CombineKey

func CombineKey(field ...string) string

func GfSpChallengePieceTaskKey

func GfSpChallengePieceTaskKey(bucket, object, id string, sIdx uint32, rIdx int32, user string) task.TKey

func GfSpCreateBucketApprovalTaskKey

func GfSpCreateBucketApprovalTaskKey(bucket string, account string, visibility int32) task.TKey

func GfSpCreateObjectApprovalTaskKey

func GfSpCreateObjectApprovalTaskKey(bucket, object string, account string, visibility int32) task.TKey

func GfSpDownloadObjectTaskKey

func GfSpDownloadObjectTaskKey(bucket, object, id string, low, high int64) task.TKey

func GfSpDownloadPieceTaskKey

func GfSpDownloadPieceTaskKey(bucket, object, pieceKey string, pieceOffset, pieceLength uint64) task.TKey

func GfSpGCObjectTaskKey

func GfSpGCObjectTaskKey(start, end uint64, time int64) task.TKey

func GfSpGCZombiePieceTaskKey

func GfSpGCZombiePieceTaskKey(time int64) task.TKey

func GfSpGfSpGCMetaTaskKey

func GfSpGfSpGCMetaTaskKey(time int64) task.TKey

func GfSpMigrateBucketApprovalTaskKey added in v0.2.3

func GfSpMigrateBucketApprovalTaskKey(bucket string, migrateBucketHash string) task.TKey

func GfSpMigrateGVGTaskKey added in v0.2.3

func GfSpMigrateGVGTaskKey(oldGvgID uint32, bucketID uint64, redundancyIndex int32) task.TKey

func GfSpMigratePieceTaskKey added in v0.2.3

func GfSpMigratePieceTaskKey(object, id string, redundancyIdx uint32, ecIdx int32) task.TKey

func GfSpReceivePieceTaskKey

func GfSpReceivePieceTaskKey(bucket, object, id string, rIdx uint32, pIdx int32) task.TKey

func GfSpRecoverPieceTaskKey added in v0.2.3

func GfSpRecoverPieceTaskKey(bucket, object, id string, pIdx uint32, replicateIdx int32, time int64) task.TKey

func GfSpReplicatePieceApprovalTaskKey

func GfSpReplicatePieceApprovalTaskKey(bucket, object, id string) task.TKey

func GfSpReplicatePieceTaskKey

func GfSpReplicatePieceTaskKey(bucket, object, id string) task.TKey

func GfSpResumableUploadObjectTaskKey added in v0.2.3

func GfSpResumableUploadObjectTaskKey(bucket, object, id string, offset uint64) task.TKey

func GfSpSealObjectTaskKey

func GfSpSealObjectTaskKey(bucket, object, id string) task.TKey

func GfSpUploadObjectTaskKey

func GfSpUploadObjectTaskKey(bucket, object, id string) task.TKey

func LimitEstimateByPriority

func LimitEstimateByPriority(priority coretask.TPriority) rcmgr.Limit

func RegisterCodec

func RegisterCodec(cdc *codec.LegacyAmino)

Types

This section is empty.

Jump to

Keyboard shortcuts

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