module

Apr 7, 2024

Changes in this version

type Approver

+ HandleDelegateCreateObjectApprovalTask func(ctx context.Context, task task.ApprovalDelegateCreateObjectTask) (bool, error)

type AuthOpType

+ const AuthOpTypeAgentPutObject

+ const AuthOpTypeAgentUpdateObject

type Authenticator

+ DeleteAuthKeysV2 func(ctx context.Context, account string, domain string, publicKeys []string) (bool, error)

+ GetAuthKeyV2 func(ctx context.Context, account string, domain string, publicKey string) (*spdb.OffChainAuthKeyV2, error)

+ ListAuthKeysV2 func(ctx context.Context, account string, domain string) ([]string, error)

+ UpdateUserPublicKeyV2 func(ctx context.Context, account string, domain string, publicKey string, ...) (bool, error)

+ VerifyGNFD2EddsaSignature func(ctx context.Context, account string, domain string, publicKey string, ...) (bool, error)

type MockApprover

+ func (m *MockApprover) HandleDelegateCreateObjectApprovalTask(ctx context.Context, task task.ApprovalDelegateCreateObjectTask) (bool, error)

type MockApproverMockRecorder

+ func (mr *MockApproverMockRecorder) HandleDelegateCreateObjectApprovalTask(ctx, task any) *gomock.Call

type MockAuthenticator

+ func (m *MockAuthenticator) DeleteAuthKeysV2(ctx context.Context, account, domain string, publicKeys []string) (bool, error)

+ func (m *MockAuthenticator) GetAuthKeyV2(ctx context.Context, account, domain, publicKey string) (*spdb.OffChainAuthKeyV2, error)

+ func (m *MockAuthenticator) ListAuthKeysV2(ctx context.Context, account, domain string) ([]string, error)

+ func (m *MockAuthenticator) UpdateUserPublicKeyV2(ctx context.Context, account, domain, publicKey string, expiryDate int64) (bool, error)

+ func (m *MockAuthenticator) VerifyGNFD2EddsaSignature(ctx context.Context, account, domain, publicKey, offChainSig string, ...) (bool, error)

type MockAuthenticatorMockRecorder

+ func (mr *MockAuthenticatorMockRecorder) DeleteAuthKeysV2(ctx, account, domain, publicKeys any) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) GetAuthKeyV2(ctx, account, domain, publicKey any) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) ListAuthKeysV2(ctx, account, domain any) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) UpdateUserPublicKeyV2(ctx, account, domain, publicKey, expiryDate any) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) VerifyGNFD2EddsaSignature(ctx, account, domain, publicKey, offChainSig, realMsgToSign any) *gomock.Call

type MockSigner

+ func (m *MockSigner) DelegateCreateObject(ctx context.Context, msg *types0.MsgDelegateCreateObject) (string, error)

+ func (m *MockSigner) DelegateUpdateObjectContent(ctx context.Context, msg *types0.MsgDelegateUpdateObjectContent) (string, error)

+ func (m *MockSigner) SealObjectV2(ctx context.Context, object *types0.MsgSealObjectV2) (string, error)

type MockSignerMockRecorder

+ func (mr *MockSignerMockRecorder) DelegateCreateObject(ctx, msg any) *gomock.Call

+ func (mr *MockSignerMockRecorder) DelegateUpdateObjectContent(ctx, msg any) *gomock.Call

+ func (mr *MockSignerMockRecorder) SealObjectV2(ctx, object any) *gomock.Call

type NilModular

+ func (m *NilModular) DelegateCreateObject(ctx context.Context, msg *storagetypes.MsgDelegateCreateObject) (string, error)

+ func (m *NilModular) DelegateUpdateObjectContent(ctx context.Context, msg *storagetypes.MsgDelegateUpdateObjectContent) (string, error)

+ func (m *NilModular) SealObjectV2(ctx context.Context, object *storagetypes.MsgSealObjectV2) (string, error)

type NullModular

+ func (m *NullModular) DeleteAuthKeysV2(ctx context.Context, account string, domain string, publicKeys []string) (bool, error)

+ func (m *NullModular) GetAuthKeyV2(ctx context.Context, account string, domain string, publicKey string) (*corespdb.OffChainAuthKeyV2, error)

+ func (m *NullModular) HandleDelegateCreateObjectApprovalTask(ctx context.Context, task task.ApprovalDelegateCreateObjectTask) (bool, error)

+ func (m *NullModular) ListAuthKeysV2(ctx context.Context, account string, domain string) ([]string, error)

+ func (m *NullModular) UpdateUserPublicKeyV2(ctx context.Context, account string, domain string, publicKey string, ...) (bool, error)

+ func (m *NullModular) VerifyGNFD2EddsaSignature(ctx context.Context, account string, domain string, publicKey string, ...) (bool, error)

type Signer

+ DelegateCreateObject func(ctx context.Context, msg *storagetypes.MsgDelegateCreateObject) (string, error)

+ DelegateUpdateObjectContent func(ctx context.Context, msg *storagetypes.MsgDelegateUpdateObjectContent) (string, error)

+ SealObjectV2 func(ctx context.Context, object *storagetypes.MsgSealObjectV2) (string, error)

Mar 13, 2024

Changes in this version

type Manager

+ HandleGCStaleVersionObjectTask func(ctx context.Context, task task.GCStaleVersionObjectTask) error

type MockManager

+ func (m *MockManager) HandleGCStaleVersionObjectTask(ctx context.Context, task task.GCStaleVersionObjectTask) error

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) HandleGCStaleVersionObjectTask(ctx, task any) *gomock.Call

type NullModular

+ func (m *NullModular) HandleGCStaleVersionObjectTask(ctx context.Context, task task.GCStaleVersionObjectTask) error

Jan 22, 2024

Changes in this version

type AuthOpType

+ const AuthOpTypeQueryBucketMigrationProgress

type Manager

+ NotifyPostMigrateBucketAndRecoupQuota func(ctx context.Context, bmStatus *gfsptask.GfSpBucketMigrationInfo) (*gfsptask.GfSpBucketQuotaInfo, error)

+ NotifyPreMigrateBucketAndDeductQuota func(ctx context.Context, bucketID uint64) (*gfsptask.GfSpBucketQuotaInfo, error)

+ QueryBucketMigrationProgress func(ctx context.Context, bucketID uint64) (*gfspserver.MigrateBucketProgressMeta, error)

+ QueryRecoverProcess func(ctx context.Context, vgfID, gvgID uint32) ([]*gfspserver.RecoverProcess, bool, error)

+ TriggerRecoverForSuccessorSP func(ctx context.Context, vgfID, gvgID uint32, redundancyIndex int32) error

type MockManager

+ func (m *MockManager) NotifyPostMigrateBucketAndRecoupQuota(ctx context.Context, bmStatus *gfsptask.GfSpBucketMigrationInfo) (*gfsptask.GfSpBucketQuotaInfo, error)

+ func (m *MockManager) NotifyPreMigrateBucketAndDeductQuota(ctx context.Context, bucketID uint64) (*gfsptask.GfSpBucketQuotaInfo, error)

+ func (m *MockManager) QueryBucketMigrationProgress(ctx context.Context, bucketID uint64) (*gfspserver.MigrateBucketProgressMeta, error)

+ func (m *MockManager) QueryRecoverProcess(ctx context.Context, vgfID, gvgID uint32) ([]*gfspserver.RecoverProcess, bool, error)

+ func (m *MockManager) TriggerRecoverForSuccessorSP(ctx context.Context, vgfID, gvgID uint32, redundancyIndex int32) error

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) NotifyPostMigrateBucketAndRecoupQuota(ctx, bmStatus any) *gomock.Call

