gfsptask

package

v0.2.3-alpha.10 Latest Latest Go to latest Published: Jul 25, 2023 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bnb-chain/greenfield-storage-provider

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, account string, visibility int32) task.TKey
func GfSpCreateObjectApprovalTaskKey(bucket, object string, account string, visibility int32) 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 GfSpMigrateBucketApprovalTaskKey(bucket string, migrateBucketHash string) task.TKey
func GfSpMigrateGVGTaskKey(gvgID uint32, bucketID uint64, redundancyIndex int32) task.TKey
func GfSpMigratePieceTaskKey(object, id string, redundancyIdx uint32, ecIdx int32) task.TKey
func GfSpReceivePieceTaskKey(bucket, object, id string, rIdx uint32, pIdx int32) task.TKey
func GfSpRecoverPieceTaskKey(bucket, object, id string, pIdx uint32, replicateIdx int32, time int64) task.TKey
func GfSpReplicatePieceApprovalTaskKey(bucket, object, id string) task.TKey
func GfSpReplicatePieceTaskKey(bucket, object, id string) task.TKey
func GfSpResumableUploadObjectTaskKey(bucket, object, id string, offset uint64) 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 ¶

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(gvgID 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.

Source Files ¶

View all Source files

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