gfsptask

package
v1.7.1 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: GPL-3.0 Imports: 18 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"
	KeyPrefixGfSpGCStaleVersionObjectTask   = "GCStaleVersionObject"
	KeyPrefixGfSpGfSpGCMetaTask             = "GCMeta"
	KeyPrefixGfSpGCBucketMigrationTask      = "GCBucketMigration"
	KeyPrefixGfSpMigrateBucketTask          = "MigrateBucket"
	KeyPrefixGfSpMigrateGVGTask             = "MigrateGVG"
	KeyPrefixGfSpMigratePieceTask           = "MigratePiece"
)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)
View Source 
var (
	ErrInvalidLengthTask        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTask = fmt.Errorf("proto: unexpected end of group")
)

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, fingerprint []byte) task.TKey

func GfSpCreateObjectApprovalTaskKey 

func GfSpCreateObjectApprovalTaskKey(bucket, object string, account string, fingerprint []byte) 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 GfSpGCBucketMigrationTaskKey added in v1.2.0 

func GfSpGCBucketMigrationTaskKey(bucketID uint64) task.TKey

func GfSpGCObjectTaskKey 

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

func GfSpGCStaleVersionObjectTaskKey added in v1.5.0 

func GfSpGCStaleVersionObjectTaskKey(objectID uint64, redundancyIndex int32, version, time int64) task.TKey

func GfSpGCZombiePieceTaskKey 

func GfSpGCZombiePieceTaskKey(start, end uint64, 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 GfSpMigrateBucketTaskKey added in v1.1.0 

func GfSpMigrateBucketTaskKey(bucketID uint64) 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) 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

type GfSpBucketMigrationInfo added in v1.1.0 

type GfSpBucketMigrationInfo struct {
	BucketId uint64 `protobuf:"varint,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	// whether the migrate bucket succeed
	Finished bool `protobuf:"varint,2,opt,name=finished,proto3" json:"finished,omitempty"`
	// total migrated bytes
	MigratedBytesSize uint64                  `protobuf:"varint,3,opt,name=migrated_bytes_size,json=migratedBytesSize,proto3" json:"migrated_bytes_size,omitempty"`
	DestSp            *types2.StorageProvider `protobuf:"bytes,4,opt,name=dest_sp,json=destSp,proto3" json:"dest_sp,omitempty"`
	SrcSp             *types2.StorageProvider `protobuf:"bytes,5,opt,name=src_sp,json=srcSp,proto3" json:"src_sp,omitempty"`
	ExpireTime        int64                   `protobuf:"varint,6,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	Signature         []byte                  `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*GfSpBucketMigrationInfo) Descriptor added in v1.1.0 

func (*GfSpBucketMigrationInfo) Descriptor() ([]byte, []int)

func (*GfSpBucketMigrationInfo) GetBucketId added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetBucketId() uint64

func (*GfSpBucketMigrationInfo) GetDestSp added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetDestSp() *types2.StorageProvider

func (*GfSpBucketMigrationInfo) GetExpireTime added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetExpireTime() int64

func (*GfSpBucketMigrationInfo) GetFinished added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetFinished() bool

func (*GfSpBucketMigrationInfo) GetMigratedBytesSize added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetMigratedBytesSize() uint64

func (*GfSpBucketMigrationInfo) GetSignBytes added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetSignBytes() []byte

func (*GfSpBucketMigrationInfo) GetSignature added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetSignature() []byte

func (*GfSpBucketMigrationInfo) GetSrcSp added in v1.1.0 

func (m *GfSpBucketMigrationInfo) GetSrcSp() *types2.StorageProvider

func (*GfSpBucketMigrationInfo) Info added in v1.1.0 

func (m *GfSpBucketMigrationInfo) Info() string

func (*GfSpBucketMigrationInfo) Key added in v1.1.0 

func (m *GfSpBucketMigrationInfo) Key() coretask.TKey

func (*GfSpBucketMigrationInfo) Marshal added in v1.1.0 

func (m *GfSpBucketMigrationInfo) Marshal() (dAtA []byte, err error)

func (*GfSpBucketMigrationInfo) MarshalTo added in v1.1.0 

func (m *GfSpBucketMigrationInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpBucketMigrationInfo) MarshalToSizedBuffer added in v1.1.0 

func (m *GfSpBucketMigrationInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpBucketMigrationInfo) ProtoMessage added in v1.1.0 

func (*GfSpBucketMigrationInfo) ProtoMessage()

func (*GfSpBucketMigrationInfo) Reset added in v1.1.0 

func (m *GfSpBucketMigrationInfo) Reset()

func (*GfSpBucketMigrationInfo) SetSignature added in v1.1.0 

func (m *GfSpBucketMigrationInfo) SetSignature(signature []byte)

func (*GfSpBucketMigrationInfo) Size added in v1.1.0 

func (m *GfSpBucketMigrationInfo) Size() (n int)

func (*GfSpBucketMigrationInfo) String added in v1.1.0 

func (m *GfSpBucketMigrationInfo) String() string

func (*GfSpBucketMigrationInfo) Unmarshal added in v1.1.0 

func (m *GfSpBucketMigrationInfo) Unmarshal(dAtA []byte) error

func (*GfSpBucketMigrationInfo) XXX_DiscardUnknown added in v1.1.0 

func (m *GfSpBucketMigrationInfo) XXX_DiscardUnknown()

func (*GfSpBucketMigrationInfo) XXX_Marshal added in v1.1.0 

func (m *GfSpBucketMigrationInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpBucketMigrationInfo) XXX_Merge added in v1.1.0 

func (m *GfSpBucketMigrationInfo) XXX_Merge(src proto.Message)

func (*GfSpBucketMigrationInfo) XXX_Size added in v1.1.0 

func (m *GfSpBucketMigrationInfo) XXX_Size() int

func (*GfSpBucketMigrationInfo) XXX_Unmarshal added in v1.1.0 

func (m *GfSpBucketMigrationInfo) XXX_Unmarshal(b []byte) error

type GfSpBucketQuotaInfo added in v1.1.0 

type GfSpBucketQuotaInfo struct {
	BucketId   uint64 `protobuf:"varint,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	Month      string `protobuf:"bytes,2,opt,name=month,proto3" json:"month,omitempty"`
	BucketName string `protobuf:"bytes,3,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// the consumed chargedQuota of this month
	ReadConsumedSize uint64 `protobuf:"varint,4,opt,name=read_consumed_size,json=readConsumedSize,proto3" json:"read_consumed_size,omitempty"`
	// the consumed free quota size of this month
	FreeQuotaConsumedSize uint64 `` /* 129-byte string literal not displayed */
	// the remained free quota
	FreeQuotaSize uint64 `protobuf:"varint,6,opt,name=free_quota_size,json=freeQuotaSize,proto3" json:"free_quota_size,omitempty"`
	// the greenfield chain bucket charged quota
	ChargedQuotaSize uint64 `protobuf:"varint,7,opt,name=charged_quota_size,json=chargedQuotaSize,proto3" json:"charged_quota_size,omitempty"`
	// used to check if the src sp has enough quota to execute bucket migration
	AllowMigrate bool `protobuf:"varint,8,opt,name=allow_migrate,json=allowMigrate,proto3" json:"allow_migrate,omitempty"`
	// the remained monthly free quota
	MonthlyFreeQuotaSize uint64 `` /* 126-byte string literal not displayed */
	// the consumed monthly free quota size of this month
	MonthlyFreeQuotaConsumedSize uint64 `` /* 153-byte string literal not displayed */
}

func (*GfSpBucketQuotaInfo) Descriptor added in v1.1.0 

func (*GfSpBucketQuotaInfo) Descriptor() ([]byte, []int)

func (*GfSpBucketQuotaInfo) GetAllowMigrate added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetAllowMigrate() bool

func (*GfSpBucketQuotaInfo) GetBucketId added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetBucketId() uint64

func (*GfSpBucketQuotaInfo) GetBucketName added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetBucketName() string

func (*GfSpBucketQuotaInfo) GetChargedQuotaSize added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetChargedQuotaSize() uint64

func (*GfSpBucketQuotaInfo) GetFreeQuotaConsumedSize added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetFreeQuotaConsumedSize() uint64

func (*GfSpBucketQuotaInfo) GetFreeQuotaSize added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetFreeQuotaSize() uint64

func (*GfSpBucketQuotaInfo) GetMonth added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetMonth() string

func (*GfSpBucketQuotaInfo) GetMonthlyFreeQuotaConsumedSize added in v1.6.0 

func (m *GfSpBucketQuotaInfo) GetMonthlyFreeQuotaConsumedSize() uint64

func (*GfSpBucketQuotaInfo) GetMonthlyFreeQuotaSize added in v1.6.0 

func (m *GfSpBucketQuotaInfo) GetMonthlyFreeQuotaSize() uint64

func (*GfSpBucketQuotaInfo) GetReadConsumedSize added in v1.1.0 

func (m *GfSpBucketQuotaInfo) GetReadConsumedSize() uint64

func (*GfSpBucketQuotaInfo) Marshal added in v1.1.0 

func (m *GfSpBucketQuotaInfo) Marshal() (dAtA []byte, err error)

func (*GfSpBucketQuotaInfo) MarshalTo added in v1.1.0 

func (m *GfSpBucketQuotaInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpBucketQuotaInfo) MarshalToSizedBuffer added in v1.1.0 

func (m *GfSpBucketQuotaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpBucketQuotaInfo) ProtoMessage added in v1.1.0 

func (*GfSpBucketQuotaInfo) ProtoMessage()

func (*GfSpBucketQuotaInfo) Reset added in v1.1.0 

func (m *GfSpBucketQuotaInfo) Reset()

func (*GfSpBucketQuotaInfo) Size added in v1.1.0 

func (m *GfSpBucketQuotaInfo) Size() (n int)

func (*GfSpBucketQuotaInfo) String added in v1.1.0 

func (m *GfSpBucketQuotaInfo) String() string

func (*GfSpBucketQuotaInfo) Unmarshal added in v1.1.0 

func (m *GfSpBucketQuotaInfo) Unmarshal(dAtA []byte) error

func (*GfSpBucketQuotaInfo) XXX_DiscardUnknown added in v1.1.0 

func (m *GfSpBucketQuotaInfo) XXX_DiscardUnknown()

func (*GfSpBucketQuotaInfo) XXX_Marshal added in v1.1.0 

func (m *GfSpBucketQuotaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpBucketQuotaInfo) XXX_Merge added in v1.1.0 

func (m *GfSpBucketQuotaInfo) XXX_Merge(src proto.Message)

func (*GfSpBucketQuotaInfo) XXX_Size added in v1.1.0 

func (m *GfSpBucketQuotaInfo) XXX_Size() int

func (*GfSpBucketQuotaInfo) XXX_Unmarshal added in v1.1.0 

func (m *GfSpBucketQuotaInfo) XXX_Unmarshal(b []byte) error

type GfSpChallengePieceTask added in v0.2.4 

type GfSpChallengePieceTask struct {
	Task          *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo    *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	BucketInfo    *types.BucketInfo `protobuf:"bytes,3,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
	StorageParams *types.Params     `protobuf:"bytes,4,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	SegmentIdx    uint32            `protobuf:"varint,5,opt,name=segment_idx,json=segmentIdx,proto3" json:"segment_idx,omitempty"`
	RedundancyIdx int32             `protobuf:"varint,6,opt,name=redundancy_idx,json=redundancyIdx,proto3" json:"redundancy_idx,omitempty"`
	IntegrityHash []byte            `protobuf:"bytes,7,opt,name=integrity_hash,json=integrityHash,proto3" json:"integrity_hash,omitempty"`
	PieceHash     [][]byte          `protobuf:"bytes,8,rep,name=piece_hash,json=pieceHash,proto3" json:"piece_hash,omitempty"`
	PieceDataSize int64             `protobuf:"varint,9,opt,name=piece_data_size,json=pieceDataSize,proto3" json:"piece_data_size,omitempty"`
}

func (*GfSpChallengePieceTask) AppendLog added in v0.2.4 

func (m *GfSpChallengePieceTask) AppendLog(log string)

func (*GfSpChallengePieceTask) Descriptor added in v0.2.4 

func (*GfSpChallengePieceTask) Descriptor() ([]byte, []int)

func (*GfSpChallengePieceTask) Error added in v0.2.4 

func (m *GfSpChallengePieceTask) Error() error

func (*GfSpChallengePieceTask) EstimateLimit added in v0.2.4 

func (m *GfSpChallengePieceTask) EstimateLimit() corercmgr.Limit

func (*GfSpChallengePieceTask) ExceedRetry added in v0.2.4 

func (m *GfSpChallengePieceTask) ExceedRetry() bool

func (*GfSpChallengePieceTask) ExceedTimeout added in v0.2.4 

func (m *GfSpChallengePieceTask) ExceedTimeout() bool

func (*GfSpChallengePieceTask) Expired added in v0.2.4 

func (m *GfSpChallengePieceTask) Expired() bool

func (*GfSpChallengePieceTask) GetAddress added in v0.2.4 

func (m *GfSpChallengePieceTask) GetAddress() string

func (*GfSpChallengePieceTask) GetBucketInfo added in v0.2.4 

func (m *GfSpChallengePieceTask) GetBucketInfo() *types.BucketInfo

func (*GfSpChallengePieceTask) GetCreateTime added in v0.2.4 

func (m *GfSpChallengePieceTask) GetCreateTime() int64

func (*GfSpChallengePieceTask) GetIntegrityHash added in v0.2.4 

func (m *GfSpChallengePieceTask) GetIntegrityHash() []byte

func (*GfSpChallengePieceTask) GetLogs added in v0.2.4 

func (m *GfSpChallengePieceTask) GetLogs() string

func (*GfSpChallengePieceTask) GetMaxRetry added in v0.2.4 

func (m *GfSpChallengePieceTask) GetMaxRetry() int64

func (*GfSpChallengePieceTask) GetObjectInfo added in v0.2.4 

func (m *GfSpChallengePieceTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpChallengePieceTask) GetPieceDataSize added in v0.2.4 

func (m *GfSpChallengePieceTask) GetPieceDataSize() int64

func (*GfSpChallengePieceTask) GetPieceHash added in v0.2.4 

func (m *GfSpChallengePieceTask) GetPieceHash() [][]byte

func (*GfSpChallengePieceTask) GetPriority added in v0.2.4 

func (m *GfSpChallengePieceTask) GetPriority() coretask.TPriority

func (*GfSpChallengePieceTask) GetRedundancyIdx added in v0.2.4 

func (m *GfSpChallengePieceTask) GetRedundancyIdx() int32

func (*GfSpChallengePieceTask) GetRetry added in v0.2.4 

func (m *GfSpChallengePieceTask) GetRetry() int64

func (*GfSpChallengePieceTask) GetSegmentIdx added in v0.2.4 

func (m *GfSpChallengePieceTask) GetSegmentIdx() uint32

func (*GfSpChallengePieceTask) GetStorageParams added in v0.2.4 

func (m *GfSpChallengePieceTask) GetStorageParams() *types.Params

func (*GfSpChallengePieceTask) GetTask added in v0.2.4 

func (m *GfSpChallengePieceTask) GetTask() *GfSpTask

func (*GfSpChallengePieceTask) GetTimeout added in v0.2.4 

func (m *GfSpChallengePieceTask) GetTimeout() int64

func (*GfSpChallengePieceTask) GetUpdateTime added in v0.2.4 

func (m *GfSpChallengePieceTask) GetUpdateTime() int64

func (*GfSpChallengePieceTask) GetUserAddress added in v0.2.4 

func (m *GfSpChallengePieceTask) GetUserAddress() string

func (*GfSpChallengePieceTask) IncRetry added in v0.2.4 

func (m *GfSpChallengePieceTask) IncRetry()

func (*GfSpChallengePieceTask) Info added in v0.2.4 

func (m *GfSpChallengePieceTask) Info() string

func (*GfSpChallengePieceTask) InitChallengePieceTask added in v0.2.4 

func (m *GfSpChallengePieceTask) InitChallengePieceTask(object *storagetypes.ObjectInfo, bucket *storagetypes.BucketInfo,
	params *storagetypes.Params, priority coretask.TPriority, userAddress string, replicateIdx int32, segmentIdx uint32,
	timeout int64, retry int64)

func (*GfSpChallengePieceTask) Key added in v0.2.4 

func (m *GfSpChallengePieceTask) Key() coretask.TKey

func (*GfSpChallengePieceTask) Marshal added in v0.2.4 

func (m *GfSpChallengePieceTask) Marshal() (dAtA []byte, err error)

func (*GfSpChallengePieceTask) MarshalTo added in v0.2.4 

func (m *GfSpChallengePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpChallengePieceTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpChallengePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpChallengePieceTask) ProtoMessage added in v0.2.4 

func (*GfSpChallengePieceTask) ProtoMessage()

func (*GfSpChallengePieceTask) Reset added in v0.2.4 

func (m *GfSpChallengePieceTask) Reset()

func (*GfSpChallengePieceTask) SetAddress added in v0.2.4 

func (m *GfSpChallengePieceTask) SetAddress(address string)

func (*GfSpChallengePieceTask) SetBucketInfo added in v0.2.4 

func (m *GfSpChallengePieceTask) SetBucketInfo(bucket *storagetypes.BucketInfo)

func (*GfSpChallengePieceTask) SetCreateTime added in v0.2.4 

func (m *GfSpChallengePieceTask) SetCreateTime(time int64)

func (*GfSpChallengePieceTask) SetError added in v0.2.4 

func (m *GfSpChallengePieceTask) SetError(err error)

func (*GfSpChallengePieceTask) SetIntegrityHash added in v0.2.4 

func (m *GfSpChallengePieceTask) SetIntegrityHash(checksum []byte)

func (*GfSpChallengePieceTask) SetLogs added in v0.2.4 

func (m *GfSpChallengePieceTask) SetLogs(logs string)

func (*GfSpChallengePieceTask) SetMaxRetry added in v0.2.4 

func (m *GfSpChallengePieceTask) SetMaxRetry(limit int64)

func (*GfSpChallengePieceTask) SetObjectInfo added in v0.2.4 

func (m *GfSpChallengePieceTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpChallengePieceTask) SetPieceDataSize added in v0.2.4 

func (m *GfSpChallengePieceTask) SetPieceDataSize(size int64)

func (*GfSpChallengePieceTask) SetPieceHash added in v0.2.4 

func (m *GfSpChallengePieceTask) SetPieceHash(checksums [][]byte)

func (*GfSpChallengePieceTask) SetPriority added in v0.2.4 

func (m *GfSpChallengePieceTask) SetPriority(priority coretask.TPriority)

func (*GfSpChallengePieceTask) SetRedundancyIdx added in v0.2.4 

func (m *GfSpChallengePieceTask) SetRedundancyIdx(idx int32)

func (*GfSpChallengePieceTask) SetRetry added in v0.2.4 

func (m *GfSpChallengePieceTask) SetRetry(retry int64)

func (*GfSpChallengePieceTask) SetSegmentIdx added in v0.2.4 

func (m *GfSpChallengePieceTask) SetSegmentIdx(idx uint32)

func (*GfSpChallengePieceTask) SetStorageParams added in v0.2.4 

func (m *GfSpChallengePieceTask) SetStorageParams(params *storagetypes.Params)

func (*GfSpChallengePieceTask) SetTimeout added in v0.2.4 

func (m *GfSpChallengePieceTask) SetTimeout(time int64)

func (*GfSpChallengePieceTask) SetUpdateTime added in v0.2.4 

func (m *GfSpChallengePieceTask) SetUpdateTime(time int64)

func (*GfSpChallengePieceTask) SetUserAddress added in v0.2.4 

func (m *GfSpChallengePieceTask) SetUserAddress(address string)

func (*GfSpChallengePieceTask) Size added in v0.2.4 

func (m *GfSpChallengePieceTask) Size() (n int)

func (*GfSpChallengePieceTask) String added in v0.2.4 

func (m *GfSpChallengePieceTask) String() string

func (*GfSpChallengePieceTask) Type added in v0.2.4 

func (m *GfSpChallengePieceTask) Type() coretask.TType

func (*GfSpChallengePieceTask) Unmarshal added in v0.2.4 

func (m *GfSpChallengePieceTask) Unmarshal(dAtA []byte) error

func (*GfSpChallengePieceTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpChallengePieceTask) XXX_DiscardUnknown()

func (*GfSpChallengePieceTask) XXX_Marshal added in v0.2.4 

func (m *GfSpChallengePieceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpChallengePieceTask) XXX_Merge added in v0.2.4 

func (m *GfSpChallengePieceTask) XXX_Merge(src proto.Message)

func (*GfSpChallengePieceTask) XXX_Size added in v0.2.4 

func (m *GfSpChallengePieceTask) XXX_Size() int

func (*GfSpChallengePieceTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpChallengePieceTask) XXX_Unmarshal(b []byte) error

type GfSpCreateBucketApprovalTask added in v0.2.4 

type GfSpCreateBucketApprovalTask struct {
	Task             *GfSpTask              `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	CreateBucketInfo *types.MsgCreateBucket `protobuf:"bytes,2,opt,name=create_bucket_info,json=createBucketInfo,proto3" json:"create_bucket_info,omitempty"`
	Fingerprint      []byte                 `protobuf:"bytes,3,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
}

func (*GfSpCreateBucketApprovalTask) AppendLog added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) AppendLog(log string)

func (*GfSpCreateBucketApprovalTask) Descriptor added in v0.2.4 

func (*GfSpCreateBucketApprovalTask) Descriptor() ([]byte, []int)

func (*GfSpCreateBucketApprovalTask) Error added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Error() error

func (*GfSpCreateBucketApprovalTask) EstimateLimit added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) EstimateLimit() corercmgr.Limit