+ func (mr *MockManagerMockRecorder) NotifyPreMigrateBucketAndDeductQuota(ctx, bucketID any) *gomock.Call

+ func (mr *MockManagerMockRecorder) QueryBucketMigrationProgress(ctx, bucketID any) *gomock.Call

+ func (mr *MockManagerMockRecorder) QueryRecoverProcess(ctx, vgfID, gvgID any) *gomock.Call

+ func (mr *MockManagerMockRecorder) TriggerRecoverForSuccessorSP(ctx, vgfID, gvgID, redundancyIndex any) *gomock.Call

type MockSigner

+ func (m *MockSigner) CancelSwapIn(ctx context.Context, cancelSwapIn *types1.MsgCancelSwapIn) (string, error)

+ func (m *MockSigner) CompleteSwapIn(ctx context.Context, reserveSwapIn *types1.MsgCompleteSwapIn) (string, error)

+ func (m *MockSigner) ReserveSwapIn(ctx context.Context, reserveSwapIn *types1.MsgReserveSwapIn) (string, error)

type MockSignerMockRecorder

+ func (mr *MockSignerMockRecorder) CancelSwapIn(ctx, cancelSwapIn any) *gomock.Call

+ func (mr *MockSignerMockRecorder) CompleteSwapIn(ctx, reserveSwapIn any) *gomock.Call

+ func (mr *MockSignerMockRecorder) DeleteGlobalVirtualGroup(ctx, deleteGVG any) *gomock.Call

+ func (mr *MockSignerMockRecorder) Deposit(ctx, deposit any) *gomock.Call

+ func (mr *MockSignerMockRecorder) ReserveSwapIn(ctx, reserveSwapIn any) *gomock.Call

type NilModular

+ func (m *NilModular) CancelSwapIn(ctx context.Context, cancelSwapIn *virtualgrouptypes.MsgCancelSwapIn) (string, error)

+ func (m *NilModular) CompleteSwapIn(ctx context.Context, reserveSwapIn *virtualgrouptypes.MsgCompleteSwapIn) (string, error)

+ func (m *NilModular) ReserveSwapIn(ctx context.Context, reserveSwapIn *virtualgrouptypes.MsgReserveSwapIn) (string, error)

type NullModular

+ func (*NullModular) NotifyPostMigrateBucketAndRecoupQuota(context.Context, *gfsptask.GfSpBucketMigrationInfo) (*gfsptask.GfSpBucketQuotaInfo, error)

+ func (*NullModular) NotifyPreMigrateBucketAndDeductQuota(context.Context, uint64) (*gfsptask.GfSpBucketQuotaInfo, error)

+ func (m *NullModular) QueryBucketMigrationProgress(ctx context.Context, bucketID uint64) (*gfspserver.MigrateBucketProgressMeta, error)

+ func (m *NullModular) QueryRecoverProcess(context.Context, uint32, uint32) ([]*gfspserver.RecoverProcess, bool, error)

+ func (m *NullModular) TriggerRecoverForSuccessorSP(ctx context.Context, vgfID, gvgID uint32, redundancyIndex int32) error

type Signer

+ CancelSwapIn func(ctx context.Context, cancelSwapIn *virtualgrouptypes.MsgCancelSwapIn) (string, error)

+ CompleteSwapIn func(ctx context.Context, reserveSwapIn *virtualgrouptypes.MsgCompleteSwapIn) (string, error)

+ ReserveSwapIn func(ctx context.Context, reserveSwapIn *virtualgrouptypes.MsgReserveSwapIn) (string, error)

Dec 14, 2023

Changes in this version

type Manager

+ HandleGCBucketMigrationTask func(ctx context.Context, task task.GCBucketMigrationTask) error

type MockManager

+ func (m *MockManager) HandleGCBucketMigrationTask(ctx context.Context, task task.GCBucketMigrationTask) error

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) HandleGCBucketMigrationTask(ctx, task interface{}) *gomock.Call

type MockSigner

+ func (m *MockSigner) DeleteGlobalVirtualGroup(ctx context.Context, deleteGVG *types1.MsgDeleteGlobalVirtualGroup) (string, error)

+ func (m *MockSigner) Deposit(ctx context.Context, deposit *types1.MsgDeposit) (string, error)

type NilModular

+ func (m *NilModular) DeleteGlobalVirtualGroup(ctx context.Context, deleteGVG *virtualgrouptypes.MsgDeleteGlobalVirtualGroup) (string, error)

+ func (m *NilModular) Deposit(ctx context.Context, deposit *virtualgrouptypes.MsgDeposit) (string, error)

type NullModular

+ func (*NullModular) HandleGCBucketMigrationTask(context.Context, task.GCBucketMigrationTask) error

type Signer

+ DeleteGlobalVirtualGroup func(ctx context.Context, deleteGVG *virtualgrouptypes.MsgDeleteGlobalVirtualGroup) (string, error)

+ Deposit func(ctx context.Context, deposit *virtualgrouptypes.MsgDeposit) (string, error)

Nov 14, 2023

Changes in this version

type Manager

+ NotifyPostMigrateBucket func(ctx context.Context, bucketID uint64) error

+ NotifyPreMigrateBucket func(ctx context.Context, bucketID uint64) error

+ ResetRecoveryFailedList func(ctx context.Context) []string

type MockManager

+ func (m *MockManager) NotifyPostMigrateBucket(ctx context.Context, bucketID uint64) error

+ func (m *MockManager) NotifyPreMigrateBucket(ctx context.Context, bucketID uint64) error

+ func (m *MockManager) ResetRecoveryFailedList(ctx context.Context) []string

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) NotifyPostMigrateBucket(ctx, bucketID any) *gomock.Call

+ func (mr *MockManagerMockRecorder) NotifyPreMigrateBucket(ctx, bucketID any) *gomock.Call

+ func (mr *MockManagerMockRecorder) ResetRecoveryFailedList(ctx any) *gomock.Call

type MockSigner

+ func (m *MockSigner) RejectMigrateBucket(ctx context.Context, rejectMigrateBucket *types0.MsgRejectMigrateBucket) (string, error)

+ func (m *MockSigner) SignBucketMigrationInfo(ctx context.Context, task *gfsptask.GfSpBucketMigrationInfo) ([]byte, error)

type MockSignerMockRecorder

+ func (mr *MockSignerMockRecorder) RejectMigrateBucket(ctx, rejectMigrateBucket any) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignBucketMigrationInfo(ctx, task any) *gomock.Call

type NilModular

+ func (*NilModular) SignBucketMigrationInfo(ctx context.Context, task *gfsptask.GfSpBucketMigrationInfo) ([]byte, error)

+ func (m *NilModular) RejectMigrateBucket(ctx context.Context, rejectMigrateBucket *storagetypes.MsgRejectMigrateBucket) (string, error)

type NullModular

+ func (*NullModular) NotifyPostMigrateBucket(context.Context, uint64) error

+ func (*NullModular) NotifyPreMigrateBucket(context.Context, uint64) error

+ func (m *NullModular) ResetRecoveryFailedList(ctx context.Context) []string

type Signer

+ RejectMigrateBucket func(ctx context.Context, rejectMigrateBucket *storagetypes.MsgRejectMigrateBucket) (string, error)

+ SignBucketMigrationInfo func(ctx context.Context, task *gfsptask.GfSpBucketMigrationInfo) ([]byte, error)

Sep 21, 2023

Changes in this version

type Manager

+ QueryTasksStats func(ctx context.Context) (int, int, int, int, int, int)

type MockManager

+ func (m *MockManager) QuerySPByOperatorAddress(ctx context.Context, operatorAddress string) (*types.StorageProvider, error)

