gfsptask

package
v0.2.3-test.23 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	Delimiter                               = "-"
	KeyPrefixGfSpCreateBucketApprovalTask   = "CreateBucketApproval"
	KeyPrefixGfSpCreateObjectApprovalTask   = "CreateObjectApproval"
	KeyPrefixGfSpReplicatePieceApprovalTask = "ReplicatePieceApproval"
	KeyPrefixGfSpDownloadObjectTask         = "DownloadObject"
	KeyPrefixGfSpDownloadPieceTask          = "DownloadPiece"
	KeyPrefixGfSpChallengeTask              = "ChallengePiece"
	KeyPrefixGfSpUploadObjectTask           = "Uploading"
	KeyPrefixGfSpReplicatePieceTask         = "Uploading"
	KeyPrefixGfSpSealObjectTask             = "Uploading"
	KeyPrefixGfSpResumableUploadObjectTask  = "ResuabmleUploading"
	KeyPrefixGfSpRecoverPieceTask           = "Recovering"
	KeyPrefixGfSpReceivePieceTask           = "ReceivePiece"
)

Variables

View Source
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)
View Source
var (
	KeyPrefixGfSpGCObjectTask      = strings.ToLower("GCObject")
	KeyPrefixGfSpGCZombiePieceTask = strings.ToLower("GCZombiePiece")
	KeyPrefixGfSpGfSpGCMetaTask    = strings.ToLower("GCMeta")
)

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 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