gfsptask

Documentation

Index

• Constants
• Variables
• func CombineKey(field ...string) string
• func GfSpChallengePieceTaskKey(bucket, object, id string, sIdx uint32, rIdx int32, user string) task.TKey
• func GfSpCreateBucketApprovalTaskKey(bucket string) task.TKey
• func GfSpCreateObjectApprovalTaskKey(bucket, object string) task.TKey
• func GfSpDownloadObjectTaskKey(bucket, object, id string, low, high int64) task.TKey
• func GfSpDownloadPieceTaskKey(bucket, object, pieceKey string, pieceOffset, pieceLength uint64) task.TKey
• func GfSpGCObjectTaskKey(start, end uint64, time int64) task.TKey
• func GfSpGCZombiePieceTaskKey(time int64) task.TKey
• func GfSpGfSpGCMetaTaskKey(time int64) task.TKey
• func GfSpReceivePieceTaskKey(bucket, object, id string, rIdx uint32, pIdx int32) task.TKey
• func GfSpReplicatePieceApprovalTaskKey(bucket, object, id string) task.TKey
• func GfSpReplicatePieceTaskKey(bucket, object, id string) task.TKey
• func GfSpSealObjectTaskKey(bucket, object, id string) task.TKey
• func GfSpUploadObjectTaskKey(bucket, object, id string) task.TKey
• func LimitEstimateByPriority(priority coretask.TPriority) rcmgr.Limit
• func RegisterCodec(cdc *codec.LegacyAmino)

Constants

const (
	Delimiter                               = "-"
	KeyPrefixGfSpCreateBucketApprovalTask   = "CreateBucketApproval"
	KeyPrefixGfSpCreateObjectApprovalTask   = "CreateObjectApproval"
	KeyPrefixGfSpReplicatePieceApprovalTask = "ReplicatePieceApproval"
	KeyPrefixGfSpDownloadObjectTask         = "DownloadObject"
	KeyPrefixGfSpDownloadPieceTask          = "DownloadPiece"
	KeyPrefixGfSpChallengeTask              = "ChallengePiece"
	KeyPrefixGfSpUploadObjectTask           = "Uploading"
	KeyPrefixGfSpReplicatePieceTask         = "Replicating"
	KeyPrefixGfSpSealObjectTask             = "Sealing"
	KeyPrefixGfSpReceivePieceTask           = "ReceivePiece"
)

Variables

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

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) task.TKey

func GfSpCreateObjectApprovalTaskKey

func GfSpCreateObjectApprovalTaskKey(bucket, object string) 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 GfSpReplicatePieceApprovalTaskKey

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

func GfSpReplicatePieceTaskKey

func GfSpReplicatePieceTaskKey(bucket, object, id string) 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)