+ func (m *MockManager) QueryTasksStats(ctx context.Context) (int, int, int, int, int, int)

type MockManagerMockRecorder

+ func (mr *MockManagerMockRecorder) QuerySPByOperatorAddress(ctx, operatorAddress interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) QueryTasksStats(ctx interface{}) *gomock.Call

type MockSigner

+ func (m *MockSigner) SignMigrateGVG(ctx context.Context, task *gfsptask.GfSpMigrateGVGTask) ([]byte, error)

type MockSignerMockRecorder

+ func (mr *MockSignerMockRecorder) SignMigrateGVG(ctx, task interface{}) *gomock.Call

type NilModular

+ func (*NilModular) SignMigrateGVG(ctx context.Context, task *gfsptask.GfSpMigrateGVGTask) ([]byte, error)

type NullModular

+ func (m *NullModular) QueryTasksStats(ctx context.Context) (int, int, int, int, int, int)

type Signer

+ SignMigrateGVG func(ctx context.Context, task *gfsptask.GfSpMigrateGVGTask) ([]byte, error)

Aug 30, 2023

Changes in this version

type Authenticator

+ VerifyGNFD1EddsaSignature func(ctx context.Context, account string, domain string, offChainSig string, ...) (bool, error)

+ type MockApprover struct

+ func NewMockApprover(ctrl *gomock.Controller) *MockApprover

+ func (m *MockApprover) EXPECT() *MockApproverMockRecorder

+ func (m *MockApprover) HandleCreateBucketApprovalTask(ctx context.Context, task task.ApprovalCreateBucketTask) (bool, error)

+ func (m *MockApprover) HandleCreateObjectApprovalTask(ctx context.Context, task task.ApprovalCreateObjectTask) (bool, error)

+ func (m *MockApprover) HandleMigrateBucketApprovalTask(ctx context.Context, task task.ApprovalMigrateBucketTask) (bool, error)

+ func (m *MockApprover) Name() string

+ func (m *MockApprover) PostCreateBucketApproval(ctx context.Context, task task.ApprovalCreateBucketTask)

+ func (m *MockApprover) PostCreateObjectApproval(ctx context.Context, task task.ApprovalCreateObjectTask)

+ func (m *MockApprover) PostMigrateBucketApproval(ctx context.Context, task task.ApprovalMigrateBucketTask)

+ func (m *MockApprover) PreCreateBucketApproval(ctx context.Context, task task.ApprovalCreateBucketTask) error

+ func (m *MockApprover) PreCreateObjectApproval(ctx context.Context, task task.ApprovalCreateObjectTask) error

+ func (m *MockApprover) PreMigrateBucketApproval(ctx context.Context, task task.ApprovalMigrateBucketTask) error

+ func (m *MockApprover) QueryTasks(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ func (m *MockApprover) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockApprover) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockApprover) Start(ctx context.Context) error

+ func (m *MockApprover) Stop(ctx context.Context) error

+ type MockApproverMockRecorder struct

+ func (mr *MockApproverMockRecorder) HandleCreateBucketApprovalTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) HandleCreateObjectApprovalTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) HandleMigrateBucketApprovalTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) Name() *gomock.Call

+ func (mr *MockApproverMockRecorder) PostCreateBucketApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) PostCreateObjectApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) PostMigrateBucketApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) PreCreateBucketApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) PreCreateObjectApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) PreMigrateBucketApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) QueryTasks(ctx, subKey interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockApproverMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockAuthenticator struct

+ func NewMockAuthenticator(ctrl *gomock.Controller) *MockAuthenticator

+ func (m *MockAuthenticator) EXPECT() *MockAuthenticatorMockRecorder

+ func (m *MockAuthenticator) GetAuthNonce(ctx context.Context, account, domain string) (*spdb.OffChainAuthKey, error)

+ func (m *MockAuthenticator) Name() string

+ func (m *MockAuthenticator) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockAuthenticator) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockAuthenticator) Start(ctx context.Context) error

+ func (m *MockAuthenticator) Stop(ctx context.Context) error

+ func (m *MockAuthenticator) UpdateUserPublicKey(ctx context.Context, account, domain string, currentNonce, nonce int32, ...) (bool, error)

+ func (m *MockAuthenticator) VerifyAuthentication(ctx context.Context, auth AuthOpType, account, bucket, object string) (bool, error)

+ func (m *MockAuthenticator) VerifyGNFD1EddsaSignature(ctx context.Context, account, domain, offChainSig string, realMsgToSign []byte) (bool, error)

+ type MockAuthenticatorMockRecorder struct

+ func (mr *MockAuthenticatorMockRecorder) GetAuthNonce(ctx, account, domain interface{}) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) Name() *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) Stop(ctx interface{}) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) UpdateUserPublicKey(...) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) VerifyAuthentication(ctx, auth, account, bucket, object interface{}) *gomock.Call

+ func (mr *MockAuthenticatorMockRecorder) VerifyGNFD1EddsaSignature(ctx, account, domain, offChainSig, realMsgToSign interface{}) *gomock.Call

+ type MockDownloader struct

+ func NewMockDownloader(ctrl *gomock.Controller) *MockDownloader

+ func (m *MockDownloader) EXPECT() *MockDownloaderMockRecorder

+ func (m *MockDownloader) HandleChallengePiece(ctx context.Context, task task.ChallengePieceTask) ([]byte, [][]byte, []byte, error)

+ func (m *MockDownloader) HandleDownloadObjectTask(ctx context.Context, task task.DownloadObjectTask) ([]byte, error)

+ func (m *MockDownloader) HandleDownloadPieceTask(ctx context.Context, task task.DownloadPieceTask) ([]byte, error)

+ func (m *MockDownloader) Name() string

+ func (m *MockDownloader) PostChallengePiece(ctx context.Context, task task.ChallengePieceTask)

+ func (m *MockDownloader) PostDownloadObject(ctx context.Context, task task.DownloadObjectTask)

+ func (m *MockDownloader) PostDownloadPiece(ctx context.Context, task task.DownloadPieceTask)

+ func (m *MockDownloader) PreChallengePiece(ctx context.Context, task task.ChallengePieceTask) error

+ func (m *MockDownloader) PreDownloadObject(ctx context.Context, task task.DownloadObjectTask) error

+ func (m *MockDownloader) PreDownloadPiece(ctx context.Context, task task.DownloadPieceTask) error

+ func (m *MockDownloader) QueryTasks(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ func (m *MockDownloader) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockDownloader) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockDownloader) Start(ctx context.Context) error

+ func (m *MockDownloader) Stop(ctx context.Context) error

+ type MockDownloaderMockRecorder struct

+ func (mr *MockDownloaderMockRecorder) HandleChallengePiece(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) HandleDownloadObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) HandleDownloadPieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) Name() *gomock.Call