func (*GfSpCreateBucketApprovalTask) ExceedRetry added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) ExceedRetry() bool

func (*GfSpCreateBucketApprovalTask) ExceedTimeout added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) ExceedTimeout() bool

func (*GfSpCreateBucketApprovalTask) Expired added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Expired() bool

func (*GfSpCreateBucketApprovalTask) GetAddress added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetAddress() string

func (*GfSpCreateBucketApprovalTask) GetCreateBucketInfo added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetCreateBucketInfo() *types.MsgCreateBucket

func (*GfSpCreateBucketApprovalTask) GetCreateTime added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetCreateTime() int64

func (*GfSpCreateBucketApprovalTask) GetExpiredHeight added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetExpiredHeight() uint64

func (*GfSpCreateBucketApprovalTask) GetFingerprint added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetFingerprint() []byte

func (*GfSpCreateBucketApprovalTask) GetLogs added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetLogs() string

func (*GfSpCreateBucketApprovalTask) GetMaxRetry added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetMaxRetry() int64

func (*GfSpCreateBucketApprovalTask) GetPriority added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetPriority() coretask.TPriority

func (*GfSpCreateBucketApprovalTask) GetRetry added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetRetry() int64

func (*GfSpCreateBucketApprovalTask) GetTask added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetTask() *GfSpTask

func (*GfSpCreateBucketApprovalTask) GetTimeout added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetTimeout() int64

func (*GfSpCreateBucketApprovalTask) GetUpdateTime added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetUpdateTime() int64

func (*GfSpCreateBucketApprovalTask) GetUserAddress added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) GetUserAddress() string

func (*GfSpCreateBucketApprovalTask) IncRetry added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) IncRetry()

func (*GfSpCreateBucketApprovalTask) Info added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Info() string

func (*GfSpCreateBucketApprovalTask) InitApprovalCreateBucketTask added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) InitApprovalCreateBucketTask(account string, bucket *storagetypes.MsgCreateBucket,
	fingerprint []byte, priority coretask.TPriority)

func (*GfSpCreateBucketApprovalTask) Key added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Key() coretask.TKey

func (*GfSpCreateBucketApprovalTask) Marshal added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Marshal() (dAtA []byte, err error)

func (*GfSpCreateBucketApprovalTask) MarshalTo added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpCreateBucketApprovalTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpCreateBucketApprovalTask) ProtoMessage added in v0.2.4 

func (*GfSpCreateBucketApprovalTask) ProtoMessage()

func (*GfSpCreateBucketApprovalTask) Reset added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Reset()

func (*GfSpCreateBucketApprovalTask) SetAddress added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetAddress(address string)

func (*GfSpCreateBucketApprovalTask) SetCreateBucketInfo added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetCreateBucketInfo(bucket *storagetypes.MsgCreateBucket)

func (*GfSpCreateBucketApprovalTask) SetCreateTime added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetCreateTime(time int64)

func (*GfSpCreateBucketApprovalTask) SetError added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetError(err error)

func (*GfSpCreateBucketApprovalTask) SetExpiredHeight added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetExpiredHeight(height uint64)

func (*GfSpCreateBucketApprovalTask) SetLogs added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetLogs(logs string)

func (*GfSpCreateBucketApprovalTask) SetMaxRetry added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetMaxRetry(limit int64)

func (*GfSpCreateBucketApprovalTask) SetPriority added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetPriority(priority coretask.TPriority)

func (*GfSpCreateBucketApprovalTask) SetRetry added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetRetry(retry int64)

func (*GfSpCreateBucketApprovalTask) SetTimeout added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetTimeout(time int64)

func (*GfSpCreateBucketApprovalTask) SetUpdateTime added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetUpdateTime(time int64)

func (*GfSpCreateBucketApprovalTask) SetUserAddress added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) SetUserAddress(address string)

func (*GfSpCreateBucketApprovalTask) Size added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Size() (n int)

func (*GfSpCreateBucketApprovalTask) String added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) String() string

func (*GfSpCreateBucketApprovalTask) Type added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Type() coretask.TType

func (*GfSpCreateBucketApprovalTask) Unmarshal added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) Unmarshal(dAtA []byte) error

func (*GfSpCreateBucketApprovalTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) XXX_DiscardUnknown()

func (*GfSpCreateBucketApprovalTask) XXX_Marshal added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpCreateBucketApprovalTask) XXX_Merge added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) XXX_Merge(src proto.Message)

func (*GfSpCreateBucketApprovalTask) XXX_Size added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) XXX_Size() int

func (*GfSpCreateBucketApprovalTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpCreateBucketApprovalTask) XXX_Unmarshal(b []byte) error

type GfSpCreateObjectApprovalTask added in v0.2.4 

type GfSpCreateObjectApprovalTask struct {
	Task             *GfSpTask              `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	CreateObjectInfo *types.MsgCreateObject `protobuf:"bytes,2,opt,name=create_object_info,json=createObjectInfo,proto3" json:"create_object_info,omitempty"`
	Fingerprint      []byte                 `protobuf:"bytes,3,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
}

func (*GfSpCreateObjectApprovalTask) AppendLog added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) AppendLog(log string)

func (*GfSpCreateObjectApprovalTask) Descriptor added in v0.2.4 

func (*GfSpCreateObjectApprovalTask) Descriptor() ([]byte, []int)

func (*GfSpCreateObjectApprovalTask) Error added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Error() error

func (*GfSpCreateObjectApprovalTask) EstimateLimit added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) EstimateLimit() corercmgr.Limit

func (*GfSpCreateObjectApprovalTask) ExceedRetry added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) ExceedRetry() bool

func (*GfSpCreateObjectApprovalTask) ExceedTimeout added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) ExceedTimeout() bool

func (*GfSpCreateObjectApprovalTask) Expired added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Expired() bool

func (*GfSpCreateObjectApprovalTask) GetAddress added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetAddress() string

func (*GfSpCreateObjectApprovalTask) GetCreateObjectInfo added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetCreateObjectInfo() *types.MsgCreateObject

func (*GfSpCreateObjectApprovalTask) GetCreateTime added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetCreateTime() int64

func (*GfSpCreateObjectApprovalTask) GetExpiredHeight added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetExpiredHeight() uint64

func (*GfSpCreateObjectApprovalTask) GetFingerprint added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetFingerprint() []byte

func (*GfSpCreateObjectApprovalTask) GetLogs added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetLogs() string

func (*GfSpCreateObjectApprovalTask) GetMaxRetry added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetMaxRetry() int64

func (*GfSpCreateObjectApprovalTask) GetPriority added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetPriority() coretask.TPriority

func (*GfSpCreateObjectApprovalTask) GetRetry added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetRetry() int64

func (*GfSpCreateObjectApprovalTask) GetTask added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetTask() *GfSpTask

func (*GfSpCreateObjectApprovalTask) GetTimeout added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetTimeout() int64

func (*GfSpCreateObjectApprovalTask) GetUpdateTime added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetUpdateTime() int64

func (*GfSpCreateObjectApprovalTask) GetUserAddress added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) GetUserAddress() string

func (*GfSpCreateObjectApprovalTask) IncRetry added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) IncRetry()

func (*GfSpCreateObjectApprovalTask) Info added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Info() string

func (*GfSpCreateObjectApprovalTask) InitApprovalCreateObjectTask added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) InitApprovalCreateObjectTask(account string, object *storagetypes.MsgCreateObject,
	fingerprint []byte, priority coretask.TPriority)

func (*GfSpCreateObjectApprovalTask) Key added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Key() coretask.TKey

func (*GfSpCreateObjectApprovalTask) Marshal added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Marshal() (dAtA []byte, err error)

func (*GfSpCreateObjectApprovalTask) MarshalTo added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpCreateObjectApprovalTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpCreateObjectApprovalTask) ProtoMessage added in v0.2.4 

func (*GfSpCreateObjectApprovalTask) ProtoMessage()

func (*GfSpCreateObjectApprovalTask) Reset added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Reset()

func (*GfSpCreateObjectApprovalTask) SetAddress added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetAddress(address string)

func (*GfSpCreateObjectApprovalTask) SetCreateObjectInfo added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetCreateObjectInfo(object *storagetypes.MsgCreateObject)

func (*GfSpCreateObjectApprovalTask) SetCreateTime added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetCreateTime(time int64)

func (*GfSpCreateObjectApprovalTask) SetError added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetError(err error)

func (*GfSpCreateObjectApprovalTask) SetExpiredHeight added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetExpiredHeight(height uint64)

func (*GfSpCreateObjectApprovalTask) SetLogs added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetLogs(logs string)

func (*GfSpCreateObjectApprovalTask) SetMaxRetry added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetMaxRetry(limit int64)

func (*GfSpCreateObjectApprovalTask) SetPriority added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetPriority(priority coretask.TPriority)

func (*GfSpCreateObjectApprovalTask) SetRetry added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetRetry(retry int64)

func (*GfSpCreateObjectApprovalTask) SetTimeout added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetTimeout(time int64)

func (*GfSpCreateObjectApprovalTask) SetUpdateTime added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetUpdateTime(time int64)

func (*GfSpCreateObjectApprovalTask) SetUserAddress added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) SetUserAddress(address string)

func (*GfSpCreateObjectApprovalTask) Size added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Size() (n int)

func (*GfSpCreateObjectApprovalTask) String added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) String() string

func (*GfSpCreateObjectApprovalTask) Type added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Type() coretask.TType

func (*GfSpCreateObjectApprovalTask) Unmarshal added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) Unmarshal(dAtA []byte) error

func (*GfSpCreateObjectApprovalTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) XXX_DiscardUnknown()

func (*GfSpCreateObjectApprovalTask) XXX_Marshal added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpCreateObjectApprovalTask) XXX_Merge added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) XXX_Merge(src proto.Message)

func (*GfSpCreateObjectApprovalTask) XXX_Size added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) XXX_Size() int

func (*GfSpCreateObjectApprovalTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpCreateObjectApprovalTask) XXX_Unmarshal(b []byte) error

type GfSpDelegateCreateObjectApprovalTask added in v1.6.0 

type GfSpDelegateCreateObjectApprovalTask struct {
	Task                 *GfSpTask                      `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	DelegateCreateObject *types.MsgDelegateCreateObject `protobuf:"bytes,2,opt,name=delegate_create_object,json=delegateCreateObject,proto3" json:"delegate_create_object,omitempty"`
	Fingerprint          []byte                         `protobuf:"bytes,3,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
}

func (*GfSpDelegateCreateObjectApprovalTask) AppendLog added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) AppendLog(log string)

func (*GfSpDelegateCreateObjectApprovalTask) Descriptor added in v1.6.0 

func (*GfSpDelegateCreateObjectApprovalTask) Descriptor() ([]byte, []int)

func (*GfSpDelegateCreateObjectApprovalTask) Error added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Error() error

func (*GfSpDelegateCreateObjectApprovalTask) EstimateLimit added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) EstimateLimit() corercmgr.Limit

func (*GfSpDelegateCreateObjectApprovalTask) ExceedRetry added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) ExceedRetry() bool

func (*GfSpDelegateCreateObjectApprovalTask) ExceedTimeout added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) ExceedTimeout() bool

func (*GfSpDelegateCreateObjectApprovalTask) Expired added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Expired() bool

func (*GfSpDelegateCreateObjectApprovalTask) GetAddress added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetAddress() string

func (*GfSpDelegateCreateObjectApprovalTask) GetCreateTime added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetCreateTime() int64

func (*GfSpDelegateCreateObjectApprovalTask) GetDelegateCreateObject added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetDelegateCreateObject() *types.MsgDelegateCreateObject

func (*GfSpDelegateCreateObjectApprovalTask) GetExpiredHeight added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetExpiredHeight() uint64

func (*GfSpDelegateCreateObjectApprovalTask) GetFingerprint added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetFingerprint() []byte

func (*GfSpDelegateCreateObjectApprovalTask) GetLogs added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetLogs() string

func (*GfSpDelegateCreateObjectApprovalTask) GetMaxRetry added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetMaxRetry() int64

func (*GfSpDelegateCreateObjectApprovalTask) GetPriority added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetPriority() coretask.TPriority

func (*GfSpDelegateCreateObjectApprovalTask) GetRetry added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetRetry() int64

func (*GfSpDelegateCreateObjectApprovalTask) GetTask added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetTask() *GfSpTask

func (*GfSpDelegateCreateObjectApprovalTask) GetTimeout added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetTimeout() int64

func (*GfSpDelegateCreateObjectApprovalTask) GetUpdateTime added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetUpdateTime() int64

func (*GfSpDelegateCreateObjectApprovalTask) GetUserAddress added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) GetUserAddress() string

func (*GfSpDelegateCreateObjectApprovalTask) IncRetry added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) IncRetry()

func (*GfSpDelegateCreateObjectApprovalTask) Info added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Info() string

func (*GfSpDelegateCreateObjectApprovalTask) InitApprovalDelegateCreateObjectTask added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) InitApprovalDelegateCreateObjectTask(account string, object *storagetypes.MsgDelegateCreateObject,
	fingerprint []byte, priority coretask.TPriority)

func (*GfSpDelegateCreateObjectApprovalTask) Key added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Key() coretask.TKey

func (*GfSpDelegateCreateObjectApprovalTask) Marshal added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Marshal() (dAtA []byte, err error)

func (*GfSpDelegateCreateObjectApprovalTask) MarshalTo added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDelegateCreateObjectApprovalTask) MarshalToSizedBuffer added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDelegateCreateObjectApprovalTask) ProtoMessage added in v1.6.0 

func (*GfSpDelegateCreateObjectApprovalTask) ProtoMessage()

func (*GfSpDelegateCreateObjectApprovalTask) Reset added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Reset()

func (*GfSpDelegateCreateObjectApprovalTask) SetAddress added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetAddress(address string)

func (*GfSpDelegateCreateObjectApprovalTask) SetCreateTime added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetCreateTime(time int64)

func (*GfSpDelegateCreateObjectApprovalTask) SetDelegateCreateObject added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetDelegateCreateObject(object *storagetypes.MsgDelegateCreateObject)

func (*GfSpDelegateCreateObjectApprovalTask) SetError added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetError(err error)

func (*GfSpDelegateCreateObjectApprovalTask) SetExpiredHeight added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetExpiredHeight(height uint64)

func (*GfSpDelegateCreateObjectApprovalTask) SetLogs added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetLogs(logs string)

func (*GfSpDelegateCreateObjectApprovalTask) SetMaxRetry added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetMaxRetry(limit int64)

func (*GfSpDelegateCreateObjectApprovalTask) SetPriority added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetPriority(priority coretask.TPriority)

func (*GfSpDelegateCreateObjectApprovalTask) SetRetry added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetRetry(retry int64)

func (*GfSpDelegateCreateObjectApprovalTask) SetTimeout added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetTimeout(time int64)

func (*GfSpDelegateCreateObjectApprovalTask) SetUpdateTime added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetUpdateTime(time int64)

func (*GfSpDelegateCreateObjectApprovalTask) SetUserAddress added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) SetUserAddress(address string)

func (*GfSpDelegateCreateObjectApprovalTask) Size added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Size() (n int)

func (*GfSpDelegateCreateObjectApprovalTask) String added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) String() string

func (*GfSpDelegateCreateObjectApprovalTask) Type added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Type() coretask.TType

func (*GfSpDelegateCreateObjectApprovalTask) Unmarshal added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) Unmarshal(dAtA []byte) error

func (*GfSpDelegateCreateObjectApprovalTask) XXX_DiscardUnknown added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) XXX_DiscardUnknown()

func (*GfSpDelegateCreateObjectApprovalTask) XXX_Marshal added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpDelegateCreateObjectApprovalTask) XXX_Merge added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) XXX_Merge(src proto.Message)

func (*GfSpDelegateCreateObjectApprovalTask) XXX_Size added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) XXX_Size() int

func (*GfSpDelegateCreateObjectApprovalTask) XXX_Unmarshal added in v1.6.0 

func (m *GfSpDelegateCreateObjectApprovalTask) XXX_Unmarshal(b []byte) error

type GfSpDownloadObjectTask added in v0.2.4 

type GfSpDownloadObjectTask struct {
	Task          *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo    *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	BucketInfo    *types.BucketInfo `protobuf:"bytes,3,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
	StorageParams *types.Params     `protobuf:"bytes,4,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	Low           int64             `protobuf:"varint,5,opt,name=low,proto3" json:"low,omitempty"`
	High          int64             `protobuf:"varint,6,opt,name=high,proto3" json:"high,omitempty"`
}

func (*GfSpDownloadObjectTask) AppendLog added in v0.2.4 

func (m *GfSpDownloadObjectTask) AppendLog(log string)

func (*GfSpDownloadObjectTask) Descriptor added in v0.2.4 

func (*GfSpDownloadObjectTask) Descriptor() ([]byte, []int)

func (*GfSpDownloadObjectTask) Error added in v0.2.4 

func (m *GfSpDownloadObjectTask) Error() error

func (*GfSpDownloadObjectTask) EstimateLimit added in v0.2.4 

func (m *GfSpDownloadObjectTask) EstimateLimit() corercmgr.Limit

func (*GfSpDownloadObjectTask) ExceedRetry added in v0.2.4 

func (m *GfSpDownloadObjectTask) ExceedRetry() bool

func (*GfSpDownloadObjectTask) ExceedTimeout added in v0.2.4 

func (m *GfSpDownloadObjectTask) ExceedTimeout() bool

func (*GfSpDownloadObjectTask) Expired added in v0.2.4 

func (m *GfSpDownloadObjectTask) Expired() bool

func (*GfSpDownloadObjectTask) GetAddress added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetAddress() string

func (*GfSpDownloadObjectTask) GetBucketInfo added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetBucketInfo() *types.BucketInfo

func (*GfSpDownloadObjectTask) GetCreateTime added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetCreateTime() int64

func (*GfSpDownloadObjectTask) GetHigh added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetHigh() int64

func (*GfSpDownloadObjectTask) GetLogs added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetLogs() string

func (*GfSpDownloadObjectTask) GetLow added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetLow() int64

func (*GfSpDownloadObjectTask) GetMaxRetry added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetMaxRetry() int64

func (*GfSpDownloadObjectTask) GetObjectInfo added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpDownloadObjectTask) GetPriority added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetPriority() coretask.TPriority

func (*GfSpDownloadObjectTask) GetRetry added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetRetry() int64

func (*GfSpDownloadObjectTask) GetSize added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetSize() int64

func (*GfSpDownloadObjectTask) GetStorageParams added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetStorageParams() *types.Params

func (*GfSpDownloadObjectTask) GetTask added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetTask() *GfSpTask

func (*GfSpDownloadObjectTask) GetTimeout added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetTimeout() int64

func (*GfSpDownloadObjectTask) GetUpdateTime added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetUpdateTime() int64

func (*GfSpDownloadObjectTask) GetUserAddress added in v0.2.4 

func (m *GfSpDownloadObjectTask) GetUserAddress() string

func (*GfSpDownloadObjectTask) IncRetry added in v0.2.4 

func (m *GfSpDownloadObjectTask) IncRetry()

func (*GfSpDownloadObjectTask) Info added in v0.2.4 

func (m *GfSpDownloadObjectTask) Info() string

func (*GfSpDownloadObjectTask) InitDownloadObjectTask added in v0.2.4 

func (m *GfSpDownloadObjectTask) InitDownloadObjectTask(object *storagetypes.ObjectInfo, bucket *storagetypes.BucketInfo,
	params *storagetypes.Params, priority coretask.TPriority, userAddress string, low int64, high int64, timeout int64, maxRetry int64)

func (*GfSpDownloadObjectTask) Key added in v0.2.4 

func (m *GfSpDownloadObjectTask) Key() coretask.TKey

func (*GfSpDownloadObjectTask) Marshal added in v0.2.4 

func (m *GfSpDownloadObjectTask) Marshal() (dAtA []byte, err error)

func (*GfSpDownloadObjectTask) MarshalTo added in v0.2.4 

func (m *GfSpDownloadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDownloadObjectTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpDownloadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDownloadObjectTask) ProtoMessage added in v0.2.4 

func (*GfSpDownloadObjectTask) ProtoMessage()

func (*GfSpDownloadObjectTask) Reset added in v0.2.4 

func (m *GfSpDownloadObjectTask) Reset()

func (*GfSpDownloadObjectTask) SetAddress added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetAddress(address string)

func (*GfSpDownloadObjectTask) SetBucketInfo added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetBucketInfo(bucket *storagetypes.BucketInfo)

func (*GfSpDownloadObjectTask) SetCreateTime added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetCreateTime(time int64)

func (*GfSpDownloadObjectTask) SetError added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetError(err error)

func (*GfSpDownloadObjectTask) SetLogs added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetLogs(logs string)

func (*GfSpDownloadObjectTask) SetMaxRetry added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetMaxRetry(limit int64)

func (*GfSpDownloadObjectTask) SetObjectInfo added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpDownloadObjectTask) SetPriority added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetPriority(priority coretask.TPriority)

func (*GfSpDownloadObjectTask) SetRetry added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetRetry(retry int64)

func (*GfSpDownloadObjectTask) SetStorageParams added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetStorageParams(params *storagetypes.Params)

func (*GfSpDownloadObjectTask) SetTimeout added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetTimeout(time int64)

func (*GfSpDownloadObjectTask) SetUpdateTime added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetUpdateTime(time int64)

func (*GfSpDownloadObjectTask) SetUserAddress added in v0.2.4 

func (m *GfSpDownloadObjectTask) SetUserAddress(address string)

func (*GfSpDownloadObjectTask) Size added in v0.2.4 

func (m *GfSpDownloadObjectTask) Size() (n int)

func (*GfSpDownloadObjectTask) String added in v0.2.4 

func (m *GfSpDownloadObjectTask) String() string

func (*GfSpDownloadObjectTask) Type added in v0.2.4 

