gfsptask

package
v0.2.4-alpha.23 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2023 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)
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 GfSpGCObjectTaskKey 

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

func GfSpGCZombiePieceTaskKey 

func GfSpGCZombiePieceTaskKey(time int64) task.TKey

func GfSpGfSpGCMetaTaskKey 

func GfSpGfSpGCMetaTaskKey(time int64) task.TKey

func GfSpMigrateBucketApprovalTaskKey added in v0.2.3 

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

func GfSpMigrateGVGTaskKey added in v0.2.3 

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

func GfSpMigratePieceTaskKey added in v0.2.3 

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

func GfSpReceivePieceTaskKey 

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

func GfSpRecoverPieceTaskKey added in v0.2.3 

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

func GfSpReplicatePieceApprovalTaskKey 

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

func GfSpReplicatePieceTaskKey 

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

func GfSpResumableUploadObjectTaskKey added in v0.2.3 

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

func GfSpSealObjectTaskKey 

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

func GfSpUploadObjectTaskKey 

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

func LimitEstimateByPriority 

func LimitEstimateByPriority(priority coretask.TPriority) rcmgr.Limit

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

Types

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

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

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

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

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

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 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"`
	Running     bool      `protobuf:"varint,4,opt,name=running,proto3" json:"running,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) GetRunning added in v0.2.4 

func (m *GfSpGCMetaTask) GetRunning() bool

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

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

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 GfSpGCZombiePieceTask added in v0.2.4 

type GfSpGCZombiePieceTask 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"`
	DeleteCount uint64    `protobuf:"varint,3,opt,name=delete_count,json=deleteCount,proto3" json:"delete_count,omitempty"`
	Running     bool      `protobuf:"varint,4,opt,name=running,proto3" json:"running,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) GetDeleteCount added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetDeleteCount() uint64

func (*GfSpGCZombiePieceTask) GetGCZombiePieceStatus added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetGCZombiePieceStatus() (uint64, uint64)

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) GetObjectId added in v0.2.4 

func (m *GfSpGCZombiePieceTask) GetObjectId() uint64

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) 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) 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) SetError added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetError(err error)

func (*GfSpGCZombiePieceTask) SetGCZombiePieceStatus added in v0.2.4 

func (m *GfSpGCZombiePieceTask) SetGCZombiePieceStatus(object uint64, delete uint64)

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

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

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"`
}

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

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"`
	Signature       []byte            `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
	IsBucketMigrate bool              `protobuf:"varint,8,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) GetSignBytes added in v0.2.4 

func (g *GfSpMigratePieceTask) GetSignBytes() []byte

func (*GfSpMigratePieceTask) GetSignature added in v0.2.4 

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

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"`
}

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

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

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"`
}

func (*GfSpRecoverPieceTask) AppendLog added in v0.2.4 

func (m *GfSpRecoverPieceTask) AppendLog(log string)

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

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

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"`
}

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

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

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 */
}

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

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

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"`
}

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

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

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

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"`
}

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

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

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.