+ func (mr *MockDownloaderMockRecorder) PostChallengePiece(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) PostDownloadObject(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) PostDownloadPiece(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) PreChallengePiece(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) PreDownloadObject(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) PreDownloadPiece(ctx, task interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) QueryTasks(ctx, subKey interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockDownloaderMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockManager struct

+ func NewMockManager(ctrl *gomock.Controller) *MockManager

+ func (m *MockManager) DispatchTask(ctx context.Context, limit rcmgr.Limit) (task.Task, error)

+ func (m *MockManager) EXPECT() *MockManagerMockRecorder

+ func (m *MockManager) HandleChallengePieceTask(ctx context.Context, task task.ChallengePieceTask) error

+ func (m *MockManager) HandleCreateResumableUploadObjectTask(ctx context.Context, task task.ResumableUploadObjectTask) error

+ func (m *MockManager) HandleCreateUploadObjectTask(ctx context.Context, task task.UploadObjectTask) error

+ func (m *MockManager) HandleDoneResumableUploadObjectTask(ctx context.Context, task task.ResumableUploadObjectTask) error

+ func (m *MockManager) HandleDoneUploadObjectTask(ctx context.Context, task task.UploadObjectTask) error

+ func (m *MockManager) HandleDownloadObjectTask(ctx context.Context, task task.DownloadObjectTask) error

+ func (m *MockManager) HandleGCMetaTask(ctx context.Context, task task.GCMetaTask) error

+ func (m *MockManager) HandleGCObjectTask(ctx context.Context, task task.GCObjectTask) error

+ func (m *MockManager) HandleGCZombiePieceTask(ctx context.Context, task task.GCZombiePieceTask) error

+ func (m *MockManager) HandleMigrateGVGTask(ctx context.Context, task task.MigrateGVGTask) error

+ func (m *MockManager) HandleReceivePieceTask(ctx context.Context, task task.ReceivePieceTask) error

+ func (m *MockManager) HandleRecoverPieceTask(ctx context.Context, task task.RecoveryPieceTask) error

+ func (m *MockManager) HandleReplicatePieceTask(ctx context.Context, task task.ReplicatePieceTask) error

+ func (m *MockManager) HandleSealObjectTask(ctx context.Context, task task.SealObjectTask) error

+ func (m *MockManager) Name() string

+ func (m *MockManager) NotifyMigrateSwapOut(ctx context.Context, swapOut *types1.MsgSwapOut) error

+ func (m *MockManager) PickVirtualGroupFamily(ctx context.Context, task task.ApprovalCreateBucketTask) (uint32, error)

+ func (m *MockManager) QueryBucketMigrate(ctx context.Context) (*gfspserver.GfSpQueryBucketMigrateResponse, error)

+ func (m *MockManager) QuerySpExit(ctx context.Context) (*gfspserver.GfSpQuerySpExitResponse, error)

+ func (m *MockManager) QueryTasks(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ func (m *MockManager) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockManager) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockManager) Start(ctx context.Context) error

+ func (m *MockManager) Stop(ctx context.Context) error

+ type MockManagerMockRecorder struct

+ func (mr *MockManagerMockRecorder) DispatchTask(ctx, limit interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleChallengePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleCreateResumableUploadObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleCreateUploadObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleDoneResumableUploadObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleDoneUploadObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleDownloadObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleGCMetaTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleGCObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleGCZombiePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleMigrateGVGTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleReceivePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleRecoverPieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleReplicatePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) HandleSealObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Name() *gomock.Call

+ func (mr *MockManagerMockRecorder) NotifyMigrateSwapOut(ctx, swapOut interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) PickVirtualGroupFamily(ctx, task interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) QueryBucketMigrate(ctx interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) QuerySpExit(ctx interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) QueryTasks(ctx, subKey interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockModular struct

+ func NewMockModular(ctrl *gomock.Controller) *MockModular

+ func (m *MockModular) EXPECT() *MockModularMockRecorder

+ func (m *MockModular) Name() string

+ func (m *MockModular) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockModular) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockModular) Start(ctx context.Context) error

+ func (m *MockModular) Stop(ctx context.Context) error

+ type MockModularMockRecorder struct

+ func (mr *MockModularMockRecorder) Name() *gomock.Call

+ func (mr *MockModularMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockModularMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockModularMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockModularMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockP2P struct

+ func NewMockP2P(ctrl *gomock.Controller) *MockP2P

+ func (m *MockP2P) EXPECT() *MockP2PMockRecorder

+ func (m *MockP2P) HandleQueryBootstrap(ctx context.Context) ([]string, error)

+ func (m *MockP2P) HandleReplicatePieceApproval(ctx context.Context, t task.ApprovalReplicatePieceTask, min, max int32, ...) ([]task.ApprovalReplicatePieceTask, error)

+ func (m *MockP2P) Name() string

+ func (m *MockP2P) QueryTasks(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ func (m *MockP2P) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockP2P) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockP2P) Start(ctx context.Context) error

+ func (m *MockP2P) Stop(ctx context.Context) error

+ type MockP2PMockRecorder struct

+ func (mr *MockP2PMockRecorder) HandleQueryBootstrap(ctx interface{}) *gomock.Call

+ func (mr *MockP2PMockRecorder) HandleReplicatePieceApproval(ctx, t, min, max, timeout interface{}) *gomock.Call

+ func (mr *MockP2PMockRecorder) Name() *gomock.Call

+ func (mr *MockP2PMockRecorder) QueryTasks(ctx, subKey interface{}) *gomock.Call

+ func (mr *MockP2PMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockP2PMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockP2PMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockP2PMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockReceiver struct

+ func NewMockReceiver(ctrl *gomock.Controller) *MockReceiver

+ func (m *MockReceiver) EXPECT() *MockReceiverMockRecorder

+ func (m *MockReceiver) HandleDoneReceivePieceTask(ctx context.Context, task task.ReceivePieceTask) ([]byte, error)

+ func (m *MockReceiver) HandleReceivePieceTask(ctx context.Context, task task.ReceivePieceTask, data []byte) error

+ func (m *MockReceiver) Name() string

+ func (m *MockReceiver) QueryTasks(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ func (m *MockReceiver) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockReceiver) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockReceiver) Start(ctx context.Context) error

+ func (m *MockReceiver) Stop(ctx context.Context) error

+ type MockReceiverMockRecorder struct

+ func (mr *MockReceiverMockRecorder) HandleDoneReceivePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockReceiverMockRecorder) HandleReceivePieceTask(ctx, task, data interface{}) *gomock.Call

+ func (mr *MockReceiverMockRecorder) Name() *gomock.Call

+ func (mr *MockReceiverMockRecorder) QueryTasks(ctx, subKey interface{}) *gomock.Call

+ func (mr *MockReceiverMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockReceiverMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockReceiverMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockReceiverMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockSigner struct

+ func NewMockSigner(ctrl *gomock.Controller) *MockSigner

+ func (m *MockSigner) CompleteMigrateBucket(ctx context.Context, migrateBucket *types0.MsgCompleteMigrateBucket) (string, error)

+ func (m *MockSigner) CompleteSPExit(ctx context.Context, completeSPExit *types1.MsgCompleteStorageProviderExit) (string, error)

+ func (m *MockSigner) CompleteSwapOut(ctx context.Context, completeSwapOut *types1.MsgCompleteSwapOut) (string, error)

+ func (m *MockSigner) CreateGlobalVirtualGroup(ctx context.Context, gvg *types1.MsgCreateGlobalVirtualGroup) (string, error)

+ func (m *MockSigner) DiscontinueBucket(ctx context.Context, bucket *types0.MsgDiscontinueBucket) (string, error)

+ func (m *MockSigner) EXPECT() *MockSignerMockRecorder

+ func (m *MockSigner) Name() string

+ func (m *MockSigner) RejectUnSealObject(ctx context.Context, object *types0.MsgRejectSealObject) (string, error)

+ func (m *MockSigner) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockSigner) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockSigner) SPExit(ctx context.Context, spExit *types1.MsgStorageProviderExit) (string, error)

+ func (m *MockSigner) SealObject(ctx context.Context, object *types0.MsgSealObject) (string, error)

+ func (m *MockSigner) SignCreateBucketApproval(ctx context.Context, bucket *types0.MsgCreateBucket) ([]byte, error)