func (m *GfSpDownloadObjectTask) Type() coretask.TType

func (*GfSpDownloadObjectTask) Unmarshal added in v0.2.4 

func (m *GfSpDownloadObjectTask) Unmarshal(dAtA []byte) error

func (*GfSpDownloadObjectTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpDownloadObjectTask) XXX_DiscardUnknown()

func (*GfSpDownloadObjectTask) XXX_Marshal added in v0.2.4 

func (m *GfSpDownloadObjectTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpDownloadObjectTask) XXX_Merge added in v0.2.4 

func (m *GfSpDownloadObjectTask) XXX_Merge(src proto.Message)

func (*GfSpDownloadObjectTask) XXX_Size added in v0.2.4 

func (m *GfSpDownloadObjectTask) XXX_Size() int

func (*GfSpDownloadObjectTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpDownloadObjectTask) XXX_Unmarshal(b []byte) error

type GfSpDownloadPieceTask added in v0.2.4 

type GfSpDownloadPieceTask struct {
	Task          *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo    *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	BucketInfo    *types.BucketInfo `protobuf:"bytes,3,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
	StorageParams *types.Params     `protobuf:"bytes,4,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	EnableCheck   bool              `protobuf:"varint,5,opt,name=enable_check,json=enableCheck,proto3" json:"enable_check,omitempty"`
	TotalSize     uint64            `protobuf:"varint,6,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	PieceKey      string            `protobuf:"bytes,7,opt,name=piece_key,json=pieceKey,proto3" json:"piece_key,omitempty"`
	PieceOffset   uint64            `protobuf:"varint,8,opt,name=piece_offset,json=pieceOffset,proto3" json:"piece_offset,omitempty"`
	PieceLength   uint64            `protobuf:"varint,9,opt,name=piece_length,json=pieceLength,proto3" json:"piece_length,omitempty"`
}

func (*GfSpDownloadPieceTask) AppendLog added in v0.2.4 

func (m *GfSpDownloadPieceTask) AppendLog(log string)

func (*GfSpDownloadPieceTask) Descriptor added in v0.2.4 

func (*GfSpDownloadPieceTask) Descriptor() ([]byte, []int)

func (*GfSpDownloadPieceTask) Error added in v0.2.4 

func (m *GfSpDownloadPieceTask) Error() error

func (*GfSpDownloadPieceTask) EstimateLimit added in v0.2.4 

func (m *GfSpDownloadPieceTask) EstimateLimit() corercmgr.Limit

func (*GfSpDownloadPieceTask) ExceedRetry added in v0.2.4 

func (m *GfSpDownloadPieceTask) ExceedRetry() bool

func (*GfSpDownloadPieceTask) ExceedTimeout added in v0.2.4 

func (m *GfSpDownloadPieceTask) ExceedTimeout() bool

func (*GfSpDownloadPieceTask) Expired added in v0.2.4 

func (m *GfSpDownloadPieceTask) Expired() bool

func (*GfSpDownloadPieceTask) GetAddress added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetAddress() string

func (*GfSpDownloadPieceTask) GetBucketInfo added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetBucketInfo() *types.BucketInfo

func (*GfSpDownloadPieceTask) GetCreateTime added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetCreateTime() int64

func (*GfSpDownloadPieceTask) GetEnableCheck added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetEnableCheck() bool

func (*GfSpDownloadPieceTask) GetLogs added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetLogs() string

func (*GfSpDownloadPieceTask) GetMaxRetry added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetMaxRetry() int64

func (*GfSpDownloadPieceTask) GetObjectInfo added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpDownloadPieceTask) GetPieceKey added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetPieceKey() string

func (*GfSpDownloadPieceTask) GetPieceLength added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetPieceLength() uint64

func (*GfSpDownloadPieceTask) GetPieceOffset added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetPieceOffset() uint64

func (*GfSpDownloadPieceTask) GetPriority added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetPriority() coretask.TPriority

func (*GfSpDownloadPieceTask) GetRetry added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetRetry() int64

func (*GfSpDownloadPieceTask) GetSize added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetSize() int64

func (*GfSpDownloadPieceTask) GetStorageParams added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetStorageParams() *types.Params

func (*GfSpDownloadPieceTask) GetTask added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetTask() *GfSpTask

func (*GfSpDownloadPieceTask) GetTimeout added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetTimeout() int64

func (*GfSpDownloadPieceTask) GetTotalSize added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetTotalSize() uint64

func (*GfSpDownloadPieceTask) GetUpdateTime added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetUpdateTime() int64

func (*GfSpDownloadPieceTask) GetUserAddress added in v0.2.4 

func (m *GfSpDownloadPieceTask) GetUserAddress() string

func (*GfSpDownloadPieceTask) IncRetry added in v0.2.4 

func (m *GfSpDownloadPieceTask) IncRetry()

func (*GfSpDownloadPieceTask) Info added in v0.2.4 

func (m *GfSpDownloadPieceTask) Info() string

func (*GfSpDownloadPieceTask) InitDownloadPieceTask added in v0.2.4 

func (m *GfSpDownloadPieceTask) InitDownloadPieceTask(object *storagetypes.ObjectInfo, bucket *storagetypes.BucketInfo,
	params *storagetypes.Params, priority coretask.TPriority, enableCheck bool, userAddress string, totalSize uint64,
	pieceKey string, pieceOffset uint64, pieceLength uint64, timeout int64, maxRetry int64)

func (*GfSpDownloadPieceTask) Key added in v0.2.4 

func (m *GfSpDownloadPieceTask) Key() coretask.TKey

func (*GfSpDownloadPieceTask) Marshal added in v0.2.4 

func (m *GfSpDownloadPieceTask) Marshal() (dAtA []byte, err error)

func (*GfSpDownloadPieceTask) MarshalTo added in v0.2.4 

func (m *GfSpDownloadPieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDownloadPieceTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpDownloadPieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDownloadPieceTask) ProtoMessage added in v0.2.4 

func (*GfSpDownloadPieceTask) ProtoMessage()

func (*GfSpDownloadPieceTask) Reset added in v0.2.4 

func (m *GfSpDownloadPieceTask) Reset()

func (*GfSpDownloadPieceTask) SetAddress added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetAddress(address string)

func (*GfSpDownloadPieceTask) SetBucketInfo added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetBucketInfo(bucket *storagetypes.BucketInfo)

func (*GfSpDownloadPieceTask) SetCreateTime added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetCreateTime(time int64)

func (*GfSpDownloadPieceTask) SetError added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetError(err error)

func (*GfSpDownloadPieceTask) SetLogs added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetLogs(logs string)

func (*GfSpDownloadPieceTask) SetMaxRetry added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetMaxRetry(limit int64)

func (*GfSpDownloadPieceTask) SetObjectInfo added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpDownloadPieceTask) SetPriority added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetPriority(priority coretask.TPriority)

func (*GfSpDownloadPieceTask) SetRetry added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetRetry(retry int64)

func (*GfSpDownloadPieceTask) SetStorageParams added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetStorageParams(params *storagetypes.Params)

func (*GfSpDownloadPieceTask) SetTimeout added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetTimeout(time int64)

func (*GfSpDownloadPieceTask) SetUpdateTime added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetUpdateTime(time int64)

func (*GfSpDownloadPieceTask) SetUserAddress added in v0.2.4 

func (m *GfSpDownloadPieceTask) SetUserAddress(address string)

func (*GfSpDownloadPieceTask) Size added in v0.2.4 

func (m *GfSpDownloadPieceTask) Size() (n int)

func (*GfSpDownloadPieceTask) String added in v0.2.4 

func (m *GfSpDownloadPieceTask) String() string

func (*GfSpDownloadPieceTask) Type added in v0.2.4 

func (m *GfSpDownloadPieceTask) Type() coretask.TType

func (*GfSpDownloadPieceTask) Unmarshal added in v0.2.4 

func (m *GfSpDownloadPieceTask) Unmarshal(dAtA []byte) error

func (*GfSpDownloadPieceTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpDownloadPieceTask) XXX_DiscardUnknown()

func (*GfSpDownloadPieceTask) XXX_Marshal added in v0.2.4 

func (m *GfSpDownloadPieceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpDownloadPieceTask) XXX_Merge added in v0.2.4 

func (m *GfSpDownloadPieceTask) XXX_Merge(src proto.Message)

func (*GfSpDownloadPieceTask) XXX_Size added in v0.2.4 

func (m *GfSpDownloadPieceTask) XXX_Size() int

func (*GfSpDownloadPieceTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpDownloadPieceTask) XXX_Unmarshal(b []byte) error

type GfSpGCBucketMigrationTask added in v1.2.0 

type GfSpGCBucketMigrationTask struct {
	Task           *GfSpTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	BucketId       uint64    `protobuf:"varint,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	LastGcObjectId uint64    `protobuf:"varint,3,opt,name=last_gc_object_id,json=lastGcObjectId,proto3" json:"last_gc_object_id,omitempty"`
	LastGcGvgId    uint64    `protobuf:"varint,4,opt,name=last_gc_gvg_id,json=lastGcGvgId,proto3" json:"last_gc_gvg_id,omitempty"`
	// whether the gc of bucket migration succeed
	Finished         bool   `protobuf:"varint,5,opt,name=finished,proto3" json:"finished,omitempty"`
	TotalGvgNum      uint64 `protobuf:"varint,6,opt,name=total_gvg_num,json=totalGvgNum,proto3" json:"total_gvg_num,omitempty"`
	GcFinishedGvgNum uint64 `protobuf:"varint,7,opt,name=gc_finished_gvg_num,json=gcFinishedGvgNum,proto3" json:"gc_finished_gvg_num,omitempty"`
}

func (*GfSpGCBucketMigrationTask) AppendLog added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) AppendLog(log string)

func (*GfSpGCBucketMigrationTask) Descriptor added in v1.2.0 

func (*GfSpGCBucketMigrationTask) Descriptor() ([]byte, []int)

func (*GfSpGCBucketMigrationTask) Error added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Error() error

func (*GfSpGCBucketMigrationTask) EstimateLimit added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) EstimateLimit() corercmgr.Limit

func (*GfSpGCBucketMigrationTask) ExceedRetry added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) ExceedRetry() bool

func (*GfSpGCBucketMigrationTask) ExceedTimeout added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) ExceedTimeout() bool

func (*GfSpGCBucketMigrationTask) Expired added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Expired() bool

func (*GfSpGCBucketMigrationTask) GetAddress added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetAddress() string

func (*GfSpGCBucketMigrationTask) GetBucketID added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetBucketID() uint64

func (*GfSpGCBucketMigrationTask) GetBucketId added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetBucketId() uint64

func (*GfSpGCBucketMigrationTask) GetCreateTime added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetCreateTime() int64

func (*GfSpGCBucketMigrationTask) GetFinished added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetFinished() bool

func (*GfSpGCBucketMigrationTask) GetGCFinishedGvgNum added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetGCFinishedGvgNum() uint64

func (*GfSpGCBucketMigrationTask) GetGcFinishedGvgNum added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetGcFinishedGvgNum() uint64

func (*GfSpGCBucketMigrationTask) GetLastGCGvgID added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetLastGCGvgID() uint64

func (*GfSpGCBucketMigrationTask) GetLastGCObjectID added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetLastGCObjectID() uint64

func (*GfSpGCBucketMigrationTask) GetLastGcGvgId added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetLastGcGvgId() uint64

func (*GfSpGCBucketMigrationTask) GetLastGcObjectId added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetLastGcObjectId() uint64

func (*GfSpGCBucketMigrationTask) GetLogs added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetLogs() string

func (*GfSpGCBucketMigrationTask) GetMaxRetry added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetMaxRetry() int64

func (*GfSpGCBucketMigrationTask) GetPriority added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetPriority() coretask.TPriority

func (*GfSpGCBucketMigrationTask) GetRetry added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetRetry() int64

func (*GfSpGCBucketMigrationTask) GetTask added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetTask() *GfSpTask

func (*GfSpGCBucketMigrationTask) GetTimeout added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetTimeout() int64

func (*GfSpGCBucketMigrationTask) GetTotalGvgNum added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) GetTotalGvgNum() uint64

func (*GfSpGCBucketMigrationTask) GetUpdateTime added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetUpdateTime() int64

func (*GfSpGCBucketMigrationTask) GetUserAddress added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) GetUserAddress() string

func (*GfSpGCBucketMigrationTask) IncRetry added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) IncRetry()

func (*GfSpGCBucketMigrationTask) Info added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Info() string

func (*GfSpGCBucketMigrationTask) InitGCBucketMigrationTask added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) InitGCBucketMigrationTask(priority coretask.TPriority, bucketID uint64, timeout, retry int64)

func (*GfSpGCBucketMigrationTask) Key added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Key() coretask.TKey

func (*GfSpGCBucketMigrationTask) Marshal added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Marshal() (dAtA []byte, err error)

func (*GfSpGCBucketMigrationTask) MarshalTo added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpGCBucketMigrationTask) MarshalToSizedBuffer added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpGCBucketMigrationTask) ProtoMessage added in v1.2.0 

func (*GfSpGCBucketMigrationTask) ProtoMessage()

func (*GfSpGCBucketMigrationTask) Reset added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Reset()

func (*GfSpGCBucketMigrationTask) SetAddress added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetAddress(address string)

func (*GfSpGCBucketMigrationTask) SetBucketID added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetBucketID(bucketID uint64)

func (*GfSpGCBucketMigrationTask) SetCreateTime added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetCreateTime(time int64)

func (*GfSpGCBucketMigrationTask) SetError added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetError(err error)

func (*GfSpGCBucketMigrationTask) SetFinished added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) SetFinished(finished bool)

func (*GfSpGCBucketMigrationTask) SetGCFinishedGvgNum added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) SetGCFinishedGvgNum(gvgGcNum uint64)

func (*GfSpGCBucketMigrationTask) SetLastGCGvgID added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) SetLastGCGvgID(lastGcGvgID uint64)

func (*GfSpGCBucketMigrationTask) SetLastGCObjectID added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) SetLastGCObjectID(lastGcObjectId uint64)

func (*GfSpGCBucketMigrationTask) SetLogs added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetLogs(logs string)

func (*GfSpGCBucketMigrationTask) SetMaxRetry added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetMaxRetry(limit int64)

func (*GfSpGCBucketMigrationTask) SetPriority added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetPriority(priority coretask.TPriority)

func (*GfSpGCBucketMigrationTask) SetRetry added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetRetry(retry int64)

func (*GfSpGCBucketMigrationTask) SetTimeout added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetTimeout(time int64)

func (*GfSpGCBucketMigrationTask) SetTotalGvgNum added in v1.3.0 

func (m *GfSpGCBucketMigrationTask) SetTotalGvgNum(gvgNum uint64)

func (*GfSpGCBucketMigrationTask) SetUpdateTime added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetUpdateTime(time int64)

func (*GfSpGCBucketMigrationTask) SetUserAddress added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) SetUserAddress(s string)

func (*GfSpGCBucketMigrationTask) Size added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Size() (n int)

func (*GfSpGCBucketMigrationTask) String added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) String() string

func (*GfSpGCBucketMigrationTask) Type added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Type() coretask.TType

func (*GfSpGCBucketMigrationTask) Unmarshal added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) Unmarshal(dAtA []byte) error

func (*GfSpGCBucketMigrationTask) XXX_DiscardUnknown added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) XXX_DiscardUnknown()

func (*GfSpGCBucketMigrationTask) XXX_Marshal added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpGCBucketMigrationTask) XXX_Merge added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) XXX_Merge(src proto.Message)

func (*GfSpGCBucketMigrationTask) XXX_Size added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) XXX_Size() int

func (*GfSpGCBucketMigrationTask) XXX_Unmarshal added in v1.2.0 

func (m *GfSpGCBucketMigrationTask) XXX_Unmarshal(b []byte) error

type GfSpGCMetaTask added in v0.2.4 

type GfSpGCMetaTask struct {
	Task        *GfSpTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	CurrentIdx  uint64    `protobuf:"varint,2,opt,name=current_idx,json=currentIdx,proto3" json:"current_idx,omitempty"`
	DeleteCount uint64    `protobuf:"varint,3,opt,name=delete_count,json=deleteCount,proto3" json:"delete_count,omitempty"`
}

func (*GfSpGCMetaTask) AppendLog added in v0.2.4 

func (m *GfSpGCMetaTask) AppendLog(log string)

func (*GfSpGCMetaTask) Descriptor added in v0.2.4 

func (*GfSpGCMetaTask) Descriptor() ([]byte, []int)

func (*GfSpGCMetaTask) Error added in v0.2.4 

func (m *GfSpGCMetaTask) Error() error

func (*GfSpGCMetaTask) EstimateLimit added in v0.2.4 

func (m *GfSpGCMetaTask) EstimateLimit() corercmgr.Limit

func (*GfSpGCMetaTask) ExceedRetry added in v0.2.4 

func (m *GfSpGCMetaTask) ExceedRetry() bool

func (*GfSpGCMetaTask) ExceedTimeout added in v0.2.4 

func (m *GfSpGCMetaTask) ExceedTimeout() bool

func (*GfSpGCMetaTask) Expired added in v0.2.4 

func (m *GfSpGCMetaTask) Expired() bool

func (*GfSpGCMetaTask) GetAddress added in v0.2.4 

func (m *GfSpGCMetaTask) GetAddress() string

func (*GfSpGCMetaTask) GetCreateTime added in v0.2.4 

func (m *GfSpGCMetaTask) GetCreateTime() int64

func (*GfSpGCMetaTask) GetCurrentIdx added in v0.2.4 

func (m *GfSpGCMetaTask) GetCurrentIdx() uint64

func (*GfSpGCMetaTask) GetDeleteCount added in v0.2.4 

func (m *GfSpGCMetaTask) GetDeleteCount() uint64

func (*GfSpGCMetaTask) GetGCMetaStatus added in v0.2.4 

func (m *GfSpGCMetaTask) GetGCMetaStatus() (uint64, uint64)

func (*GfSpGCMetaTask) GetLogs added in v0.2.4 

func (m *GfSpGCMetaTask) GetLogs() string

func (*GfSpGCMetaTask) GetMaxRetry added in v0.2.4 

func (m *GfSpGCMetaTask) GetMaxRetry() int64

func (*GfSpGCMetaTask) GetPriority added in v0.2.4 

func (m *GfSpGCMetaTask) GetPriority() coretask.TPriority

func (*GfSpGCMetaTask) GetRetry added in v0.2.4 

func (m *GfSpGCMetaTask) GetRetry() int64

func (*GfSpGCMetaTask) GetTask added in v0.2.4 

func (m *GfSpGCMetaTask) GetTask() *GfSpTask

func (*GfSpGCMetaTask) GetTimeout added in v0.2.4 

func (m *GfSpGCMetaTask) GetTimeout() int64

func (*GfSpGCMetaTask) GetUpdateTime added in v0.2.4 

func (m *GfSpGCMetaTask) GetUpdateTime() int64

func (*GfSpGCMetaTask) GetUserAddress added in v0.2.4 

func (m *GfSpGCMetaTask) GetUserAddress() string

func (*GfSpGCMetaTask) IncRetry added in v0.2.4 

func (m *GfSpGCMetaTask) IncRetry()

func (*GfSpGCMetaTask) Info added in v0.2.4 

func (m *GfSpGCMetaTask) Info() string

func (*GfSpGCMetaTask) InitGCMetaTask added in v1.2.0 

func (m *GfSpGCMetaTask) InitGCMetaTask(priority coretask.TPriority, timeout int64)

func (*GfSpGCMetaTask) Key added in v0.2.4 

func (m *GfSpGCMetaTask) Key() coretask.TKey

func (*GfSpGCMetaTask) Marshal added in v0.2.4 

func (m *GfSpGCMetaTask) Marshal() (dAtA []byte, err error)

func (*GfSpGCMetaTask) MarshalTo added in v0.2.4 

func (m *GfSpGCMetaTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpGCMetaTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpGCMetaTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpGCMetaTask) ProtoMessage added in v0.2.4 

func (*GfSpGCMetaTask) ProtoMessage()

func (*GfSpGCMetaTask) Reset added in v0.2.4 

func (m *GfSpGCMetaTask) Reset()

func (*GfSpGCMetaTask) SetAddress added in v0.2.4 

func (m *GfSpGCMetaTask) SetAddress(address string)

func (*GfSpGCMetaTask) SetCreateTime added in v0.2.4 

func (m *GfSpGCMetaTask) SetCreateTime(time int64)

func (*GfSpGCMetaTask) SetError added in v0.2.4 

func (m *GfSpGCMetaTask) SetError(err error)

func (*GfSpGCMetaTask) SetGCMetaStatus added in v0.2.4 

func (m *GfSpGCMetaTask) SetGCMetaStatus(current uint64, delete uint64)

func (*GfSpGCMetaTask) SetLogs added in v0.2.4 

func (m *GfSpGCMetaTask) SetLogs(logs string)

func (*GfSpGCMetaTask) SetMaxRetry added in v0.2.4 

func (m *GfSpGCMetaTask) SetMaxRetry(limit int64)

func (*GfSpGCMetaTask) SetPriority added in v0.2.4 

func (m *GfSpGCMetaTask) SetPriority(priority coretask.TPriority)

func (*GfSpGCMetaTask) SetRetry added in v0.2.4 

func (m *GfSpGCMetaTask) SetRetry(retry int64)

func (*GfSpGCMetaTask) SetTimeout added in v0.2.4 

func (m *GfSpGCMetaTask) SetTimeout(time int64)

func (*GfSpGCMetaTask) SetUpdateTime added in v0.2.4 

func (m *GfSpGCMetaTask) SetUpdateTime(time int64)

func (*GfSpGCMetaTask) SetUserAddress added in v0.2.4 

func (m *GfSpGCMetaTask) SetUserAddress(address string)

func (*GfSpGCMetaTask) Size added in v0.2.4 

func (m *GfSpGCMetaTask) Size() (n int)

func (*GfSpGCMetaTask) String added in v0.2.4 

func (m *GfSpGCMetaTask) String() string

func (*GfSpGCMetaTask) Type added in v0.2.4 

func (m *GfSpGCMetaTask) Type() coretask.TType

func (*GfSpGCMetaTask) Unmarshal added in v0.2.4 

func (m *GfSpGCMetaTask) Unmarshal(dAtA []byte) error

func (*GfSpGCMetaTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpGCMetaTask) XXX_DiscardUnknown()

func (*GfSpGCMetaTask) XXX_Marshal added in v0.2.4 

func (m *GfSpGCMetaTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpGCMetaTask) XXX_Merge added in v0.2.4 

func (m *GfSpGCMetaTask) XXX_Merge(src proto.Message)

func (*GfSpGCMetaTask) XXX_Size added in v0.2.4 

func (m *GfSpGCMetaTask) XXX_Size() int

func (*GfSpGCMetaTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpGCMetaTask) XXX_Unmarshal(b []byte) error

type GfSpGCObjectTask added in v0.2.4 

type GfSpGCObjectTask struct {
	Task                *GfSpTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	StartBlockNumber    uint64    `protobuf:"varint,2,opt,name=start_block_number,json=startBlockNumber,proto3" json:"start_block_number,omitempty"`
	EndBlockNumber      uint64    `protobuf:"varint,3,opt,name=end_block_number,json=endBlockNumber,proto3" json:"end_block_number,omitempty"`
	CurrentBlockNumber  uint64    `protobuf:"varint,4,opt,name=current_block_number,json=currentBlockNumber,proto3" json:"current_block_number,omitempty"`
	LastDeletedObjectId uint64    `protobuf:"varint,5,opt,name=last_deleted_object_id,json=lastDeletedObjectId,proto3" json:"last_deleted_object_id,omitempty"`
	Running             bool      `protobuf:"varint,6,opt,name=running,proto3" json:"running,omitempty"`
}

func (*GfSpGCObjectTask) AppendLog added in v0.2.4 

func (m *GfSpGCObjectTask) AppendLog(log string)

func (*GfSpGCObjectTask) Descriptor added in v0.2.4 

func (*GfSpGCObjectTask) Descriptor() ([]byte, []int)

func (*GfSpGCObjectTask) Error added in v0.2.4 

func (m *GfSpGCObjectTask) Error() error

func (*GfSpGCObjectTask) EstimateLimit added in v0.2.4 

func (m *GfSpGCObjectTask) EstimateLimit() corercmgr.Limit

func (*GfSpGCObjectTask) ExceedRetry added in v0.2.4 

func (m *GfSpGCObjectTask) ExceedRetry() bool

func (*GfSpGCObjectTask) ExceedTimeout added in v0.2.4 

func (m *GfSpGCObjectTask) ExceedTimeout() bool

func (*GfSpGCObjectTask) Expired added in v0.2.4 

func (m *GfSpGCObjectTask) Expired() bool

func (*GfSpGCObjectTask) GetAddress added in v0.2.4 

func (m *GfSpGCObjectTask) GetAddress() string

func (*GfSpGCObjectTask) GetCreateTime added in v0.2.4 

func (m *GfSpGCObjectTask) GetCreateTime() int64

func (*GfSpGCObjectTask) GetCurrentBlockNumber added in v0.2.4 

func (m *GfSpGCObjectTask) GetCurrentBlockNumber() uint64

func (*GfSpGCObjectTask) GetEndBlockNumber added in v0.2.4 

func (m *GfSpGCObjectTask) GetEndBlockNumber() uint64

func (*GfSpGCObjectTask) GetGCObjectProgress added in v0.2.4 

func (m *GfSpGCObjectTask) GetGCObjectProgress() (uint64, uint64)

func (*GfSpGCObjectTask) GetLastDeletedObjectId added in v0.2.4 

func (m *GfSpGCObjectTask) GetLastDeletedObjectId() uint64

func (*GfSpGCObjectTask) GetLogs added in v0.2.4 

func (m *GfSpGCObjectTask) GetLogs() string

func (*GfSpGCObjectTask) GetMaxRetry added in v0.2.4 

func (m *GfSpGCObjectTask) GetMaxRetry() int64

func (*GfSpGCObjectTask) GetPriority added in v0.2.4 

func (m *GfSpGCObjectTask) GetPriority() coretask.TPriority

func (*GfSpGCObjectTask) GetRetry added in v0.2.4 

func (m *GfSpGCObjectTask) GetRetry() int64

func (*GfSpGCObjectTask) GetRunning added in v0.2.4 

func (m *GfSpGCObjectTask) GetRunning() bool

func (*GfSpGCObjectTask) GetStartBlockNumber added in v0.2.4 

func (m *GfSpGCObjectTask) GetStartBlockNumber() uint64

func (*GfSpGCObjectTask) GetTask added in v0.2.4 

func (m *GfSpGCObjectTask) GetTask() *GfSpTask

func (*GfSpGCObjectTask) GetTimeout added in v0.2.4 

func (m *GfSpGCObjectTask) GetTimeout() int64

func (*GfSpGCObjectTask) GetUpdateTime added in v0.2.4 

func (m *GfSpGCObjectTask) GetUpdateTime() int64

func (*GfSpGCObjectTask) GetUserAddress added in v0.2.4 

func (m *GfSpGCObjectTask) GetUserAddress() string

func (*GfSpGCObjectTask) IncRetry added in v0.2.4 

func (m *GfSpGCObjectTask) IncRetry()

func (*GfSpGCObjectTask) Info added in v0.2.4 

func (m *GfSpGCObjectTask) Info() string

func (*GfSpGCObjectTask) InitGCObjectTask added in v0.2.4 

func (m *GfSpGCObjectTask) InitGCObjectTask(priority coretask.TPriority, start, end uint64, timeout int64)

func (*GfSpGCObjectTask) Key added in v0.2.4 

func (m *GfSpGCObjectTask) Key() coretask.TKey

func (*GfSpGCObjectTask) Marshal added in v0.2.4 

func (m *GfSpGCObjectTask) Marshal() (dAtA []byte, err error)

func (*GfSpGCObjectTask) MarshalTo added in v0.2.4 

func (m *GfSpGCObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpGCObjectTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpGCObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpGCObjectTask) ProtoMessage added in v0.2.4 

func (*GfSpGCObjectTask) ProtoMessage()

func (*GfSpGCObjectTask) Reset added in v0.2.4 

func (m *GfSpGCObjectTask) Reset()

func (*GfSpGCObjectTask) SetAddress added in v0.2.4 

func (m *GfSpGCObjectTask) SetAddress(address string)

func (*GfSpGCObjectTask) SetCreateTime added in v0.2.4 

func (m *GfSpGCObjectTask) SetCreateTime(time int64)

func (*GfSpGCObjectTask) SetCurrentBlockNumber added in v0.2.4 

func (m *GfSpGCObjectTask) SetCurrentBlockNumber(block uint64)

func (*GfSpGCObjectTask) SetEndBlockNumber added in v0.2.4 

func (m *GfSpGCObjectTask) SetEndBlockNumber(block uint64)

func (*GfSpGCObjectTask) SetError added in v0.2.4 

func (m *GfSpGCObjectTask) SetError(err error)

func (*GfSpGCObjectTask) SetGCObjectProgress added in v0.2.4 

func (m *GfSpGCObjectTask) SetGCObjectProgress(block uint64, object uint64)

func (*GfSpGCObjectTask) SetLastDeletedObjectId added in v0.2.4 

func (m *GfSpGCObjectTask) SetLastDeletedObjectId(object uint64)

func (*GfSpGCObjectTask) SetLogs added in v0.2.4 

func (m *GfSpGCObjectTask) SetLogs(logs string)

func (*GfSpGCObjectTask) SetMaxRetry added in v0.2.4 

func (m *GfSpGCObjectTask) SetMaxRetry(limit int64)

func (*GfSpGCObjectTask) SetPriority added in v0.2.4 

func (m *GfSpGCObjectTask) SetPriority(priority coretask.TPriority)

func (*GfSpGCObjectTask) SetRetry added in v0.2.4 

func (m *GfSpGCObjectTask) SetRetry(retry int64)

func (*GfSpGCObjectTask) SetStartBlockNumber added in v0.2.4 

func (m *GfSpGCObjectTask) SetStartBlockNumber(block uint64)

func (*GfSpGCObjectTask) SetTimeout added in v0.2.4 

func (m *GfSpGCObjectTask) SetTimeout(time int64)

func (*GfSpGCObjectTask) SetUpdateTime added in v0.2.4 

func (m *GfSpGCObjectTask) SetUpdateTime(time int64)

func (*GfSpGCObjectTask) SetUserAddress added in v0.2.4 

func (m *GfSpGCObjectTask) SetUserAddress(address string)

func (*GfSpGCObjectTask) Size added in v0.2.4 

func (m *GfSpGCObjectTask) Size() (n int)

func (*GfSpGCObjectTask) String added in v0.2.4 

func (m *GfSpGCObjectTask) String() string

func (*GfSpGCObjectTask) Type added in v0.2.4 

func (m *GfSpGCObjectTask) Type() coretask.TType

func (*GfSpGCObjectTask) Unmarshal added in v0.2.4 

func (m *GfSpGCObjectTask) Unmarshal(dAtA []byte) error

func (*GfSpGCObjectTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpGCObjectTask) XXX_DiscardUnknown()

func (*GfSpGCObjectTask) XXX_Marshal added in v0.2.4 

func (m *GfSpGCObjectTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpGCObjectTask) XXX_Merge added in v0.2.4 

func (m *GfSpGCObjectTask) XXX_Merge(src proto.Message)

func (*GfSpGCObjectTask) XXX_Size added in v0.2.4 

func (m *GfSpGCObjectTask) XXX_Size() int

func (*GfSpGCObjectTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpGCObjectTask) XXX_Unmarshal(b []byte) error

type GfSpGCStaleVersionObjectTask added in v1.5.0 

type GfSpGCStaleVersionObjectTask struct {
	Task              *GfSpTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectId          uint64    `protobuf:"varint,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	RedundancyIndex   int32     `protobuf:"varint,3,opt,name=redundancy_index,json=redundancyIndex,proto3" json:"redundancy_index,omitempty"`
	Version           int64     `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	IntegrityChecksum []byte    `protobuf:"bytes,5,opt,name=integrity_checksum,json=integrityChecksum,proto3" json:"integrity_checksum,omitempty"`
	PieceChecksumList [][]byte  `protobuf:"bytes,6,rep,name=piece_checksum_list,json=pieceChecksumList,proto3" json:"piece_checksum_list,omitempty"`
	ObjectSize        uint64    `protobuf:"varint,7,opt,name=object_size,json=objectSize,proto3" json:"object_size,omitempty"`
}

func (*GfSpGCStaleVersionObjectTask) AppendLog added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) AppendLog(log string)

func (*GfSpGCStaleVersionObjectTask) Descriptor added in v1.5.0 

func (*GfSpGCStaleVersionObjectTask) Descriptor() ([]byte, []int)

func (*GfSpGCStaleVersionObjectTask) Error added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Error() error

func (*GfSpGCStaleVersionObjectTask) EstimateLimit added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) EstimateLimit() corercmgr.Limit

func (*GfSpGCStaleVersionObjectTask) ExceedRetry added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) ExceedRetry() bool

func (*GfSpGCStaleVersionObjectTask) ExceedTimeout added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) ExceedTimeout() bool

func (*GfSpGCStaleVersionObjectTask) Expired added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Expired() bool

func (*GfSpGCStaleVersionObjectTask) GetAddress added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetAddress() string

func (*GfSpGCStaleVersionObjectTask) GetCreateTime added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetCreateTime() int64

func (*GfSpGCStaleVersionObjectTask) GetIntegrityChecksum added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetIntegrityChecksum() []byte

func (*GfSpGCStaleVersionObjectTask) GetLogs added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetLogs() string

func (*GfSpGCStaleVersionObjectTask) GetMaxRetry added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetMaxRetry() int64

func (*GfSpGCStaleVersionObjectTask) GetObjectId added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetObjectId() uint64

func (*GfSpGCStaleVersionObjectTask) GetObjectSize added in v1.6.0 

func (m *GfSpGCStaleVersionObjectTask) GetObjectSize() uint64

func (*GfSpGCStaleVersionObjectTask) GetPieceChecksumList added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetPieceChecksumList() [][]byte

func (*GfSpGCStaleVersionObjectTask) GetPriority added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetPriority() coretask.TPriority

func (*GfSpGCStaleVersionObjectTask) GetRedundancyIndex added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetRedundancyIndex() int32

func (*GfSpGCStaleVersionObjectTask) GetRetry added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetRetry() int64

func (*GfSpGCStaleVersionObjectTask) GetTask added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetTask() *GfSpTask

func (*GfSpGCStaleVersionObjectTask) GetTimeout added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetTimeout() int64

func (*GfSpGCStaleVersionObjectTask) GetUpdateTime added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetUpdateTime() int64

func (*GfSpGCStaleVersionObjectTask) GetUserAddress added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetUserAddress() string

func (*GfSpGCStaleVersionObjectTask) GetVersion added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) GetVersion() int64

func (*GfSpGCStaleVersionObjectTask) IncRetry added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) IncRetry()

func (*GfSpGCStaleVersionObjectTask) Info added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Info() string

func (*GfSpGCStaleVersionObjectTask) InitGCStaleVersionObjectTask added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) InitGCStaleVersionObjectTask(priority coretask.TPriority,
	objectID uint64,
	redundancyIndex int32,
	integrityChecksum []byte,
	pieceChecksumList [][]byte,
	version int64,
	objectSize uint64,
	timeout int64)

func (*GfSpGCStaleVersionObjectTask) Key added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Key() coretask.TKey

func (*GfSpGCStaleVersionObjectTask) Marshal added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Marshal() (dAtA []byte, err error)

func (*GfSpGCStaleVersionObjectTask) MarshalTo added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpGCStaleVersionObjectTask) MarshalToSizedBuffer added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpGCStaleVersionObjectTask) ProtoMessage added in v1.5.0 

func (*GfSpGCStaleVersionObjectTask) ProtoMessage()

func (*GfSpGCStaleVersionObjectTask) Reset added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Reset()

func (*GfSpGCStaleVersionObjectTask) SetAddress added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetAddress(address string)

func (*GfSpGCStaleVersionObjectTask) SetCreateTime added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetCreateTime(time int64)

func (*GfSpGCStaleVersionObjectTask) SetError added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetError(err error)

func (*GfSpGCStaleVersionObjectTask) SetIntegrityChecksum added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetIntegrityChecksum(integrityChecksum []byte)

func (*GfSpGCStaleVersionObjectTask) SetLogs added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetLogs(logs string)

func (*GfSpGCStaleVersionObjectTask) SetMaxRetry added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetMaxRetry(limit int64)

func (*GfSpGCStaleVersionObjectTask) SetObjectID added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetObjectID(id uint64)

func (*GfSpGCStaleVersionObjectTask) SetObjectSize added in v1.6.0 

func (m *GfSpGCStaleVersionObjectTask) SetObjectSize(objectSize uint64)

func (*GfSpGCStaleVersionObjectTask) SetPieceChecksumList added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetPieceChecksumList(pieceChecksumList [][]byte)

func (*GfSpGCStaleVersionObjectTask) SetPriority added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetPriority(priority coretask.TPriority)

func (*GfSpGCStaleVersionObjectTask) SetRedundancyIndex added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetRedundancyIndex(redundancyIndex int32)

func (*GfSpGCStaleVersionObjectTask) SetRetry added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetRetry(retry int64)

func (*GfSpGCStaleVersionObjectTask) SetTimeout added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetTimeout(time int64)

func (*GfSpGCStaleVersionObjectTask) SetUpdateTime added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetUpdateTime(time int64)

func (*GfSpGCStaleVersionObjectTask) SetUserAddress added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetUserAddress(address string)

func (*GfSpGCStaleVersionObjectTask) SetVersion added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) SetVersion(version int64)

func (*GfSpGCStaleVersionObjectTask) Size added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Size() (n int)

func (*GfSpGCStaleVersionObjectTask) String added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) String() string

func (*GfSpGCStaleVersionObjectTask) Type added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Type() coretask.TType

func (*GfSpGCStaleVersionObjectTask) Unmarshal added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) Unmarshal(dAtA []byte) error

func (*GfSpGCStaleVersionObjectTask) XXX_DiscardUnknown added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) XXX_DiscardUnknown()

func (*GfSpGCStaleVersionObjectTask) XXX_Marshal added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpGCStaleVersionObjectTask) XXX_Merge added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) XXX_Merge(src proto.Message)

func (*GfSpGCStaleVersionObjectTask) XXX_Size added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) XXX_Size() int

func (*GfSpGCStaleVersionObjectTask) XXX_Unmarshal added in v1.5.0 

func (m *GfSpGCStaleVersionObjectTask) XXX_Unmarshal(b []byte) error

type GfSpGCZombiePieceTask added in v0.2.4 

type GfSpGCZombiePieceTask struct {
	Task          *GfSpTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Running       bool      `protobuf:"varint,2,opt,name=running,proto3" json:"running,omitempty"`
	StartObjectId uint64    `protobuf:"varint,3,opt,name=start_object_id,json=startObjectId,proto3" json:"start_object_id,omitempty"`
	EndObjectId   uint64    `protobuf:"varint,4,opt,name=end_object_id,json=endObjectId,proto3" json:"end_object_id,omitempty"`
	Finished      bool      `protobuf:"varint,5,opt,name=finished,proto3" json:"finished,omitempty"`
}

func (*GfSpGCZombiePieceTask) AppendLog added in v0.2.4 

func (m *GfSpGCZombiePieceTask) AppendLog(log string)

func (*GfSpGCZombiePieceTask) Descriptor added in v0.2.4 

func (*GfSpGCZombiePieceTask) Descriptor() ([]byte, []int)

func (*GfSpGCZombiePieceTask) Error added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Error() error

func (*GfSpGCZombiePieceTask) EstimateLimit added in v0.2.4 

func (m *GfSpGCZombiePieceTask) EstimateLimit() corercmgr.Limit

func (*GfSpGCZombiePieceTask) ExceedRetry added in v0.2.4 

func (m *GfSpGCZombiePieceTask) ExceedRetry() bool

func (*GfSpGCZombiePieceTask) ExceedTimeout added in v0.2.4 

func (m *GfSpGCZombiePieceTask) ExceedTimeout() bool

func (*GfSpGCZombiePieceTask) Expired added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Expired() bool

func (*GfSpGCZombiePieceTask) GetAddress added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetAddress() string

func (*GfSpGCZombiePieceTask) GetCreateTime added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetCreateTime() int64

func (*GfSpGCZombiePieceTask) GetEndObjectId added in v1.2.0 

func (m *GfSpGCZombiePieceTask) GetEndObjectId() uint64

func (*GfSpGCZombiePieceTask) GetFinished added in v1.2.0 

func (m *GfSpGCZombiePieceTask) GetFinished() bool

func (*GfSpGCZombiePieceTask) GetLogs added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetLogs() string

func (*GfSpGCZombiePieceTask) GetMaxRetry added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetMaxRetry() int64

func (*GfSpGCZombiePieceTask) GetPriority added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetPriority() coretask.TPriority

func (*GfSpGCZombiePieceTask) GetRetry added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetRetry() int64

func (*GfSpGCZombiePieceTask) GetRunning added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetRunning() bool

func (*GfSpGCZombiePieceTask) GetStartObjectId added in v1.2.0 

func (m *GfSpGCZombiePieceTask) GetStartObjectId() uint64

func (*GfSpGCZombiePieceTask) GetTask added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetTask() *GfSpTask

func (*GfSpGCZombiePieceTask) GetTimeout added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetTimeout() int64

func (*GfSpGCZombiePieceTask) GetUpdateTime added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetUpdateTime() int64

func (*GfSpGCZombiePieceTask) GetUserAddress added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetUserAddress() string

func (*GfSpGCZombiePieceTask) IncRetry added in v0.2.4 

func (m *GfSpGCZombiePieceTask) IncRetry()

func (*GfSpGCZombiePieceTask) Info added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Info() string

func (*GfSpGCZombiePieceTask) InitGCZombiePieceTask added in v1.2.0 

func (m *GfSpGCZombiePieceTask) InitGCZombiePieceTask(priority coretask.TPriority, start, end uint64, timeout int64)

func (*GfSpGCZombiePieceTask) Key added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Key() coretask.TKey

func (*GfSpGCZombiePieceTask) Marshal added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Marshal() (dAtA []byte, err error)

func (*GfSpGCZombiePieceTask) MarshalTo added in v0.2.4 

func (m *GfSpGCZombiePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpGCZombiePieceTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpGCZombiePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpGCZombiePieceTask) ProtoMessage added in v0.2.4 

func (*GfSpGCZombiePieceTask) ProtoMessage()

func (*GfSpGCZombiePieceTask) Reset added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Reset()

func (*GfSpGCZombiePieceTask) SetAddress added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetAddress(address string)

func (*GfSpGCZombiePieceTask) SetCreateTime added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetCreateTime(time int64)

func (*GfSpGCZombiePieceTask) SetEndObjectID added in v1.2.0 

func (m *GfSpGCZombiePieceTask) SetEndObjectID(id uint64)

func (*GfSpGCZombiePieceTask) SetError added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetError(err error)

func (*GfSpGCZombiePieceTask) SetLogs added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetLogs(logs string)

func (*GfSpGCZombiePieceTask) SetMaxRetry added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetMaxRetry(limit int64)

func (*GfSpGCZombiePieceTask) SetPriority added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetPriority(priority coretask.TPriority)