+ func (m *MockSigner) SignCreateObjectApproval(ctx context.Context, task *types0.MsgCreateObject) ([]byte, error)

+ func (m *MockSigner) SignMigrateBucketApproval(ctx context.Context, bucket *types0.MsgMigrateBucket) ([]byte, error)

+ func (m *MockSigner) SignMigratePiece(ctx context.Context, task *gfsptask.GfSpMigratePieceTask) ([]byte, error)

+ func (m *MockSigner) SignP2PPingMsg(ctx context.Context, ping *gfspp2p.GfSpPing) ([]byte, error)

+ func (m *MockSigner) SignP2PPongMsg(ctx context.Context, pong *gfspp2p.GfSpPong) ([]byte, error)

+ func (m *MockSigner) SignReceivePieceTask(ctx context.Context, task task.ReceivePieceTask) ([]byte, error)

+ func (m *MockSigner) SignRecoveryPieceTask(ctx context.Context, task task.RecoveryPieceTask) ([]byte, error)

+ func (m *MockSigner) SignReplicatePieceApproval(ctx context.Context, task task.ApprovalReplicatePieceTask) ([]byte, error)

+ func (m *MockSigner) SignSecondarySPMigrationBucket(ctx context.Context, signDoc *types0.SecondarySpMigrationBucketSignDoc) ([]byte, error)

+ func (m *MockSigner) SignSecondarySealBls(ctx context.Context, objectID uint64, gvgId uint32, hash [][]byte) ([]byte, error)

+ func (m *MockSigner) SignSwapOut(ctx context.Context, swapOut *types1.MsgSwapOut) ([]byte, error)

+ func (m *MockSigner) Start(ctx context.Context) error

+ func (m *MockSigner) Stop(ctx context.Context) error

+ func (m *MockSigner) SwapOut(ctx context.Context, swapOut *types1.MsgSwapOut) (string, error)

+ func (m *MockSigner) UpdateSPPrice(ctx context.Context, price *types.MsgUpdateSpStoragePrice) (string, error)

+ type MockSignerMockRecorder struct

+ func (mr *MockSignerMockRecorder) CompleteMigrateBucket(ctx, migrateBucket interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) CompleteSPExit(ctx, completeSPExit interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) CompleteSwapOut(ctx, completeSwapOut interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) CreateGlobalVirtualGroup(ctx, gvg interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) DiscontinueBucket(ctx, bucket interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) Name() *gomock.Call