func (*GfSpGCZombiePieceTask) SetRetry added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetRetry(retry int64)

func (*GfSpGCZombiePieceTask) SetStartObjectID added in v1.2.0 

func (m *GfSpGCZombiePieceTask) SetStartObjectID(id uint64)

func (*GfSpGCZombiePieceTask) SetTimeout added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetTimeout(time int64)

func (*GfSpGCZombiePieceTask) SetUpdateTime added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetUpdateTime(time int64)

func (*GfSpGCZombiePieceTask) SetUserAddress added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetUserAddress(address string)

func (*GfSpGCZombiePieceTask) Size added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Size() (n int)

func (*GfSpGCZombiePieceTask) String added in v0.2.4 

func (m *GfSpGCZombiePieceTask) String() string

func (*GfSpGCZombiePieceTask) Type added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Type() coretask.TType

func (*GfSpGCZombiePieceTask) Unmarshal added in v0.2.4 

func (m *GfSpGCZombiePieceTask) Unmarshal(dAtA []byte) error

func (*GfSpGCZombiePieceTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpGCZombiePieceTask) XXX_DiscardUnknown()

func (*GfSpGCZombiePieceTask) XXX_Marshal added in v0.2.4 

func (m *GfSpGCZombiePieceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpGCZombiePieceTask) XXX_Merge added in v0.2.4 

func (m *GfSpGCZombiePieceTask) XXX_Merge(src proto.Message)

func (*GfSpGCZombiePieceTask) XXX_Size added in v0.2.4 

func (m *GfSpGCZombiePieceTask) XXX_Size() int

func (*GfSpGCZombiePieceTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpGCZombiePieceTask) XXX_Unmarshal(b []byte) error

type GfSpMigrateBucketApprovalTask added in v0.2.4 

type GfSpMigrateBucketApprovalTask struct {
	Task              *GfSpTask               `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	MigrateBucketInfo *types.MsgMigrateBucket `protobuf:"bytes,2,opt,name=migrate_bucket_info,json=migrateBucketInfo,proto3" json:"migrate_bucket_info,omitempty"`
}

func (*GfSpMigrateBucketApprovalTask) AppendLog added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) AppendLog(log string)

func (*GfSpMigrateBucketApprovalTask) Descriptor added in v0.2.4 

func (*GfSpMigrateBucketApprovalTask) Descriptor() ([]byte, []int)

func (*GfSpMigrateBucketApprovalTask) Error added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Error() error

func (*GfSpMigrateBucketApprovalTask) EstimateLimit added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) EstimateLimit() corercmgr.Limit

func (*GfSpMigrateBucketApprovalTask) ExceedRetry added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) ExceedRetry() bool

func (*GfSpMigrateBucketApprovalTask) ExceedTimeout added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) ExceedTimeout() bool

func (*GfSpMigrateBucketApprovalTask) Expired added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Expired() bool

func (*GfSpMigrateBucketApprovalTask) GetAddress added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetAddress() string

func (*GfSpMigrateBucketApprovalTask) GetCreateTime added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetCreateTime() int64

func (*GfSpMigrateBucketApprovalTask) GetExpiredHeight added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetExpiredHeight() uint64

func (*GfSpMigrateBucketApprovalTask) GetLogs added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetLogs() string

func (*GfSpMigrateBucketApprovalTask) GetMaxRetry added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetMaxRetry() int64

func (*GfSpMigrateBucketApprovalTask) GetMigrateBucketInfo added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetMigrateBucketInfo() *types.MsgMigrateBucket

func (*GfSpMigrateBucketApprovalTask) GetPriority added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetPriority() coretask.TPriority

func (*GfSpMigrateBucketApprovalTask) GetRetry added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetRetry() int64

func (*GfSpMigrateBucketApprovalTask) GetTask added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetTask() *GfSpTask

func (*GfSpMigrateBucketApprovalTask) GetTimeout added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetTimeout() int64

func (*GfSpMigrateBucketApprovalTask) GetUpdateTime added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetUpdateTime() int64

func (*GfSpMigrateBucketApprovalTask) GetUserAddress added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) GetUserAddress() string

func (*GfSpMigrateBucketApprovalTask) IncRetry added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) IncRetry()

func (*GfSpMigrateBucketApprovalTask) Info added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Info() string

func (*GfSpMigrateBucketApprovalTask) InitApprovalMigrateBucketTask added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) InitApprovalMigrateBucketTask(bucket *storagetypes.MsgMigrateBucket, priority coretask.TPriority)

func (*GfSpMigrateBucketApprovalTask) Key added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Key() coretask.TKey

func (*GfSpMigrateBucketApprovalTask) Marshal added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Marshal() (dAtA []byte, err error)

func (*GfSpMigrateBucketApprovalTask) MarshalTo added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpMigrateBucketApprovalTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpMigrateBucketApprovalTask) ProtoMessage added in v0.2.4 

func (*GfSpMigrateBucketApprovalTask) ProtoMessage()

func (*GfSpMigrateBucketApprovalTask) Reset added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Reset()

func (*GfSpMigrateBucketApprovalTask) SetAddress added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetAddress(address string)

func (*GfSpMigrateBucketApprovalTask) SetCreateTime added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetCreateTime(time int64)

func (*GfSpMigrateBucketApprovalTask) SetError added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetError(err error)

func (*GfSpMigrateBucketApprovalTask) SetExpiredHeight added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetExpiredHeight(height uint64)

func (*GfSpMigrateBucketApprovalTask) SetLogs added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetLogs(logs string)

func (*GfSpMigrateBucketApprovalTask) SetMaxRetry added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetMaxRetry(limit int64)

func (*GfSpMigrateBucketApprovalTask) SetMigrateBucketInfo added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetMigrateBucketInfo(bucket *storagetypes.MsgMigrateBucket)

func (*GfSpMigrateBucketApprovalTask) SetPriority added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetPriority(priority coretask.TPriority)

func (*GfSpMigrateBucketApprovalTask) SetRetry added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetRetry(retry int64)

func (*GfSpMigrateBucketApprovalTask) SetTimeout added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetTimeout(time int64)

func (*GfSpMigrateBucketApprovalTask) SetUpdateTime added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetUpdateTime(time int64)

func (*GfSpMigrateBucketApprovalTask) SetUserAddress added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) SetUserAddress(address string)

func (*GfSpMigrateBucketApprovalTask) Size added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Size() (n int)

func (*GfSpMigrateBucketApprovalTask) String added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) String() string

func (*GfSpMigrateBucketApprovalTask) Type added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Type() coretask.TType

func (*GfSpMigrateBucketApprovalTask) Unmarshal added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) Unmarshal(dAtA []byte) error

func (*GfSpMigrateBucketApprovalTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) XXX_DiscardUnknown()

func (*GfSpMigrateBucketApprovalTask) XXX_Marshal added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpMigrateBucketApprovalTask) XXX_Merge added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) XXX_Merge(src proto.Message)

func (*GfSpMigrateBucketApprovalTask) XXX_Size added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) XXX_Size() int

func (*GfSpMigrateBucketApprovalTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpMigrateBucketApprovalTask) XXX_Unmarshal(b []byte) error

type GfSpMigrateGVGTask added in v0.2.4 

type GfSpMigrateGVGTask struct {
	Task                 *GfSpTask                  `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	BucketId             uint64                     `protobuf:"varint,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	SrcGvg               *types1.GlobalVirtualGroup `protobuf:"bytes,3,opt,name=src_gvg,json=srcGvg,proto3" json:"src_gvg,omitempty"`
	DestGvg              *types1.GlobalVirtualGroup `protobuf:"bytes,4,opt,name=dest_gvg,json=destGvg,proto3" json:"dest_gvg,omitempty"`
	RedundancyIdx        int32                      `protobuf:"varint,5,opt,name=redundancy_idx,json=redundancyIdx,proto3" json:"redundancy_idx,omitempty"`
	SrcSp                *types2.StorageProvider    `protobuf:"bytes,6,opt,name=src_sp,json=srcSp,proto3" json:"src_sp,omitempty"`
	LastMigratedObjectId uint64                     `` /* 126-byte string literal not displayed */
	Finished             bool                       `protobuf:"varint,8,opt,name=finished,proto3" json:"finished,omitempty"`
	ExpireTime           int64                      `protobuf:"varint,9,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	Signature            []byte                     `protobuf:"bytes,10,opt,name=signature,proto3" json:"signature,omitempty"`
	MigratedBytesSize    uint64                     `protobuf:"varint,11,opt,name=migrated_bytes_size,json=migratedBytesSize,proto3" json:"migrated_bytes_size,omitempty"`
}

func (*GfSpMigrateGVGTask) AppendLog added in v0.2.4 

func (m *GfSpMigrateGVGTask) AppendLog(log string)

func (*GfSpMigrateGVGTask) Descriptor added in v0.2.4 

func (*GfSpMigrateGVGTask) Descriptor() ([]byte, []int)

func (*GfSpMigrateGVGTask) Error added in v0.2.4 

func (m *GfSpMigrateGVGTask) Error() error

func (*GfSpMigrateGVGTask) EstimateLimit added in v0.2.4 

func (m *GfSpMigrateGVGTask) EstimateLimit() corercmgr.Limit

func (*GfSpMigrateGVGTask) ExceedRetry added in v0.2.4 

func (m *GfSpMigrateGVGTask) ExceedRetry() bool

func (*GfSpMigrateGVGTask) ExceedTimeout added in v0.2.4 

func (m *GfSpMigrateGVGTask) ExceedTimeout() bool

func (*GfSpMigrateGVGTask) Expired added in v0.2.4 

func (m *GfSpMigrateGVGTask) Expired() bool

func (*GfSpMigrateGVGTask) GetAddress added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetAddress() string

func (*GfSpMigrateGVGTask) GetBucketID added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetBucketID() uint64

func (*GfSpMigrateGVGTask) GetBucketId added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetBucketId() uint64

func (*GfSpMigrateGVGTask) GetCreateTime added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetCreateTime() int64

func (*GfSpMigrateGVGTask) GetDestGvg added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetDestGvg() *types1.GlobalVirtualGroup

func (*GfSpMigrateGVGTask) GetExpireTime added in v0.2.6 

func (m *GfSpMigrateGVGTask) GetExpireTime() int64

func (*GfSpMigrateGVGTask) GetFinished added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetFinished() bool

func (*GfSpMigrateGVGTask) GetLastMigratedObjectID added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetLastMigratedObjectID() uint64

func (*GfSpMigrateGVGTask) GetLastMigratedObjectId added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetLastMigratedObjectId() uint64

func (*GfSpMigrateGVGTask) GetLogs added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetLogs() string

func (*GfSpMigrateGVGTask) GetMaxRetry added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetMaxRetry() int64

func (*GfSpMigrateGVGTask) GetMigratedBytesSize added in v1.1.0 

func (m *GfSpMigrateGVGTask) GetMigratedBytesSize() uint64

func (*GfSpMigrateGVGTask) GetPriority added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetPriority() coretask.TPriority

func (*GfSpMigrateGVGTask) GetRedundancyIdx added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetRedundancyIdx() int32

func (*GfSpMigrateGVGTask) GetRetry added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetRetry() int64

func (*GfSpMigrateGVGTask) GetSignBytes added in v0.2.6 

func (m *GfSpMigrateGVGTask) GetSignBytes() []byte

func (*GfSpMigrateGVGTask) GetSignature added in v0.2.6 

func (m *GfSpMigrateGVGTask) GetSignature() []byte

func (*GfSpMigrateGVGTask) GetSrcGvg added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetSrcGvg() *types1.GlobalVirtualGroup

func (*GfSpMigrateGVGTask) GetSrcSp added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetSrcSp() *types2.StorageProvider

func (*GfSpMigrateGVGTask) GetTask added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetTask() *GfSpTask

func (*GfSpMigrateGVGTask) GetTimeout added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetTimeout() int64

func (*GfSpMigrateGVGTask) GetUpdateTime added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetUpdateTime() int64

func (*GfSpMigrateGVGTask) GetUserAddress added in v0.2.4 

func (m *GfSpMigrateGVGTask) GetUserAddress() string

func (*GfSpMigrateGVGTask) IncRetry added in v0.2.4 

func (m *GfSpMigrateGVGTask) IncRetry()

func (*GfSpMigrateGVGTask) Info added in v0.2.4 

func (m *GfSpMigrateGVGTask) Info() string

func (*GfSpMigrateGVGTask) InitMigrateGVGTask added in v0.2.4 

func (m *GfSpMigrateGVGTask) InitMigrateGVGTask(priority coretask.TPriority, bucketID uint64, srcGvg *virtualgrouptypes.GlobalVirtualGroup,
	redundancyIndex int32, srcSP *sptypes.StorageProvider, timeout, retry int64)

func (*GfSpMigrateGVGTask) Key added in v0.2.4 

func (m *GfSpMigrateGVGTask) Key() coretask.TKey

func (*GfSpMigrateGVGTask) Marshal added in v0.2.4 

func (m *GfSpMigrateGVGTask) Marshal() (dAtA []byte, err error)

func (*GfSpMigrateGVGTask) MarshalTo added in v0.2.4 

func (m *GfSpMigrateGVGTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpMigrateGVGTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpMigrateGVGTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpMigrateGVGTask) ProtoMessage added in v0.2.4 

func (*GfSpMigrateGVGTask) ProtoMessage()

func (*GfSpMigrateGVGTask) Reset added in v0.2.4 

func (m *GfSpMigrateGVGTask) Reset()

func (*GfSpMigrateGVGTask) SetAddress added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetAddress(address string)

func (*GfSpMigrateGVGTask) SetBucketID added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetBucketID(bucketID uint64)

func (*GfSpMigrateGVGTask) SetCreateTime added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetCreateTime(time int64)

func (*GfSpMigrateGVGTask) SetDestGvg added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetDestGvg(gvg *virtualgrouptypes.GlobalVirtualGroup)

func (*GfSpMigrateGVGTask) SetError added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetError(err error)

func (*GfSpMigrateGVGTask) SetFinished added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetFinished(finished bool)

func (*GfSpMigrateGVGTask) SetLastMigratedObjectID added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetLastMigratedObjectID(lastMigratedObjectID uint64)

func (*GfSpMigrateGVGTask) SetLogs added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetLogs(logs string)

func (*GfSpMigrateGVGTask) SetMaxRetry added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetMaxRetry(limit int64)

func (*GfSpMigrateGVGTask) SetMigratedBytesSize added in v1.1.0 

func (m *GfSpMigrateGVGTask) SetMigratedBytesSize(migratedBytesSize uint64)

func (*GfSpMigrateGVGTask) SetPriority added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetPriority(priority coretask.TPriority)

func (*GfSpMigrateGVGTask) SetRedundancyIdx added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetRedundancyIdx(rIdx int32)

func (*GfSpMigrateGVGTask) SetRetry added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetRetry(retry int64)

func (*GfSpMigrateGVGTask) SetSignature added in v0.2.6 

func (m *GfSpMigrateGVGTask) SetSignature(signature []byte)

func (*GfSpMigrateGVGTask) SetSrcGvg added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetSrcGvg(gvg *virtualgrouptypes.GlobalVirtualGroup)

func (*GfSpMigrateGVGTask) SetSrcSp added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetSrcSp(srcSP *sptypes.StorageProvider)

func (*GfSpMigrateGVGTask) SetTimeout added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetTimeout(time int64)

func (*GfSpMigrateGVGTask) SetUpdateTime added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetUpdateTime(time int64)

func (*GfSpMigrateGVGTask) SetUserAddress added in v0.2.4 

func (m *GfSpMigrateGVGTask) SetUserAddress(s string)

func (*GfSpMigrateGVGTask) Size added in v0.2.4 

func (m *GfSpMigrateGVGTask) Size() (n int)

func (*GfSpMigrateGVGTask) String added in v0.2.4 

func (m *GfSpMigrateGVGTask) String() string

func (*GfSpMigrateGVGTask) Type added in v0.2.4 

func (m *GfSpMigrateGVGTask) Type() coretask.TType

func (*GfSpMigrateGVGTask) Unmarshal added in v0.2.4 

func (m *GfSpMigrateGVGTask) Unmarshal(dAtA []byte) error

func (*GfSpMigrateGVGTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpMigrateGVGTask) XXX_DiscardUnknown()

func (*GfSpMigrateGVGTask) XXX_Marshal added in v0.2.4 

func (m *GfSpMigrateGVGTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpMigrateGVGTask) XXX_Merge added in v0.2.4 

func (m *GfSpMigrateGVGTask) XXX_Merge(src proto.Message)

func (*GfSpMigrateGVGTask) XXX_Size added in v0.2.4 

func (m *GfSpMigrateGVGTask) XXX_Size() int

func (*GfSpMigrateGVGTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpMigrateGVGTask) XXX_Unmarshal(b []byte) error

type GfSpMigratePieceTask added in v0.2.4 

type GfSpMigratePieceTask struct {
	Task            *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo      *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams   *types.Params     `protobuf:"bytes,3,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	SrcSpEndpoint   string            `protobuf:"bytes,4,opt,name=src_sp_endpoint,json=srcSpEndpoint,proto3" json:"src_sp_endpoint,omitempty"`
	SegmentIdx      uint32            `protobuf:"varint,5,opt,name=segment_idx,json=segmentIdx,proto3" json:"segment_idx,omitempty"`
	RedundancyIdx   int32             `protobuf:"varint,6,opt,name=redundancy_idx,json=redundancyIdx,proto3" json:"redundancy_idx,omitempty"`
	IsBucketMigrate bool              `protobuf:"varint,7,opt,name=is_bucket_migrate,json=isBucketMigrate,proto3" json:"is_bucket_migrate,omitempty"`
}

func (*GfSpMigratePieceTask) Descriptor added in v0.2.4 

func (*GfSpMigratePieceTask) Descriptor() ([]byte, []int)

func (*GfSpMigratePieceTask) GetIsBucketMigrate added in v0.2.4 

func (m *GfSpMigratePieceTask) GetIsBucketMigrate() bool

func (*GfSpMigratePieceTask) GetObjectInfo added in v0.2.4 

func (m *GfSpMigratePieceTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpMigratePieceTask) GetRedundancyIdx added in v0.2.4 

func (m *GfSpMigratePieceTask) GetRedundancyIdx() int32

func (*GfSpMigratePieceTask) GetSegmentIdx added in v0.2.4 

func (m *GfSpMigratePieceTask) GetSegmentIdx() uint32

func (*GfSpMigratePieceTask) GetSrcSpEndpoint added in v0.2.4 

func (m *GfSpMigratePieceTask) GetSrcSpEndpoint() string

func (*GfSpMigratePieceTask) GetStorageParams added in v0.2.4 

func (m *GfSpMigratePieceTask) GetStorageParams() *types.Params

func (*GfSpMigratePieceTask) GetTask added in v0.2.4 

func (m *GfSpMigratePieceTask) GetTask() *GfSpTask

func (*GfSpMigratePieceTask) Key added in v0.2.4 

func (g *GfSpMigratePieceTask) Key() coretask.TKey

func (*GfSpMigratePieceTask) Marshal added in v0.2.4 

func (m *GfSpMigratePieceTask) Marshal() (dAtA []byte, err error)

func (*GfSpMigratePieceTask) MarshalTo added in v0.2.4 

func (m *GfSpMigratePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpMigratePieceTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpMigratePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpMigratePieceTask) ProtoMessage added in v0.2.4 

func (*GfSpMigratePieceTask) ProtoMessage()

func (*GfSpMigratePieceTask) Reset added in v0.2.4 

func (m *GfSpMigratePieceTask) Reset()

func (*GfSpMigratePieceTask) Size added in v0.2.4 

func (m *GfSpMigratePieceTask) Size() (n int)

func (*GfSpMigratePieceTask) String added in v0.2.4 

func (m *GfSpMigratePieceTask) String() string

func (*GfSpMigratePieceTask) Unmarshal added in v0.2.4 

func (m *GfSpMigratePieceTask) Unmarshal(dAtA []byte) error

func (*GfSpMigratePieceTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpMigratePieceTask) XXX_DiscardUnknown()

func (*GfSpMigratePieceTask) XXX_Marshal added in v0.2.4 

func (m *GfSpMigratePieceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpMigratePieceTask) XXX_Merge added in v0.2.4 

func (m *GfSpMigratePieceTask) XXX_Merge(src proto.Message)

func (*GfSpMigratePieceTask) XXX_Size added in v0.2.4 

func (m *GfSpMigratePieceTask) XXX_Size() int

func (*GfSpMigratePieceTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpMigratePieceTask) XXX_Unmarshal(b []byte) error

type GfSpReceivePieceTask added in v0.2.4 

type GfSpReceivePieceTask struct {
	Task                 *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo           *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams        *types.Params     `protobuf:"bytes,3,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	SegmentIdx           uint32            `protobuf:"varint,4,opt,name=segment_idx,json=segmentIdx,proto3" json:"segment_idx,omitempty"`
	RedundancyIdx        int32             `protobuf:"varint,5,opt,name=redundancy_idx,json=redundancyIdx,proto3" json:"redundancy_idx,omitempty"`
	PieceSize            int64             `protobuf:"varint,6,opt,name=piece_size,json=pieceSize,proto3" json:"piece_size,omitempty"`
	PieceChecksum        []byte            `protobuf:"bytes,7,opt,name=piece_checksum,json=pieceChecksum,proto3" json:"piece_checksum,omitempty"`
	Signature            []byte            `protobuf:"bytes,8,opt,name=signature,proto3" json:"signature,omitempty"`
	Sealed               bool              `protobuf:"varint,9,opt,name=sealed,proto3" json:"sealed,omitempty"`
	Finished             bool              `protobuf:"varint,10,opt,name=finished,proto3" json:"finished,omitempty"`
	GlobalVirtualGroupId uint32            `` /* 127-byte string literal not displayed */
	BucketMigration      bool              `protobuf:"varint,12,opt,name=bucket_migration,json=bucketMigration,proto3" json:"bucket_migration,omitempty"`
	IsAgentUploadTask    bool              `protobuf:"varint,13,opt,name=is_agent_upload_task,json=isAgentUploadTask,proto3" json:"is_agent_upload_task,omitempty"`
}

func (*GfSpReceivePieceTask) AppendLog added in v0.2.4 

func (m *GfSpReceivePieceTask) AppendLog(log string)

func (*GfSpReceivePieceTask) Descriptor added in v0.2.4 

func (*GfSpReceivePieceTask) Descriptor() ([]byte, []int)

func (*GfSpReceivePieceTask) Error added in v0.2.4 

func (m *GfSpReceivePieceTask) Error() error

func (*GfSpReceivePieceTask) EstimateLimit added in v0.2.4 

func (m *GfSpReceivePieceTask) EstimateLimit() corercmgr.Limit

func (*GfSpReceivePieceTask) ExceedRetry added in v0.2.4 

func (m *GfSpReceivePieceTask) ExceedRetry() bool

func (*GfSpReceivePieceTask) ExceedTimeout added in v0.2.4 

func (m *GfSpReceivePieceTask) ExceedTimeout() bool

func (*GfSpReceivePieceTask) Expired added in v0.2.4 

func (m *GfSpReceivePieceTask) Expired() bool

func (*GfSpReceivePieceTask) GetAddress added in v0.2.4 

func (m *GfSpReceivePieceTask) GetAddress() string

func (*GfSpReceivePieceTask) GetBucketMigration added in v0.2.4 

func (m *GfSpReceivePieceTask) GetBucketMigration() bool

func (*GfSpReceivePieceTask) GetCreateTime added in v0.2.4 

func (m *GfSpReceivePieceTask) GetCreateTime() int64

func (*GfSpReceivePieceTask) GetFinished added in v0.2.4 

func (m *GfSpReceivePieceTask) GetFinished() bool

func (*GfSpReceivePieceTask) GetGlobalVirtualGroupID added in v0.2.4 

func (m *GfSpReceivePieceTask) GetGlobalVirtualGroupID() uint32

func (*GfSpReceivePieceTask) GetGlobalVirtualGroupId added in v0.2.4 

func (m *GfSpReceivePieceTask) GetGlobalVirtualGroupId() uint32

func (*GfSpReceivePieceTask) GetIsAgentUploadTask added in v1.6.0 

func (m *GfSpReceivePieceTask) GetIsAgentUploadTask() bool

func (*GfSpReceivePieceTask) GetLogs added in v0.2.4 

func (m *GfSpReceivePieceTask) GetLogs() string

func (*GfSpReceivePieceTask) GetMaxRetry added in v0.2.4 

func (m *GfSpReceivePieceTask) GetMaxRetry() int64

func (*GfSpReceivePieceTask) GetObjectInfo added in v0.2.4 

func (m *GfSpReceivePieceTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpReceivePieceTask) GetPieceChecksum added in v0.2.4 

func (m *GfSpReceivePieceTask) GetPieceChecksum() []byte

func (*GfSpReceivePieceTask) GetPieceSize added in v0.2.4 

func (m *GfSpReceivePieceTask) GetPieceSize() int64

func (*GfSpReceivePieceTask) GetPriority added in v0.2.4 

func (m *GfSpReceivePieceTask) GetPriority() coretask.TPriority

func (*GfSpReceivePieceTask) GetRedundancyIdx added in v0.2.4 

func (m *GfSpReceivePieceTask) GetRedundancyIdx() int32

func (*GfSpReceivePieceTask) GetRetry added in v0.2.4 

func (m *GfSpReceivePieceTask) GetRetry() int64

func (*GfSpReceivePieceTask) GetSealed added in v0.2.4 

func (m *GfSpReceivePieceTask) GetSealed() bool

func (*GfSpReceivePieceTask) GetSegmentIdx added in v0.2.4 

func (m *GfSpReceivePieceTask) GetSegmentIdx() uint32

func (*GfSpReceivePieceTask) GetSignBytes added in v0.2.4 

func (m *GfSpReceivePieceTask) GetSignBytes() []byte

func (*GfSpReceivePieceTask) GetSignature added in v0.2.4 

func (m *GfSpReceivePieceTask) GetSignature() []byte

func (*GfSpReceivePieceTask) GetStorageParams added in v0.2.4 

func (m *GfSpReceivePieceTask) GetStorageParams() *types.Params

func (*GfSpReceivePieceTask) GetTask added in v0.2.4 

func (m *GfSpReceivePieceTask) GetTask() *GfSpTask

func (*GfSpReceivePieceTask) GetTimeout added in v0.2.4 

func (m *GfSpReceivePieceTask) GetTimeout() int64

func (*GfSpReceivePieceTask) GetUpdateTime added in v0.2.4 

func (m *GfSpReceivePieceTask) GetUpdateTime() int64

func (*GfSpReceivePieceTask) GetUserAddress added in v0.2.4 

func (m *GfSpReceivePieceTask) GetUserAddress() string

func (*GfSpReceivePieceTask) IncRetry added in v0.2.4 

func (m *GfSpReceivePieceTask) IncRetry()

func (*GfSpReceivePieceTask) Info added in v0.2.4 

func (m *GfSpReceivePieceTask) Info() string

func (*GfSpReceivePieceTask) InitReceivePieceTask added in v0.2.4 

func (m *GfSpReceivePieceTask) InitReceivePieceTask(gvgID uint32, object *storagetypes.ObjectInfo, params *storagetypes.Params,
	priority coretask.TPriority, segmentIdx uint32, redundancyIdx int32, pieceSize int64, isAgentUpload bool)

func (*GfSpReceivePieceTask) Key added in v0.2.4 

func (m *GfSpReceivePieceTask) Key() coretask.TKey

func (*GfSpReceivePieceTask) Marshal added in v0.2.4 

func (m *GfSpReceivePieceTask) Marshal() (dAtA []byte, err error)

func (*GfSpReceivePieceTask) MarshalTo added in v0.2.4 

func (m *GfSpReceivePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReceivePieceTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpReceivePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReceivePieceTask) ProtoMessage added in v0.2.4 

func (*GfSpReceivePieceTask) ProtoMessage()

func (*GfSpReceivePieceTask) Reset added in v0.2.4 

func (m *GfSpReceivePieceTask) Reset()

func (*GfSpReceivePieceTask) SetAddress added in v0.2.4 

func (m *GfSpReceivePieceTask) SetAddress(address string)

func (*GfSpReceivePieceTask) SetBucketMigration added in v0.2.4 

func (m *GfSpReceivePieceTask) SetBucketMigration(migration bool)

func (*GfSpReceivePieceTask) SetCreateTime added in v0.2.4 

func (m *GfSpReceivePieceTask) SetCreateTime(time int64)

func (*GfSpReceivePieceTask) SetError added in v0.2.4 

func (m *GfSpReceivePieceTask) SetError(err error)

func (*GfSpReceivePieceTask) SetFinished added in v0.2.4 

func (m *GfSpReceivePieceTask) SetFinished(finished bool)

func (*GfSpReceivePieceTask) SetGlobalVirtualGroupID added in v0.2.4 

func (m *GfSpReceivePieceTask) SetGlobalVirtualGroupID(gvgID uint32)

func (*GfSpReceivePieceTask) SetLogs added in v0.2.4 

func (m *GfSpReceivePieceTask) SetLogs(logs string)

func (*GfSpReceivePieceTask) SetMaxRetry added in v0.2.4 

func (m *GfSpReceivePieceTask) SetMaxRetry(limit int64)

func (*GfSpReceivePieceTask) SetObjectInfo added in v0.2.4 

func (m *GfSpReceivePieceTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpReceivePieceTask) SetPieceChecksum added in v0.2.4 

func (m *GfSpReceivePieceTask) SetPieceChecksum(checksum []byte)

func (*GfSpReceivePieceTask) SetPieceSize added in v0.2.4 

func (m *GfSpReceivePieceTask) SetPieceSize(size int64)

func (*GfSpReceivePieceTask) SetPriority added in v0.2.4 

func (m *GfSpReceivePieceTask) SetPriority(priority coretask.TPriority)

func (*GfSpReceivePieceTask) SetRedundancyIdx added in v0.2.4 

func (m *GfSpReceivePieceTask) SetRedundancyIdx(idx int32)

func (*GfSpReceivePieceTask) SetRetry added in v0.2.4 

func (m *GfSpReceivePieceTask) SetRetry(retry int64)

func (*GfSpReceivePieceTask) SetSealed added in v0.2.4 

func (m *GfSpReceivePieceTask) SetSealed(seal bool)

func (*GfSpReceivePieceTask) SetSegmentIdx added in v0.2.4 

func (m *GfSpReceivePieceTask) SetSegmentIdx(idx uint32)

func (*GfSpReceivePieceTask) SetSignature added in v0.2.4 

func (m *GfSpReceivePieceTask) SetSignature(signature []byte)

func (*GfSpReceivePieceTask) SetStorageParams added in v0.2.4 

func (m *GfSpReceivePieceTask) SetStorageParams(param *storagetypes.Params)

func (*GfSpReceivePieceTask) SetTimeout added in v0.2.4 

func (m *GfSpReceivePieceTask) SetTimeout(time int64)

func (*GfSpReceivePieceTask) SetUpdateTime added in v0.2.4 

func (m *GfSpReceivePieceTask) SetUpdateTime(time int64)

func (*GfSpReceivePieceTask) SetUserAddress added in v0.2.4 

func (m *GfSpReceivePieceTask) SetUserAddress(address string)

func (*GfSpReceivePieceTask) Size added in v0.2.4 

func (m *GfSpReceivePieceTask) Size() (n int)

func (*GfSpReceivePieceTask) String added in v0.2.4 

func (m *GfSpReceivePieceTask) String() string

func (*GfSpReceivePieceTask) Type added in v0.2.4 

func (m *GfSpReceivePieceTask) Type() coretask.TType

func (*GfSpReceivePieceTask) Unmarshal added in v0.2.4 

func (m *GfSpReceivePieceTask) Unmarshal(dAtA []byte) error

func (*GfSpReceivePieceTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpReceivePieceTask) XXX_DiscardUnknown()

func (*GfSpReceivePieceTask) XXX_Marshal added in v0.2.4 

func (m *GfSpReceivePieceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpReceivePieceTask) XXX_Merge added in v0.2.4 

func (m *GfSpReceivePieceTask) XXX_Merge(src proto.Message)

func (*GfSpReceivePieceTask) XXX_Size added in v0.2.4 

func (m *GfSpReceivePieceTask) XXX_Size() int

func (*GfSpReceivePieceTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpReceivePieceTask) XXX_Unmarshal(b []byte) error

type GfSpRecoverPieceTask added in v0.2.4 

type GfSpRecoverPieceTask struct {
	Task          *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo    *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams *types.Params     `protobuf:"bytes,3,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	SegmentIdx    uint32            `protobuf:"varint,4,opt,name=segment_idx,json=segmentIdx,proto3" json:"segment_idx,omitempty"`
	EcIdx         int32             `protobuf:"varint,5,opt,name=ec_idx,json=ecIdx,proto3" json:"ec_idx,omitempty"`
	PieceSize     uint64            `protobuf:"varint,6,opt,name=piece_size,json=pieceSize,proto3" json:"piece_size,omitempty"`
	Signature     []byte            `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
	Recovered     bool              `protobuf:"varint,8,opt,name=recovered,proto3" json:"recovered,omitempty"`
	BySuccessorSp bool              `protobuf:"varint,9,opt,name=by_successor_sp,json=bySuccessorSp,proto3" json:"by_successor_sp,omitempty"`
	GvgId         uint32            `protobuf:"varint,10,opt,name=gvg_id,json=gvgId,proto3" json:"gvg_id,omitempty"`
}

func (*GfSpRecoverPieceTask) AppendLog added in v0.2.4 

func (m *GfSpRecoverPieceTask) AppendLog(log string)

func (*GfSpRecoverPieceTask) BySuccessorSP added in v1.3.0 

func (m *GfSpRecoverPieceTask) BySuccessorSP() bool

func (*GfSpRecoverPieceTask) Descriptor added in v0.2.4 

func (*GfSpRecoverPieceTask) Descriptor() ([]byte, []int)

func (*GfSpRecoverPieceTask) Error added in v0.2.4 

func (m *GfSpRecoverPieceTask) Error() error

func (*GfSpRecoverPieceTask) EstimateLimit added in v0.2.4 

func (m *GfSpRecoverPieceTask) EstimateLimit() corercmgr.Limit

func (*GfSpRecoverPieceTask) ExceedRetry added in v0.2.4 

func (m *GfSpRecoverPieceTask) ExceedRetry() bool

func (*GfSpRecoverPieceTask) ExceedTimeout added in v0.2.4 

func (m *GfSpRecoverPieceTask) ExceedTimeout() bool

func (*GfSpRecoverPieceTask) Expired added in v0.2.4 

func (m *GfSpRecoverPieceTask) Expired() bool

func (*GfSpRecoverPieceTask) GetAddress added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetAddress() string

func (*GfSpRecoverPieceTask) GetBySuccessorSp added in v1.3.0 

func (m *GfSpRecoverPieceTask) GetBySuccessorSp() bool

func (*GfSpRecoverPieceTask) GetCreateTime added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetCreateTime() int64

func (*GfSpRecoverPieceTask) GetEcIdx added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetEcIdx() int32

func (*GfSpRecoverPieceTask) GetGVGID added in v1.3.0 

func (m *GfSpRecoverPieceTask) GetGVGID() uint32

func (*GfSpRecoverPieceTask) GetGvgId added in v1.3.0 

func (m *GfSpRecoverPieceTask) GetGvgId() uint32

func (*GfSpRecoverPieceTask) GetLogs added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetLogs() string

func (*GfSpRecoverPieceTask) GetMaxRetry added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetMaxRetry() int64

func (*GfSpRecoverPieceTask) GetObjectInfo added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpRecoverPieceTask) GetPieceSize added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetPieceSize() uint64

func (*GfSpRecoverPieceTask) GetPriority added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetPriority() coretask.TPriority

func (*GfSpRecoverPieceTask) GetRecovered added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetRecovered() bool

func (*GfSpRecoverPieceTask) GetRetry added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetRetry() int64

func (*GfSpRecoverPieceTask) GetSegmentIdx added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetSegmentIdx() uint32

func (*GfSpRecoverPieceTask) GetSignBytes added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetSignBytes() []byte

func (*GfSpRecoverPieceTask) GetSignature added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetSignature() []byte

func (*GfSpRecoverPieceTask) GetStorageParams added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetStorageParams() *types.Params

func (*GfSpRecoverPieceTask) GetTask added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetTask() *GfSpTask

func (*GfSpRecoverPieceTask) GetTimeout added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetTimeout() int64

func (*GfSpRecoverPieceTask) GetUpdateTime added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetUpdateTime() int64

func (*GfSpRecoverPieceTask) GetUserAddress added in v0.2.4 

func (m *GfSpRecoverPieceTask) GetUserAddress() string

func (*GfSpRecoverPieceTask) IncRetry added in v0.2.4 

func (m *GfSpRecoverPieceTask) IncRetry()

func (*GfSpRecoverPieceTask) Info added in v0.2.4 

func (m *GfSpRecoverPieceTask) Info() string

func (*GfSpRecoverPieceTask) InitRecoverPieceTask added in v0.2.4 

func (m *GfSpRecoverPieceTask) InitRecoverPieceTask(object *storagetypes.ObjectInfo, params *storagetypes.Params,
	priority coretask.TPriority, segmentIdx uint32, ecIdx int32, pieceSize uint64, timeout int64, retry int64)

func (*GfSpRecoverPieceTask) Key added in v0.2.4 

func (m *GfSpRecoverPieceTask) Key() coretask.TKey

func (*GfSpRecoverPieceTask) Marshal added in v0.2.4 

func (m *GfSpRecoverPieceTask) Marshal() (dAtA []byte, err error)

func (*GfSpRecoverPieceTask) MarshalTo added in v0.2.4 

func (m *GfSpRecoverPieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpRecoverPieceTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpRecoverPieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpRecoverPieceTask) ProtoMessage added in v0.2.4 

func (*GfSpRecoverPieceTask) ProtoMessage()

func (*GfSpRecoverPieceTask) Reset added in v0.2.4 

func (m *GfSpRecoverPieceTask) Reset()

func (*GfSpRecoverPieceTask) SetAddress added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetAddress(address string)

func (*GfSpRecoverPieceTask) SetBySuccessorSP added in v1.3.0 

func (m *GfSpRecoverPieceTask) SetBySuccessorSP(bySuccessor bool)

func (*GfSpRecoverPieceTask) SetCreateTime added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetCreateTime(time int64)

func (*GfSpRecoverPieceTask) SetECIndex added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetECIndex(index int32)

func (*GfSpRecoverPieceTask) SetError added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetError(err error)

func (*GfSpRecoverPieceTask) SetGVGID added in v1.3.0 

func (m *GfSpRecoverPieceTask) SetGVGID(gvgID uint32)

func (*GfSpRecoverPieceTask) SetLogs added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetLogs(logs string)

func (*GfSpRecoverPieceTask) SetMaxRetry added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetMaxRetry(limit int64)

func (*GfSpRecoverPieceTask) SetObjectInfo added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpRecoverPieceTask) SetPieceSize added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetPieceSize(size uint64)

func (*GfSpRecoverPieceTask) SetPriority added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetPriority(priority coretask.TPriority)

func (*GfSpRecoverPieceTask) SetRecoverDone added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetRecoverDone()

func (*GfSpRecoverPieceTask) SetRetry added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetRetry(retry int64)

func (*GfSpRecoverPieceTask) SetSegmentIndex added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetSegmentIndex(index uint32)

func (*GfSpRecoverPieceTask) SetSignature added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetSignature(signature []byte)

func (*GfSpRecoverPieceTask) SetStorageParams added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetStorageParams(param *storagetypes.Params)

func (*GfSpRecoverPieceTask) SetTimeout added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetTimeout(time int64)

func (*GfSpRecoverPieceTask) SetUpdateTime added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetUpdateTime(time int64)

func (*GfSpRecoverPieceTask) SetUserAddress added in v0.2.4 

func (m *GfSpRecoverPieceTask) SetUserAddress(address string)

func (*GfSpRecoverPieceTask) Size added in v0.2.4 

func (m *GfSpRecoverPieceTask) Size() (n int)

func (*GfSpRecoverPieceTask) String added in v0.2.4 

func (m *GfSpRecoverPieceTask) String() string

func (*GfSpRecoverPieceTask) Type added in v0.2.4 

func (m *GfSpRecoverPieceTask) Type() coretask.TType

func (*GfSpRecoverPieceTask) Unmarshal added in v0.2.4 

func (m *GfSpRecoverPieceTask) Unmarshal(dAtA []byte) error

func (*GfSpRecoverPieceTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpRecoverPieceTask) XXX_DiscardUnknown()

func (*GfSpRecoverPieceTask) XXX_Marshal added in v0.2.4 

func (m *GfSpRecoverPieceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpRecoverPieceTask) XXX_Merge added in v0.2.4 

func (m *GfSpRecoverPieceTask) XXX_Merge(src proto.Message)

func (*GfSpRecoverPieceTask) XXX_Size added in v0.2.4 

func (m *GfSpRecoverPieceTask) XXX_Size() int

func (*GfSpRecoverPieceTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpRecoverPieceTask) XXX_Unmarshal(b []byte) error

type GfSpReplicatePieceApprovalTask added in v0.2.4 