+ func (mr *MockSignerMockRecorder) RejectUnSealObject(ctx, object interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SPExit(ctx, spExit interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SealObject(ctx, object interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignCreateBucketApproval(ctx, bucket interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignCreateObjectApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignMigrateBucketApproval(ctx, bucket interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignMigratePiece(ctx, task interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignP2PPingMsg(ctx, ping interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignP2PPongMsg(ctx, pong interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignReceivePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignRecoveryPieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignReplicatePieceApproval(ctx, task interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignSecondarySPMigrationBucket(ctx, signDoc interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignSecondarySealBls(ctx, objectID, gvgId, hash interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SignSwapOut(ctx, swapOut interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) Stop(ctx interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) SwapOut(ctx, swapOut interface{}) *gomock.Call

+ func (mr *MockSignerMockRecorder) UpdateSPPrice(ctx, price interface{}) *gomock.Call

+ type MockTaskExecutor struct

+ func NewMockTaskExecutor(ctrl *gomock.Controller) *MockTaskExecutor

+ func (m *MockTaskExecutor) AskTask(ctx context.Context) error

+ func (m *MockTaskExecutor) EXPECT() *MockTaskExecutorMockRecorder

+ func (m *MockTaskExecutor) HandleGCMetaTask(ctx context.Context, task task.GCMetaTask)

+ func (m *MockTaskExecutor) HandleGCObjectTask(ctx context.Context, task task.GCObjectTask)

+ func (m *MockTaskExecutor) HandleGCZombiePieceTask(ctx context.Context, task task.GCZombiePieceTask)

+ func (m *MockTaskExecutor) HandleMigrateGVGTask(ctx context.Context, gvgTask task.MigrateGVGTask)

+ func (m *MockTaskExecutor) HandleReceivePieceTask(ctx context.Context, task task.ReceivePieceTask)

+ func (m *MockTaskExecutor) HandleReplicatePieceTask(ctx context.Context, task task.ReplicatePieceTask)

+ func (m *MockTaskExecutor) HandleSealObjectTask(ctx context.Context, task task.SealObjectTask)

+ func (m *MockTaskExecutor) Name() string

+ func (m *MockTaskExecutor) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockTaskExecutor) ReportTask(ctx context.Context, task task.Task) error

+ func (m *MockTaskExecutor) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockTaskExecutor) Start(ctx context.Context) error

+ func (m *MockTaskExecutor) Stop(ctx context.Context) error

+ type MockTaskExecutorMockRecorder struct

+ func (mr *MockTaskExecutorMockRecorder) AskTask(ctx interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) HandleGCMetaTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) HandleGCObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) HandleGCZombiePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) HandleMigrateGVGTask(ctx, gvgTask interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) HandleReceivePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) HandleReplicatePieceTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) HandleSealObjectTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) Name() *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) ReportTask(ctx, task interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockTaskExecutorMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockUploader struct

+ func NewMockUploader(ctrl *gomock.Controller) *MockUploader

+ func (m *MockUploader) EXPECT() *MockUploaderMockRecorder

+ func (m *MockUploader) HandleResumableUploadObjectTask(ctx context.Context, task task.ResumableUploadObjectTask, stream io.Reader) error

+ func (m *MockUploader) HandleUploadObjectTask(ctx context.Context, task task.UploadObjectTask, stream io.Reader) error

+ func (m *MockUploader) Name() string

+ func (m *MockUploader) PostResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask)

+ func (m *MockUploader) PostUploadObject(ctx context.Context, task task.UploadObjectTask)

+ func (m *MockUploader) PreResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask) error

+ func (m *MockUploader) PreUploadObject(ctx context.Context, task task.UploadObjectTask) error

+ func (m *MockUploader) QueryTasks(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ func (m *MockUploader) ReleaseResource(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ func (m *MockUploader) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (m *MockUploader) Start(ctx context.Context) error

+ func (m *MockUploader) Stop(ctx context.Context) error

+ type MockUploaderMockRecorder struct

+ func (mr *MockUploaderMockRecorder) HandleResumableUploadObjectTask(ctx, task, stream interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) HandleUploadObjectTask(ctx, task, stream interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) Name() *gomock.Call

+ func (mr *MockUploaderMockRecorder) PostResumableUploadObject(ctx, task interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) PostUploadObject(ctx, task interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) PreResumableUploadObject(ctx, task interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) PreUploadObject(ctx, task interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) QueryTasks(ctx, subKey interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) ReleaseResource(ctx, scope interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) ReserveResource(ctx, state interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockUploaderMockRecorder) Stop(ctx interface{}) *gomock.Call

type NullModular

+ func (*NullModular) VerifyGNFD1EddsaSignature(ctx context.Context, account string, domain string, offChainSig string, ...) (bool, error)

Jul 31, 2023

Changes in this version

+ var BlockSyncerModularDescription = "Synchronize data on the chain to SP"

+ var BlockSyncerModularName = strings.ToLower("BlockSyncer")

+ var MetadataModularDescription = "Retrieves sp metadata and info."

+ var MetadataModularName = strings.ToLower("Metadata")

type Approver

+ HandleMigrateBucketApprovalTask func(ctx context.Context, task task.ApprovalMigrateBucketTask) (bool, error)

+ PostMigrateBucketApproval func(ctx context.Context, task task.ApprovalMigrateBucketTask)

+ PreMigrateBucketApproval func(ctx context.Context, task task.ApprovalMigrateBucketTask) error

type AuthOpType

+ const AuthOpAskMigrateBucketApproval

+ const AuthOpTypeGetRecoveryPiece

type Manager

+ HandleCreateResumableUploadObjectTask func(ctx context.Context, task task.ResumableUploadObjectTask) error

+ HandleDoneResumableUploadObjectTask func(ctx context.Context, task task.ResumableUploadObjectTask) error

+ HandleMigrateGVGTask func(ctx context.Context, task task.MigrateGVGTask) error

+ HandleRecoverPieceTask func(ctx context.Context, task task.RecoveryPieceTask) error

+ NotifyMigrateSwapOut func(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) error

+ PickVirtualGroupFamily func(ctx context.Context, task task.ApprovalCreateBucketTask) (uint32, error)

+ QueryBucketMigrate func(ctx context.Context) (*gfspserver.GfSpQueryBucketMigrateResponse, error)

+ QuerySpExit func(ctx context.Context) (*gfspserver.GfSpQuerySpExitResponse, error)

type NilModular

+ func (*NilModular) CompleteMigrateBucket(ctx context.Context, migrateBucket *storagetypes.MsgCompleteMigrateBucket) (string, error)

+ func (*NilModular) CompleteSPExit(ctx context.Context, ...) (string, error)

+ func (*NilModular) CompleteSwapOut(ctx context.Context, completeSwapOut *virtualgrouptypes.MsgCompleteSwapOut) (string, error)

+ func (*NilModular) CreateGlobalVirtualGroup(context.Context, *virtualgrouptypes.MsgCreateGlobalVirtualGroup) error

+ func (*NilModular) HandleMigrateGVGTask(ctx context.Context, gvgTask task.MigrateGVGTask)

+ func (*NilModular) SPExit(ctx context.Context, spExit *virtualgrouptypes.MsgStorageProviderExit) (string, error)

+ func (*NilModular) SignMigrateBucketApproval(context.Context, *storagetypes.MsgMigrateBucket) ([]byte, error)

+ func (*NilModular) SignMigratePiece(ctx context.Context, task *gfsptask.GfSpMigratePieceTask) ([]byte, error)

+ func (*NilModular) SignRecoveryPieceTask(context.Context, task.RecoveryPieceTask) ([]byte, error)

+ func (*NilModular) SignSecondarySPMigrationBucket(ctx context.Context, signDoc *storagetypes.SecondarySpMigrationBucketSignDoc) ([]byte, error)

+ func (*NilModular) SignSecondarySealBls(context.Context, uint64, uint32, [][]byte) ([]byte, error)

+ func (*NilModular) SignSwapOut(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) ([]byte, error)

+ func (*NilModular) SwapOut(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) (string, error)

+ func (*NilModular) UpdateSPPrice(ctx context.Context, price *sptypes.MsgUpdateSpStoragePrice) (string, error)

type NullModular

+ func (*NullModular) HandleCreateResumableUploadObjectTask(context.Context, task.ResumableUploadObjectTask) error

+ func (*NullModular) HandleDoneResumableUploadObjectTask(context.Context, task.ResumableUploadObjectTask) error

+ func (*NullModular) HandleMigrateBucketApprovalTask(context.Context, task.ApprovalMigrateBucketTask) (bool, error)

+ func (*NullModular) HandleMigrateGVGTask(ctx context.Context, gvgTask task.MigrateGVGTask) error

+ func (*NullModular) HandleRecoverPieceTask(ctx context.Context, task task.RecoveryPieceTask) error

+ func (*NullModular) HandleResumableUploadObjectTask(ctx context.Context, task task.ResumableUploadObjectTask, stream io.Reader) error

+ func (*NullModular) NotifyMigrateSwapOut(context.Context, *virtualgrouptypes.MsgSwapOut) error

+ func (*NullModular) PickVirtualGroupFamily(context.Context, task.ApprovalCreateBucketTask) (uint32, error)

+ func (*NullModular) PostMigrateBucketApproval(context.Context, task.ApprovalMigrateBucketTask)

+ func (*NullModular) PostResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask)

+ func (*NullModular) PreMigrateBucketApproval(context.Context, task.ApprovalMigrateBucketTask) error

+ func (*NullModular) PreResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask) error

+ func (m *NullModular) QueryBucketMigrate(ctx context.Context) (*gfspserver.GfSpQueryBucketMigrateResponse, error)

+ func (m *NullModular) QuerySpExit(ctx context.Context) (*gfspserver.GfSpQuerySpExitResponse, error)

type Signer

+ CompleteMigrateBucket func(ctx context.Context, migrateBucket *storagetypes.MsgCompleteMigrateBucket) (string, error)

+ CompleteSPExit func(ctx context.Context, ...) (string, error)

+ CompleteSwapOut func(ctx context.Context, completeSwapOut *virtualgrouptypes.MsgCompleteSwapOut) (string, error)

+ CreateGlobalVirtualGroup func(ctx context.Context, gvg *virtualgrouptypes.MsgCreateGlobalVirtualGroup) error

+ SPExit func(ctx context.Context, spExit *virtualgrouptypes.MsgStorageProviderExit) (string, error)

+ SignMigrateBucketApproval func(ctx context.Context, bucket *storagetypes.MsgMigrateBucket) ([]byte, error)

+ SignMigratePiece func(ctx context.Context, task *gfsptask.GfSpMigratePieceTask) ([]byte, error)

+ SignRecoveryPieceTask func(ctx context.Context, task task.RecoveryPieceTask) ([]byte, error)

+ SignSecondarySPMigrationBucket func(ctx context.Context, signDoc *storagetypes.SecondarySpMigrationBucketSignDoc) ([]byte, error)

+ SignSecondarySealBls func(ctx context.Context, objectID uint64, gvgId uint32, hash [][]byte) ([]byte, error)

+ SignSwapOut func(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) ([]byte, error)

+ SwapOut func(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) (string, error)

+ UpdateSPPrice func(ctx context.Context, price *sptypes.MsgUpdateSpStoragePrice) (string, error)

type TaskExecutor

+ HandleMigrateGVGTask func(ctx context.Context, gvgTask task.MigrateGVGTask)

type Uploader

+ HandleResumableUploadObjectTask func(ctx context.Context, task task.ResumableUploadObjectTask, stream io.Reader) error

+ PostResumableUploadObject func(ctx context.Context, task task.ResumableUploadObjectTask)

+ PreResumableUploadObject func(ctx context.Context, task task.ResumableUploadObjectTask) error

Jun 21, 2023

Changes in this version

+ var ApprovalModularDescription = "Handles the ask crate bucket/object and replicates piece approval request."

+ var ApprovalModularName = strings.ToLower("Approver")

+ var AuthenticationModularDescription = "Checks authentication."

+ var AuthenticationModularName = strings.ToLower("Authenticator")

+ var DownloadModularDescription = "Downloads object and gets challenge info and statistical read traffic from the backend."

+ var DownloadModularName = strings.ToLower("Downloader")

+ var ErrNilModular = errors.New("call nil module, please check again")

+ var ExecuteModularDescription = "Executes background tasks."

+ var ExecuteModularName = strings.ToLower("TaskExecutor")

+ var GateModularDescription = "Receives the user request and routes to the responding service."

+ var GateModularName = strings.ToLower("Gateway")

+ var ManageModularDescription = "Manages SPs and schedules tasks."

+ var ManageModularName = strings.ToLower("Manager")

+ var P2PModularDescription = "Communicates between SPs on p2p protocol."

+ var P2PModularName = strings.ToLower("p2p")

+ var ReceiveModularDescription = "Receives data pieces of an object from other storage provider and store."

+ var ReceiveModularName = strings.ToLower("Receiver")

+ var SignModularDescription = "Signs the transaction and broadcasts to chain."

+ var SignModularName = strings.ToLower("Signer")

+ var UploadModularDescription = "Uploads object payload to primary SP."

+ var UploadModularName = strings.ToLower("Uploader")

+ type Approver interface

+ HandleCreateBucketApprovalTask func(ctx context.Context, task task.ApprovalCreateBucketTask) (bool, error)

+ HandleCreateObjectApprovalTask func(ctx context.Context, task task.ApprovalCreateObjectTask) (bool, error)

+ PostCreateBucketApproval func(ctx context.Context, task task.ApprovalCreateBucketTask)

+ PostCreateObjectApproval func(ctx context.Context, task task.ApprovalCreateObjectTask)

+ PreCreateBucketApproval func(ctx context.Context, task task.ApprovalCreateBucketTask) error

+ PreCreateObjectApproval func(ctx context.Context, task task.ApprovalCreateObjectTask) error

+ QueryTasks func(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ type AuthOpType int32

+ const AuthOpAskCreateBucketApproval

+ const AuthOpAskCreateObjectApproval

+ const AuthOpTypeGetBucketQuota

+ const AuthOpTypeGetChallengePieceInfo

+ const AuthOpTypeGetObject

+ const AuthOpTypeGetUploadingState

+ const AuthOpTypeListBucketReadRecord

+ const AuthOpTypePutObject

+ const AuthOpTypeUnKnown

+ type Authenticator interface

+ GetAuthNonce func(ctx context.Context, account string, domain string) (*spdb.OffChainAuthKey, error)

+ UpdateUserPublicKey func(ctx context.Context, account string, domain string, currentNonce int32, ...) (bool, error)

+ VerifyAuthentication func(ctx context.Context, auth AuthOpType, account, bucket, object string) (bool, error)

+ VerifyOffChainSignature func(ctx context.Context, account string, domain string, offChainSig string, ...) (bool, error)

+ type Downloader interface

+ HandleChallengePiece func(ctx context.Context, task task.ChallengePieceTask) ([]byte, [][]byte, []byte, error)

+ HandleDownloadObjectTask func(ctx context.Context, task task.DownloadObjectTask) ([]byte, error)

+ HandleDownloadPieceTask func(ctx context.Context, task task.DownloadPieceTask) ([]byte, error)

+ PostChallengePiece func(ctx context.Context, task task.ChallengePieceTask)

+ PostDownloadObject func(ctx context.Context, task task.DownloadObjectTask)

+ PostDownloadPiece func(ctx context.Context, task task.DownloadPieceTask)

+ PreChallengePiece func(ctx context.Context, task task.ChallengePieceTask) error

+ PreDownloadObject func(ctx context.Context, task task.DownloadObjectTask) error

+ PreDownloadPiece func(ctx context.Context, task task.DownloadPieceTask) error

+ QueryTasks func(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ type Manager interface

+ DispatchTask func(ctx context.Context, limit rcmgr.Limit) (task.Task, error)

+ HandleChallengePieceTask func(ctx context.Context, task task.ChallengePieceTask) error

+ HandleCreateUploadObjectTask func(ctx context.Context, task task.UploadObjectTask) error

+ HandleDoneUploadObjectTask func(ctx context.Context, task task.UploadObjectTask) error

+ HandleDownloadObjectTask func(ctx context.Context, task task.DownloadObjectTask) error

+ HandleGCMetaTask func(ctx context.Context, task task.GCMetaTask) error

+ HandleGCObjectTask func(ctx context.Context, task task.GCObjectTask) error

+ HandleGCZombiePieceTask func(ctx context.Context, task task.GCZombiePieceTask) error

+ HandleReceivePieceTask func(ctx context.Context, task task.ReceivePieceTask) error

+ HandleReplicatePieceTask func(ctx context.Context, task task.ReplicatePieceTask) error

+ HandleSealObjectTask func(ctx context.Context, task task.SealObjectTask) error

+ QueryTasks func(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ type Modular interface

+ ReleaseResource func(ctx context.Context, scope rcmgr.ResourceScopeSpan)

+ ReserveResource func(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ type NilModular struct

+ func (*NilModular) AskTask(context.Context) error

+ func (*NilModular) DiscontinueBucket(context.Context, *storagetypes.MsgDiscontinueBucket) error

+ func (*NilModular) HandleChallengePiece(context.Context, task.ChallengePieceTask) ([]byte, [][]byte, []byte, error)

+ func (*NilModular) HandleDownloadObjectTask(context.Context, task.DownloadObjectTask) ([]byte, error)

+ func (*NilModular) HandleDownloadPieceTask(context.Context, task.DownloadPieceTask) ([]byte, error)

+ func (*NilModular) HandleGCMetaTask(context.Context, task.GCMetaTask)

+ func (*NilModular) HandleGCObjectTask(context.Context, task.GCObjectTask)

+ func (*NilModular) HandleGCZombiePieceTask(context.Context, task.GCZombiePieceTask)

+ func (*NilModular) HandleQueryBootstrap(context.Context) ([]string, error)

+ func (*NilModular) HandleReceivePieceTask(context.Context, task.ReceivePieceTask)

+ func (*NilModular) HandleReplicatePieceApproval(context.Context, task.ApprovalReplicatePieceTask, int32, int32, int64) ([]task.ApprovalReplicatePieceTask, error)

+ func (*NilModular) HandleReplicatePieceTask(context.Context, task.ReplicatePieceTask)

+ func (*NilModular) HandleSealObjectTask(context.Context, task.SealObjectTask)

+ func (*NilModular) Name() string

+ func (*NilModular) PostChallengePiece(context.Context, task.ChallengePieceTask)

+ func (*NilModular) PostDownloadObject(context.Context, task.DownloadObjectTask)

+ func (*NilModular) PostDownloadPiece(context.Context, task.DownloadPieceTask)

+ func (*NilModular) PreChallengePiece(context.Context, task.ChallengePieceTask) error

+ func (*NilModular) PreDownloadObject(context.Context, task.DownloadObjectTask) error

+ func (*NilModular) PreDownloadPiece(context.Context, task.DownloadPieceTask) error

+ func (*NilModular) QueryTasks(ctx context.Context, keyPrefix task.TKey) ([]task.Task, error)

+ func (*NilModular) RejectUnSealObject(context.Context, *storagetypes.MsgRejectSealObject) error

+ func (*NilModular) ReleaseResource(context.Context, rcmgr.ResourceScopeSpan)

+ func (*NilModular) ReportTask(context.Context, task.Task) error

+ func (*NilModular) ReserveResource(context.Context, *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (*NilModular) SealObject(context.Context, *storagetypes.MsgSealObject) error

+ func (*NilModular) SignCreateBucketApproval(context.Context, *storagetypes.MsgCreateBucket) ([]byte, error)

+ func (*NilModular) SignCreateObjectApproval(context.Context, *storagetypes.MsgCreateObject) ([]byte, error)

+ func (*NilModular) SignIntegrityHash(ctx context.Context, objectID uint64, hash [][]byte) ([]byte, []byte, error)

+ func (*NilModular) SignP2PPingMsg(context.Context, *gfspp2p.GfSpPing) ([]byte, error)

+ func (*NilModular) SignP2PPongMsg(context.Context, *gfspp2p.GfSpPong) ([]byte, error)

+ func (*NilModular) SignReceivePieceTask(context.Context, task.ReceivePieceTask) ([]byte, error)

+ func (*NilModular) SignReplicatePieceApproval(context.Context, task.ApprovalReplicatePieceTask) ([]byte, error)

+ func (*NilModular) Start(context.Context) error

+ func (*NilModular) Stop(context.Context) error

+ type NullModular struct

+ func (*NullModular) DispatchTask(context.Context, rcmgr.Limit) (task.Task, error)

+ func (*NullModular) GetAuthNonce(ctx context.Context, account string, domain string) (*corespdb.OffChainAuthKey, error)

+ func (*NullModular) HandleChallengePieceTask(context.Context, task.ChallengePieceTask) error

+ func (*NullModular) HandleCreateBucketApprovalTask(context.Context, task.ApprovalCreateBucketTask) (bool, error)

+ func (*NullModular) HandleCreateObjectApprovalTask(context.Context, task.ApprovalCreateObjectTask) (bool, error)

+ func (*NullModular) HandleCreateUploadObjectTask(context.Context, task.UploadObjectTask) error

+ func (*NullModular) HandleDoneUploadObjectTask(context.Context, task.UploadObjectTask) error

+ func (*NullModular) HandleDownloadObjectTask(context.Context, task.DownloadObjectTask) error

+ func (*NullModular) HandleGCMetaTask(context.Context, task.GCMetaTask) error

+ func (*NullModular) HandleGCObjectTask(context.Context, task.GCObjectTask) error

+ func (*NullModular) HandleGCZombiePieceTask(context.Context, task.GCZombiePieceTask) error

+ func (*NullModular) HandleReceivePieceTask(context.Context, task.ReceivePieceTask) error

+ func (*NullModular) HandleReplicatePieceApproval(context.Context, task.ApprovalReplicatePieceTask) (bool, error)

+ func (*NullModular) HandleReplicatePieceTask(context.Context, task.ReplicatePieceTask) error

+ func (*NullModular) HandleSealObjectTask(context.Context, task.SealObjectTask) error

+ func (*NullModular) HandleUploadObjectTask(ctx context.Context, task task.UploadObjectTask, stream io.Reader) error

+ func (*NullModular) Name() string

+ func (*NullModular) PostCreateBucketApproval(context.Context, task.ApprovalCreateBucketTask)

+ func (*NullModular) PostCreateObjectApproval(context.Context, task.ApprovalCreateObjectTask)

+ func (*NullModular) PostReplicatePieceApproval(context.Context, task.ApprovalReplicatePieceTask)

+ func (*NullModular) PostUploadObject(ctx context.Context, task task.UploadObjectTask)

+ func (*NullModular) PreCreateBucketApproval(context.Context, task.ApprovalCreateBucketTask) error

+ func (*NullModular) PreCreateObjectApproval(context.Context, task.ApprovalCreateObjectTask) error

+ func (*NullModular) PreReplicatePieceApproval(context.Context, task.ApprovalReplicatePieceTask) error

+ func (*NullModular) PreUploadObject(ctx context.Context, task task.UploadObjectTask) error

+ func (*NullModular) QueryTask(context.Context, task.TKey) (task.Task, error)

+ func (*NullModular) QueryTasks(ctx context.Context, keyPrefix task.TKey) ([]task.Task, error)

+ func (*NullModular) ReleaseResource(context.Context, rcmgr.ResourceScopeSpan)

+ func (*NullModular) ReserveResource(context.Context, *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (*NullModular) Start(context.Context) error

+ func (*NullModular) Stop(context.Context) error

+ func (*NullModular) UpdateUserPublicKey(ctx context.Context, account string, domain string, currentNonce int32, ...) (bool, error)

+ func (*NullModular) VerifyAuthentication(context.Context, AuthOpType, string, string, string) (bool, error)

+ func (*NullModular) VerifyOffChainSignature(ctx context.Context, account string, domain string, offChainSig string, ...) (bool, error)

+ type NullReceiveModular struct

+ func (*NullReceiveModular) HandleDoneReceivePieceTask(context.Context, task.ReceivePieceTask) ([]byte, []byte, error)

+ func (*NullReceiveModular) HandleReceivePieceTask(context.Context, task.ReceivePieceTask, []byte) error

+ func (*NullReceiveModular) Name() string

+ func (*NullReceiveModular) QueryTasks(ctx context.Context, keyPrefix task.TKey) ([]task.Task, error)

+ func (*NullReceiveModular) ReleaseResource(context.Context, rcmgr.ResourceScopeSpan)

+ func (*NullReceiveModular) ReserveResource(context.Context, *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)

+ func (*NullReceiveModular) Start(context.Context) error

+ func (*NullReceiveModular) Stop(context.Context) error

+ type P2P interface

+ HandleQueryBootstrap func(ctx context.Context) ([]string, error)

+ HandleReplicatePieceApproval func(ctx context.Context, task task.ApprovalReplicatePieceTask, min, max int32, ...) ([]task.ApprovalReplicatePieceTask, error)

+ QueryTasks func(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ type Receiver interface

+ HandleDoneReceivePieceTask func(ctx context.Context, task task.ReceivePieceTask) ([]byte, []byte, error)

+ HandleReceivePieceTask func(ctx context.Context, task task.ReceivePieceTask, data []byte) error

+ QueryTasks func(ctx context.Context, subKey task.TKey) ([]task.Task, error)

+ type Signer interface

+ DiscontinueBucket func(ctx context.Context, bucket *storagetypes.MsgDiscontinueBucket) error

+ RejectUnSealObject func(ctx context.Context, object *storagetypes.MsgRejectSealObject) error

+ SealObject func(ctx context.Context, object *storagetypes.MsgSealObject) error

+ SignCreateBucketApproval func(ctx context.Context, bucket *storagetypes.MsgCreateBucket) ([]byte, error)

+ SignCreateObjectApproval func(ctx context.Context, task *storagetypes.MsgCreateObject) ([]byte, error)

+ SignIntegrityHash func(ctx context.Context, objectID uint64, hash [][]byte) ([]byte, []byte, error)

+ SignP2PPingMsg func(ctx context.Context, ping *gfspp2p.GfSpPing) ([]byte, error)

+ SignP2PPongMsg func(ctx context.Context, pong *gfspp2p.GfSpPong) ([]byte, error)

+ SignReceivePieceTask func(ctx context.Context, task task.ReceivePieceTask) ([]byte, error)

+ SignReplicatePieceApproval func(ctx context.Context, task task.ApprovalReplicatePieceTask) ([]byte, error)

+ type TaskExecutor interface

+ AskTask func(ctx context.Context) error

+ HandleGCMetaTask func(ctx context.Context, task task.GCMetaTask)

+ HandleGCObjectTask func(ctx context.Context, task task.GCObjectTask)

+ HandleGCZombiePieceTask func(ctx context.Context, task task.GCZombiePieceTask)

+ HandleReceivePieceTask func(ctx context.Context, task task.ReceivePieceTask)

+ HandleReplicatePieceTask func(ctx context.Context, task task.ReplicatePieceTask)

+ HandleSealObjectTask func(ctx context.Context, task task.SealObjectTask)

+ ReportTask func(ctx context.Context, task task.Task) error

+ type Uploader interface

+ HandleUploadObjectTask func(ctx context.Context, task task.UploadObjectTask, stream io.Reader) error

+ PostUploadObject func(ctx context.Context, task task.UploadObjectTask)

+ PreUploadObject func(ctx context.Context, task task.UploadObjectTask) error

+ QueryTasks func(ctx context.Context, subKey task.TKey) ([]task.Task, error)