type GfSpReplicatePieceApprovalTask struct {
	Task                      *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo                *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams             *types.Params     `protobuf:"bytes,3,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	AskSpOperatorAddress      string            `protobuf:"bytes,4,opt,name=ask_sp_operator_address,json=askSpOperatorAddress,proto3" json:"ask_sp_operator_address,omitempty"`
	AskSignature              []byte            `protobuf:"bytes,5,opt,name=ask_signature,json=askSignature,proto3" json:"ask_signature,omitempty"`
	ApprovedSpEndpoint        string            `protobuf:"bytes,6,opt,name=approved_sp_endpoint,json=approvedSpEndpoint,proto3" json:"approved_sp_endpoint,omitempty"`
	ApprovedSpOperatorAddress string            `` /* 140-byte string literal not displayed */
	ApprovedSignature         []byte            `protobuf:"bytes,8,opt,name=approved_signature,json=approvedSignature,proto3" json:"approved_signature,omitempty"`
	ApprovedSpApprovalAddress string            `` /* 140-byte string literal not displayed */
	ExpiredHeight             uint64            `protobuf:"varint,10,opt,name=expired_height,json=expiredHeight,proto3" json:"expired_height,omitempty"`
}

func (*GfSpReplicatePieceApprovalTask) AppendLog added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) AppendLog(log string)

func (*GfSpReplicatePieceApprovalTask) Descriptor added in v0.2.4 

func (*GfSpReplicatePieceApprovalTask) Descriptor() ([]byte, []int)

func (*GfSpReplicatePieceApprovalTask) Error added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Error() error

func (*GfSpReplicatePieceApprovalTask) EstimateLimit added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) EstimateLimit() corercmgr.Limit

func (*GfSpReplicatePieceApprovalTask) ExceedRetry added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) ExceedRetry() bool

func (*GfSpReplicatePieceApprovalTask) ExceedTimeout added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) ExceedTimeout() bool

func (*GfSpReplicatePieceApprovalTask) Expired added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Expired() bool

func (*GfSpReplicatePieceApprovalTask) GetAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetAddress() string

func (*GfSpReplicatePieceApprovalTask) GetApprovedSignature added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetApprovedSignature() []byte

func (*GfSpReplicatePieceApprovalTask) GetApprovedSpApprovalAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetApprovedSpApprovalAddress() string

func (*GfSpReplicatePieceApprovalTask) GetApprovedSpEndpoint added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetApprovedSpEndpoint() string

func (*GfSpReplicatePieceApprovalTask) GetApprovedSpOperatorAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetApprovedSpOperatorAddress() string

func (*GfSpReplicatePieceApprovalTask) GetAskSignature added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetAskSignature() []byte

func (*GfSpReplicatePieceApprovalTask) GetAskSpOperatorAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetAskSpOperatorAddress() string

func (*GfSpReplicatePieceApprovalTask) GetCreateTime added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetCreateTime() int64

func (*GfSpReplicatePieceApprovalTask) GetExpiredHeight added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetExpiredHeight() uint64

func (*GfSpReplicatePieceApprovalTask) GetLogs added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetLogs() string

func (*GfSpReplicatePieceApprovalTask) GetMaxRetry added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetMaxRetry() int64

func (*GfSpReplicatePieceApprovalTask) GetObjectInfo added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpReplicatePieceApprovalTask) GetPriority added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetPriority() coretask.TPriority

func (*GfSpReplicatePieceApprovalTask) GetRetry added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetRetry() int64

func (*GfSpReplicatePieceApprovalTask) GetSignBytes added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetSignBytes() []byte

func (*GfSpReplicatePieceApprovalTask) GetStorageParams added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetStorageParams() *types.Params

func (*GfSpReplicatePieceApprovalTask) GetTask added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetTask() *GfSpTask

func (*GfSpReplicatePieceApprovalTask) GetTimeout added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetTimeout() int64

func (*GfSpReplicatePieceApprovalTask) GetUpdateTime added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetUpdateTime() int64

func (*GfSpReplicatePieceApprovalTask) GetUserAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) GetUserAddress() string

func (*GfSpReplicatePieceApprovalTask) IncRetry added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) IncRetry()

func (*GfSpReplicatePieceApprovalTask) Info added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Info() string

func (*GfSpReplicatePieceApprovalTask) InitApprovalReplicatePieceTask added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) InitApprovalReplicatePieceTask(object *storagetypes.ObjectInfo,
	params *storagetypes.Params, priority coretask.TPriority, askOpAddress string)

func (*GfSpReplicatePieceApprovalTask) Key added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Key() coretask.TKey

func (*GfSpReplicatePieceApprovalTask) Marshal added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Marshal() (dAtA []byte, err error)

func (*GfSpReplicatePieceApprovalTask) MarshalTo added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReplicatePieceApprovalTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReplicatePieceApprovalTask) ProtoMessage added in v0.2.4 

func (*GfSpReplicatePieceApprovalTask) ProtoMessage()

func (*GfSpReplicatePieceApprovalTask) Reset added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Reset()

func (*GfSpReplicatePieceApprovalTask) SetAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetAddress(address string)

func (*GfSpReplicatePieceApprovalTask) SetApprovedSignature added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetApprovedSignature(signature []byte)

func (*GfSpReplicatePieceApprovalTask) SetApprovedSpApprovalAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetApprovedSpApprovalAddress(address string)

func (*GfSpReplicatePieceApprovalTask) SetApprovedSpEndpoint added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetApprovedSpEndpoint(endpoint string)

func (*GfSpReplicatePieceApprovalTask) SetApprovedSpOperatorAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetApprovedSpOperatorAddress(address string)

func (*GfSpReplicatePieceApprovalTask) SetAskSignature added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetAskSignature(signature []byte)

func (*GfSpReplicatePieceApprovalTask) SetAskSpOperatorAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetAskSpOperatorAddress(address string)

func (*GfSpReplicatePieceApprovalTask) SetCreateTime added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetCreateTime(time int64)

func (*GfSpReplicatePieceApprovalTask) SetError added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetError(err error)

func (*GfSpReplicatePieceApprovalTask) SetExpiredHeight added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetExpiredHeight(height uint64)

func (*GfSpReplicatePieceApprovalTask) SetLogs added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetLogs(logs string)

func (*GfSpReplicatePieceApprovalTask) SetMaxRetry added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetMaxRetry(limit int64)

func (*GfSpReplicatePieceApprovalTask) SetObjectInfo added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpReplicatePieceApprovalTask) SetPriority added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetPriority(priority coretask.TPriority)

func (*GfSpReplicatePieceApprovalTask) SetRetry added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetRetry(retry int64)

func (*GfSpReplicatePieceApprovalTask) SetStorageParams added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetStorageParams(params *storagetypes.Params)

func (*GfSpReplicatePieceApprovalTask) SetTimeout added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetTimeout(time int64)

func (*GfSpReplicatePieceApprovalTask) SetUpdateTime added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetUpdateTime(time int64)

func (*GfSpReplicatePieceApprovalTask) SetUserAddress added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) SetUserAddress(address string)

func (*GfSpReplicatePieceApprovalTask) Size added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Size() (n int)

func (*GfSpReplicatePieceApprovalTask) String added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) String() string

func (*GfSpReplicatePieceApprovalTask) Type added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Type() coretask.TType

func (*GfSpReplicatePieceApprovalTask) Unmarshal added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) Unmarshal(dAtA []byte) error

func (*GfSpReplicatePieceApprovalTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) XXX_DiscardUnknown()

func (*GfSpReplicatePieceApprovalTask) XXX_Marshal added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpReplicatePieceApprovalTask) XXX_Merge added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) XXX_Merge(src proto.Message)

func (*GfSpReplicatePieceApprovalTask) XXX_Size added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) XXX_Size() int

func (*GfSpReplicatePieceApprovalTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpReplicatePieceApprovalTask) XXX_Unmarshal(b []byte) error

type GfSpReplicatePieceTask added in v0.2.4 

type GfSpReplicatePieceTask struct {
	Task                 *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo           *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams        *types.Params     `protobuf:"bytes,3,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	SecondaryAddresses   []string          `protobuf:"bytes,4,rep,name=secondary_addresses,json=secondaryAddresses,proto3" json:"secondary_addresses,omitempty"`
	SecondarySignatures  [][]byte          `protobuf:"bytes,5,rep,name=secondary_signatures,json=secondarySignatures,proto3" json:"secondary_signatures,omitempty"`
	Sealed               bool              `protobuf:"varint,6,opt,name=sealed,proto3" json:"sealed,omitempty"`
	GlobalVirtualGroupId uint32            `` /* 126-byte string literal not displayed */
	SecondaryEndpoints   []string          `protobuf:"bytes,8,rep,name=secondary_endpoints,json=secondaryEndpoints,proto3" json:"secondary_endpoints,omitempty"`
	NotAvailableSpIdx    int32             `protobuf:"varint,9,opt,name=not_available_sp_idx,json=notAvailableSpIdx,proto3" json:"not_available_sp_idx,omitempty"`
	IsAgentUploadTask    bool              `protobuf:"varint,10,opt,name=is_agent_upload_task,json=isAgentUploadTask,proto3" json:"is_agent_upload_task,omitempty"`
}

func (*GfSpReplicatePieceTask) AppendLog added in v0.2.4 

func (m *GfSpReplicatePieceTask) AppendLog(log string)

func (*GfSpReplicatePieceTask) Descriptor added in v0.2.4 

func (*GfSpReplicatePieceTask) Descriptor() ([]byte, []int)

func (*GfSpReplicatePieceTask) Error added in v0.2.4 

func (m *GfSpReplicatePieceTask) Error() error

func (*GfSpReplicatePieceTask) EstimateLimit added in v0.2.4 

func (m *GfSpReplicatePieceTask) EstimateLimit() corercmgr.Limit

func (*GfSpReplicatePieceTask) ExceedRetry added in v0.2.4 

func (m *GfSpReplicatePieceTask) ExceedRetry() bool

func (*GfSpReplicatePieceTask) ExceedTimeout added in v0.2.4 

func (m *GfSpReplicatePieceTask) ExceedTimeout() bool

func (*GfSpReplicatePieceTask) Expired added in v0.2.4 

func (m *GfSpReplicatePieceTask) Expired() bool

func (*GfSpReplicatePieceTask) GetAddress added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetAddress() string

func (*GfSpReplicatePieceTask) GetCreateTime added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetCreateTime() int64

func (*GfSpReplicatePieceTask) GetGlobalVirtualGroupId added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetGlobalVirtualGroupId() uint32

func (*GfSpReplicatePieceTask) GetIsAgentUpload added in v1.6.0 

func (m *GfSpReplicatePieceTask) GetIsAgentUpload() bool

func (*GfSpReplicatePieceTask) GetIsAgentUploadTask added in v1.6.0 

func (m *GfSpReplicatePieceTask) GetIsAgentUploadTask() bool

func (*GfSpReplicatePieceTask) GetLogs added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetLogs() string

func (*GfSpReplicatePieceTask) GetMaxRetry added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetMaxRetry() int64

func (*GfSpReplicatePieceTask) GetNotAvailableSpIdx added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetNotAvailableSpIdx() int32

func (*GfSpReplicatePieceTask) GetObjectInfo added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpReplicatePieceTask) GetPriority added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetPriority() coretask.TPriority

func (*GfSpReplicatePieceTask) GetRetry added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetRetry() int64

func (*GfSpReplicatePieceTask) GetSealed added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetSealed() bool

func (*GfSpReplicatePieceTask) GetSecondaryAddresses added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetSecondaryAddresses() []string

func (*GfSpReplicatePieceTask) GetSecondaryEndpoints added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetSecondaryEndpoints() []string

func (*GfSpReplicatePieceTask) GetSecondarySignatures added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetSecondarySignatures() [][]byte

func (*GfSpReplicatePieceTask) GetStorageParams added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetStorageParams() *types.Params

func (*GfSpReplicatePieceTask) GetTask added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetTask() *GfSpTask

func (*GfSpReplicatePieceTask) GetTimeout added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetTimeout() int64

func (*GfSpReplicatePieceTask) GetUpdateTime added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetUpdateTime() int64

func (*GfSpReplicatePieceTask) GetUserAddress added in v0.2.4 

func (m *GfSpReplicatePieceTask) GetUserAddress() string

func (*GfSpReplicatePieceTask) IncRetry added in v0.2.4 

func (m *GfSpReplicatePieceTask) IncRetry()

func (*GfSpReplicatePieceTask) Info added in v0.2.4 

func (m *GfSpReplicatePieceTask) Info() string

func (*GfSpReplicatePieceTask) InitReplicatePieceTask added in v0.2.4 

func (m *GfSpReplicatePieceTask) InitReplicatePieceTask(object *storagetypes.ObjectInfo, params *storagetypes.Params,
	priority coretask.TPriority, timeout int64, retry int64, isAgentUploadTask bool)

func (*GfSpReplicatePieceTask) Key added in v0.2.4 

func (m *GfSpReplicatePieceTask) Key() coretask.TKey

func (*GfSpReplicatePieceTask) Marshal added in v0.2.4 

func (m *GfSpReplicatePieceTask) Marshal() (dAtA []byte, err error)

func (*GfSpReplicatePieceTask) MarshalTo added in v0.2.4 

func (m *GfSpReplicatePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReplicatePieceTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpReplicatePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReplicatePieceTask) ProtoMessage added in v0.2.4 

func (*GfSpReplicatePieceTask) ProtoMessage()

func (*GfSpReplicatePieceTask) Reset added in v0.2.4 

func (m *GfSpReplicatePieceTask) Reset()

func (*GfSpReplicatePieceTask) SetAddress added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetAddress(address string)

func (*GfSpReplicatePieceTask) SetCreateTime added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetCreateTime(time int64)

func (*GfSpReplicatePieceTask) SetError added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetError(err error)

func (*GfSpReplicatePieceTask) SetLogs added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetLogs(logs string)

func (*GfSpReplicatePieceTask) SetMaxRetry added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetMaxRetry(limit int64)

func (*GfSpReplicatePieceTask) SetNotAvailableSpIdx added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetNotAvailableSpIdx(idx int32)

func (*GfSpReplicatePieceTask) SetObjectInfo added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpReplicatePieceTask) SetPriority added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetPriority(priority coretask.TPriority)

func (*GfSpReplicatePieceTask) SetRetry added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetRetry(retry int64)

func (*GfSpReplicatePieceTask) SetSealed added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetSealed(sealed bool)

func (*GfSpReplicatePieceTask) SetSecondaryAddresses added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetSecondaryAddresses(addresses []string)

func (*GfSpReplicatePieceTask) SetSecondarySignatures added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetSecondarySignatures(signatures [][]byte)

func (*GfSpReplicatePieceTask) SetStorageParams added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetStorageParams(param *storagetypes.Params)

func (*GfSpReplicatePieceTask) SetTimeout added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetTimeout(time int64)

func (*GfSpReplicatePieceTask) SetUpdateTime added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetUpdateTime(time int64)

func (*GfSpReplicatePieceTask) SetUserAddress added in v0.2.4 

func (m *GfSpReplicatePieceTask) SetUserAddress(address string)

func (*GfSpReplicatePieceTask) Size added in v0.2.4 

func (m *GfSpReplicatePieceTask) Size() (n int)

func (*GfSpReplicatePieceTask) String added in v0.2.4 

func (m *GfSpReplicatePieceTask) String() string

func (*GfSpReplicatePieceTask) Type added in v0.2.4 

func (m *GfSpReplicatePieceTask) Type() coretask.TType

func (*GfSpReplicatePieceTask) Unmarshal added in v0.2.4 

func (m *GfSpReplicatePieceTask) Unmarshal(dAtA []byte) error

func (*GfSpReplicatePieceTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpReplicatePieceTask) XXX_DiscardUnknown()

func (*GfSpReplicatePieceTask) XXX_Marshal added in v0.2.4 

func (m *GfSpReplicatePieceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpReplicatePieceTask) XXX_Merge added in v0.2.4 

func (m *GfSpReplicatePieceTask) XXX_Merge(src proto.Message)

func (*GfSpReplicatePieceTask) XXX_Size added in v0.2.4 

func (m *GfSpReplicatePieceTask) XXX_Size() int

func (*GfSpReplicatePieceTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpReplicatePieceTask) XXX_Unmarshal(b []byte) error

type GfSpResumableUploadObjectTask added in v0.2.4 

type GfSpResumableUploadObjectTask struct {
	Task                 *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo           *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams        *types.Params     `protobuf:"bytes,3,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	Offset               uint64            `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Length               uint64            `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"`
	Completed            bool              `protobuf:"varint,6,opt,name=completed,proto3" json:"completed,omitempty"`
	VirtualGroupFamilyId uint32            `` /* 126-byte string literal not displayed */
	IsAgentUpload        bool              `protobuf:"varint,8,opt,name=is_agent_upload,json=isAgentUpload,proto3" json:"is_agent_upload,omitempty"`
}

func (*GfSpResumableUploadObjectTask) AppendLog added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) AppendLog(log string)

func (*GfSpResumableUploadObjectTask) Descriptor added in v0.2.4 

func (*GfSpResumableUploadObjectTask) Descriptor() ([]byte, []int)

func (*GfSpResumableUploadObjectTask) Error added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Error() error

func (*GfSpResumableUploadObjectTask) EstimateLimit added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) EstimateLimit() corercmgr.Limit

func (*GfSpResumableUploadObjectTask) ExceedRetry added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) ExceedRetry() bool

func (*GfSpResumableUploadObjectTask) ExceedTimeout added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) ExceedTimeout() bool

func (*GfSpResumableUploadObjectTask) Expired added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Expired() bool

func (*GfSpResumableUploadObjectTask) GetAddress added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetAddress() string

func (*GfSpResumableUploadObjectTask) GetCompleted added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetCompleted() bool

func (*GfSpResumableUploadObjectTask) GetCreateTime added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetCreateTime() int64

func (*GfSpResumableUploadObjectTask) GetIsAgentUpload added in v1.6.0 

func (m *GfSpResumableUploadObjectTask) GetIsAgentUpload() bool

func (*GfSpResumableUploadObjectTask) GetLength added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetLength() uint64

func (*GfSpResumableUploadObjectTask) GetLogs added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetLogs() string

func (*GfSpResumableUploadObjectTask) GetMaxRetry added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetMaxRetry() int64

func (*GfSpResumableUploadObjectTask) GetObjectInfo added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpResumableUploadObjectTask) GetOffset added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetOffset() uint64

func (*GfSpResumableUploadObjectTask) GetPriority added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetPriority() coretask.TPriority

func (*GfSpResumableUploadObjectTask) GetResumeOffset added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetResumeOffset() uint64

func (*GfSpResumableUploadObjectTask) GetRetry added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetRetry() int64

func (*GfSpResumableUploadObjectTask) GetStorageParams added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetStorageParams() *types.Params

func (*GfSpResumableUploadObjectTask) GetTask added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetTask() *GfSpTask

func (*GfSpResumableUploadObjectTask) GetTimeout added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetTimeout() int64

func (*GfSpResumableUploadObjectTask) GetUpdateTime added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetUpdateTime() int64

func (*GfSpResumableUploadObjectTask) GetUserAddress added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetUserAddress() string

func (*GfSpResumableUploadObjectTask) GetVirtualGroupFamilyId added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) GetVirtualGroupFamilyId() uint32

func (*GfSpResumableUploadObjectTask) IncRetry added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) IncRetry()

func (*GfSpResumableUploadObjectTask) Info added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Info() string

func (*GfSpResumableUploadObjectTask) InitResumableUploadObjectTask added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) InitResumableUploadObjectTask(vgfID uint32, object *storagetypes.ObjectInfo, params *storagetypes.Params,
	timeout int64, complete bool, offset uint64, isAgentUpload bool)

func (*GfSpResumableUploadObjectTask) Key added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Key() coretask.TKey

func (*GfSpResumableUploadObjectTask) Marshal added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Marshal() (dAtA []byte, err error)

func (*GfSpResumableUploadObjectTask) MarshalTo added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpResumableUploadObjectTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpResumableUploadObjectTask) ProtoMessage added in v0.2.4 

func (*GfSpResumableUploadObjectTask) ProtoMessage()

func (*GfSpResumableUploadObjectTask) Reset added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Reset()

func (*GfSpResumableUploadObjectTask) SetAddress added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetAddress(address string)

func (*GfSpResumableUploadObjectTask) SetCompleted added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetCompleted(completed bool)

func (*GfSpResumableUploadObjectTask) SetCreateTime added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetCreateTime(time int64)

func (*GfSpResumableUploadObjectTask) SetError added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetError(err error)

func (*GfSpResumableUploadObjectTask) SetLogs added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetLogs(logs string)

func (*GfSpResumableUploadObjectTask) SetMaxRetry added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetMaxRetry(limit int64)

func (*GfSpResumableUploadObjectTask) SetObjectInfo added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpResumableUploadObjectTask) SetPriority added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetPriority(priority coretask.TPriority)

func (*GfSpResumableUploadObjectTask) SetResumeOffset added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetResumeOffset(offset uint64)

func (*GfSpResumableUploadObjectTask) SetRetry added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetRetry(retry int64)

func (*GfSpResumableUploadObjectTask) SetStorageParams added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetStorageParams(param *storagetypes.Params)

func (*GfSpResumableUploadObjectTask) SetTimeout added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetTimeout(time int64)

func (*GfSpResumableUploadObjectTask) SetUpdateTime added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetUpdateTime(time int64)

func (*GfSpResumableUploadObjectTask) SetUserAddress added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) SetUserAddress(address string)

func (*GfSpResumableUploadObjectTask) Size added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Size() (n int)

func (*GfSpResumableUploadObjectTask) String added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) String() string

func (*GfSpResumableUploadObjectTask) Type added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Type() coretask.TType

func (*GfSpResumableUploadObjectTask) Unmarshal added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) Unmarshal(dAtA []byte) error

func (*GfSpResumableUploadObjectTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) XXX_DiscardUnknown()

func (*GfSpResumableUploadObjectTask) XXX_Marshal added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpResumableUploadObjectTask) XXX_Merge added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) XXX_Merge(src proto.Message)

func (*GfSpResumableUploadObjectTask) XXX_Size added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) XXX_Size() int

func (*GfSpResumableUploadObjectTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpResumableUploadObjectTask) XXX_Unmarshal(b []byte) error

type GfSpSealObjectTask added in v0.2.4 

type GfSpSealObjectTask struct {
	Task                 *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ObjectInfo           *types.ObjectInfo `protobuf:"bytes,2,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams        *types.Params     `protobuf:"bytes,3,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	SecondaryAddresses   []string          `protobuf:"bytes,4,rep,name=secondary_addresses,json=secondaryAddresses,proto3" json:"secondary_addresses,omitempty"`
	SecondarySignatures  [][]byte          `protobuf:"bytes,5,rep,name=secondary_signatures,json=secondarySignatures,proto3" json:"secondary_signatures,omitempty"`
	GlobalVirtualGroupId uint32            `` /* 126-byte string literal not displayed */
	SecondaryEndpoints   []string          `protobuf:"bytes,7,rep,name=secondary_endpoints,json=secondaryEndpoints,proto3" json:"secondary_endpoints,omitempty"`
	IsAgentUploadTask    bool              `protobuf:"varint,8,opt,name=is_agent_upload_task,json=isAgentUploadTask,proto3" json:"is_agent_upload_task,omitempty"`
}

func (*GfSpSealObjectTask) AppendLog added in v0.2.4 

func (m *GfSpSealObjectTask) AppendLog(log string)

func (*GfSpSealObjectTask) Descriptor added in v0.2.4 

func (*GfSpSealObjectTask) Descriptor() ([]byte, []int)

func (*GfSpSealObjectTask) Error added in v0.2.4 

func (m *GfSpSealObjectTask) Error() error

func (*GfSpSealObjectTask) EstimateLimit added in v0.2.4 

func (m *GfSpSealObjectTask) EstimateLimit() corercmgr.Limit

func (*GfSpSealObjectTask) ExceedRetry added in v0.2.4 

func (m *GfSpSealObjectTask) ExceedRetry() bool

func (*GfSpSealObjectTask) ExceedTimeout added in v0.2.4 

func (m *GfSpSealObjectTask) ExceedTimeout() bool

func (*GfSpSealObjectTask) Expired added in v0.2.4 

func (m *GfSpSealObjectTask) Expired() bool

func (*GfSpSealObjectTask) GetAddress added in v0.2.4 

func (m *GfSpSealObjectTask) GetAddress() string

func (*GfSpSealObjectTask) GetCreateTime added in v0.2.4 

func (m *GfSpSealObjectTask) GetCreateTime() int64

func (*GfSpSealObjectTask) GetGlobalVirtualGroupId added in v0.2.4 

func (m *GfSpSealObjectTask) GetGlobalVirtualGroupId() uint32

func (*GfSpSealObjectTask) GetIsAgentUpload added in v1.6.0 

func (m *GfSpSealObjectTask) GetIsAgentUpload() bool

func (*GfSpSealObjectTask) GetIsAgentUploadTask added in v1.6.0 

func (m *GfSpSealObjectTask) GetIsAgentUploadTask() bool

func (*GfSpSealObjectTask) GetLogs added in v0.2.4 

func (m *GfSpSealObjectTask) GetLogs() string

func (*GfSpSealObjectTask) GetMaxRetry added in v0.2.4 

func (m *GfSpSealObjectTask) GetMaxRetry() int64

func (*GfSpSealObjectTask) GetObjectInfo added in v0.2.4 

func (m *GfSpSealObjectTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpSealObjectTask) GetPriority added in v0.2.4 

func (m *GfSpSealObjectTask) GetPriority() coretask.TPriority

func (*GfSpSealObjectTask) GetRetry added in v0.2.4 

func (m *GfSpSealObjectTask) GetRetry() int64

func (*GfSpSealObjectTask) GetSecondaryAddresses added in v0.2.4 

func (m *GfSpSealObjectTask) GetSecondaryAddresses() []string

func (*GfSpSealObjectTask) GetSecondaryEndpoints added in v0.2.4 

func (m *GfSpSealObjectTask) GetSecondaryEndpoints() []string

func (*GfSpSealObjectTask) GetSecondarySignatures added in v0.2.4 

func (m *GfSpSealObjectTask) GetSecondarySignatures() [][]byte

func (*GfSpSealObjectTask) GetStorageParams added in v0.2.4 

func (m *GfSpSealObjectTask) GetStorageParams() *types.Params

func (*GfSpSealObjectTask) GetTask added in v0.2.4 

func (m *GfSpSealObjectTask) GetTask() *GfSpTask

func (*GfSpSealObjectTask) GetTimeout added in v0.2.4 

func (m *GfSpSealObjectTask) GetTimeout() int64

func (*GfSpSealObjectTask) GetUpdateTime added in v0.2.4 

func (m *GfSpSealObjectTask) GetUpdateTime() int64

func (*GfSpSealObjectTask) GetUserAddress added in v0.2.4 

func (m *GfSpSealObjectTask) GetUserAddress() string

func (*GfSpSealObjectTask) IncRetry added in v0.2.4 

func (m *GfSpSealObjectTask) IncRetry()

func (*GfSpSealObjectTask) Info added in v0.2.4 

func (m *GfSpSealObjectTask) Info() string

func (*GfSpSealObjectTask) InitSealObjectTask added in v0.2.4 

func (m *GfSpSealObjectTask) InitSealObjectTask(vgfID uint32, object *storagetypes.ObjectInfo, params *storagetypes.Params, priority coretask.TPriority,
	endpoints []string, signatures [][]byte, timeout int64, retry int64, isAgentUpload bool)

func (*GfSpSealObjectTask) Key added in v0.2.4 

func (m *GfSpSealObjectTask) Key() coretask.TKey

func (*GfSpSealObjectTask) Marshal added in v0.2.4 

func (m *GfSpSealObjectTask) Marshal() (dAtA []byte, err error)

func (*GfSpSealObjectTask) MarshalTo added in v0.2.4 

func (m *GfSpSealObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSealObjectTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpSealObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSealObjectTask) ProtoMessage added in v0.2.4 

func (*GfSpSealObjectTask) ProtoMessage()

func (*GfSpSealObjectTask) Reset added in v0.2.4 

func (m *GfSpSealObjectTask) Reset()

func (*GfSpSealObjectTask) SetAddress added in v0.2.4 

func (m *GfSpSealObjectTask) SetAddress(address string)

func (*GfSpSealObjectTask) SetCreateTime added in v0.2.4 

func (m *GfSpSealObjectTask) SetCreateTime(time int64)

func (*GfSpSealObjectTask) SetError added in v0.2.4 

func (m *GfSpSealObjectTask) SetError(err error)

func (*GfSpSealObjectTask) SetLogs added in v0.2.4 

func (m *GfSpSealObjectTask) SetLogs(logs string)

func (*GfSpSealObjectTask) SetMaxRetry added in v0.2.4 

func (m *GfSpSealObjectTask) SetMaxRetry(limit int64)

func (*GfSpSealObjectTask) SetObjectInfo added in v0.2.4 

func (m *GfSpSealObjectTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpSealObjectTask) SetPriority added in v0.2.4 

func (m *GfSpSealObjectTask) SetPriority(priority coretask.TPriority)

func (*GfSpSealObjectTask) SetRetry added in v0.2.4 

func (m *GfSpSealObjectTask) SetRetry(retry int64)

func (*GfSpSealObjectTask) SetSecondaryAddresses added in v0.2.4 

func (m *GfSpSealObjectTask) SetSecondaryAddresses(addresses []string)

func (*GfSpSealObjectTask) SetSecondarySignatures added in v0.2.4 

func (m *GfSpSealObjectTask) SetSecondarySignatures(signatures [][]byte)

func (*GfSpSealObjectTask) SetStorageParams added in v0.2.4 

func (m *GfSpSealObjectTask) SetStorageParams(param *storagetypes.Params)

func (*GfSpSealObjectTask) SetTimeout added in v0.2.4 

func (m *GfSpSealObjectTask) SetTimeout(time int64)

func (*GfSpSealObjectTask) SetUpdateTime added in v0.2.4 

func (m *GfSpSealObjectTask) SetUpdateTime(time int64)

func (*GfSpSealObjectTask) SetUserAddress added in v0.2.4 

func (m *GfSpSealObjectTask) SetUserAddress(address string)

func (*GfSpSealObjectTask) Size added in v0.2.4 

func (m *GfSpSealObjectTask) Size() (n int)

func (*GfSpSealObjectTask) String added in v0.2.4 

func (m *GfSpSealObjectTask) String() string

func (*GfSpSealObjectTask) Type added in v0.2.4 

func (m *GfSpSealObjectTask) Type() coretask.TType

func (*GfSpSealObjectTask) Unmarshal added in v0.2.4 

func (m *GfSpSealObjectTask) Unmarshal(dAtA []byte) error

func (*GfSpSealObjectTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpSealObjectTask) XXX_DiscardUnknown()

func (*GfSpSealObjectTask) XXX_Marshal added in v0.2.4 

func (m *GfSpSealObjectTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpSealObjectTask) XXX_Merge added in v0.2.4 

func (m *GfSpSealObjectTask) XXX_Merge(src proto.Message)

func (*GfSpSealObjectTask) XXX_Size added in v0.2.4 

func (m *GfSpSealObjectTask) XXX_Size() int

func (*GfSpSealObjectTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpSealObjectTask) XXX_Unmarshal(b []byte) error

type GfSpTask added in v0.2.4 

type GfSpTask struct {
	Address      string                `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	CreateTime   int64                 `protobuf:"varint,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	UpdateTime   int64                 `protobuf:"varint,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	Timeout      int64                 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	TaskPriority int32                 `protobuf:"varint,5,opt,name=task_priority,json=taskPriority,proto3" json:"task_priority,omitempty"`
	Retry        int64                 `protobuf:"varint,6,opt,name=retry,proto3" json:"retry,omitempty"`
	MaxRetry     int64                 `protobuf:"varint,7,opt,name=max_retry,json=maxRetry,proto3" json:"max_retry,omitempty"`
	UserAddress  string                `protobuf:"bytes,8,opt,name=user_address,json=userAddress,proto3" json:"user_address,omitempty"`
	Logs         string                `protobuf:"bytes,9,opt,name=logs,proto3" json:"logs,omitempty"`
	Err          *gfsperrors.GfSpError `protobuf:"bytes,10,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GfSpTask) AppendLog added in v0.2.4 

func (m *GfSpTask) AppendLog(log string)

func (*GfSpTask) Descriptor added in v0.2.4 

func (*GfSpTask) Descriptor() ([]byte, []int)

func (*GfSpTask) Error added in v0.2.4 

func (m *GfSpTask) Error() error

func (*GfSpTask) EstimateLimit added in v0.2.4 

func (m *GfSpTask) EstimateLimit() rcmgr.Limit

func (*GfSpTask) ExceedRetry added in v0.2.4 

func (m *GfSpTask) ExceedRetry() bool

func (*GfSpTask) ExceedTimeout added in v0.2.4 

func (m *GfSpTask) ExceedTimeout() bool

func (*GfSpTask) Expired added in v0.2.4 

func (m *GfSpTask) Expired() bool

func (*GfSpTask) GetAddress added in v0.2.4 

func (m *GfSpTask) GetAddress() string

func (*GfSpTask) GetCreateTime added in v0.2.4 

func (m *GfSpTask) GetCreateTime() int64

func (*GfSpTask) GetErr added in v0.2.4 

func (m *GfSpTask) GetErr() *gfsperrors.GfSpError

func (*GfSpTask) GetLogs added in v0.2.4 

func (m *GfSpTask) GetLogs() string

func (*GfSpTask) GetMaxRetry added in v0.2.4 

func (m *GfSpTask) GetMaxRetry() int64

func (*GfSpTask) GetPriority added in v0.2.4 

func (m *GfSpTask) GetPriority() coretask.TPriority

func (*GfSpTask) GetRetry added in v0.2.4 

func (m *GfSpTask) GetRetry() int64

func (*GfSpTask) GetTaskPriority added in v0.2.4 

func (m *GfSpTask) GetTaskPriority() int32

func (*GfSpTask) GetTimeout added in v0.2.4 

func (m *GfSpTask) GetTimeout() int64

func (*GfSpTask) GetUpdateTime added in v0.2.4 

func (m *GfSpTask) GetUpdateTime() int64

func (*GfSpTask) GetUserAddress added in v0.2.4 

func (m *GfSpTask) GetUserAddress() string

func (*GfSpTask) IncRetry added in v0.2.4 

func (m *GfSpTask) IncRetry()

func (*GfSpTask) Info added in v0.2.4 

func (m *GfSpTask) Info() string

func (*GfSpTask) Key added in v0.2.4 

func (m *GfSpTask) Key() coretask.TKey

func (*GfSpTask) Marshal added in v0.2.4 

func (m *GfSpTask) Marshal() (dAtA []byte, err error)

func (*GfSpTask) MarshalTo added in v0.2.4 

func (m *GfSpTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpTask) ProtoMessage added in v0.2.4 

func (*GfSpTask) ProtoMessage()

func (*GfSpTask) Reset added in v0.2.4 

func (m *GfSpTask) Reset()

func (*GfSpTask) SetAddress added in v0.2.4 

func (m *GfSpTask) SetAddress(address string)

func (*GfSpTask) SetCreateTime added in v0.2.4 

func (m *GfSpTask) SetCreateTime(time int64)

func (*GfSpTask) SetError added in v0.2.4 

func (m *GfSpTask) SetError(err error)

func (*GfSpTask) SetLogs added in v0.2.4 

func (m *GfSpTask) SetLogs(logs string)

func (*GfSpTask) SetMaxRetry added in v0.2.4 

func (m *GfSpTask) SetMaxRetry(limit int64)

func (*GfSpTask) SetPriority added in v0.2.4 

func (m *GfSpTask) SetPriority(priority coretask.TPriority)

func (*GfSpTask) SetRetry added in v0.2.4 

func (m *GfSpTask) SetRetry(retry int64)

func (*GfSpTask) SetTimeout added in v0.2.4 

func (m *GfSpTask) SetTimeout(timeout int64)

func (*GfSpTask) SetUpdateTime added in v0.2.4 

func (m *GfSpTask) SetUpdateTime(time int64)

func (*GfSpTask) SetUserAddress added in v0.2.4 

func (m *GfSpTask) SetUserAddress(address string)

func (*GfSpTask) Size added in v0.2.4 

func (m *GfSpTask) Size() (n int)

func (*GfSpTask) String added in v0.2.4 

func (m *GfSpTask) String() string

func (*GfSpTask) Type added in v0.2.4 

func (m *GfSpTask) Type() coretask.TType

func (*GfSpTask) Unmarshal added in v0.2.4 

func (m *GfSpTask) Unmarshal(dAtA []byte) error

func (*GfSpTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpTask) XXX_DiscardUnknown()

func (*GfSpTask) XXX_Marshal added in v0.2.4 

func (m *GfSpTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpTask) XXX_Merge added in v0.2.4 

func (m *GfSpTask) XXX_Merge(src proto.Message)

func (*GfSpTask) XXX_Size added in v0.2.4 

func (m *GfSpTask) XXX_Size() int

func (*GfSpTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpTask) XXX_Unmarshal(b []byte) error

type GfSpUploadObjectTask added in v0.2.4 

type GfSpUploadObjectTask struct {
	Task                 *GfSpTask         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	VirtualGroupFamilyId uint32            `` /* 126-byte string literal not displayed */
	ObjectInfo           *types.ObjectInfo `protobuf:"bytes,3,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	StorageParams        *types.Params     `protobuf:"bytes,4,opt,name=storage_params,json=storageParams,proto3" json:"storage_params,omitempty"`
	IsAgentUpload        bool              `protobuf:"varint,5,opt,name=is_agent_upload,json=isAgentUpload,proto3" json:"is_agent_upload,omitempty"`
}

func (*GfSpUploadObjectTask) AppendLog added in v0.2.4 

func (m *GfSpUploadObjectTask) AppendLog(log string)

func (*GfSpUploadObjectTask) Descriptor added in v0.2.4 

func (*GfSpUploadObjectTask) Descriptor() ([]byte, []int)

func (*GfSpUploadObjectTask) Error added in v0.2.4 

func (m *GfSpUploadObjectTask) Error() error

func (*GfSpUploadObjectTask) EstimateLimit added in v0.2.4 

func (m *GfSpUploadObjectTask) EstimateLimit() corercmgr.Limit

func (*GfSpUploadObjectTask) ExceedRetry added in v0.2.4 

func (m *GfSpUploadObjectTask) ExceedRetry() bool

func (*GfSpUploadObjectTask) ExceedTimeout added in v0.2.4 

func (m *GfSpUploadObjectTask) ExceedTimeout() bool

func (*GfSpUploadObjectTask) Expired added in v0.2.4 

func (m *GfSpUploadObjectTask) Expired() bool

func (*GfSpUploadObjectTask) GetAddress added in v0.2.4 

func (m *GfSpUploadObjectTask) GetAddress() string

func (*GfSpUploadObjectTask) GetCreateTime added in v0.2.4 

func (m *GfSpUploadObjectTask) GetCreateTime() int64

func (*GfSpUploadObjectTask) GetIsAgentUpload added in v1.6.0 

func (m *GfSpUploadObjectTask) GetIsAgentUpload() bool

func (*GfSpUploadObjectTask) GetLogs added in v0.2.4 

func (m *GfSpUploadObjectTask) GetLogs() string

func (*GfSpUploadObjectTask) GetMaxRetry added in v0.2.4 

func (m *GfSpUploadObjectTask) GetMaxRetry() int64

func (*GfSpUploadObjectTask) GetObjectInfo added in v0.2.4 

func (m *GfSpUploadObjectTask) GetObjectInfo() *types.ObjectInfo

func (*GfSpUploadObjectTask) GetPriority added in v0.2.4 

func (m *GfSpUploadObjectTask) GetPriority() coretask.TPriority

func (*GfSpUploadObjectTask) GetRetry added in v0.2.4 

func (m *GfSpUploadObjectTask) GetRetry() int64

func (*GfSpUploadObjectTask) GetStorageParams added in v0.2.4 

func (m *GfSpUploadObjectTask) GetStorageParams() *types.Params

func (*GfSpUploadObjectTask) GetTask added in v0.2.4 

func (m *GfSpUploadObjectTask) GetTask() *GfSpTask

func (*GfSpUploadObjectTask) GetTimeout added in v0.2.4 

func (m *GfSpUploadObjectTask) GetTimeout() int64

func (*GfSpUploadObjectTask) GetUpdateTime added in v0.2.4 

func (m *GfSpUploadObjectTask) GetUpdateTime() int64

func (*GfSpUploadObjectTask) GetUserAddress added in v0.2.4 

func (m *GfSpUploadObjectTask) GetUserAddress() string

func (*GfSpUploadObjectTask) GetVirtualGroupFamilyId added in v0.2.4 

func (m *GfSpUploadObjectTask) GetVirtualGroupFamilyId() uint32

func (*GfSpUploadObjectTask) IncRetry added in v0.2.4 

func (m *GfSpUploadObjectTask) IncRetry()

func (*GfSpUploadObjectTask) Info added in v0.2.4 

func (m *GfSpUploadObjectTask) Info() string

func (*GfSpUploadObjectTask) InitUploadObjectTask added in v0.2.4 

func (m *GfSpUploadObjectTask) InitUploadObjectTask(vgfID uint32, object *storagetypes.ObjectInfo, params *storagetypes.Params, timeout int64, isAgentUpload bool)

func (*GfSpUploadObjectTask) Key added in v0.2.4 

func (m *GfSpUploadObjectTask) Key() coretask.TKey

func (*GfSpUploadObjectTask) Marshal added in v0.2.4 

func (m *GfSpUploadObjectTask) Marshal() (dAtA []byte, err error)

func (*GfSpUploadObjectTask) MarshalTo added in v0.2.4 

func (m *GfSpUploadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpUploadObjectTask) MarshalToSizedBuffer added in v0.2.4 

func (m *GfSpUploadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpUploadObjectTask) ProtoMessage added in v0.2.4 

func (*GfSpUploadObjectTask) ProtoMessage()

func (*GfSpUploadObjectTask) Reset added in v0.2.4 

func (m *GfSpUploadObjectTask) Reset()

func (*GfSpUploadObjectTask) SetAddress added in v0.2.4 

func (m *GfSpUploadObjectTask) SetAddress(address string)

func (*GfSpUploadObjectTask) SetCreateTime added in v0.2.4 

func (m *GfSpUploadObjectTask) SetCreateTime(time int64)

func (*GfSpUploadObjectTask) SetError added in v0.2.4 

func (m *GfSpUploadObjectTask) SetError(err error)

func (*GfSpUploadObjectTask) SetLogs added in v0.2.4 

func (m *GfSpUploadObjectTask) SetLogs(logs string)

func (*GfSpUploadObjectTask) SetMaxRetry added in v0.2.4 

func (m *GfSpUploadObjectTask) SetMaxRetry(limit int64)

func (*GfSpUploadObjectTask) SetObjectInfo added in v0.2.4 

func (m *GfSpUploadObjectTask) SetObjectInfo(object *storagetypes.ObjectInfo)

func (*GfSpUploadObjectTask) SetPriority added in v0.2.4 

func (m *GfSpUploadObjectTask) SetPriority(priority coretask.TPriority)

func (*GfSpUploadObjectTask) SetRetry added in v0.2.4 

func (m *GfSpUploadObjectTask) SetRetry(retry int64)

func (*GfSpUploadObjectTask) SetStorageParams added in v0.2.4 

func (m *GfSpUploadObjectTask) SetStorageParams(param *storagetypes.Params)

func (*GfSpUploadObjectTask) SetTimeout added in v0.2.4 

func (m *GfSpUploadObjectTask) SetTimeout(time int64)

func (*GfSpUploadObjectTask) SetUpdateTime added in v0.2.4 

func (m *GfSpUploadObjectTask) SetUpdateTime(time int64)

func (*GfSpUploadObjectTask) SetUserAddress added in v0.2.4 

func (m *GfSpUploadObjectTask) SetUserAddress(address string)

func (*GfSpUploadObjectTask) Size added in v0.2.4 

func (m *GfSpUploadObjectTask) Size() (n int)

func (*GfSpUploadObjectTask) String added in v0.2.4 

func (m *GfSpUploadObjectTask) String() string

func (*GfSpUploadObjectTask) Type added in v0.2.4 

func (m *GfSpUploadObjectTask) Type() coretask.TType

func (*GfSpUploadObjectTask) Unmarshal added in v0.2.4 

func (m *GfSpUploadObjectTask) Unmarshal(dAtA []byte) error

func (*GfSpUploadObjectTask) XXX_DiscardUnknown added in v0.2.4 

func (m *GfSpUploadObjectTask) XXX_DiscardUnknown()

func (*GfSpUploadObjectTask) XXX_Marshal added in v0.2.4 

func (m *GfSpUploadObjectTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GfSpUploadObjectTask) XXX_Merge added in v0.2.4 

func (m *GfSpUploadObjectTask) XXX_Merge(src proto.Message)

func (*GfSpUploadObjectTask) XXX_Size added in v0.2.4 

func (m *GfSpUploadObjectTask) XXX_Size() int

func (*GfSpUploadObjectTask) XXX_Unmarshal added in v0.2.4 

func (m *GfSpUploadObjectTask) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.