gfspclient

package
v1.6.1 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: GPL-3.0 Imports: 34 Imported by: 0

Documentation

Overview

Package gfspclient is a generated GoMock package.

Index

Constants

View Source 
const (
	// MaxClientCallMsgSize defines the max message size for grpc client
	MaxClientCallMsgSize = 3 * 1024 * 1024 * 1024
	// ClientCodeSpace defines the code space for gfsp client
	ClientCodeSpace = "GfSpClient"
	// HTTPMaxIdleConns defines the max idle connections for HTTP server
	HTTPMaxIdleConns = 20
	// HTTPIdleConnTimout defines the idle time of connection for closing
	HTTPIdleConnTimout = 60 * time.Second

	// DefaultStreamBufSize defines gateway stream forward payload buf size
	DefaultStreamBufSize = 16 * 1024 * 1024
)
View Source 
const (
	// ReplicateObjectPiecePath defines replicate-object path style
	ReplicateObjectPiecePath = "/greenfield/receiver/v1/replicate-piece"
	// GnfdReplicatePieceApprovalHeader defines secondary approved msg for replicating piece
	GnfdReplicatePieceApprovalHeader = "X-Gnfd-Replicate-Piece-Approval-Msg"
	// GnfdReceiveMsgHeader defines receive piece data meta
	GnfdReceiveMsgHeader = "X-Gnfd-Receive-Msg"
	// GnfdIntegrityHashHeader defines integrity hash, which is used by challenge and receiver
	GnfdIntegrityHashHeader = "X-Gnfd-Integrity-Hash"
	// GnfdIntegrityHashSignatureHeader defines integrity hash signature, which is used by receiver
	GnfdIntegrityHashSignatureHeader = "X-Gnfd-Integrity-Hash-Signature"
	// RecoveryObjectPiecePath defines recovery-object path style
	RecoveryObjectPiecePath = "/greenfield/recovery/v1/get-piece"
	// GnfdRecoveryMsgHeader defines receive piece data meta
	GnfdRecoveryMsgHeader = "X-Gnfd-Recovery-Msg"

	// MigratePiecePath defines migrate piece path which is used in SP exiting case
	MigratePiecePath = "/greenfield/migrate/v1/migrate-piece"
	// GnfdMigratePieceMsgHeader defines migrate piece msg header
	GnfdMigratePieceMsgHeader = "X-Gnfd-Migrate-Piece-Msg"
	// GnfdMigrateGVGMsgHeader defines migrate gvg msg header
	GnfdMigrateGVGMsgHeader = "X-Gnfd-Migrate-GVG-Msg"
	// NotifyMigrateSwapOutTaskPath defines dispatch migrate gvg task from src sp to dest sp.
	NotifyMigrateSwapOutTaskPath = "/greenfield/migrate/v1/notify-migrate-swap-out-task"
	// GnfdMigrateSwapOutMsgHeader defines migrate swap out msg header
	GnfdMigrateSwapOutMsgHeader = "X-Gnfd-Migrate-Swap-Out-Msg"
	// SecondarySPMigrationBucketApprovalPath defines secondary sp sign migration bucket approval
	SecondarySPMigrationBucketApprovalPath = "/greenfield/migrate/v1/migration-bucket-approval"
	// SwapOutApprovalPath defines get swap out approval path
	SwapOutApprovalPath = "/greenfield/migrate/v1/get-swap-out-approval"
	// GnfdSecondarySPMigrationBucketMsgHeader defines secondary sp migration bucket sign doc header.
	GnfdSecondarySPMigrationBucketMsgHeader = "X-Gnfd-Secondary-Migration-Bucket-Msg"
	// GnfdSecondarySPMigrationBucketApprovalHeader defines secondary sp migration bucket bls approval header.
	GnfdSecondarySPMigrationBucketApprovalHeader = "X-Gnfd-Secondary-Migration-Bucket-Approval"
	// MigrateQueryBucketQuotaPath defines query bucket quota from src sp
	MigrateQueryBucketQuotaPath = "/greenfield/migrate/v1/migrate-query-bucket-quota"
	// MigrateQueryBucketQuotaHasEnoughQuotaPath defines query bucket quota from src sp
	MigrateQueryBucketQuotaHasEnoughQuotaPath = "/greenfield/migrate/v1/migrate-query-bucket-has-enough-quota"
	// PreMigrateBucketPath defines pre migrate bucket, can lock quota for migrate bucket
	PreMigrateBucketPath = "/greenfield/migrate/v1/pre-migrate-bucket"
	// PostMigrateBucketPath defines notifying the source sp about the completion of migration bucket
	PostMigrateBucketPath = "/greenfield/migrate/v1/post-migrate-bucket"
	// GnfdMigrateBucketMsgHeader defines migrate bucket msg header
	GnfdMigrateBucketMsgHeader = "X-Gnfd-Migrate-Bucket-Msg"
	// GnfdUnsignedApprovalMsgHeader defines unsigned msg, which is used by get-approval
	GnfdUnsignedApprovalMsgHeader = "X-Gnfd-Unsigned-Msg"
	// GnfdSignedApprovalMsgHeader defines signed msg, which is used by get-approval
	GnfdSignedApprovalMsgHeader = "X-Gnfd-Signed-Msg"
	// GnfdQuotaInfoHeader defines quota info, which is used by sp
	GnfdQuotaInfoHeader = "X-Gnfd-Quota-Info"
)

spilt server and client const definition avoids circular references TODO:: extract the common parts of http to the gfsp app layer

Variables

View Source 
var (
	ErrExceptionsStream = gfsperrors.Register(ClientCodeSpace, http.StatusBadRequest, 98002, "stream closed abnormally")
	ErrTypeMismatch     = gfsperrors.Register(ClientCodeSpace, http.StatusBadRequest, 98101, "response type mismatch")
	ErrNoSuchObject     = gfsperrors.Register(ClientCodeSpace, http.StatusBadRequest, 98093, "no such object from metadata")
)

Functions

func DefaultClientOptions 

func DefaultClientOptions() []grpc.DialOption

func ErrRPCUnknownWithDetail added in v0.2.4 

func ErrRPCUnknownWithDetail(detail string, err error) *gfsperrors.GfSpError

Types

type ApproverAPI added in v0.2.4 

type ApproverAPI interface {
	AskCreateBucketApproval(ctx context.Context, t coretask.ApprovalCreateBucketTask) (bool, coretask.ApprovalCreateBucketTask, error)
	AskMigrateBucketApproval(ctx context.Context, t coretask.ApprovalMigrateBucketTask) (bool, coretask.ApprovalMigrateBucketTask, error)
	AskCreateObjectApproval(ctx context.Context, t coretask.ApprovalCreateObjectTask) (bool, coretask.ApprovalCreateObjectTask, error)
	AskDelegateCreateObjectApproval(ctx context.Context, t coretask.ApprovalDelegateCreateObjectTask) (bool, coretask.ApprovalDelegateCreateObjectTask, error)
}

ApproverAPI for mock use

type AuthenticatorAPI added in v0.2.4 

type AuthenticatorAPI interface {
	VerifyAuthentication(ctx context.Context, auth coremodule.AuthOpType, account, bucket, object string, opts ...grpc.DialOption) (bool, error)
	GetAuthNonce(ctx context.Context, account string, domain string, opts ...grpc.DialOption) (currentNonce int32, nextNonce int32, currentPublicKey string, expiryDate int64, err error)
	UpdateUserPublicKey(ctx context.Context, account string, domain string, currentNonce int32, nonce int32, userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)
	VerifyGNFD1EddsaSignature(ctx context.Context, account string, domain string, offChainSig string, realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)
	GetAuthKeyV2(ctx context.Context, account string, domain string, userPublicKey string, opts ...grpc.DialOption) (string, int64, error)
	UpdateUserPublicKeyV2(ctx context.Context, account string, domain string, userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)
	VerifyGNFD2EddsaSignature(ctx context.Context, account string, domain string, userPublicKey string, offChainSig string, realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)
	ListAuthKeysV2(ctx context.Context, account string, domain string, opts ...grpc.DialOption) ([]string, error)
	DeleteAuthKeysV2(ctx context.Context, account string, domain string, userPublicKeys []string, opts ...grpc.DialOption) (bool, error)
}

AuthenticatorAPI for mock use

type DownloaderAPI added in v0.2.4 

type DownloaderAPI interface {
	GetObject(ctx context.Context, downloadObjectTask coretask.DownloadObjectTask, opts ...grpc.DialOption) ([]byte, error)
	GetPiece(ctx context.Context, downloadPieceTask coretask.DownloadPieceTask, opts ...grpc.DialOption) ([]byte, error)
	GetChallengeInfo(ctx context.Context, challengePieceTask coretask.ChallengePieceTask, opts ...grpc.DialOption) ([]byte, [][]byte, []byte, error)
	RecoupQuota(ctx context.Context, bucketID, extraQuota uint64, yearMonth string, opts ...grpc.DialOption) error
	DeductQuotaForBucketMigrate(ctx context.Context, bucketID, deductQuota uint64, yearMonth string, opts ...grpc.DialOption) error
}

DownloaderAPI for mock use

type GaterAPI added in v0.2.4 

type GaterAPI interface {
	ReplicatePieceToSecondary(ctx context.Context, endpoint string, receive coretask.ReceivePieceTask, data []byte) error
	GetPieceFromECChunks(ctx context.Context, endpoint string, task coretask.RecoveryPieceTask) (io.ReadCloser, error)
	DoneReplicatePieceToSecondary(ctx context.Context, endpoint string, receive coretask.ReceivePieceTask) ([]byte, error)
	MigratePiece(ctx context.Context, gvgTask *gfsptask.GfSpMigrateGVGTask, pieceTask *gfsptask.GfSpMigratePieceTask) ([]byte, error)
	NotifyDestSPMigrateSwapOut(ctx context.Context, destEndpoint string, swapOut *virtualgrouptypes.MsgSwapOut) error
	GetSecondarySPMigrationBucketApproval(ctx context.Context, secondarySPEndpoint string, signDoc *storagetypes.SecondarySpMigrationBucketSignDoc) ([]byte, error)
	GetSwapOutApproval(ctx context.Context, destSPEndpoint string, swapOutApproval *virtualgrouptypes.MsgSwapOut) (*virtualgrouptypes.MsgSwapOut, error)
	QueryLatestBucketQuota(ctx context.Context, endpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)
	PreMigrateBucket(ctx context.Context, srcSPEndpoint string, preMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)
	PostMigrateBucket(ctx context.Context, srcSPEndpoint string, postMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)
	QuerySPHasEnoughQuotaForMigrateBucket(ctx context.Context, srcSPEndpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) error
}

GaterAPI for mock use

type GfSpClient 

type GfSpClient struct {
	// contains filtered or unexported fields
}

func NewGfSpClient 

func NewGfSpClient(approverEndpoint, managerEndpoint, downloaderEndpoint, receiverEndpoint, metadataEndpoint,
	uploaderEndpoint, p2pEndpoint, signerEndpoint, authenticatorEndpoint string, metrics bool) *GfSpClient

func (*GfSpClient) ApproverConn 

func (s *GfSpClient) ApproverConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*GfSpClient) AskCreateBucketApproval 

func (s *GfSpClient) AskCreateBucketApproval(ctx context.Context, task coretask.ApprovalCreateBucketTask) (
	bool, coretask.ApprovalCreateBucketTask, error)

func (*GfSpClient) AskCreateObjectApproval 

func (s *GfSpClient) AskCreateObjectApproval(ctx context.Context, task coretask.ApprovalCreateObjectTask) (
	bool, coretask.ApprovalCreateObjectTask, error)

func (*GfSpClient) AskDelegateCreateObjectApproval added in v1.6.0 

func (s *GfSpClient) AskDelegateCreateObjectApproval(ctx context.Context, task coretask.ApprovalDelegateCreateObjectTask) (bool, coretask.ApprovalDelegateCreateObjectTask, error)

func (*GfSpClient) AskMigrateBucketApproval added in v0.2.3 

func (s *GfSpClient) AskMigrateBucketApproval(ctx context.Context, task coretask.ApprovalMigrateBucketTask) (
	bool, coretask.ApprovalMigrateBucketTask, error)

func (*GfSpClient) AskSecondaryReplicatePieceApproval 

func (s *GfSpClient) AskSecondaryReplicatePieceApproval(ctx context.Context, task coretask.ApprovalReplicatePieceTask,
	low, high int, timeout int64) ([]*gfsptask.GfSpReplicatePieceApprovalTask, error)

func (*GfSpClient) AskTask 

func (s *GfSpClient) AskTask(ctx context.Context, limit corercmgr.Limit) (coretask.Task, error)

func (*GfSpClient) CancelSwapIn added in v1.3.0 

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

func (*GfSpClient) Close 

func (s *GfSpClient) Close() error

func (*GfSpClient) CompleteMigrateBucket added in v0.2.3 

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

func (*GfSpClient) CompleteSPExit added in v0.2.3 

func (s *GfSpClient) CompleteSPExit(ctx context.Context, completeSPExit *virtualgrouptypes.MsgCompleteStorageProviderExit) (string, error)

func (*GfSpClient) CompleteSpExit added in v1.3.0 

func (s *GfSpClient) CompleteSpExit(ctx context.Context, completeSpExit *virtualgrouptypes.MsgCompleteStorageProviderExit) (string, error)

func (*GfSpClient) CompleteSwapIn added in v1.3.0 

func (s *GfSpClient) CompleteSwapIn(ctx context.Context, completeSwapIn *virtualgrouptypes.MsgCompleteSwapIn) (string, error)

func (*GfSpClient) CompleteSwapOut added in v0.2.3 

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

func (*GfSpClient) Connection 

func (s *GfSpClient) Connection(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*GfSpClient) CreateGlobalVirtualGroup added in v0.2.3 

func (s *GfSpClient) CreateGlobalVirtualGroup(ctx context.Context, group *gfspserver.GfSpCreateGlobalVirtualGroup) error

func (*GfSpClient) CreateResumableUploadObject added in v0.2.3 

func (s *GfSpClient) CreateResumableUploadObject(ctx context.Context, task coretask.ResumableUploadObjectTask) error

func (*GfSpClient) CreateUploadObject 

func (s *GfSpClient) CreateUploadObject(ctx context.Context, task coretask.UploadObjectTask) error

func (*GfSpClient) DeductQuotaForBucketMigrate added in v1.1.0 

func (s *GfSpClient) DeductQuotaForBucketMigrate(ctx context.Context, bucketID, deductQuota uint64, yearMonth string, opts ...grpc.DialOption) error

func (*GfSpClient) DelegateCreateObject added in v1.6.0 

func (s *GfSpClient) DelegateCreateObject(ctx context.Context, object *storagetypes.MsgDelegateCreateObject) (string, error)

func (*GfSpClient) DelegateUpdateObjectContent added in v1.6.0 

func (s *GfSpClient) DelegateUpdateObjectContent(ctx context.Context, object *storagetypes.MsgDelegateUpdateObjectContent) (string, error)

func (*GfSpClient) DeleteAuthKeysV2 added in v1.6.0 

func (s *GfSpClient) DeleteAuthKeysV2(ctx context.Context, account string, domain string, userPublicKeys []string, opts ...grpc.DialOption) (bool, error)

func (*GfSpClient) DeleteGlobalVirtualGroup added in v1.2.0 

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

func (*GfSpClient) Deposit added in v1.2.0 

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

func (*GfSpClient) DiscontinueBucket 

func (s *GfSpClient) DiscontinueBucket(ctx context.Context, bucket *storagetypes.MsgDiscontinueBucket) (string, error)

func (*GfSpClient) DoneReplicatePiece 

func (s *GfSpClient) DoneReplicatePiece(ctx context.Context, task coretask.ReceivePieceTask, opts ...grpc.DialOption) (
	[]byte, []byte, error)

func (*GfSpClient) DoneReplicatePieceToSecondary 

func (s *GfSpClient) DoneReplicatePieceToSecondary(ctx context.Context, endpoint string,
	receive coretask.ReceivePieceTask) ([]byte, error)

func (*GfSpClient) GetAuthKeyV2 added in v1.6.0 

func (s *GfSpClient) GetAuthKeyV2(ctx context.Context, account string, domain string, userPublicKey string, opts ...grpc.DialOption) (publicKey string, expiryDate int64, err error)

func (*GfSpClient) GetAuthNonce 

func (s *GfSpClient) GetAuthNonce(ctx context.Context, account string, domain string, opts ...grpc.DialOption) (
	currentNonce int32, nextNonce int32, currentPublicKey string, expiryDate int64, err error)

GetAuthNonce get the auth nonce for which the Dapp or client can generate EDDSA key pairs.

func (*GfSpClient) GetBucketByBucketID 

func (s *GfSpClient) GetBucketByBucketID(ctx context.Context, bucketID int64, includePrivate bool,
	opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketByBucketID get bucket info by a bucket id

func (*GfSpClient) GetBucketByBucketName 

func (s *GfSpClient) GetBucketByBucketName(ctx context.Context, bucketName string, includePrivate bool,
	opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketByBucketName get bucket info by a bucket name

func (*GfSpClient) GetBucketInfoByBucketName added in v1.5.0 

func (s *GfSpClient) GetBucketInfoByBucketName(ctx context.Context, bucketName string,
	opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketInfoByBucketName get bucket info by a bucket name, including deleted and private

func (*GfSpClient) GetBucketMeta 

func (s *GfSpClient) GetBucketMeta(ctx context.Context, bucketName string, includePrivate bool,
	opts ...grpc.DialOption) (*types.VGFInfoBucket, *payment_types.StreamRecord, error)

GetBucketMeta get bucket info along with its related info such as payment

func (*GfSpClient) GetBucketReadQuota 

func (s *GfSpClient) GetBucketReadQuota(ctx context.Context, bucket *storage_types.BucketInfo, yearMonth string, opts ...grpc.DialOption) (
	uint64, uint64, uint64, uint64, uint64, uint64, error)

func (*GfSpClient) GetBucketReadQuotaCount added in v1.6.0 

func (s *GfSpClient) GetBucketReadQuotaCount(ctx context.Context, yearMonth string, opts ...grpc.DialOption) (int64, error)

func (*GfSpClient) GetBucketSize added in v1.1.0 

func (s *GfSpClient) GetBucketSize(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (string, error)

GetBucketSize get bucket total object size

func (*GfSpClient) GetChallengeInfo 

func (s *GfSpClient) GetChallengeInfo(ctx context.Context, challengePieceTask coretask.ChallengePieceTask, opts ...grpc.DialOption) (
	[]byte, [][]byte, []byte, error)

func (*GfSpClient) GetEndpointBySpID added in v0.2.4 

func (s *GfSpClient) GetEndpointBySpID(ctx context.Context, spId uint32, opts ...grpc.DialOption) (string, error)

GetEndpointBySpID get endpoint by sp id

func (*GfSpClient) GetGlobalVirtualGroup added in v0.2.3 

func (s *GfSpClient) GetGlobalVirtualGroup(ctx context.Context, bucketID uint64, lvgID uint32, opts ...grpc.DialOption) (*virtual_types.GlobalVirtualGroup, error)

func (*GfSpClient) GetGlobalVirtualGroupByGvgID added in v0.2.3 

func (s *GfSpClient) GetGlobalVirtualGroupByGvgID(ctx context.Context, gvgID uint32, opts ...grpc.DialOption) (*virtual_types.GlobalVirtualGroup, error)

func (*GfSpClient) GetGroupList 

func (s *GfSpClient) GetGroupList(ctx context.Context, name string, prefix string, sourceType string, limit int64,
	offset int64, includeRemoved bool, opts ...grpc.DialOption) ([]*types.Group, int64, error)

func (*GfSpClient) GetGroupMembers added in v0.2.4 

func (s *GfSpClient) GetGroupMembers(ctx context.Context, groupID uint64, startAfter string, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

func (*GfSpClient) GetLatestBucketReadQuota added in v1.1.0 

func (s *GfSpClient) GetLatestBucketReadQuota(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (
	*gfsptask.GfSpBucketQuotaInfo, error)

func (*GfSpClient) GetLatestObjectID added in v1.2.0 

func (s *GfSpClient) GetLatestObjectID(ctx context.Context, opts ...grpc.DialOption) (uint64, error)

GetLatestObjectID get latest object id

func (*GfSpClient) GetMigrateBucketProgress added in v1.3.0 

func (s *GfSpClient) GetMigrateBucketProgress(ctx context.Context, bucketID uint64) (*gfspserver.MigrateBucketProgressMeta, error)

func (*GfSpClient) GetObject 

func (s *GfSpClient) GetObject(ctx context.Context, downloadObjectTask coretask.DownloadObjectTask, opts ...grpc.DialOption) (
	[]byte, error)

func (*GfSpClient) GetObjectByID added in v0.2.3 

func (s *GfSpClient) GetObjectByID(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (*storage_types.ObjectInfo, error)

func (*GfSpClient) GetObjectMeta 

func (s *GfSpClient) GetObjectMeta(ctx context.Context, objectName string, bucketName string,
	includePrivate bool, opts ...grpc.DialOption) (*types.Object, error)

GetObjectMeta get object metadata

func (*GfSpClient) GetPaymentByBucketID 

func (s *GfSpClient) GetPaymentByBucketID(ctx context.Context, bucketID int64, includePrivate bool,
	opts ...grpc.DialOption) (*payment_types.StreamRecord, error)

GetPaymentByBucketID get bucket payment info by a bucket id

func (*GfSpClient) GetPaymentByBucketName 

func (s *GfSpClient) GetPaymentByBucketName(ctx context.Context, bucketName string, includePrivate bool,
	opts ...grpc.DialOption) (*payment_types.StreamRecord, error)

GetPaymentByBucketName get bucket payment info by a bucket name

func (*GfSpClient) GetPiece 

func (s *GfSpClient) GetPiece(ctx context.Context, downloadPieceTask coretask.DownloadPieceTask, opts ...grpc.DialOption) (
	[]byte, error)

func (*GfSpClient) GetPieceFromECChunks added in v0.2.3 

func (s *GfSpClient) GetPieceFromECChunks(ctx context.Context, endpoint string, task coretask.RecoveryPieceTask) (io.ReadCloser, error)

func (*GfSpClient) GetSPInfo added in v0.2.3 

func (s *GfSpClient) GetSPInfo(ctx context.Context, operatorAddress string, opts ...grpc.DialOption) (*sptypes.StorageProvider, error)

func (*GfSpClient) GetSPMigratingBucketNumber added in v0.2.5 

func (s *GfSpClient) GetSPMigratingBucketNumber(ctx context.Context, spID uint32, opts ...grpc.DialOption) (uint64, error)

func (*GfSpClient) GetSecondarySPMigrationBucketApproval added in v0.2.3 

func (s *GfSpClient) GetSecondarySPMigrationBucketApproval(ctx context.Context, secondarySPEndpoint string,
	signDoc *storagetypes.SecondarySpMigrationBucketSignDoc) ([]byte, error)

func (*GfSpClient) GetStatus added in v0.2.4 

func (s *GfSpClient) GetStatus(ctx context.Context, opts ...grpc.DialOption) (*types.Status, error)

func (*GfSpClient) GetSwapOutApproval added in v0.2.3 

func (s *GfSpClient) GetSwapOutApproval(ctx context.Context, destSPEndpoint string, swapOutApproval *virtualgrouptypes.MsgSwapOut) (
	*virtualgrouptypes.MsgSwapOut, error)

func (*GfSpClient) GetTasksStats added in v0.2.6 

func (s *GfSpClient) GetTasksStats(ctx context.Context) (*gfspserver.TasksStats, error)

func (*GfSpClient) GetUploadObjectSegment added in v0.2.3 

func (s *GfSpClient) GetUploadObjectSegment(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (uint32, error)

func (*GfSpClient) GetUploadObjectState 

func (s *GfSpClient) GetUploadObjectState(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (int32, string, error)

func (*GfSpClient) GetUserBuckets 

func (s *GfSpClient) GetUserBuckets(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) ([]*types.VGFInfoBucket, error)

func (*GfSpClient) GetUserBucketsCount 

func (s *GfSpClient) GetUserBucketsCount(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) (int64, error)

func (*GfSpClient) GetUserGroups added in v0.2.4 

func (s *GfSpClient) GetUserGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

func (*GfSpClient) GetUserOwnedGroups added in v0.2.4 

func (s *GfSpClient) GetUserOwnedGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

func (*GfSpClient) GetVirtualGroupFamily added in v0.2.3 

func (s *GfSpClient) GetVirtualGroupFamily(ctx context.Context, vgfID uint32, opts ...grpc.DialOption) (*virtual_types.GlobalVirtualGroupFamily, error)

func (*GfSpClient) HTTPClient 

func (s *GfSpClient) HTTPClient(ctx context.Context) *http.Client

func (*GfSpClient) ListAuthKeysV2 added in v1.6.0 

func (s *GfSpClient) ListAuthKeysV2(ctx context.Context, account string, domain string, opts ...grpc.DialOption) ([]string, error)

func (*GfSpClient) ListBucketReadQuota added in v1.6.0 

func (s *GfSpClient) ListBucketReadQuota(ctx context.Context, yearMonth string, offset, limit uint32, opts ...grpc.DialOption) ([]*types.BucketReadQuotaRecord, error)

func (*GfSpClient) ListBucketReadRecord 

func (s *GfSpClient) ListBucketReadRecord(ctx context.Context, bucket *storage_types.BucketInfo, startTimestampUs,
	endTimestampUs, maxRecordNum int64, opts ...grpc.DialOption) ([]*types.ReadRecord, int64, error)

func (*GfSpClient) ListBucketsByIDs added in v0.2.4 

func (s *GfSpClient) ListBucketsByIDs(ctx context.Context, bucketIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Bucket, error)

func (*GfSpClient) ListCompleteMigrationBucketEvents added in v1.3.0 

func (s *GfSpClient) ListCompleteMigrationBucketEvents(ctx context.Context, blockID uint64, srcSpId uint32, opts ...grpc.DialOption) ([]*storage_types.EventCompleteMigrationBucket, error)

func (*GfSpClient) ListDeletedObjectsByBlockNumberRange 

func (s *GfSpClient) ListDeletedObjectsByBlockNumberRange(ctx context.Context, spOperatorAddress string, startBlockNumber uint64,
	endBlockNumber uint64, includePrivate bool, opts ...grpc.DialOption) ([]*types.Object, uint64, error)

func (*GfSpClient) ListExpiredBucketsBySp 

func (s *GfSpClient) ListExpiredBucketsBySp(ctx context.Context, createAt int64, primarySpID uint32,
	limit int64, opts ...grpc.DialOption) ([]*types.Bucket, error)

ListExpiredBucketsBySp list buckets that are expired by specific sp

func (*GfSpClient) ListGlobalVirtualGroupsByBucket added in v0.2.3 

func (s *GfSpClient) ListGlobalVirtualGroupsByBucket(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) ([]*virtual_types.GlobalVirtualGroup, error)

func (*GfSpClient) ListGlobalVirtualGroupsBySecondarySP added in v0.2.3 

func (s *GfSpClient) ListGlobalVirtualGroupsBySecondarySP(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*virtual_types.GlobalVirtualGroup, error)

func (*GfSpClient) ListGroupsByIDs added in v0.2.5 

func (s *GfSpClient) ListGroupsByIDs(ctx context.Context, groupIDs []uint64, opts ...grpc.DialOption) (map[uint64]*types.Group, error)

func (*GfSpClient) ListMigrateBucketEvents added in v0.2.3 

func (s *GfSpClient) ListMigrateBucketEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListMigrateBucketEvents, error)

func (*GfSpClient) ListObjectPolicies added in v0.2.5 

func (s *GfSpClient) ListObjectPolicies(ctx context.Context, objectName, bucketName string, startAfter uint64, actionType int32, limit uint32, opts ...grpc.DialOption) ([]*types.Policy, error)

func (*GfSpClient) ListObjectsByBucketName 

func (s *GfSpClient) ListObjectsByBucketName(ctx context.Context, bucketName string, accountID string, maxKeys uint64,
	startAfter string, continuationToken string, delimiter string, prefix string, includeRemoved bool, opts ...grpc.DialOption) (
	objects []*types.Object, keyCount, maxKeysRe uint64, isTruncated bool, nextContinuationToken, name, prefixRe, delimiterRe string,
	commonPrefixes []string, continuationTokenRe string, err error)

ListObjectsByBucketName list objects info by a bucket name

func (*GfSpClient) ListObjectsByGVGAndBucketForGC added in v0.2.3 

func (s *GfSpClient) ListObjectsByGVGAndBucketForGC(ctx context.Context, dstGvgID uint32, bucketID uint64, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

func (*GfSpClient) ListObjectsByIDs added in v0.2.4 

func (s *GfSpClient) ListObjectsByIDs(ctx context.Context, objectIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Object, error)

func (*GfSpClient) ListObjectsInGVG added in v0.2.3 

func (s *GfSpClient) ListObjectsInGVG(ctx context.Context, gvgID uint32, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

func (*GfSpClient) ListObjectsInGVGAndBucket added in v0.2.3 

func (s *GfSpClient) ListObjectsInGVGAndBucket(ctx context.Context, gvgID uint32, bucketID uint64, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

func (*GfSpClient) ListPaymentAccountStreams added in v0.2.5 

func (s *GfSpClient) ListPaymentAccountStreams(ctx context.Context, paymentAccount string, opts ...grpc.DialOption) ([]*types.Bucket, error)

func (*GfSpClient) ListSpExitEvents added in v0.2.3 

func (s *GfSpClient) ListSpExitEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) (*types.ListSpExitEvents, error)

func (*GfSpClient) ListSwapOutEvents added in v0.2.3 

func (s *GfSpClient) ListSwapOutEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListSwapOutEvents, error)

func (*GfSpClient) ListUserPaymentAccounts added in v0.2.5 

func (s *GfSpClient) ListUserPaymentAccounts(ctx context.Context, accountID string, opts ...grpc.DialOption) ([]*types.PaymentAccountMeta, error)

func (*GfSpClient) ListVirtualGroupFamiliesSpID added in v0.2.3 

func (s *GfSpClient) ListVirtualGroupFamiliesSpID(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*virtual_types.GlobalVirtualGroupFamily, error)

func (*GfSpClient) ManagerConn 

func (s *GfSpClient) ManagerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*GfSpClient) MigratePiece added in v0.2.3 

func (s *GfSpClient) MigratePiece(ctx context.Context, gvgTask *gfsptask.GfSpMigrateGVGTask, pieceTask *gfsptask.GfSpMigratePieceTask) ([]byte, error)

func (*GfSpClient) NotifyDestSPMigrateSwapOut added in v0.2.3 

func (s *GfSpClient) NotifyDestSPMigrateSwapOut(ctx context.Context, destEndpoint string, swapOut *virtualgrouptypes.MsgSwapOut) error

NotifyDestSPMigrateSwapOut is used to notify dest sp start migrate swap out task.

func (*GfSpClient) NotifyMigrateSwapOut added in v0.2.3 

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

func (*GfSpClient) NotifyPostMigrateBucketAndRecoupQuota added in v1.3.0 

func (s *GfSpClient) NotifyPostMigrateBucketAndRecoupQuota(ctx context.Context, bmInfo *gfsptask.GfSpBucketMigrationInfo) (*gfsptask.GfSpBucketQuotaInfo, error)

func (*GfSpClient) NotifyPreMigrateBucketAndDeductQuota added in v1.3.0 

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

func (*GfSpClient) P2PConn 

func (s *GfSpClient) P2PConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*GfSpClient) PickVirtualGroupFamilyID added in v0.2.3 

func (s *GfSpClient) PickVirtualGroupFamilyID(ctx context.Context, task coretask.ApprovalCreateBucketTask) (uint32, error)

func (*GfSpClient) PostMigrateBucket added in v1.1.0 

func (s *GfSpClient) PostMigrateBucket(ctx context.Context, srcSPEndpoint string, postMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

PostMigrateBucket is used to notify src sp the completion of bucket migrate before dest sp send CompleteMigrateBucket Tx

func (*GfSpClient) PreMigrateBucket added in v1.1.0 

func (s *GfSpClient) PreMigrateBucket(ctx context.Context, srcSPEndpoint string, preMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

PreMigrateBucket is used to notify src sp and deduct bucket quota before send dest sp migrate gvg task

func (*GfSpClient) PrimarySpIncomeDetails added in v1.1.0 

func (s *GfSpClient) PrimarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.PrimarySpIncomeDetail, error)

PrimarySpIncomeDetails return the primary sp income for the current timestamp

func (*GfSpClient) QueryBucketMigrate added in v0.2.3 

func (s *GfSpClient) QueryBucketMigrate(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)

func (*GfSpClient) QueryLatestBucketQuota added in v1.1.0 

func (s *GfSpClient) QueryLatestBucketQuota(ctx context.Context, endpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

QueryLatestBucketQuota is used to query src sp bucket quota before send CompleteMigrateBucket Tx

func (*GfSpClient) QueryP2PBootstrap 

func (s *GfSpClient) QueryP2PBootstrap(ctx context.Context) ([]string, error)

func (*GfSpClient) QueryRecoverProcess added in v1.3.0 

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

func (*GfSpClient) QuerySPExit added in v0.2.3 

func (s *GfSpClient) QuerySPExit(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)

func (*GfSpClient) QuerySPHasEnoughQuotaForMigrateBucket added in v1.1.0 

func (s *GfSpClient) QuerySPHasEnoughQuotaForMigrateBucket(ctx context.Context, srcSPEndpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) error

QuerySPHasEnoughQuotaForMigrateBucket is used to query src sp bucket quota at approval phase

func (*GfSpClient) QueryTasks 

func (s *GfSpClient) QueryTasks(ctx context.Context, endpoint string, subKey string, opts ...grpc.DialOption) ([]string, error)

func (*GfSpClient) RecoupQuota added in v0.2.5 

func (s *GfSpClient) RecoupQuota(ctx context.Context, bucketID, extraQuota uint64, yearMonth string, opts ...grpc.DialOption) error

func (*GfSpClient) RejectMigrateBucket added in v1.1.0 

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

func (*GfSpClient) RejectUnSealObject 

func (s *GfSpClient) RejectUnSealObject(ctx context.Context, object *storagetypes.MsgRejectSealObject) (string, error)

func (*GfSpClient) ReplicatePiece 

func (s *GfSpClient) ReplicatePiece(ctx context.Context, task coretask.ReceivePieceTask, data []byte,
	opts ...grpc.DialOption) error

func (*GfSpClient) ReplicatePieceToSecondary 

func (s *GfSpClient) ReplicatePieceToSecondary(ctx context.Context, endpoint string, receive coretask.ReceivePieceTask,
	data []byte) error

func (*GfSpClient) ReportTask 

func (s *GfSpClient) ReportTask(ctx context.Context, report coretask.Task) error

func (*GfSpClient) ReserveSwapIn added in v1.3.0 

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

func (*GfSpClient) ResetRecoveryFailedList added in v1.1.0 

func (s *GfSpClient) ResetRecoveryFailedList(ctx context.Context) ([]string, error)

func (*GfSpClient) ResumableUploadObject added in v0.2.3 

func (s *GfSpClient) ResumableUploadObject(ctx context.Context, task coretask.ResumableUploadObjectTask, stream io.Reader,
	opts ...grpc.DialOption) error

func (*GfSpClient) SPExit added in v0.2.3 

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

func (*GfSpClient) SealObject 

func (s *GfSpClient) SealObject(ctx context.Context, object *storagetypes.MsgSealObject) (string, error)

func (*GfSpClient) SealObjectV2 added in v1.6.0 

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

func (*GfSpClient) SecondarySpIncomeDetails added in v1.1.0 

func (s *GfSpClient) SecondarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.SecondarySpIncomeDetail, error)

SecondarySpIncomeDetails return the secondary sp income for the current timestamp

func (*GfSpClient) SignBucketMigrationInfo added in v1.1.0 

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

func (*GfSpClient) SignCreateBucketApproval 

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

func (*GfSpClient) SignCreateObjectApproval 

func (s *GfSpClient) SignCreateObjectApproval(ctx context.Context, object *storagetypes.MsgCreateObject) ([]byte, error)

func (*GfSpClient) SignMigrateBucketApproval added in v0.2.3 

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

func (*GfSpClient) SignMigrateGVG added in v0.2.6 

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

func (*GfSpClient) SignP2PPingMsg 

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

func (*GfSpClient) SignP2PPongMsg 

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

func (*GfSpClient) SignReceiveTask 

func (s *GfSpClient) SignReceiveTask(ctx context.Context, receiveTask coretask.ReceivePieceTask) ([]byte, error)

func (*GfSpClient) SignRecoveryTask added in v0.2.3 

func (s *GfSpClient) SignRecoveryTask(ctx context.Context, recoveryTask coretask.RecoveryPieceTask) ([]byte, error)

func (*GfSpClient) SignReplicatePieceApproval 

func (s *GfSpClient) SignReplicatePieceApproval(ctx context.Context, task coretask.ApprovalReplicatePieceTask) ([]byte, error)

func (*GfSpClient) SignSecondarySPMigrationBucket added in v0.2.3 

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

func (*GfSpClient) SignSecondarySealBls added in v0.2.3 

func (s *GfSpClient) SignSecondarySealBls(ctx context.Context, objectID uint64, gvgId uint32, checksums [][]byte) ([]byte, error)

func (*GfSpClient) SignSwapOut added in v0.2.3 

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

func (*GfSpClient) SignerConn 

func (s *GfSpClient) SignerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*GfSpClient) SpExit added in v1.3.0 

func (s *GfSpClient) SpExit(ctx context.Context, spExit *virtualgrouptypes.MsgStorageProviderExit) (string, error)

SpExit sent sp exit tx for sp gracefully exit

func (*GfSpClient) SwapOut added in v0.2.3 

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

func (*GfSpClient) TriggerRecoverForSuccessorSP added in v1.3.0 

func (s *GfSpClient) TriggerRecoverForSuccessorSP(ctx context.Context, vgfID, gvgID uint32, replicateIndex int32) error

func (*GfSpClient) UpdateSPPrice added in v0.2.3 

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

func (*GfSpClient) UpdateUserPublicKey 

func (s *GfSpClient) UpdateUserPublicKey(ctx context.Context, account string, domain string, currentNonce int32, nonce int32,
	userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)

UpdateUserPublicKey updates the user public key once the Dapp or client generates the EDDSA key pairs.

func (*GfSpClient) UpdateUserPublicKeyV2 added in v1.6.0 

func (s *GfSpClient) UpdateUserPublicKeyV2(ctx context.Context, account string, domain string, userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)

func (*GfSpClient) UploadObject 

func (s *GfSpClient) UploadObject(ctx context.Context, task coretask.UploadObjectTask, stream io.Reader,
	opts ...grpc.DialOption) error

func (*GfSpClient) VerifyAuthentication 

func (s *GfSpClient) VerifyAuthentication(ctx context.Context, auth coremodule.AuthOpType, account, bucket, object string,
	opts ...grpc.DialOption) (bool, error)

func (*GfSpClient) VerifyGNFD1EddsaSignature added in v0.2.4 

func (s *GfSpClient) VerifyGNFD1EddsaSignature(ctx context.Context, account string, domain string, offChainSig string,
	realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)

VerifyGNFD1EddsaSignature verifies the signature signed by user's EDDSA private key.

func (*GfSpClient) VerifyGNFD2EddsaSignature added in v1.6.0 

func (s *GfSpClient) VerifyGNFD2EddsaSignature(ctx context.Context, account string, domain string, userPublicKey string, offChainSig string, realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)

func (*GfSpClient) VerifyMigrateGVGPermission added in v0.2.6 

func (s *GfSpClient) VerifyMigrateGVGPermission(ctx context.Context, bucketID uint64, gvgID, dstSpID uint32, opts ...grpc.DialOption) (*permission_types.Effect, error)

VerifyMigrateGVGPermission verify the destination sp id of bucket migration & swap out

func (*GfSpClient) VerifyPermission 

func (s *GfSpClient) VerifyPermission(ctx context.Context, Operator string, bucketName string, objectName string,
	actionType permission_types.ActionType, opts ...grpc.DialOption) (*permission_types.Effect, error)

VerifyPermission Verify the input account’s permission to input items

func (*GfSpClient) VerifyPermissionByID added in v0.2.3 

func (s *GfSpClient) VerifyPermissionByID(ctx context.Context, Operator string, resourceType resource.ResourceType, resourceID uint64,
	actionType permission_types.ActionType, opts ...grpc.DialOption) (*permission_types.Effect, error)

VerifyPermissionByID Verify the input account’s permission to input source type and resource id

type GfSpClientAPI added in v0.2.4 

type GfSpClientAPI interface {
	ApproverAPI
	AuthenticatorAPI
	DownloaderAPI
	GaterAPI
	ManagerAPI
	MetadataAPI
	P2PAPI
	QueryAPI
	ReceiverAPI
	SignerAPI
	UploaderAPI
	GfSpConnAPI
}

GfSpClientAPI for mock use

type GfSpConnAPI added in v0.2.4 

type GfSpConnAPI interface {
	Connection(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
	ManagerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
	ApproverConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
	P2PConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
	SignerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
	HTTPClient(ctx context.Context) *http.Client
	Close() error
}

GfSpConnAPI for mock use

type ManagerAPI added in v0.2.4 

type ManagerAPI interface {
	CreateUploadObject(ctx context.Context, task coretask.UploadObjectTask) error
	CreateResumableUploadObject(ctx context.Context, task coretask.ResumableUploadObjectTask) error
	AskTask(ctx context.Context, limit corercmgr.Limit) (coretask.Task, error)
	ReportTask(ctx context.Context, report coretask.Task) error
	PickVirtualGroupFamilyID(ctx context.Context, task coretask.ApprovalCreateBucketTask) (uint32, error)
	NotifyMigrateSwapOut(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) error
	GetTasksStats(ctx context.Context) (*gfspserver.TasksStats, error)
	GetMigrateBucketProgress(ctx context.Context, bucketID uint64) (*gfspserver.MigrateBucketProgressMeta, error)
	NotifyPostMigrateBucketAndRecoupQuota(ctx context.Context, bmInfo *gfsptask.GfSpBucketMigrationInfo) (*gfsptask.GfSpBucketQuotaInfo, error)
	NotifyPreMigrateBucketAndDeductQuota(ctx context.Context, bucketID uint64) (*gfsptask.GfSpBucketQuotaInfo, error)
}

ManagerAPI for mock use

type MetadataAPI added in v0.2.4 

type MetadataAPI interface {
	GetUserBucketsCount(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) (int64, error)
	ListDeletedObjectsByBlockNumberRange(ctx context.Context, spOperatorAddress string, startBlockNumber uint64, endBlockNumber uint64, includePrivate bool, opts ...grpc.DialOption) ([]*types.Object, uint64, error)
	GetUserBuckets(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) ([]*types.VGFInfoBucket, error)
	ListObjectsByBucketName(ctx context.Context, bucketName string, accountID string, maxKeys uint64, startAfter string, continuationToken string, delimiter string, prefix string, includeRemoved bool,
		opts ...grpc.DialOption) (objects []*types.Object, keyCount, maxKeysRe uint64, isTruncated bool, nextContinuationToken, name, prefixRe, delimiterRe string, commonPrefixes []string, continuationTokenRe string, err error)
	GetBucketByBucketName(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, error)
	GetBucketByBucketID(ctx context.Context, bucketID int64, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, error)
	ListExpiredBucketsBySp(ctx context.Context, createAt int64, primarySpID uint32, limit int64, opts ...grpc.DialOption) ([]*types.Bucket, error)
	GetObjectMeta(ctx context.Context, objectName string, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Object, error)
	GetLatestObjectID(ctx context.Context, opts ...grpc.DialOption) (uint64, error)
	GetPaymentByBucketName(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*payment_types.StreamRecord, error)
	GetPaymentByBucketID(ctx context.Context, bucketID int64, includePrivate bool, opts ...grpc.DialOption) (*payment_types.StreamRecord, error)
	VerifyPermission(ctx context.Context, Operator string, bucketName string, objectName string, actionType permission_types.ActionType, opts ...grpc.DialOption) (*permission_types.Effect, error)
	GetBucketMeta(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.VGFInfoBucket, *payment_types.StreamRecord, error)
	GetEndpointBySpID(ctx context.Context, spID uint32, opts ...grpc.DialOption) (string, error)
	GetBucketReadQuota(ctx context.Context, bucket *storagetypes.BucketInfo, yearMonth string, opts ...grpc.DialOption) (uint64, uint64, uint64, uint64, uint64, uint64, error)
	ListBucketReadQuota(ctx context.Context, yearMonth string, offset, limit uint32, opts ...grpc.DialOption) ([]*types.BucketReadQuotaRecord, error)
	GetBucketReadQuotaCount(ctx context.Context, yearMonth string, opts ...grpc.DialOption) (int64, error)
	GetLatestBucketReadQuota(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (*gfsptask.GfSpBucketQuotaInfo, error)
	ListBucketReadRecord(ctx context.Context, bucket *storagetypes.BucketInfo, startTimestampUs, endTimestampUs, maxRecordNum int64, opts ...grpc.DialOption) ([]*types.ReadRecord, int64, error)
	GetUploadObjectState(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (int32, string, error)
	GetUploadObjectSegment(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (uint32, error)
	GetGroupList(ctx context.Context, name string, prefix string, sourceType string, limit int64, offset int64, includeRemoved bool, opts ...grpc.DialOption) ([]*types.Group, int64, error)
	ListBucketsByIDs(ctx context.Context, bucketIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Bucket, error)
	ListObjectsByIDs(ctx context.Context, objectIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Object, error)
	ListVirtualGroupFamiliesSpID(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*virtualgrouptypes.GlobalVirtualGroupFamily, error)
	GetGlobalVirtualGroupByGvgID(ctx context.Context, gvgID uint32, opts ...grpc.DialOption) (*virtualgrouptypes.GlobalVirtualGroup, error)
	ListObjectsInGVGAndBucket(ctx context.Context, gvgID uint32, bucketID uint64, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)
	ListObjectsInGVG(ctx context.Context, gvgID uint32, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)
	ListObjectsByGVGAndBucketForGC(ctx context.Context, gvgID uint32, bucketID uint64, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)
	GetVirtualGroupFamily(ctx context.Context, vgfID uint32, opts ...grpc.DialOption) (*virtualgrouptypes.GlobalVirtualGroupFamily, error)
	GetGlobalVirtualGroup(ctx context.Context, bucketID uint64, lvgID uint32, opts ...grpc.DialOption) (*virtualgrouptypes.GlobalVirtualGroup, error)
	ListGlobalVirtualGroupsByBucket(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) ([]*virtualgrouptypes.GlobalVirtualGroup, error)
	ListGlobalVirtualGroupsBySecondarySP(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*virtualgrouptypes.GlobalVirtualGroup, error)
	ListMigrateBucketEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListMigrateBucketEvents, error)
	ListCompleteMigrationBucketEvents(ctx context.Context, blockID uint64, srcSpID uint32, opts ...grpc.DialOption) ([]*storagetypes.EventCompleteMigrationBucket, error)
	ListSwapOutEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListSwapOutEvents, error)
	ListSpExitEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) (*types.ListSpExitEvents, error)
	GetObjectByID(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (*storagetypes.ObjectInfo, error)
	VerifyPermissionByID(ctx context.Context, Operator string, resourceType resource.ResourceType, resourceID uint64, actionType permission_types.ActionType, opts ...grpc.DialOption) (*permission_types.Effect, error)
	GetSPInfo(ctx context.Context, operatorAddress string, opts ...grpc.DialOption) (*sptypes.StorageProvider, error)
	GetStatus(ctx context.Context, opts ...grpc.DialOption) (*types.Status, error)
	GetUserGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)
	GetGroupMembers(ctx context.Context, groupID uint64, startAfter string, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)
	GetUserOwnedGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)
	ListObjectPolicies(ctx context.Context, objectName, bucketName string, startAfter uint64, actionType int32, limit uint32, opts ...grpc.DialOption) ([]*types.Policy, error)
	ListPaymentAccountStreams(ctx context.Context, paymentAccount string, opts ...grpc.DialOption) ([]*types.Bucket, error)
	ListUserPaymentAccounts(ctx context.Context, accountID string, opts ...grpc.DialOption) ([]*types.PaymentAccountMeta, error)
	ListGroupsByIDs(ctx context.Context, groupIDs []uint64, opts ...grpc.DialOption) (map[uint64]*types.Group, error)
	GetSPMigratingBucketNumber(ctx context.Context, spID uint32, opts ...grpc.DialOption) (uint64, error)
	VerifyMigrateGVGPermission(ctx context.Context, bucketID uint64, gvgID, dstSpID uint32, opts ...grpc.DialOption) (*permission_types.Effect, error)
	PrimarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.PrimarySpIncomeDetail, error)
	SecondarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.SecondarySpIncomeDetail, error)
	GetBucketSize(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (string, error)
	GetBucketInfoByBucketName(ctx context.Context, bucketName string, opts ...grpc.DialOption) (*types.Bucket, error)
}

MetadataAPI for mock sue

type MockApproverAPI added in v0.2.4 

type MockApproverAPI struct {
	// contains filtered or unexported fields
}

MockApproverAPI is a mock of ApproverAPI interface.

func NewMockApproverAPI added in v0.2.4 

func NewMockApproverAPI(ctrl *gomock.Controller) *MockApproverAPI

NewMockApproverAPI creates a new mock instance.

func (*MockApproverAPI) AskCreateBucketApproval added in v0.2.4 

func (m *MockApproverAPI) AskCreateBucketApproval(ctx context.Context, t task.ApprovalCreateBucketTask) (bool, task.ApprovalCreateBucketTask, error)

AskCreateBucketApproval mocks base method.

func (*MockApproverAPI) AskCreateObjectApproval added in v0.2.4 

func (m *MockApproverAPI) AskCreateObjectApproval(ctx context.Context, t task.ApprovalCreateObjectTask) (bool, task.ApprovalCreateObjectTask, error)

AskCreateObjectApproval mocks base method.

func (*MockApproverAPI) AskDelegateCreateObjectApproval added in v1.6.0 

func (m *MockApproverAPI) AskDelegateCreateObjectApproval(ctx context.Context, t task.ApprovalDelegateCreateObjectTask) (bool, task.ApprovalDelegateCreateObjectTask, error)

AskDelegateCreateObjectApproval mocks base method.

func (*MockApproverAPI) AskMigrateBucketApproval added in v0.2.4 

func (m *MockApproverAPI) AskMigrateBucketApproval(ctx context.Context, t task.ApprovalMigrateBucketTask) (bool, task.ApprovalMigrateBucketTask, error)

AskMigrateBucketApproval mocks base method.

func (*MockApproverAPI) EXPECT added in v0.2.4 

func (m *MockApproverAPI) EXPECT() *MockApproverAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockApproverAPIMockRecorder added in v0.2.4 

type MockApproverAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockApproverAPIMockRecorder is the mock recorder for MockApproverAPI.

func (*MockApproverAPIMockRecorder) AskCreateBucketApproval added in v0.2.4 

func (mr *MockApproverAPIMockRecorder) AskCreateBucketApproval(ctx, t any) *gomock.Call

AskCreateBucketApproval indicates an expected call of AskCreateBucketApproval.

func (*MockApproverAPIMockRecorder) AskCreateObjectApproval added in v0.2.4 

func (mr *MockApproverAPIMockRecorder) AskCreateObjectApproval(ctx, t any) *gomock.Call

AskCreateObjectApproval indicates an expected call of AskCreateObjectApproval.

func (*MockApproverAPIMockRecorder) AskDelegateCreateObjectApproval added in v1.6.0 

func (mr *MockApproverAPIMockRecorder) AskDelegateCreateObjectApproval(ctx, t any) *gomock.Call

AskDelegateCreateObjectApproval indicates an expected call of AskDelegateCreateObjectApproval.

func (*MockApproverAPIMockRecorder) AskMigrateBucketApproval added in v0.2.4 

func (mr *MockApproverAPIMockRecorder) AskMigrateBucketApproval(ctx, t any) *gomock.Call

AskMigrateBucketApproval indicates an expected call of AskMigrateBucketApproval.

type MockAuthenticatorAPI added in v0.2.4 

type MockAuthenticatorAPI struct {
	// contains filtered or unexported fields
}

MockAuthenticatorAPI is a mock of AuthenticatorAPI interface.

func NewMockAuthenticatorAPI added in v0.2.4 

func NewMockAuthenticatorAPI(ctrl *gomock.Controller) *MockAuthenticatorAPI

NewMockAuthenticatorAPI creates a new mock instance.

func (*MockAuthenticatorAPI) DeleteAuthKeysV2 added in v1.6.0 

func (m *MockAuthenticatorAPI) DeleteAuthKeysV2(ctx context.Context, account, domain string, userPublicKeys []string, opts ...grpc.DialOption) (bool, error)

DeleteAuthKeysV2 mocks base method.

func (*MockAuthenticatorAPI) EXPECT added in v0.2.4 

func (m *MockAuthenticatorAPI) EXPECT() *MockAuthenticatorAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAuthenticatorAPI) GetAuthKeyV2 added in v1.6.0 

func (m *MockAuthenticatorAPI) GetAuthKeyV2(ctx context.Context, account, domain, userPublicKey string, opts ...grpc.DialOption) (string, int64, error)

GetAuthKeyV2 mocks base method.

func (*MockAuthenticatorAPI) GetAuthNonce added in v0.2.4 

func (m *MockAuthenticatorAPI) GetAuthNonce(ctx context.Context, account, domain string, opts ...grpc.DialOption) (int32, int32, string, int64, error)

GetAuthNonce mocks base method.

func (*MockAuthenticatorAPI) ListAuthKeysV2 added in v1.6.0 

func (m *MockAuthenticatorAPI) ListAuthKeysV2(ctx context.Context, account, domain string, opts ...grpc.DialOption) ([]string, error)

ListAuthKeysV2 mocks base method.

func (*MockAuthenticatorAPI) UpdateUserPublicKey added in v0.2.4 

func (m *MockAuthenticatorAPI) UpdateUserPublicKey(ctx context.Context, account, domain string, currentNonce, nonce int32, userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)

UpdateUserPublicKey mocks base method.

func (*MockAuthenticatorAPI) UpdateUserPublicKeyV2 added in v1.6.0 

func (m *MockAuthenticatorAPI) UpdateUserPublicKeyV2(ctx context.Context, account, domain, userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)

UpdateUserPublicKeyV2 mocks base method.

func (*MockAuthenticatorAPI) VerifyAuthentication added in v0.2.4 

func (m *MockAuthenticatorAPI) VerifyAuthentication(ctx context.Context, auth module.AuthOpType, account, bucket, object string, opts ...grpc.DialOption) (bool, error)

VerifyAuthentication mocks base method.

func (*MockAuthenticatorAPI) VerifyGNFD1EddsaSignature added in v0.2.4 

func (m *MockAuthenticatorAPI) VerifyGNFD1EddsaSignature(ctx context.Context, account, domain, offChainSig string, realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)

VerifyGNFD1EddsaSignature mocks base method.

func (*MockAuthenticatorAPI) VerifyGNFD2EddsaSignature added in v1.6.0 

func (m *MockAuthenticatorAPI) VerifyGNFD2EddsaSignature(ctx context.Context, account, domain, userPublicKey, offChainSig string, realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)

VerifyGNFD2EddsaSignature mocks base method.

type MockAuthenticatorAPIMockRecorder added in v0.2.4 

type MockAuthenticatorAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockAuthenticatorAPIMockRecorder is the mock recorder for MockAuthenticatorAPI.

func (*MockAuthenticatorAPIMockRecorder) DeleteAuthKeysV2 added in v1.6.0 

func (mr *MockAuthenticatorAPIMockRecorder) DeleteAuthKeysV2(ctx, account, domain, userPublicKeys any, opts ...any) *gomock.Call

DeleteAuthKeysV2 indicates an expected call of DeleteAuthKeysV2.

func (*MockAuthenticatorAPIMockRecorder) GetAuthKeyV2 added in v1.6.0 

func (mr *MockAuthenticatorAPIMockRecorder) GetAuthKeyV2(ctx, account, domain, userPublicKey any, opts ...any) *gomock.Call

GetAuthKeyV2 indicates an expected call of GetAuthKeyV2.

func (*MockAuthenticatorAPIMockRecorder) GetAuthNonce added in v0.2.4 

func (mr *MockAuthenticatorAPIMockRecorder) GetAuthNonce(ctx, account, domain any, opts ...any) *gomock.Call

GetAuthNonce indicates an expected call of GetAuthNonce.

func (*MockAuthenticatorAPIMockRecorder) ListAuthKeysV2 added in v1.6.0 

func (mr *MockAuthenticatorAPIMockRecorder) ListAuthKeysV2(ctx, account, domain any, opts ...any) *gomock.Call

ListAuthKeysV2 indicates an expected call of ListAuthKeysV2.

func (*MockAuthenticatorAPIMockRecorder) UpdateUserPublicKey added in v0.2.4 

func (mr *MockAuthenticatorAPIMockRecorder) UpdateUserPublicKey(ctx, account, domain, currentNonce, nonce, userPublicKey, expiryDate any, opts ...any) *gomock.Call

UpdateUserPublicKey indicates an expected call of UpdateUserPublicKey.

func (*MockAuthenticatorAPIMockRecorder) UpdateUserPublicKeyV2 added in v1.6.0 

func (mr *MockAuthenticatorAPIMockRecorder) UpdateUserPublicKeyV2(ctx, account, domain, userPublicKey, expiryDate any, opts ...any) *gomock.Call

UpdateUserPublicKeyV2 indicates an expected call of UpdateUserPublicKeyV2.

func (*MockAuthenticatorAPIMockRecorder) VerifyAuthentication added in v0.2.4 

func (mr *MockAuthenticatorAPIMockRecorder) VerifyAuthentication(ctx, auth, account, bucket, object any, opts ...any) *gomock.Call

VerifyAuthentication indicates an expected call of VerifyAuthentication.

func (*MockAuthenticatorAPIMockRecorder) VerifyGNFD1EddsaSignature added in v0.2.4 

func (mr *MockAuthenticatorAPIMockRecorder) VerifyGNFD1EddsaSignature(ctx, account, domain, offChainSig, realMsgToSign any, opts ...any) *gomock.Call

VerifyGNFD1EddsaSignature indicates an expected call of VerifyGNFD1EddsaSignature.

func (*MockAuthenticatorAPIMockRecorder) VerifyGNFD2EddsaSignature added in v1.6.0 

func (mr *MockAuthenticatorAPIMockRecorder) VerifyGNFD2EddsaSignature(ctx, account, domain, userPublicKey, offChainSig, realMsgToSign any, opts ...any) *gomock.Call

VerifyGNFD2EddsaSignature indicates an expected call of VerifyGNFD2EddsaSignature.

type MockDownloaderAPI added in v0.2.4 

type MockDownloaderAPI struct {
	// contains filtered or unexported fields
}

MockDownloaderAPI is a mock of DownloaderAPI interface.

func NewMockDownloaderAPI added in v0.2.4 

func NewMockDownloaderAPI(ctrl *gomock.Controller) *MockDownloaderAPI

NewMockDownloaderAPI creates a new mock instance.

func (*MockDownloaderAPI) DeductQuotaForBucketMigrate added in v1.1.0 

func (m *MockDownloaderAPI) DeductQuotaForBucketMigrate(ctx context.Context, bucketID, deductQuota uint64, yearMonth string, opts ...grpc.DialOption) error

DeductQuotaForBucketMigrate mocks base method.

func (*MockDownloaderAPI) EXPECT added in v0.2.4 

func (m *MockDownloaderAPI) EXPECT() *MockDownloaderAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDownloaderAPI) GetChallengeInfo added in v0.2.4 

func (m *MockDownloaderAPI) GetChallengeInfo(ctx context.Context, challengePieceTask task.ChallengePieceTask, opts ...grpc.DialOption) ([]byte, [][]byte, []byte, error)

GetChallengeInfo mocks base method.

func (*MockDownloaderAPI) GetObject added in v0.2.4 

func (m *MockDownloaderAPI) GetObject(ctx context.Context, downloadObjectTask task.DownloadObjectTask, opts ...grpc.DialOption) ([]byte, error)

GetObject mocks base method.

func (*MockDownloaderAPI) GetPiece added in v0.2.4 

func (m *MockDownloaderAPI) GetPiece(ctx context.Context, downloadPieceTask task.DownloadPieceTask, opts ...grpc.DialOption) ([]byte, error)

GetPiece mocks base method.

func (*MockDownloaderAPI) RecoupQuota added in v0.2.5 

func (m *MockDownloaderAPI) RecoupQuota(ctx context.Context, bucketID, extraQuota uint64, yearMonth string, opts ...grpc.DialOption) error

RecoupQuota mocks base method.

type MockDownloaderAPIMockRecorder added in v0.2.4 

type MockDownloaderAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockDownloaderAPIMockRecorder is the mock recorder for MockDownloaderAPI.

func (*MockDownloaderAPIMockRecorder) DeductQuotaForBucketMigrate added in v1.1.0 

func (mr *MockDownloaderAPIMockRecorder) DeductQuotaForBucketMigrate(ctx, bucketID, deductQuota, yearMonth any, opts ...any) *gomock.Call

DeductQuotaForBucketMigrate indicates an expected call of DeductQuotaForBucketMigrate.

func (*MockDownloaderAPIMockRecorder) GetChallengeInfo added in v0.2.4 

func (mr *MockDownloaderAPIMockRecorder) GetChallengeInfo(ctx, challengePieceTask any, opts ...any) *gomock.Call

GetChallengeInfo indicates an expected call of GetChallengeInfo.

func (*MockDownloaderAPIMockRecorder) GetObject added in v0.2.4 

func (mr *MockDownloaderAPIMockRecorder) GetObject(ctx, downloadObjectTask any, opts ...any) *gomock.Call

GetObject indicates an expected call of GetObject.

func (*MockDownloaderAPIMockRecorder) GetPiece added in v0.2.4 

func (mr *MockDownloaderAPIMockRecorder) GetPiece(ctx, downloadPieceTask any, opts ...any) *gomock.Call

GetPiece indicates an expected call of GetPiece.

func (*MockDownloaderAPIMockRecorder) RecoupQuota added in v0.2.5 

func (mr *MockDownloaderAPIMockRecorder) RecoupQuota(ctx, bucketID, extraQuota, yearMonth any, opts ...any) *gomock.Call

RecoupQuota indicates an expected call of RecoupQuota.

type MockGaterAPI added in v0.2.4 

type MockGaterAPI struct {
	// contains filtered or unexported fields
}

MockGaterAPI is a mock of GaterAPI interface.

func NewMockGaterAPI added in v0.2.4 

func NewMockGaterAPI(ctrl *gomock.Controller) *MockGaterAPI

NewMockGaterAPI creates a new mock instance.

func (*MockGaterAPI) DoneReplicatePieceToSecondary added in v0.2.4 

func (m *MockGaterAPI) DoneReplicatePieceToSecondary(ctx context.Context, endpoint string, receive task.ReceivePieceTask) ([]byte, error)

DoneReplicatePieceToSecondary mocks base method.

func (*MockGaterAPI) EXPECT added in v0.2.4 

func (m *MockGaterAPI) EXPECT() *MockGaterAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockGaterAPI) GetPieceFromECChunks added in v0.2.4 

func (m *MockGaterAPI) GetPieceFromECChunks(ctx context.Context, endpoint string, task task.RecoveryPieceTask) (io.ReadCloser, error)

GetPieceFromECChunks mocks base method.

func (*MockGaterAPI) GetSecondarySPMigrationBucketApproval added in v0.2.4 

func (m *MockGaterAPI) GetSecondarySPMigrationBucketApproval(ctx context.Context, secondarySPEndpoint string, signDoc *types3.SecondarySpMigrationBucketSignDoc) ([]byte, error)

GetSecondarySPMigrationBucketApproval mocks base method.

func (*MockGaterAPI) GetSwapOutApproval added in v0.2.4 

func (m *MockGaterAPI) GetSwapOutApproval(ctx context.Context, destSPEndpoint string, swapOutApproval *types4.MsgSwapOut) (*types4.MsgSwapOut, error)

GetSwapOutApproval mocks base method.

func (*MockGaterAPI) MigratePiece added in v0.2.4 

func (m *MockGaterAPI) MigratePiece(ctx context.Context, gvgTask *gfsptask.GfSpMigrateGVGTask, pieceTask *gfsptask.GfSpMigratePieceTask) ([]byte, error)

MigratePiece mocks base method.

func (*MockGaterAPI) NotifyDestSPMigrateSwapOut added in v0.2.4 

func (m *MockGaterAPI) NotifyDestSPMigrateSwapOut(ctx context.Context, destEndpoint string, swapOut *types4.MsgSwapOut) error

NotifyDestSPMigrateSwapOut mocks base method.

func (*MockGaterAPI) PostMigrateBucket added in v1.1.0 

func (m *MockGaterAPI) PostMigrateBucket(ctx context.Context, srcSPEndpoint string, postMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

PostMigrateBucket mocks base method.

func (*MockGaterAPI) PreMigrateBucket added in v1.1.0 

func (m *MockGaterAPI) PreMigrateBucket(ctx context.Context, srcSPEndpoint string, preMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

PreMigrateBucket mocks base method.

func (*MockGaterAPI) QueryLatestBucketQuota added in v1.1.0 

func (m *MockGaterAPI) QueryLatestBucketQuota(ctx context.Context, endpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

QueryLatestBucketQuota mocks base method.

func (*MockGaterAPI) QuerySPHasEnoughQuotaForMigrateBucket added in v1.1.0 

func (m *MockGaterAPI) QuerySPHasEnoughQuotaForMigrateBucket(ctx context.Context, srcSPEndpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) error

QuerySPHasEnoughQuotaForMigrateBucket mocks base method.

func (*MockGaterAPI) ReplicatePieceToSecondary added in v0.2.4 

func (m *MockGaterAPI) ReplicatePieceToSecondary(ctx context.Context, endpoint string, receive task.ReceivePieceTask, data []byte) error

ReplicatePieceToSecondary mocks base method.

type MockGaterAPIMockRecorder added in v0.2.4 

type MockGaterAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockGaterAPIMockRecorder is the mock recorder for MockGaterAPI.

func (*MockGaterAPIMockRecorder) DoneReplicatePieceToSecondary added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) DoneReplicatePieceToSecondary(ctx, endpoint, receive any) *gomock.Call

DoneReplicatePieceToSecondary indicates an expected call of DoneReplicatePieceToSecondary.

func (*MockGaterAPIMockRecorder) GetPieceFromECChunks added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) GetPieceFromECChunks(ctx, endpoint, task any) *gomock.Call

GetPieceFromECChunks indicates an expected call of GetPieceFromECChunks.

func (*MockGaterAPIMockRecorder) GetSecondarySPMigrationBucketApproval added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) GetSecondarySPMigrationBucketApproval(ctx, secondarySPEndpoint, signDoc any) *gomock.Call

GetSecondarySPMigrationBucketApproval indicates an expected call of GetSecondarySPMigrationBucketApproval.

func (*MockGaterAPIMockRecorder) GetSwapOutApproval added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) GetSwapOutApproval(ctx, destSPEndpoint, swapOutApproval any) *gomock.Call

GetSwapOutApproval indicates an expected call of GetSwapOutApproval.

func (*MockGaterAPIMockRecorder) MigratePiece added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) MigratePiece(ctx, gvgTask, pieceTask any) *gomock.Call

MigratePiece indicates an expected call of MigratePiece.

func (*MockGaterAPIMockRecorder) NotifyDestSPMigrateSwapOut added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) NotifyDestSPMigrateSwapOut(ctx, destEndpoint, swapOut any) *gomock.Call

NotifyDestSPMigrateSwapOut indicates an expected call of NotifyDestSPMigrateSwapOut.

func (*MockGaterAPIMockRecorder) PostMigrateBucket added in v1.1.0 

func (mr *MockGaterAPIMockRecorder) PostMigrateBucket(ctx, srcSPEndpoint, postMsg any) *gomock.Call

PostMigrateBucket indicates an expected call of PostMigrateBucket.

func (*MockGaterAPIMockRecorder) PreMigrateBucket added in v1.1.0 

func (mr *MockGaterAPIMockRecorder) PreMigrateBucket(ctx, srcSPEndpoint, preMsg any) *gomock.Call

PreMigrateBucket indicates an expected call of PreMigrateBucket.

func (*MockGaterAPIMockRecorder) QueryLatestBucketQuota added in v1.1.0 

func (mr *MockGaterAPIMockRecorder) QueryLatestBucketQuota(ctx, endpoint, queryMsg any) *gomock.Call

QueryLatestBucketQuota indicates an expected call of QueryLatestBucketQuota.

func (*MockGaterAPIMockRecorder) QuerySPHasEnoughQuotaForMigrateBucket added in v1.1.0 

func (mr *MockGaterAPIMockRecorder) QuerySPHasEnoughQuotaForMigrateBucket(ctx, srcSPEndpoint, queryMsg any) *gomock.Call

QuerySPHasEnoughQuotaForMigrateBucket indicates an expected call of QuerySPHasEnoughQuotaForMigrateBucket.

func (*MockGaterAPIMockRecorder) ReplicatePieceToSecondary added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) ReplicatePieceToSecondary(ctx, endpoint, receive, data any) *gomock.Call

ReplicatePieceToSecondary indicates an expected call of ReplicatePieceToSecondary.

type MockGfSpClientAPI added in v0.2.4 

type MockGfSpClientAPI struct {
	// contains filtered or unexported fields
}

MockGfSpClientAPI is a mock of GfSpClientAPI interface.

func NewMockGfSpClientAPI added in v0.2.4 

func NewMockGfSpClientAPI(ctrl *gomock.Controller) *MockGfSpClientAPI

NewMockGfSpClientAPI creates a new mock instance.

func (*MockGfSpClientAPI) ApproverConn added in v0.2.4 

func (m *MockGfSpClientAPI) ApproverConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

ApproverConn mocks base method.

func (*MockGfSpClientAPI) AskCreateBucketApproval added in v0.2.4 

func (m *MockGfSpClientAPI) AskCreateBucketApproval(ctx context.Context, t task.ApprovalCreateBucketTask) (bool, task.ApprovalCreateBucketTask, error)

AskCreateBucketApproval mocks base method.

func (*MockGfSpClientAPI) AskCreateObjectApproval added in v0.2.4 

func (m *MockGfSpClientAPI) AskCreateObjectApproval(ctx context.Context, t task.ApprovalCreateObjectTask) (bool, task.ApprovalCreateObjectTask, error)

AskCreateObjectApproval mocks base method.

func (*MockGfSpClientAPI) AskDelegateCreateObjectApproval added in v1.6.0 

func (m *MockGfSpClientAPI) AskDelegateCreateObjectApproval(ctx context.Context, t task.ApprovalDelegateCreateObjectTask) (bool, task.ApprovalDelegateCreateObjectTask, error)

AskDelegateCreateObjectApproval mocks base method.

func (*MockGfSpClientAPI) AskMigrateBucketApproval added in v0.2.4 

func (m *MockGfSpClientAPI) AskMigrateBucketApproval(ctx context.Context, t task.ApprovalMigrateBucketTask) (bool, task.ApprovalMigrateBucketTask, error)

AskMigrateBucketApproval mocks base method.

func (*MockGfSpClientAPI) AskSecondaryReplicatePieceApproval added in v0.2.4 

func (m *MockGfSpClientAPI) AskSecondaryReplicatePieceApproval(ctx context.Context, task task.ApprovalReplicatePieceTask, low, high int, timeout int64) ([]*gfsptask.GfSpReplicatePieceApprovalTask, error)

AskSecondaryReplicatePieceApproval mocks base method.

func (*MockGfSpClientAPI) AskTask added in v0.2.4 

func (m *MockGfSpClientAPI) AskTask(ctx context.Context, limit rcmgr.Limit) (task.Task, error)

AskTask mocks base method.

func (*MockGfSpClientAPI) Close added in v0.2.4 

func (m *MockGfSpClientAPI) Close() error

Close mocks base method.

func (*MockGfSpClientAPI) CompleteMigrateBucket added in v0.2.4 

func (m *MockGfSpClientAPI) CompleteMigrateBucket(ctx context.Context, migrateBucket *types3.MsgCompleteMigrateBucket) (string, error)

CompleteMigrateBucket mocks base method.

func (*MockGfSpClientAPI) CompleteSPExit added in v0.2.4 

func (m *MockGfSpClientAPI) CompleteSPExit(ctx context.Context, completeSPExit *types4.MsgCompleteStorageProviderExit) (string, error)

CompleteSPExit mocks base method.

func (*MockGfSpClientAPI) CompleteSwapIn added in v1.3.0 

func (m *MockGfSpClientAPI) CompleteSwapIn(ctx context.Context, completeSwpIn *types4.MsgCompleteSwapIn) (string, error)

CompleteSwapIn mocks base method.

func (*MockGfSpClientAPI) CompleteSwapOut added in v0.2.4 

func (m *MockGfSpClientAPI) CompleteSwapOut(ctx context.Context, completeSwapOut *types4.MsgCompleteSwapOut) (string, error)

CompleteSwapOut mocks base method.

func (*MockGfSpClientAPI) Connection added in v0.2.4 

func (m *MockGfSpClientAPI) Connection(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

Connection mocks base method.

func (*MockGfSpClientAPI) CreateGlobalVirtualGroup added in v0.2.4 

func (m *MockGfSpClientAPI) CreateGlobalVirtualGroup(ctx context.Context, group *gfspserver.GfSpCreateGlobalVirtualGroup) error

CreateGlobalVirtualGroup mocks base method.

func (*MockGfSpClientAPI) CreateResumableUploadObject added in v0.2.4 

func (m *MockGfSpClientAPI) CreateResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask) error

CreateResumableUploadObject mocks base method.

func (*MockGfSpClientAPI) CreateUploadObject added in v0.2.4 

func (m *MockGfSpClientAPI) CreateUploadObject(ctx context.Context, task task.UploadObjectTask) error

CreateUploadObject mocks base method.

func (*MockGfSpClientAPI) DeductQuotaForBucketMigrate added in v1.1.0 

func (m *MockGfSpClientAPI) DeductQuotaForBucketMigrate(ctx context.Context, bucketID, deductQuota uint64, yearMonth string, opts ...grpc.DialOption) error

DeductQuotaForBucketMigrate mocks base method.

func (*MockGfSpClientAPI) DelegateCreateObject added in v1.6.0 

func (m *MockGfSpClientAPI) DelegateCreateObject(ctx context.Context, object *types3.MsgDelegateCreateObject) (string, error)

DelegateCreateObject mocks base method.

func (*MockGfSpClientAPI) DelegateUpdateObjectContent added in v1.6.0 

func (m *MockGfSpClientAPI) DelegateUpdateObjectContent(ctx context.Context, object *types3.MsgDelegateUpdateObjectContent) (string, error)

DelegateUpdateObjectContent mocks base method.

func (*MockGfSpClientAPI) DeleteAuthKeysV2 added in v1.6.0 

func (m *MockGfSpClientAPI) DeleteAuthKeysV2(ctx context.Context, account, domain string, userPublicKeys []string, opts ...grpc.DialOption) (bool, error)

DeleteAuthKeysV2 mocks base method.

func (*MockGfSpClientAPI) DeleteGlobalVirtualGroup added in v1.2.0 

func (m *MockGfSpClientAPI) DeleteGlobalVirtualGroup(ctx context.Context, deleteGVG *types4.MsgDeleteGlobalVirtualGroup) (string, error)

DeleteGlobalVirtualGroup mocks base method.

func (*MockGfSpClientAPI) Deposit added in v1.2.0 

func (m *MockGfSpClientAPI) Deposit(ctx context.Context, deposit *types4.MsgDeposit) (string, error)

Deposit mocks base method.

func (*MockGfSpClientAPI) DiscontinueBucket added in v0.2.4 

func (m *MockGfSpClientAPI) DiscontinueBucket(ctx context.Context, bucket *types3.MsgDiscontinueBucket) (string, error)

DiscontinueBucket mocks base method.

func (*MockGfSpClientAPI) DoneReplicatePiece added in v0.2.4 

func (m *MockGfSpClientAPI) DoneReplicatePiece(ctx context.Context, task task.ReceivePieceTask, opts ...grpc.DialOption) ([]byte, []byte, error)

DoneReplicatePiece mocks base method.

func (*MockGfSpClientAPI) DoneReplicatePieceToSecondary added in v0.2.4 

func (m *MockGfSpClientAPI) DoneReplicatePieceToSecondary(ctx context.Context, endpoint string, receive task.ReceivePieceTask) ([]byte, error)

DoneReplicatePieceToSecondary mocks base method.

func (*MockGfSpClientAPI) EXPECT added in v0.2.4 

func (m *MockGfSpClientAPI) EXPECT() *MockGfSpClientAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockGfSpClientAPI) GetAuthKeyV2 added in v1.6.0 

func (m *MockGfSpClientAPI) GetAuthKeyV2(ctx context.Context, account, domain, userPublicKey string, opts ...grpc.DialOption) (string, int64, error)

GetAuthKeyV2 mocks base method.

func (*MockGfSpClientAPI) GetAuthNonce added in v0.2.4 

func (m *MockGfSpClientAPI) GetAuthNonce(ctx context.Context, account, domain string, opts ...grpc.DialOption) (int32, int32, string, int64, error)

GetAuthNonce mocks base method.

func (*MockGfSpClientAPI) GetBucketByBucketID added in v0.2.4 

func (m *MockGfSpClientAPI) GetBucketByBucketID(ctx context.Context, bucketID int64, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketByBucketID mocks base method.

func (*MockGfSpClientAPI) GetBucketByBucketName added in v0.2.4 

func (m *MockGfSpClientAPI) GetBucketByBucketName(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketByBucketName mocks base method.

func (*MockGfSpClientAPI) GetBucketInfoByBucketName added in v1.5.0 

func (m *MockGfSpClientAPI) GetBucketInfoByBucketName(ctx context.Context, bucketName string, opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketInfoByBucketName mocks base method.

func (*MockGfSpClientAPI) GetBucketMeta added in v0.2.4 

func (m *MockGfSpClientAPI) GetBucketMeta(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.VGFInfoBucket, *types0.StreamRecord, error)

GetBucketMeta mocks base method.

func (*MockGfSpClientAPI) GetBucketReadQuota added in v0.2.4 

func (m *MockGfSpClientAPI) GetBucketReadQuota(ctx context.Context, bucket *types3.BucketInfo, yearMonth string, opts ...grpc.DialOption) (uint64, uint64, uint64, uint64, uint64, uint64, error)

GetBucketReadQuota mocks base method.

func (*MockGfSpClientAPI) GetBucketReadQuotaCount added in v1.6.0 

func (m *MockGfSpClientAPI) GetBucketReadQuotaCount(ctx context.Context, yearMonth string, opts ...grpc.DialOption) (int64, error)

GetBucketReadQuotaCount mocks base method.

func (*MockGfSpClientAPI) GetBucketSize added in v1.1.0 

func (m *MockGfSpClientAPI) GetBucketSize(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (string, error)

GetBucketSize mocks base method.

func (*MockGfSpClientAPI) GetChallengeInfo added in v0.2.4 

func (m *MockGfSpClientAPI) GetChallengeInfo(ctx context.Context, challengePieceTask task.ChallengePieceTask, opts ...grpc.DialOption) ([]byte, [][]byte, []byte, error)

GetChallengeInfo mocks base method.

func (*MockGfSpClientAPI) GetEndpointBySpID added in v0.2.4 

func (m *MockGfSpClientAPI) GetEndpointBySpID(ctx context.Context, spID uint32, opts ...grpc.DialOption) (string, error)

GetEndpointBySpID mocks base method.

func (*MockGfSpClientAPI) GetGlobalVirtualGroup added in v0.2.4 

func (m *MockGfSpClientAPI) GetGlobalVirtualGroup(ctx context.Context, bucketID uint64, lvgID uint32, opts ...grpc.DialOption) (*types4.GlobalVirtualGroup, error)

GetGlobalVirtualGroup mocks base method.

func (*MockGfSpClientAPI) GetGlobalVirtualGroupByGvgID added in v0.2.4 

func (m *MockGfSpClientAPI) GetGlobalVirtualGroupByGvgID(ctx context.Context, gvgID uint32, opts ...grpc.DialOption) (*types4.GlobalVirtualGroup, error)

GetGlobalVirtualGroupByGvgID mocks base method.

func (*MockGfSpClientAPI) GetGroupList added in v0.2.4 

func (m *MockGfSpClientAPI) GetGroupList(ctx context.Context, name, prefix, sourceType string, limit, offset int64, includeRemoved bool, opts ...grpc.DialOption) ([]*types.Group, int64, error)

GetGroupList mocks base method.

func (*MockGfSpClientAPI) GetGroupMembers added in v0.2.4 

func (m *MockGfSpClientAPI) GetGroupMembers(ctx context.Context, groupID uint64, startAfter string, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

GetGroupMembers mocks base method.

func (*MockGfSpClientAPI) GetLatestBucketReadQuota added in v1.1.0 

func (m *MockGfSpClientAPI) GetLatestBucketReadQuota(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (*gfsptask.GfSpBucketQuotaInfo, error)

GetLatestBucketReadQuota mocks base method.

func (*MockGfSpClientAPI) GetLatestObjectID added in v1.2.0 

func (m *MockGfSpClientAPI) GetLatestObjectID(ctx context.Context, opts ...grpc.DialOption) (uint64, error)

GetLatestObjectID mocks base method.

func (*MockGfSpClientAPI) GetMigrateBucketProgress added in v1.3.0 

func (m *MockGfSpClientAPI) GetMigrateBucketProgress(ctx context.Context, bucketID uint64) (*gfspserver.MigrateBucketProgressMeta, error)

GetMigrateBucketProgress mocks base method.

func (*MockGfSpClientAPI) GetObject added in v0.2.4 

func (m *MockGfSpClientAPI) GetObject(ctx context.Context, downloadObjectTask task.DownloadObjectTask, opts ...grpc.DialOption) ([]byte, error)

GetObject mocks base method.

func (*MockGfSpClientAPI) GetObjectByID added in v0.2.4 

func (m *MockGfSpClientAPI) GetObjectByID(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (*types3.ObjectInfo, error)

GetObjectByID mocks base method.

func (*MockGfSpClientAPI) GetObjectMeta added in v0.2.4 

func (m *MockGfSpClientAPI) GetObjectMeta(ctx context.Context, objectName, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Object, error)

GetObjectMeta mocks base method.

func (*MockGfSpClientAPI) GetPaymentByBucketID added in v0.2.4 

func (m *MockGfSpClientAPI) GetPaymentByBucketID(ctx context.Context, bucketID int64, includePrivate bool, opts ...grpc.DialOption) (*types0.StreamRecord, error)

GetPaymentByBucketID mocks base method.

func (*MockGfSpClientAPI) GetPaymentByBucketName added in v0.2.4 

func (m *MockGfSpClientAPI) GetPaymentByBucketName(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types0.StreamRecord, error)

GetPaymentByBucketName mocks base method.

func (*MockGfSpClientAPI) GetPiece added in v0.2.4 

func (m *MockGfSpClientAPI) GetPiece(ctx context.Context, downloadPieceTask task.DownloadPieceTask, opts ...grpc.DialOption) ([]byte, error)

GetPiece mocks base method.

func (*MockGfSpClientAPI) GetPieceFromECChunks added in v0.2.4 

func (m *MockGfSpClientAPI) GetPieceFromECChunks(ctx context.Context, endpoint string, task task.RecoveryPieceTask) (io.ReadCloser, error)

GetPieceFromECChunks mocks base method.

func (*MockGfSpClientAPI) GetSPInfo added in v0.2.4 

func (m *MockGfSpClientAPI) GetSPInfo(ctx context.Context, operatorAddress string, opts ...grpc.DialOption) (*types2.StorageProvider, error)

GetSPInfo mocks base method.

func (*MockGfSpClientAPI) GetSPMigratingBucketNumber added in v0.2.5 

func (m *MockGfSpClientAPI) GetSPMigratingBucketNumber(ctx context.Context, spID uint32, opts ...grpc.DialOption) (uint64, error)

GetSPMigratingBucketNumber mocks base method.

func (*MockGfSpClientAPI) GetSecondarySPMigrationBucketApproval added in v0.2.4 

func (m *MockGfSpClientAPI) GetSecondarySPMigrationBucketApproval(ctx context.Context, secondarySPEndpoint string, signDoc *types3.SecondarySpMigrationBucketSignDoc) ([]byte, error)

GetSecondarySPMigrationBucketApproval mocks base method.

func (*MockGfSpClientAPI) GetStatus added in v0.2.4 

func (m *MockGfSpClientAPI) GetStatus(ctx context.Context, opts ...grpc.DialOption) (*types.Status, error)

GetStatus mocks base method.

func (*MockGfSpClientAPI) GetSwapOutApproval added in v0.2.4 

func (m *MockGfSpClientAPI) GetSwapOutApproval(ctx context.Context, destSPEndpoint string, swapOutApproval *types4.MsgSwapOut) (*types4.MsgSwapOut, error)

GetSwapOutApproval mocks base method.

func (*MockGfSpClientAPI) GetTasksStats added in v0.2.6 

func (m *MockGfSpClientAPI) GetTasksStats(ctx context.Context) (*gfspserver.TasksStats, error)

GetTasksStats mocks base method.

func (*MockGfSpClientAPI) GetUploadObjectSegment added in v0.2.4 

func (m *MockGfSpClientAPI) GetUploadObjectSegment(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (uint32, error)

GetUploadObjectSegment mocks base method.

func (*MockGfSpClientAPI) GetUploadObjectState added in v0.2.4 

func (m *MockGfSpClientAPI) GetUploadObjectState(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (int32, string, error)

GetUploadObjectState mocks base method.

func (*MockGfSpClientAPI) GetUserBuckets added in v0.2.4 

func (m *MockGfSpClientAPI) GetUserBuckets(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) ([]*types.VGFInfoBucket, error)

GetUserBuckets mocks base method.

func (*MockGfSpClientAPI) GetUserBucketsCount added in v0.2.4 

func (m *MockGfSpClientAPI) GetUserBucketsCount(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) (int64, error)

GetUserBucketsCount mocks base method.

func (*MockGfSpClientAPI) GetUserGroups added in v0.2.4 

func (m *MockGfSpClientAPI) GetUserGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

GetUserGroups mocks base method.

func (*MockGfSpClientAPI) GetUserOwnedGroups added in v0.2.4 

func (m *MockGfSpClientAPI) GetUserOwnedGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

GetUserOwnedGroups mocks base method.

func (*MockGfSpClientAPI) GetVirtualGroupFamily added in v0.2.4 

func (m *MockGfSpClientAPI) GetVirtualGroupFamily(ctx context.Context, vgfID uint32, opts ...grpc.DialOption) (*types4.GlobalVirtualGroupFamily, error)

GetVirtualGroupFamily mocks base method.

func (*MockGfSpClientAPI) HTTPClient added in v0.2.4 

func (m *MockGfSpClientAPI) HTTPClient(ctx context.Context) *http.Client

HTTPClient mocks base method.

func (*MockGfSpClientAPI) ListAuthKeysV2 added in v1.6.0 

func (m *MockGfSpClientAPI) ListAuthKeysV2(ctx context.Context, account, domain string, opts ...grpc.DialOption) ([]string, error)

ListAuthKeysV2 mocks base method.

func (*MockGfSpClientAPI) ListBucketReadQuota added in v1.6.0 

func (m *MockGfSpClientAPI) ListBucketReadQuota(ctx context.Context, yearMonth string, offset, limit uint32, opts ...grpc.DialOption) ([]*types.BucketReadQuotaRecord, error)

ListBucketReadQuota mocks base method.

func (*MockGfSpClientAPI) ListBucketReadRecord added in v0.2.4 

func (m *MockGfSpClientAPI) ListBucketReadRecord(ctx context.Context, bucket *types3.BucketInfo, startTimestampUs, endTimestampUs, maxRecordNum int64, opts ...grpc.DialOption) ([]*types.ReadRecord, int64, error)

ListBucketReadRecord mocks base method.

func (*MockGfSpClientAPI) ListBucketsByIDs added in v0.2.4 

func (m *MockGfSpClientAPI) ListBucketsByIDs(ctx context.Context, bucketIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Bucket, error)

ListBucketsByIDs mocks base method.

func (*MockGfSpClientAPI) ListCompleteMigrationBucketEvents added in v1.3.0 

func (m *MockGfSpClientAPI) ListCompleteMigrationBucketEvents(ctx context.Context, blockID uint64, srcSpID uint32, opts ...grpc.DialOption) ([]*types3.EventCompleteMigrationBucket, error)

ListCompleteMigrationBucketEvents mocks base method.

func (*MockGfSpClientAPI) ListDeletedObjectsByBlockNumberRange added in v0.2.4 

func (m *MockGfSpClientAPI) ListDeletedObjectsByBlockNumberRange(ctx context.Context, spOperatorAddress string, startBlockNumber, endBlockNumber uint64, includePrivate bool, opts ...grpc.DialOption) ([]*types.Object, uint64, error)

ListDeletedObjectsByBlockNumberRange mocks base method.

func (*MockGfSpClientAPI) ListExpiredBucketsBySp added in v0.2.4 

func (m *MockGfSpClientAPI) ListExpiredBucketsBySp(ctx context.Context, createAt int64, primarySpID uint32, limit int64, opts ...grpc.DialOption) ([]*types.Bucket, error)

ListExpiredBucketsBySp mocks base method.

func (*MockGfSpClientAPI) ListGlobalVirtualGroupsByBucket added in v0.2.4 

func (m *MockGfSpClientAPI) ListGlobalVirtualGroupsByBucket(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) ([]*types4.GlobalVirtualGroup, error)

ListGlobalVirtualGroupsByBucket mocks base method.

func (*MockGfSpClientAPI) ListGlobalVirtualGroupsBySecondarySP added in v0.2.4 

func (m *MockGfSpClientAPI) ListGlobalVirtualGroupsBySecondarySP(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*types4.GlobalVirtualGroup, error)

ListGlobalVirtualGroupsBySecondarySP mocks base method.

func (*MockGfSpClientAPI) ListGroupsByIDs added in v0.2.5 

func (m *MockGfSpClientAPI) ListGroupsByIDs(ctx context.Context, groupIDs []uint64, opts ...grpc.DialOption) (map[uint64]*types.Group, error)

ListGroupsByIDs mocks base method.

func (*MockGfSpClientAPI) ListMigrateBucketEvents added in v0.2.4 

func (m *MockGfSpClientAPI) ListMigrateBucketEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListMigrateBucketEvents, error)

ListMigrateBucketEvents mocks base method.

func (*MockGfSpClientAPI) ListObjectPolicies added in v0.2.5 

func (m *MockGfSpClientAPI) ListObjectPolicies(ctx context.Context, objectName, bucketName string, startAfter uint64, actionType int32, limit uint32, opts ...grpc.DialOption) ([]*types.Policy, error)

ListObjectPolicies mocks base method.

func (*MockGfSpClientAPI) ListObjectsByBucketName added in v0.2.4 

func (m *MockGfSpClientAPI) ListObjectsByBucketName(ctx context.Context, bucketName, accountID string, maxKeys uint64, startAfter, continuationToken, delimiter, prefix string, includeRemoved bool, opts ...grpc.DialOption) ([]*types.Object, uint64, uint64, bool, string, string, string, string, []string, string, error)

ListObjectsByBucketName mocks base method.

func (*MockGfSpClientAPI) ListObjectsByGVGAndBucketForGC added in v0.2.4 

func (m *MockGfSpClientAPI) ListObjectsByGVGAndBucketForGC(ctx context.Context, gvgID uint32, bucketID, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

ListObjectsByGVGAndBucketForGC mocks base method.

func (*MockGfSpClientAPI) ListObjectsByIDs added in v0.2.4 

func (m *MockGfSpClientAPI) ListObjectsByIDs(ctx context.Context, objectIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Object, error)

ListObjectsByIDs mocks base method.

func (*MockGfSpClientAPI) ListObjectsInGVG added in v0.2.4 

func (m *MockGfSpClientAPI) ListObjectsInGVG(ctx context.Context, gvgID uint32, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

ListObjectsInGVG mocks base method.

func (*MockGfSpClientAPI) ListObjectsInGVGAndBucket added in v0.2.4 

func (m *MockGfSpClientAPI) ListObjectsInGVGAndBucket(ctx context.Context, gvgID uint32, bucketID, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

ListObjectsInGVGAndBucket mocks base method.

func (*MockGfSpClientAPI) ListPaymentAccountStreams added in v0.2.5 

func (m *MockGfSpClientAPI) ListPaymentAccountStreams(ctx context.Context, paymentAccount string, opts ...grpc.DialOption) ([]*types.Bucket, error)

ListPaymentAccountStreams mocks base method.

func (*MockGfSpClientAPI) ListSpExitEvents added in v0.2.4 

func (m *MockGfSpClientAPI) ListSpExitEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) (*types.ListSpExitEvents, error)

ListSpExitEvents mocks base method.

func (*MockGfSpClientAPI) ListSwapOutEvents added in v0.2.4 

func (m *MockGfSpClientAPI) ListSwapOutEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListSwapOutEvents, error)

ListSwapOutEvents mocks base method.

func (*MockGfSpClientAPI) ListUserPaymentAccounts added in v0.2.5 

func (m *MockGfSpClientAPI) ListUserPaymentAccounts(ctx context.Context, accountID string, opts ...grpc.DialOption) ([]*types.PaymentAccountMeta, error)

ListUserPaymentAccounts mocks base method.

func (*MockGfSpClientAPI) ListVirtualGroupFamiliesSpID added in v0.2.4 

func (m *MockGfSpClientAPI) ListVirtualGroupFamiliesSpID(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*types4.GlobalVirtualGroupFamily, error)

ListVirtualGroupFamiliesSpID mocks base method.

func (*MockGfSpClientAPI) ManagerConn added in v0.2.4 

func (m *MockGfSpClientAPI) ManagerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

ManagerConn mocks base method.

func (*MockGfSpClientAPI) MigratePiece added in v0.2.4 

func (m *MockGfSpClientAPI) MigratePiece(ctx context.Context, gvgTask *gfsptask.GfSpMigrateGVGTask, pieceTask *gfsptask.GfSpMigratePieceTask) ([]byte, error)

MigratePiece mocks base method.

func (*MockGfSpClientAPI) NotifyDestSPMigrateSwapOut added in v0.2.4 

func (m *MockGfSpClientAPI) NotifyDestSPMigrateSwapOut(ctx context.Context, destEndpoint string, swapOut *types4.MsgSwapOut) error

NotifyDestSPMigrateSwapOut mocks base method.

func (*MockGfSpClientAPI) NotifyMigrateSwapOut added in v0.2.4 

func (m *MockGfSpClientAPI) NotifyMigrateSwapOut(ctx context.Context, swapOut *types4.MsgSwapOut) error

NotifyMigrateSwapOut mocks base method.

func (*MockGfSpClientAPI) NotifyPostMigrateBucketAndRecoupQuota added in v1.3.0 

func (m *MockGfSpClientAPI) NotifyPostMigrateBucketAndRecoupQuota(ctx context.Context, bmInfo *gfsptask.GfSpBucketMigrationInfo) (*gfsptask.GfSpBucketQuotaInfo, error)

NotifyPostMigrateBucketAndRecoupQuota mocks base method.

func (*MockGfSpClientAPI) NotifyPreMigrateBucketAndDeductQuota added in v1.3.0 

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

NotifyPreMigrateBucketAndDeductQuota mocks base method.

func (*MockGfSpClientAPI) P2PConn added in v0.2.4 

func (m *MockGfSpClientAPI) P2PConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

P2PConn mocks base method.

func (*MockGfSpClientAPI) PickVirtualGroupFamilyID added in v0.2.4 

func (m *MockGfSpClientAPI) PickVirtualGroupFamilyID(ctx context.Context, task task.ApprovalCreateBucketTask) (uint32, error)

PickVirtualGroupFamilyID mocks base method.

func (*MockGfSpClientAPI) PostMigrateBucket added in v1.1.0 

func (m *MockGfSpClientAPI) PostMigrateBucket(ctx context.Context, srcSPEndpoint string, postMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

PostMigrateBucket mocks base method.

func (*MockGfSpClientAPI) PreMigrateBucket added in v1.1.0 

func (m *MockGfSpClientAPI) PreMigrateBucket(ctx context.Context, srcSPEndpoint string, preMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

PreMigrateBucket mocks base method.

func (*MockGfSpClientAPI) PrimarySpIncomeDetails added in v1.1.0 

func (m *MockGfSpClientAPI) PrimarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.PrimarySpIncomeDetail, error)

PrimarySpIncomeDetails mocks base method.

func (*MockGfSpClientAPI) QueryBucketMigrate added in v0.2.4 

func (m *MockGfSpClientAPI) QueryBucketMigrate(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)

QueryBucketMigrate mocks base method.

func (*MockGfSpClientAPI) QueryLatestBucketQuota added in v1.1.0 

func (m *MockGfSpClientAPI) QueryLatestBucketQuota(ctx context.Context, endpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) (gfsptask.GfSpBucketQuotaInfo, error)

QueryLatestBucketQuota mocks base method.

func (*MockGfSpClientAPI) QueryP2PBootstrap added in v0.2.4 

func (m *MockGfSpClientAPI) QueryP2PBootstrap(ctx context.Context) ([]string, error)

QueryP2PBootstrap mocks base method.

func (*MockGfSpClientAPI) QuerySPExit added in v0.2.4 

func (m *MockGfSpClientAPI) QuerySPExit(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)

QuerySPExit mocks base method.

func (*MockGfSpClientAPI) QuerySPHasEnoughQuotaForMigrateBucket added in v1.1.0 

func (m *MockGfSpClientAPI) QuerySPHasEnoughQuotaForMigrateBucket(ctx context.Context, srcSPEndpoint string, queryMsg *gfsptask.GfSpBucketMigrationInfo) error

QuerySPHasEnoughQuotaForMigrateBucket mocks base method.

func (*MockGfSpClientAPI) QueryTasks added in v0.2.4 

func (m *MockGfSpClientAPI) QueryTasks(ctx context.Context, endpoint, subKey string, opts ...grpc.DialOption) ([]string, error)

QueryTasks mocks base method.

func (*MockGfSpClientAPI) RecoupQuota added in v0.2.5 

func (m *MockGfSpClientAPI) RecoupQuota(ctx context.Context, bucketID, extraQuota uint64, yearMonth string, opts ...grpc.DialOption) error

RecoupQuota mocks base method.

func (*MockGfSpClientAPI) RejectMigrateBucket added in v1.1.0 

func (m *MockGfSpClientAPI) RejectMigrateBucket(ctx context.Context, rejectMigrateBucket *types3.MsgRejectMigrateBucket) (string, error)

RejectMigrateBucket mocks base method.

func (*MockGfSpClientAPI) RejectUnSealObject added in v0.2.4 

func (m *MockGfSpClientAPI) RejectUnSealObject(ctx context.Context, object *types3.MsgRejectSealObject) (string, error)

RejectUnSealObject mocks base method.

func (*MockGfSpClientAPI) ReplicatePiece added in v0.2.4 

func (m *MockGfSpClientAPI) ReplicatePiece(ctx context.Context, task task.ReceivePieceTask, data []byte, opts ...grpc.DialOption) error

ReplicatePiece mocks base method.

func (*MockGfSpClientAPI) ReplicatePieceToSecondary added in v0.2.4 

func (m *MockGfSpClientAPI) ReplicatePieceToSecondary(ctx context.Context, endpoint string, receive task.ReceivePieceTask, data []byte) error

ReplicatePieceToSecondary mocks base method.

func (*MockGfSpClientAPI) ReportTask added in v0.2.4 

func (m *MockGfSpClientAPI) ReportTask(ctx context.Context, report task.Task) error

ReportTask mocks base method.

func (*MockGfSpClientAPI) ReserveSwapIn added in v1.3.0 

func (m *MockGfSpClientAPI) ReserveSwapIn(ctx context.Context, reserveSwapIn *types4.MsgReserveSwapIn) (string, error)

ReserveSwapIn mocks base method.

func (*MockGfSpClientAPI) ResumableUploadObject added in v0.2.4 

func (m *MockGfSpClientAPI) ResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask, stream io.Reader, opts ...grpc.DialOption) error

ResumableUploadObject mocks base method.

func (*MockGfSpClientAPI) SPExit added in v0.2.4 

func (m *MockGfSpClientAPI) SPExit(ctx context.Context, spExit *types4.MsgStorageProviderExit) (string, error)

SPExit mocks base method.

func (*MockGfSpClientAPI) SealObject added in v0.2.4 

func (m *MockGfSpClientAPI) SealObject(ctx context.Context, object *types3.MsgSealObject) (string, error)

SealObject mocks base method.

func (*MockGfSpClientAPI) SealObjectV2 added in v1.6.0 

func (m *MockGfSpClientAPI) SealObjectV2(ctx context.Context, object *types3.MsgSealObjectV2) (string, error)

SealObjectV2 mocks base method.

func (*MockGfSpClientAPI) SecondarySpIncomeDetails added in v1.1.0 

func (m *MockGfSpClientAPI) SecondarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.SecondarySpIncomeDetail, error)

SecondarySpIncomeDetails mocks base method.

func (*MockGfSpClientAPI) SignBucketMigrationInfo added in v1.1.0 

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

SignBucketMigrationInfo mocks base method.

func (*MockGfSpClientAPI) SignCreateBucketApproval added in v0.2.4 

func (m *MockGfSpClientAPI) SignCreateBucketApproval(ctx context.Context, bucket *types3.MsgCreateBucket) ([]byte, error)

SignCreateBucketApproval mocks base method.

func (*MockGfSpClientAPI) SignCreateObjectApproval added in v0.2.4 

func (m *MockGfSpClientAPI) SignCreateObjectApproval(ctx context.Context, object *types3.MsgCreateObject) ([]byte, error)

SignCreateObjectApproval mocks base method.

func (*MockGfSpClientAPI) SignMigrateBucketApproval added in v0.2.4 

func (m *MockGfSpClientAPI) SignMigrateBucketApproval(ctx context.Context, bucket *types3.MsgMigrateBucket) ([]byte, error)

SignMigrateBucketApproval mocks base method.

func (*MockGfSpClientAPI) SignMigrateGVG added in v0.2.6 

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

SignMigrateGVG mocks base method.

func (*MockGfSpClientAPI) SignP2PPingMsg added in v0.2.4 

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

SignP2PPingMsg mocks base method.

func (*MockGfSpClientAPI) SignP2PPongMsg added in v0.2.4 

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

SignP2PPongMsg mocks base method.

func (*MockGfSpClientAPI) SignReceiveTask added in v0.2.4 

func (m *MockGfSpClientAPI) SignReceiveTask(ctx context.Context, receiveTask task.ReceivePieceTask) ([]byte, error)

SignReceiveTask mocks base method.

func (*MockGfSpClientAPI) SignRecoveryTask added in v0.2.4 

func (m *MockGfSpClientAPI) SignRecoveryTask(ctx context.Context, recoveryTask task.RecoveryPieceTask) ([]byte, error)

SignRecoveryTask mocks base method.

func (*MockGfSpClientAPI) SignReplicatePieceApproval added in v0.2.4 

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

SignReplicatePieceApproval mocks base method.

func (*MockGfSpClientAPI) SignSecondarySPMigrationBucket added in v0.2.4 

func (m *MockGfSpClientAPI) SignSecondarySPMigrationBucket(ctx context.Context, signDoc *types3.SecondarySpMigrationBucketSignDoc) ([]byte, error)

SignSecondarySPMigrationBucket mocks base method.

func (*MockGfSpClientAPI) SignSecondarySealBls added in v0.2.4 

func (m *MockGfSpClientAPI) SignSecondarySealBls(ctx context.Context, objectID uint64, gvgId uint32, checksums [][]byte) ([]byte, error)

SignSecondarySealBls mocks base method.

func (*MockGfSpClientAPI) SignSwapOut added in v0.2.4 

func (m *MockGfSpClientAPI) SignSwapOut(ctx context.Context, swapOut *types4.MsgSwapOut) ([]byte, error)

SignSwapOut mocks base method.

func (*MockGfSpClientAPI) SignerConn added in v0.2.4 

func (m *MockGfSpClientAPI) SignerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

SignerConn mocks base method.

func (*MockGfSpClientAPI) SwapOut added in v0.2.4 

func (m *MockGfSpClientAPI) SwapOut(ctx context.Context, swapOut *types4.MsgSwapOut) (string, error)

SwapOut mocks base method.

func (*MockGfSpClientAPI) UpdateSPPrice added in v0.2.4 

func (m *MockGfSpClientAPI) UpdateSPPrice(ctx context.Context, price *types2.MsgUpdateSpStoragePrice) (string, error)

UpdateSPPrice mocks base method.

func (*MockGfSpClientAPI) UpdateUserPublicKey added in v0.2.4 

func (m *MockGfSpClientAPI) UpdateUserPublicKey(ctx context.Context, account, domain string, currentNonce, nonce int32, userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)

UpdateUserPublicKey mocks base method.

func (*MockGfSpClientAPI) UpdateUserPublicKeyV2 added in v1.6.0 

func (m *MockGfSpClientAPI) UpdateUserPublicKeyV2(ctx context.Context, account, domain, userPublicKey string, expiryDate int64, opts ...grpc.DialOption) (bool, error)

UpdateUserPublicKeyV2 mocks base method.

func (*MockGfSpClientAPI) UploadObject added in v0.2.4 

func (m *MockGfSpClientAPI) UploadObject(ctx context.Context, task task.UploadObjectTask, stream io.Reader, opts ...grpc.DialOption) error

UploadObject mocks base method.

func (*MockGfSpClientAPI) VerifyAuthentication added in v0.2.4 

func (m *MockGfSpClientAPI) VerifyAuthentication(ctx context.Context, auth module.AuthOpType, account, bucket, object string, opts ...grpc.DialOption) (bool, error)

VerifyAuthentication mocks base method.

func (*MockGfSpClientAPI) VerifyGNFD1EddsaSignature added in v0.2.4 

func (m *MockGfSpClientAPI) VerifyGNFD1EddsaSignature(ctx context.Context, account, domain, offChainSig string, realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)

VerifyGNFD1EddsaSignature mocks base method.

func (*MockGfSpClientAPI) VerifyGNFD2EddsaSignature added in v1.6.0 

func (m *MockGfSpClientAPI) VerifyGNFD2EddsaSignature(ctx context.Context, account, domain, userPublicKey, offChainSig string, realMsgToSign []byte, opts ...grpc.DialOption) (bool, error)

VerifyGNFD2EddsaSignature mocks base method.

func (*MockGfSpClientAPI) VerifyMigrateGVGPermission added in v0.2.6 

func (m *MockGfSpClientAPI) VerifyMigrateGVGPermission(ctx context.Context, bucketID uint64, gvgID, dstSpID uint32, opts ...grpc.DialOption) (*types1.Effect, error)

VerifyMigrateGVGPermission mocks base method.

func (*MockGfSpClientAPI) VerifyPermission added in v0.2.4 

func (m *MockGfSpClientAPI) VerifyPermission(ctx context.Context, Operator, bucketName, objectName string, actionType types1.ActionType, opts ...grpc.DialOption) (*types1.Effect, error)

VerifyPermission mocks base method.

func (*MockGfSpClientAPI) VerifyPermissionByID added in v0.2.4 

func (m *MockGfSpClientAPI) VerifyPermissionByID(ctx context.Context, Operator string, resourceType resource.ResourceType, resourceID uint64, actionType types1.ActionType, opts ...grpc.DialOption) (*types1.Effect, error)

VerifyPermissionByID mocks base method.

type MockGfSpClientAPIMockRecorder added in v0.2.4 

type MockGfSpClientAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockGfSpClientAPIMockRecorder is the mock recorder for MockGfSpClientAPI.

func (*MockGfSpClientAPIMockRecorder) ApproverConn added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ApproverConn(ctx any, opts ...any) *gomock.Call

ApproverConn indicates an expected call of ApproverConn.

func (*MockGfSpClientAPIMockRecorder) AskCreateBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskCreateBucketApproval(ctx, t any) *gomock.Call

AskCreateBucketApproval indicates an expected call of AskCreateBucketApproval.

func (*MockGfSpClientAPIMockRecorder) AskCreateObjectApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskCreateObjectApproval(ctx, t any) *gomock.Call

AskCreateObjectApproval indicates an expected call of AskCreateObjectApproval.

func (*MockGfSpClientAPIMockRecorder) AskDelegateCreateObjectApproval added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) AskDelegateCreateObjectApproval(ctx, t any) *gomock.Call

AskDelegateCreateObjectApproval indicates an expected call of AskDelegateCreateObjectApproval.

func (*MockGfSpClientAPIMockRecorder) AskMigrateBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskMigrateBucketApproval(ctx, t any) *gomock.Call

AskMigrateBucketApproval indicates an expected call of AskMigrateBucketApproval.

func (*MockGfSpClientAPIMockRecorder) AskSecondaryReplicatePieceApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskSecondaryReplicatePieceApproval(ctx, task, low, high, timeout any) *gomock.Call

AskSecondaryReplicatePieceApproval indicates an expected call of AskSecondaryReplicatePieceApproval.

func (*MockGfSpClientAPIMockRecorder) AskTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskTask(ctx, limit any) *gomock.Call

AskTask indicates an expected call of AskTask.

func (*MockGfSpClientAPIMockRecorder) Close added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockGfSpClientAPIMockRecorder) CompleteMigrateBucket added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CompleteMigrateBucket(ctx, migrateBucket any) *gomock.Call

CompleteMigrateBucket indicates an expected call of CompleteMigrateBucket.

func (*MockGfSpClientAPIMockRecorder) CompleteSPExit added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CompleteSPExit(ctx, completeSPExit any) *gomock.Call

CompleteSPExit indicates an expected call of CompleteSPExit.

func (*MockGfSpClientAPIMockRecorder) CompleteSwapIn added in v1.3.0 

func (mr *MockGfSpClientAPIMockRecorder) CompleteSwapIn(ctx, completeSwpIn any) *gomock.Call

CompleteSwapIn indicates an expected call of CompleteSwapIn.

func (*MockGfSpClientAPIMockRecorder) CompleteSwapOut added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CompleteSwapOut(ctx, completeSwapOut any) *gomock.Call

CompleteSwapOut indicates an expected call of CompleteSwapOut.

func (*MockGfSpClientAPIMockRecorder) Connection added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) Connection(ctx, address any, opts ...any) *gomock.Call

Connection indicates an expected call of Connection.

func (*MockGfSpClientAPIMockRecorder) CreateGlobalVirtualGroup added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CreateGlobalVirtualGroup(ctx, group any) *gomock.Call

CreateGlobalVirtualGroup indicates an expected call of CreateGlobalVirtualGroup.

func (*MockGfSpClientAPIMockRecorder) CreateResumableUploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CreateResumableUploadObject(ctx, task any) *gomock.Call

CreateResumableUploadObject indicates an expected call of CreateResumableUploadObject.

func (*MockGfSpClientAPIMockRecorder) CreateUploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CreateUploadObject(ctx, task any) *gomock.Call

CreateUploadObject indicates an expected call of CreateUploadObject.

func (*MockGfSpClientAPIMockRecorder) DeductQuotaForBucketMigrate added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) DeductQuotaForBucketMigrate(ctx, bucketID, deductQuota, yearMonth any, opts ...any) *gomock.Call

DeductQuotaForBucketMigrate indicates an expected call of DeductQuotaForBucketMigrate.

func (*MockGfSpClientAPIMockRecorder) DelegateCreateObject added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) DelegateCreateObject(ctx, object any) *gomock.Call

DelegateCreateObject indicates an expected call of DelegateCreateObject.

func (*MockGfSpClientAPIMockRecorder) DelegateUpdateObjectContent added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) DelegateUpdateObjectContent(ctx, object any) *gomock.Call

DelegateUpdateObjectContent indicates an expected call of DelegateUpdateObjectContent.

func (*MockGfSpClientAPIMockRecorder) DeleteAuthKeysV2 added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) DeleteAuthKeysV2(ctx, account, domain, userPublicKeys any, opts ...any) *gomock.Call

DeleteAuthKeysV2 indicates an expected call of DeleteAuthKeysV2.

func (*MockGfSpClientAPIMockRecorder) DeleteGlobalVirtualGroup added in v1.2.0 

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

DeleteGlobalVirtualGroup indicates an expected call of DeleteGlobalVirtualGroup.

func (*MockGfSpClientAPIMockRecorder) Deposit added in v1.2.0 

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

Deposit indicates an expected call of Deposit.

func (*MockGfSpClientAPIMockRecorder) DiscontinueBucket added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) DiscontinueBucket(ctx, bucket any) *gomock.Call

DiscontinueBucket indicates an expected call of DiscontinueBucket.

func (*MockGfSpClientAPIMockRecorder) DoneReplicatePiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) DoneReplicatePiece(ctx, task any, opts ...any) *gomock.Call

DoneReplicatePiece indicates an expected call of DoneReplicatePiece.

func (*MockGfSpClientAPIMockRecorder) DoneReplicatePieceToSecondary added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) DoneReplicatePieceToSecondary(ctx, endpoint, receive any) *gomock.Call

DoneReplicatePieceToSecondary indicates an expected call of DoneReplicatePieceToSecondary.

func (*MockGfSpClientAPIMockRecorder) GetAuthKeyV2 added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) GetAuthKeyV2(ctx, account, domain, userPublicKey any, opts ...any) *gomock.Call

GetAuthKeyV2 indicates an expected call of GetAuthKeyV2.

func (*MockGfSpClientAPIMockRecorder) GetAuthNonce added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetAuthNonce(ctx, account, domain any, opts ...any) *gomock.Call

GetAuthNonce indicates an expected call of GetAuthNonce.

func (*MockGfSpClientAPIMockRecorder) GetBucketByBucketID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketByBucketID(ctx, bucketID, includePrivate any, opts ...any) *gomock.Call

GetBucketByBucketID indicates an expected call of GetBucketByBucketID.

func (*MockGfSpClientAPIMockRecorder) GetBucketByBucketName added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketByBucketName(ctx, bucketName, includePrivate any, opts ...any) *gomock.Call

GetBucketByBucketName indicates an expected call of GetBucketByBucketName.

func (*MockGfSpClientAPIMockRecorder) GetBucketInfoByBucketName added in v1.5.0 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketInfoByBucketName(ctx, bucketName any, opts ...any) *gomock.Call

GetBucketInfoByBucketName indicates an expected call of GetBucketInfoByBucketName.

func (*MockGfSpClientAPIMockRecorder) GetBucketMeta added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketMeta(ctx, bucketName, includePrivate any, opts ...any) *gomock.Call

GetBucketMeta indicates an expected call of GetBucketMeta.

func (*MockGfSpClientAPIMockRecorder) GetBucketReadQuota added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketReadQuota(ctx, bucket, yearMonth any, opts ...any) *gomock.Call

GetBucketReadQuota indicates an expected call of GetBucketReadQuota.

func (*MockGfSpClientAPIMockRecorder) GetBucketReadQuotaCount added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketReadQuotaCount(ctx, yearMonth any, opts ...any) *gomock.Call

GetBucketReadQuotaCount indicates an expected call of GetBucketReadQuotaCount.

func (*MockGfSpClientAPIMockRecorder) GetBucketSize added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketSize(ctx, bucketID any, opts ...any) *gomock.Call

GetBucketSize indicates an expected call of GetBucketSize.

func (*MockGfSpClientAPIMockRecorder) GetChallengeInfo added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetChallengeInfo(ctx, challengePieceTask any, opts ...any) *gomock.Call

GetChallengeInfo indicates an expected call of GetChallengeInfo.

func (*MockGfSpClientAPIMockRecorder) GetEndpointBySpID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetEndpointBySpID(ctx, spID any, opts ...any) *gomock.Call

GetEndpointBySpID indicates an expected call of GetEndpointBySpID.

func (*MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroup added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroup(ctx, bucketID, lvgID any, opts ...any) *gomock.Call

GetGlobalVirtualGroup indicates an expected call of GetGlobalVirtualGroup.

func (*MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroupByGvgID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroupByGvgID(ctx, gvgID any, opts ...any) *gomock.Call

GetGlobalVirtualGroupByGvgID indicates an expected call of GetGlobalVirtualGroupByGvgID.

func (*MockGfSpClientAPIMockRecorder) GetGroupList added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetGroupList(ctx, name, prefix, sourceType, limit, offset, includeRemoved any, opts ...any) *gomock.Call

GetGroupList indicates an expected call of GetGroupList.

func (*MockGfSpClientAPIMockRecorder) GetGroupMembers added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetGroupMembers(ctx, groupID, startAfter, limit any, opts ...any) *gomock.Call

GetGroupMembers indicates an expected call of GetGroupMembers.

func (*MockGfSpClientAPIMockRecorder) GetLatestBucketReadQuota added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) GetLatestBucketReadQuota(ctx, bucketID any, opts ...any) *gomock.Call

GetLatestBucketReadQuota indicates an expected call of GetLatestBucketReadQuota.

func (*MockGfSpClientAPIMockRecorder) GetLatestObjectID added in v1.2.0 

func (mr *MockGfSpClientAPIMockRecorder) GetLatestObjectID(ctx any, opts ...any) *gomock.Call

GetLatestObjectID indicates an expected call of GetLatestObjectID.

func (*MockGfSpClientAPIMockRecorder) GetMigrateBucketProgress added in v1.3.0 

func (mr *MockGfSpClientAPIMockRecorder) GetMigrateBucketProgress(ctx, bucketID any) *gomock.Call

GetMigrateBucketProgress indicates an expected call of GetMigrateBucketProgress.

func (*MockGfSpClientAPIMockRecorder) GetObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetObject(ctx, downloadObjectTask any, opts ...any) *gomock.Call

GetObject indicates an expected call of GetObject.

func (*MockGfSpClientAPIMockRecorder) GetObjectByID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetObjectByID(ctx, objectID any, opts ...any) *gomock.Call

GetObjectByID indicates an expected call of GetObjectByID.

func (*MockGfSpClientAPIMockRecorder) GetObjectMeta added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetObjectMeta(ctx, objectName, bucketName, includePrivate any, opts ...any) *gomock.Call

GetObjectMeta indicates an expected call of GetObjectMeta.

func (*MockGfSpClientAPIMockRecorder) GetPaymentByBucketID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPaymentByBucketID(ctx, bucketID, includePrivate any, opts ...any) *gomock.Call

GetPaymentByBucketID indicates an expected call of GetPaymentByBucketID.

func (*MockGfSpClientAPIMockRecorder) GetPaymentByBucketName added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPaymentByBucketName(ctx, bucketName, includePrivate any, opts ...any) *gomock.Call

GetPaymentByBucketName indicates an expected call of GetPaymentByBucketName.

func (*MockGfSpClientAPIMockRecorder) GetPiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPiece(ctx, downloadPieceTask any, opts ...any) *gomock.Call

GetPiece indicates an expected call of GetPiece.

func (*MockGfSpClientAPIMockRecorder) GetPieceFromECChunks added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPieceFromECChunks(ctx, endpoint, task any) *gomock.Call

GetPieceFromECChunks indicates an expected call of GetPieceFromECChunks.

func (*MockGfSpClientAPIMockRecorder) GetSPInfo added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetSPInfo(ctx, operatorAddress any, opts ...any) *gomock.Call

GetSPInfo indicates an expected call of GetSPInfo.

func (*MockGfSpClientAPIMockRecorder) GetSPMigratingBucketNumber added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) GetSPMigratingBucketNumber(ctx, spID any, opts ...any) *gomock.Call

GetSPMigratingBucketNumber indicates an expected call of GetSPMigratingBucketNumber.

func (*MockGfSpClientAPIMockRecorder) GetSecondarySPMigrationBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetSecondarySPMigrationBucketApproval(ctx, secondarySPEndpoint, signDoc any) *gomock.Call

GetSecondarySPMigrationBucketApproval indicates an expected call of GetSecondarySPMigrationBucketApproval.

func (*MockGfSpClientAPIMockRecorder) GetStatus added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetStatus(ctx any, opts ...any) *gomock.Call

GetStatus indicates an expected call of GetStatus.

func (*MockGfSpClientAPIMockRecorder) GetSwapOutApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetSwapOutApproval(ctx, destSPEndpoint, swapOutApproval any) *gomock.Call

GetSwapOutApproval indicates an expected call of GetSwapOutApproval.

func (*MockGfSpClientAPIMockRecorder) GetTasksStats added in v0.2.6 

func (mr *MockGfSpClientAPIMockRecorder) GetTasksStats(ctx any) *gomock.Call

GetTasksStats indicates an expected call of GetTasksStats.

func (*MockGfSpClientAPIMockRecorder) GetUploadObjectSegment added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUploadObjectSegment(ctx, objectID any, opts ...any) *gomock.Call

GetUploadObjectSegment indicates an expected call of GetUploadObjectSegment.

func (*MockGfSpClientAPIMockRecorder) GetUploadObjectState added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUploadObjectState(ctx, objectID any, opts ...any) *gomock.Call

GetUploadObjectState indicates an expected call of GetUploadObjectState.

func (*MockGfSpClientAPIMockRecorder) GetUserBuckets added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUserBuckets(ctx, account, includeRemoved any, opts ...any) *gomock.Call

GetUserBuckets indicates an expected call of GetUserBuckets.

func (*MockGfSpClientAPIMockRecorder) GetUserBucketsCount added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUserBucketsCount(ctx, account, includeRemoved any, opts ...any) *gomock.Call

GetUserBucketsCount indicates an expected call of GetUserBucketsCount.

func (*MockGfSpClientAPIMockRecorder) GetUserGroups added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUserGroups(ctx, accountID, startAfter, limit any, opts ...any) *gomock.Call

GetUserGroups indicates an expected call of GetUserGroups.

func (*MockGfSpClientAPIMockRecorder) GetUserOwnedGroups added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUserOwnedGroups(ctx, accountID, startAfter, limit any, opts ...any) *gomock.Call

GetUserOwnedGroups indicates an expected call of GetUserOwnedGroups.

func (*MockGfSpClientAPIMockRecorder) GetVirtualGroupFamily added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetVirtualGroupFamily(ctx, vgfID any, opts ...any) *gomock.Call

GetVirtualGroupFamily indicates an expected call of GetVirtualGroupFamily.

func (*MockGfSpClientAPIMockRecorder) HTTPClient added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) HTTPClient(ctx any) *gomock.Call

HTTPClient indicates an expected call of HTTPClient.

func (*MockGfSpClientAPIMockRecorder) ListAuthKeysV2 added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) ListAuthKeysV2(ctx, account, domain any, opts ...any) *gomock.Call

ListAuthKeysV2 indicates an expected call of ListAuthKeysV2.

func (*MockGfSpClientAPIMockRecorder) ListBucketReadQuota added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) ListBucketReadQuota(ctx, yearMonth, offset, limit any, opts ...any) *gomock.Call

ListBucketReadQuota indicates an expected call of ListBucketReadQuota.

func (*MockGfSpClientAPIMockRecorder) ListBucketReadRecord added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListBucketReadRecord(ctx, bucket, startTimestampUs, endTimestampUs, maxRecordNum any, opts ...any) *gomock.Call

ListBucketReadRecord indicates an expected call of ListBucketReadRecord.

func (*MockGfSpClientAPIMockRecorder) ListBucketsByIDs added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListBucketsByIDs(ctx, bucketIDs, includeRemoved any, opts ...any) *gomock.Call

ListBucketsByIDs indicates an expected call of ListBucketsByIDs.

func (*MockGfSpClientAPIMockRecorder) ListCompleteMigrationBucketEvents added in v1.3.0 

func (mr *MockGfSpClientAPIMockRecorder) ListCompleteMigrationBucketEvents(ctx, blockID, srcSpID any, opts ...any) *gomock.Call

ListCompleteMigrationBucketEvents indicates an expected call of ListCompleteMigrationBucketEvents.

func (*MockGfSpClientAPIMockRecorder) ListDeletedObjectsByBlockNumberRange added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListDeletedObjectsByBlockNumberRange(ctx, spOperatorAddress, startBlockNumber, endBlockNumber, includePrivate any, opts ...any) *gomock.Call

ListDeletedObjectsByBlockNumberRange indicates an expected call of ListDeletedObjectsByBlockNumberRange.

func (*MockGfSpClientAPIMockRecorder) ListExpiredBucketsBySp added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListExpiredBucketsBySp(ctx, createAt, primarySpID, limit any, opts ...any) *gomock.Call

ListExpiredBucketsBySp indicates an expected call of ListExpiredBucketsBySp.

func (*MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsByBucket added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsByBucket(ctx, bucketID any, opts ...any) *gomock.Call

ListGlobalVirtualGroupsByBucket indicates an expected call of ListGlobalVirtualGroupsByBucket.

func (*MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP(ctx, spID any, opts ...any) *gomock.Call

ListGlobalVirtualGroupsBySecondarySP indicates an expected call of ListGlobalVirtualGroupsBySecondarySP.

func (*MockGfSpClientAPIMockRecorder) ListGroupsByIDs added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) ListGroupsByIDs(ctx, groupIDs any, opts ...any) *gomock.Call

ListGroupsByIDs indicates an expected call of ListGroupsByIDs.

func (*MockGfSpClientAPIMockRecorder) ListMigrateBucketEvents added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListMigrateBucketEvents(ctx, blockID, spID any, opts ...any) *gomock.Call

ListMigrateBucketEvents indicates an expected call of ListMigrateBucketEvents.

func (*MockGfSpClientAPIMockRecorder) ListObjectPolicies added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) ListObjectPolicies(ctx, objectName, bucketName, startAfter, actionType, limit any, opts ...any) *gomock.Call

ListObjectPolicies indicates an expected call of ListObjectPolicies.

func (*MockGfSpClientAPIMockRecorder) ListObjectsByBucketName added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListObjectsByBucketName(ctx, bucketName, accountID, maxKeys, startAfter, continuationToken, delimiter, prefix, includeRemoved any, opts ...any) *gomock.Call

ListObjectsByBucketName indicates an expected call of ListObjectsByBucketName.

func (*MockGfSpClientAPIMockRecorder) ListObjectsByGVGAndBucketForGC added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListObjectsByGVGAndBucketForGC(ctx, gvgID, bucketID, startAfter, limit any, opts ...any) *gomock.Call

ListObjectsByGVGAndBucketForGC indicates an expected call of ListObjectsByGVGAndBucketForGC.

func (*MockGfSpClientAPIMockRecorder) ListObjectsByIDs added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListObjectsByIDs(ctx, objectIDs, includeRemoved any, opts ...any) *gomock.Call

ListObjectsByIDs indicates an expected call of ListObjectsByIDs.

func (*MockGfSpClientAPIMockRecorder) ListObjectsInGVG added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListObjectsInGVG(ctx, gvgID, startAfter, limit any, opts ...any) *gomock.Call

ListObjectsInGVG indicates an expected call of ListObjectsInGVG.

func (*MockGfSpClientAPIMockRecorder) ListObjectsInGVGAndBucket added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListObjectsInGVGAndBucket(ctx, gvgID, bucketID, startAfter, limit any, opts ...any) *gomock.Call

ListObjectsInGVGAndBucket indicates an expected call of ListObjectsInGVGAndBucket.

func (*MockGfSpClientAPIMockRecorder) ListPaymentAccountStreams added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) ListPaymentAccountStreams(ctx, paymentAccount any, opts ...any) *gomock.Call

ListPaymentAccountStreams indicates an expected call of ListPaymentAccountStreams.

func (*MockGfSpClientAPIMockRecorder) ListSpExitEvents added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListSpExitEvents(ctx, blockID, spID any, opts ...any) *gomock.Call

ListSpExitEvents indicates an expected call of ListSpExitEvents.

func (*MockGfSpClientAPIMockRecorder) ListSwapOutEvents added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListSwapOutEvents(ctx, blockID, spID any, opts ...any) *gomock.Call

ListSwapOutEvents indicates an expected call of ListSwapOutEvents.

func (*MockGfSpClientAPIMockRecorder) ListUserPaymentAccounts added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) ListUserPaymentAccounts(ctx, accountID any, opts ...any) *gomock.Call

ListUserPaymentAccounts indicates an expected call of ListUserPaymentAccounts.

func (*MockGfSpClientAPIMockRecorder) ListVirtualGroupFamiliesSpID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListVirtualGroupFamiliesSpID(ctx, spID any, opts ...any) *gomock.Call

ListVirtualGroupFamiliesSpID indicates an expected call of ListVirtualGroupFamiliesSpID.

func (*MockGfSpClientAPIMockRecorder) ManagerConn added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ManagerConn(ctx any, opts ...any) *gomock.Call

ManagerConn indicates an expected call of ManagerConn.

func (*MockGfSpClientAPIMockRecorder) MigratePiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) MigratePiece(ctx, gvgTask, pieceTask any) *gomock.Call

MigratePiece indicates an expected call of MigratePiece.

func (*MockGfSpClientAPIMockRecorder) NotifyDestSPMigrateSwapOut added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) NotifyDestSPMigrateSwapOut(ctx, destEndpoint, swapOut any) *gomock.Call

NotifyDestSPMigrateSwapOut indicates an expected call of NotifyDestSPMigrateSwapOut.

func (*MockGfSpClientAPIMockRecorder) NotifyMigrateSwapOut added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) NotifyMigrateSwapOut(ctx, swapOut any) *gomock.Call

NotifyMigrateSwapOut indicates an expected call of NotifyMigrateSwapOut.

func (*MockGfSpClientAPIMockRecorder) NotifyPostMigrateBucketAndRecoupQuota added in v1.3.0 

func (mr *MockGfSpClientAPIMockRecorder) NotifyPostMigrateBucketAndRecoupQuota(ctx, bmInfo any) *gomock.Call

NotifyPostMigrateBucketAndRecoupQuota indicates an expected call of NotifyPostMigrateBucketAndRecoupQuota.

func (*MockGfSpClientAPIMockRecorder) NotifyPreMigrateBucketAndDeductQuota added in v1.3.0 

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

NotifyPreMigrateBucketAndDeductQuota indicates an expected call of NotifyPreMigrateBucketAndDeductQuota.

func (*MockGfSpClientAPIMockRecorder) P2PConn added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) P2PConn(ctx any, opts ...any) *gomock.Call

P2PConn indicates an expected call of P2PConn.

func (*MockGfSpClientAPIMockRecorder) PickVirtualGroupFamilyID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) PickVirtualGroupFamilyID(ctx, task any) *gomock.Call

PickVirtualGroupFamilyID indicates an expected call of PickVirtualGroupFamilyID.

func (*MockGfSpClientAPIMockRecorder) PostMigrateBucket added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) PostMigrateBucket(ctx, srcSPEndpoint, postMsg any) *gomock.Call

PostMigrateBucket indicates an expected call of PostMigrateBucket.

func (*MockGfSpClientAPIMockRecorder) PreMigrateBucket added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) PreMigrateBucket(ctx, srcSPEndpoint, preMsg any) *gomock.Call

PreMigrateBucket indicates an expected call of PreMigrateBucket.

func (*MockGfSpClientAPIMockRecorder) PrimarySpIncomeDetails added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) PrimarySpIncomeDetails(ctx, spID any, opts ...any) *gomock.Call

PrimarySpIncomeDetails indicates an expected call of PrimarySpIncomeDetails.

func (*MockGfSpClientAPIMockRecorder) QueryBucketMigrate added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QueryBucketMigrate(ctx, endpoint any, opts ...any) *gomock.Call

QueryBucketMigrate indicates an expected call of QueryBucketMigrate.

func (*MockGfSpClientAPIMockRecorder) QueryLatestBucketQuota added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) QueryLatestBucketQuota(ctx, endpoint, queryMsg any) *gomock.Call

QueryLatestBucketQuota indicates an expected call of QueryLatestBucketQuota.

func (*MockGfSpClientAPIMockRecorder) QueryP2PBootstrap added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QueryP2PBootstrap(ctx any) *gomock.Call

QueryP2PBootstrap indicates an expected call of QueryP2PBootstrap.

func (*MockGfSpClientAPIMockRecorder) QuerySPExit added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QuerySPExit(ctx, endpoint any, opts ...any) *gomock.Call

QuerySPExit indicates an expected call of QuerySPExit.

func (*MockGfSpClientAPIMockRecorder) QuerySPHasEnoughQuotaForMigrateBucket added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) QuerySPHasEnoughQuotaForMigrateBucket(ctx, srcSPEndpoint, queryMsg any) *gomock.Call

QuerySPHasEnoughQuotaForMigrateBucket indicates an expected call of QuerySPHasEnoughQuotaForMigrateBucket.

func (*MockGfSpClientAPIMockRecorder) QueryTasks added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QueryTasks(ctx, endpoint, subKey any, opts ...any) *gomock.Call

QueryTasks indicates an expected call of QueryTasks.

func (*MockGfSpClientAPIMockRecorder) RecoupQuota added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) RecoupQuota(ctx, bucketID, extraQuota, yearMonth any, opts ...any) *gomock.Call

RecoupQuota indicates an expected call of RecoupQuota.

func (*MockGfSpClientAPIMockRecorder) RejectMigrateBucket added in v1.1.0 

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

RejectMigrateBucket indicates an expected call of RejectMigrateBucket.

func (*MockGfSpClientAPIMockRecorder) RejectUnSealObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) RejectUnSealObject(ctx, object any) *gomock.Call

RejectUnSealObject indicates an expected call of RejectUnSealObject.

func (*MockGfSpClientAPIMockRecorder) ReplicatePiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ReplicatePiece(ctx, task, data any, opts ...any) *gomock.Call

ReplicatePiece indicates an expected call of ReplicatePiece.

func (*MockGfSpClientAPIMockRecorder) ReplicatePieceToSecondary added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ReplicatePieceToSecondary(ctx, endpoint, receive, data any) *gomock.Call

ReplicatePieceToSecondary indicates an expected call of ReplicatePieceToSecondary.

func (*MockGfSpClientAPIMockRecorder) ReportTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ReportTask(ctx, report any) *gomock.Call

ReportTask indicates an expected call of ReportTask.

func (*MockGfSpClientAPIMockRecorder) ReserveSwapIn added in v1.3.0 

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

ReserveSwapIn indicates an expected call of ReserveSwapIn.

func (*MockGfSpClientAPIMockRecorder) ResumableUploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ResumableUploadObject(ctx, task, stream any, opts ...any) *gomock.Call

ResumableUploadObject indicates an expected call of ResumableUploadObject.

func (*MockGfSpClientAPIMockRecorder) SPExit added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SPExit(ctx, spExit any) *gomock.Call

SPExit indicates an expected call of SPExit.

func (*MockGfSpClientAPIMockRecorder) SealObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SealObject(ctx, object any) *gomock.Call

SealObject indicates an expected call of SealObject.

func (*MockGfSpClientAPIMockRecorder) SealObjectV2 added in v1.6.0 

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

SealObjectV2 indicates an expected call of SealObjectV2.

func (*MockGfSpClientAPIMockRecorder) SecondarySpIncomeDetails added in v1.1.0 

func (mr *MockGfSpClientAPIMockRecorder) SecondarySpIncomeDetails(ctx, spID any, opts ...any) *gomock.Call

SecondarySpIncomeDetails indicates an expected call of SecondarySpIncomeDetails.

func (*MockGfSpClientAPIMockRecorder) SignBucketMigrationInfo added in v1.1.0 

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

SignBucketMigrationInfo indicates an expected call of SignBucketMigrationInfo.

func (*MockGfSpClientAPIMockRecorder) SignCreateBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignCreateBucketApproval(ctx, bucket any) *gomock.Call

SignCreateBucketApproval indicates an expected call of SignCreateBucketApproval.

func (*MockGfSpClientAPIMockRecorder) SignCreateObjectApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignCreateObjectApproval(ctx, object any) *gomock.Call

SignCreateObjectApproval indicates an expected call of SignCreateObjectApproval.

func (*MockGfSpClientAPIMockRecorder) SignMigrateBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignMigrateBucketApproval(ctx, bucket any) *gomock.Call

SignMigrateBucketApproval indicates an expected call of SignMigrateBucketApproval.

func (*MockGfSpClientAPIMockRecorder) SignMigrateGVG added in v0.2.6 

func (mr *MockGfSpClientAPIMockRecorder) SignMigrateGVG(ctx, task any) *gomock.Call

SignMigrateGVG indicates an expected call of SignMigrateGVG.

func (*MockGfSpClientAPIMockRecorder) SignP2PPingMsg added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignP2PPingMsg(ctx, ping any) *gomock.Call

SignP2PPingMsg indicates an expected call of SignP2PPingMsg.

func (*MockGfSpClientAPIMockRecorder) SignP2PPongMsg added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignP2PPongMsg(ctx, pong any) *gomock.Call

SignP2PPongMsg indicates an expected call of SignP2PPongMsg.

func (*MockGfSpClientAPIMockRecorder) SignReceiveTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignReceiveTask(ctx, receiveTask any) *gomock.Call

SignReceiveTask indicates an expected call of SignReceiveTask.

func (*MockGfSpClientAPIMockRecorder) SignRecoveryTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignRecoveryTask(ctx, recoveryTask any) *gomock.Call

SignRecoveryTask indicates an expected call of SignRecoveryTask.

func (*MockGfSpClientAPIMockRecorder) SignReplicatePieceApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignReplicatePieceApproval(ctx, task any) *gomock.Call

SignReplicatePieceApproval indicates an expected call of SignReplicatePieceApproval.

func (*MockGfSpClientAPIMockRecorder) SignSecondarySPMigrationBucket added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignSecondarySPMigrationBucket(ctx, signDoc any) *gomock.Call

SignSecondarySPMigrationBucket indicates an expected call of SignSecondarySPMigrationBucket.

func (*MockGfSpClientAPIMockRecorder) SignSecondarySealBls added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignSecondarySealBls(ctx, objectID, gvgId, checksums any) *gomock.Call

SignSecondarySealBls indicates an expected call of SignSecondarySealBls.

func (*MockGfSpClientAPIMockRecorder) SignSwapOut added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignSwapOut(ctx, swapOut any) *gomock.Call

SignSwapOut indicates an expected call of SignSwapOut.

func (*MockGfSpClientAPIMockRecorder) SignerConn added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignerConn(ctx any, opts ...any) *gomock.Call

SignerConn indicates an expected call of SignerConn.

func (*MockGfSpClientAPIMockRecorder) SwapOut added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SwapOut(ctx, swapOut any) *gomock.Call

SwapOut indicates an expected call of SwapOut.

func (*MockGfSpClientAPIMockRecorder) UpdateSPPrice added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) UpdateSPPrice(ctx, price any) *gomock.Call

UpdateSPPrice indicates an expected call of UpdateSPPrice.

func (*MockGfSpClientAPIMockRecorder) UpdateUserPublicKey added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) UpdateUserPublicKey(ctx, account, domain, currentNonce, nonce, userPublicKey, expiryDate any, opts ...any) *gomock.Call

UpdateUserPublicKey indicates an expected call of UpdateUserPublicKey.

func (*MockGfSpClientAPIMockRecorder) UpdateUserPublicKeyV2 added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) UpdateUserPublicKeyV2(ctx, account, domain, userPublicKey, expiryDate any, opts ...any) *gomock.Call

UpdateUserPublicKeyV2 indicates an expected call of UpdateUserPublicKeyV2.

func (*MockGfSpClientAPIMockRecorder) UploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) UploadObject(ctx, task, stream any, opts ...any) *gomock.Call

UploadObject indicates an expected call of UploadObject.

func (*MockGfSpClientAPIMockRecorder) VerifyAuthentication added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) VerifyAuthentication(ctx, auth, account, bucket, object any, opts ...any) *gomock.Call

VerifyAuthentication indicates an expected call of VerifyAuthentication.

func (*MockGfSpClientAPIMockRecorder) VerifyGNFD1EddsaSignature added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) VerifyGNFD1EddsaSignature(ctx, account, domain, offChainSig, realMsgToSign any, opts ...any) *gomock.Call

VerifyGNFD1EddsaSignature indicates an expected call of VerifyGNFD1EddsaSignature.

func (*MockGfSpClientAPIMockRecorder) VerifyGNFD2EddsaSignature added in v1.6.0 

func (mr *MockGfSpClientAPIMockRecorder) VerifyGNFD2EddsaSignature(ctx, account, domain, userPublicKey, offChainSig, realMsgToSign any, opts ...any) *gomock.Call

VerifyGNFD2EddsaSignature indicates an expected call of VerifyGNFD2EddsaSignature.

func (*MockGfSpClientAPIMockRecorder) VerifyMigrateGVGPermission added in v0.2.6 

func (mr *MockGfSpClientAPIMockRecorder) VerifyMigrateGVGPermission(ctx, bucketID, gvgID, dstSpID any, opts ...any) *gomock.Call

VerifyMigrateGVGPermission indicates an expected call of VerifyMigrateGVGPermission.

func (*MockGfSpClientAPIMockRecorder) VerifyPermission added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) VerifyPermission(ctx, Operator, bucketName, objectName, actionType any, opts ...any) *gomock.Call

VerifyPermission indicates an expected call of VerifyPermission.

func (*MockGfSpClientAPIMockRecorder) VerifyPermissionByID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) VerifyPermissionByID(ctx, Operator, resourceType, resourceID, actionType any, opts ...any) *gomock.Call

VerifyPermissionByID indicates an expected call of VerifyPermissionByID.

type MockGfSpConnAPI added in v0.2.4 

type MockGfSpConnAPI struct {
	// contains filtered or unexported fields
}

MockGfSpConnAPI is a mock of GfSpConnAPI interface.

func NewMockGfSpConnAPI added in v0.2.4 

func NewMockGfSpConnAPI(ctrl *gomock.Controller) *MockGfSpConnAPI

NewMockGfSpConnAPI creates a new mock instance.

func (*MockGfSpConnAPI) ApproverConn added in v0.2.4 

func (m *MockGfSpConnAPI) ApproverConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

ApproverConn mocks base method.

func (*MockGfSpConnAPI) Close added in v0.2.4 

func (m *MockGfSpConnAPI) Close() error

Close mocks base method.

func (*MockGfSpConnAPI) Connection added in v0.2.4 

func (m *MockGfSpConnAPI) Connection(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

Connection mocks base method.

func (*MockGfSpConnAPI) EXPECT added in v0.2.4 

func (m *MockGfSpConnAPI) EXPECT() *MockGfSpConnAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockGfSpConnAPI) HTTPClient added in v0.2.4 

func (m *MockGfSpConnAPI) HTTPClient(ctx context.Context) *http.Client

HTTPClient mocks base method.

func (*MockGfSpConnAPI) ManagerConn added in v0.2.4 

func (m *MockGfSpConnAPI) ManagerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

ManagerConn mocks base method.

func (*MockGfSpConnAPI) P2PConn added in v0.2.4 

func (m *MockGfSpConnAPI) P2PConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

P2PConn mocks base method.

func (*MockGfSpConnAPI) SignerConn added in v0.2.4 

func (m *MockGfSpConnAPI) SignerConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

SignerConn mocks base method.

type MockGfSpConnAPIMockRecorder added in v0.2.4 

type MockGfSpConnAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockGfSpConnAPIMockRecorder is the mock recorder for MockGfSpConnAPI.

func (*MockGfSpConnAPIMockRecorder) ApproverConn added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) ApproverConn(ctx any, opts ...any) *gomock.Call

ApproverConn indicates an expected call of ApproverConn.

func (*MockGfSpConnAPIMockRecorder) Close added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockGfSpConnAPIMockRecorder) Connection added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) Connection(ctx, address any, opts ...any) *gomock.Call

Connection indicates an expected call of Connection.

func (*MockGfSpConnAPIMockRecorder) HTTPClient added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) HTTPClient(ctx any) *gomock.Call

HTTPClient indicates an expected call of HTTPClient.

func (*MockGfSpConnAPIMockRecorder) ManagerConn added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) ManagerConn(ctx any, opts ...any) *gomock.Call

ManagerConn indicates an expected call of ManagerConn.

func (*MockGfSpConnAPIMockRecorder) P2PConn added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) P2PConn(ctx any, opts ...any) *gomock.Call

P2PConn indicates an expected call of P2PConn.

func (*MockGfSpConnAPIMockRecorder) SignerConn added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) SignerConn(ctx any, opts ...any) *gomock.Call

SignerConn indicates an expected call of SignerConn.

type MockManagerAPI added in v0.2.4 

type MockManagerAPI struct {
	// contains filtered or unexported fields
}

MockManagerAPI is a mock of ManagerAPI interface.

func NewMockManagerAPI added in v0.2.4 

func NewMockManagerAPI(ctrl *gomock.Controller) *MockManagerAPI

NewMockManagerAPI creates a new mock instance.

func (*MockManagerAPI) AskTask added in v0.2.4 

func (m *MockManagerAPI) AskTask(ctx context.Context, limit rcmgr.Limit) (task.Task, error)

AskTask mocks base method.

func (*MockManagerAPI) CreateResumableUploadObject added in v0.2.4 

func (m *MockManagerAPI) CreateResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask) error

CreateResumableUploadObject mocks base method.

func (*MockManagerAPI) CreateUploadObject added in v0.2.4 

func (m *MockManagerAPI) CreateUploadObject(ctx context.Context, task task.UploadObjectTask) error

CreateUploadObject mocks base method.

func (*MockManagerAPI) EXPECT added in v0.2.4 

func (m *MockManagerAPI) EXPECT() *MockManagerAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockManagerAPI) GetMigrateBucketProgress added in v1.3.0 

func (m *MockManagerAPI) GetMigrateBucketProgress(ctx context.Context, bucketID uint64) (*gfspserver.MigrateBucketProgressMeta, error)

GetMigrateBucketProgress mocks base method.

func (*MockManagerAPI) GetTasksStats added in v0.2.6 

func (m *MockManagerAPI) GetTasksStats(ctx context.Context) (*gfspserver.TasksStats, error)

GetTasksStats mocks base method.

func (*MockManagerAPI) NotifyMigrateSwapOut added in v0.2.4 

func (m *MockManagerAPI) NotifyMigrateSwapOut(ctx context.Context, swapOut *types4.MsgSwapOut) error

NotifyMigrateSwapOut mocks base method.

func (*MockManagerAPI) NotifyPostMigrateBucketAndRecoupQuota added in v1.3.0 

func (m *MockManagerAPI) NotifyPostMigrateBucketAndRecoupQuota(ctx context.Context, bmInfo *gfsptask.GfSpBucketMigrationInfo) (*gfsptask.GfSpBucketQuotaInfo, error)

NotifyPostMigrateBucketAndRecoupQuota mocks base method.

func (*MockManagerAPI) NotifyPreMigrateBucketAndDeductQuota added in v1.3.0 

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

NotifyPreMigrateBucketAndDeductQuota mocks base method.

func (*MockManagerAPI) PickVirtualGroupFamilyID added in v0.2.4 

func (m *MockManagerAPI) PickVirtualGroupFamilyID(ctx context.Context, task task.ApprovalCreateBucketTask) (uint32, error)

PickVirtualGroupFamilyID mocks base method.

func (*MockManagerAPI) ReportTask added in v0.2.4 

func (m *MockManagerAPI) ReportTask(ctx context.Context, report task.Task) error

ReportTask mocks base method.

type MockManagerAPIMockRecorder added in v0.2.4 

type MockManagerAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockManagerAPIMockRecorder is the mock recorder for MockManagerAPI.

func (*MockManagerAPIMockRecorder) AskTask added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) AskTask(ctx, limit any) *gomock.Call

AskTask indicates an expected call of AskTask.

func (*MockManagerAPIMockRecorder) CreateResumableUploadObject added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) CreateResumableUploadObject(ctx, task any) *gomock.Call

CreateResumableUploadObject indicates an expected call of CreateResumableUploadObject.

func (*MockManagerAPIMockRecorder) CreateUploadObject added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) CreateUploadObject(ctx, task any) *gomock.Call

CreateUploadObject indicates an expected call of CreateUploadObject.

func (*MockManagerAPIMockRecorder) GetMigrateBucketProgress added in v1.3.0 

func (mr *MockManagerAPIMockRecorder) GetMigrateBucketProgress(ctx, bucketID any) *gomock.Call

GetMigrateBucketProgress indicates an expected call of GetMigrateBucketProgress.

func (*MockManagerAPIMockRecorder) GetTasksStats added in v0.2.6 

func (mr *MockManagerAPIMockRecorder) GetTasksStats(ctx any) *gomock.Call

GetTasksStats indicates an expected call of GetTasksStats.

func (*MockManagerAPIMockRecorder) NotifyMigrateSwapOut added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) NotifyMigrateSwapOut(ctx, swapOut any) *gomock.Call

NotifyMigrateSwapOut indicates an expected call of NotifyMigrateSwapOut.

func (*MockManagerAPIMockRecorder) NotifyPostMigrateBucketAndRecoupQuota added in v1.3.0 

func (mr *MockManagerAPIMockRecorder) NotifyPostMigrateBucketAndRecoupQuota(ctx, bmInfo any) *gomock.Call

NotifyPostMigrateBucketAndRecoupQuota indicates an expected call of NotifyPostMigrateBucketAndRecoupQuota.

func (*MockManagerAPIMockRecorder) NotifyPreMigrateBucketAndDeductQuota added in v1.3.0 

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

NotifyPreMigrateBucketAndDeductQuota indicates an expected call of NotifyPreMigrateBucketAndDeductQuota.

func (*MockManagerAPIMockRecorder) PickVirtualGroupFamilyID added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) PickVirtualGroupFamilyID(ctx, task any) *gomock.Call

PickVirtualGroupFamilyID indicates an expected call of PickVirtualGroupFamilyID.

func (*MockManagerAPIMockRecorder) ReportTask added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) ReportTask(ctx, report any) *gomock.Call

ReportTask indicates an expected call of ReportTask.

type MockMetadataAPI added in v0.2.4 

type MockMetadataAPI struct {
	// contains filtered or unexported fields
}

MockMetadataAPI is a mock of MetadataAPI interface.

func NewMockMetadataAPI added in v0.2.4 

func NewMockMetadataAPI(ctrl *gomock.Controller) *MockMetadataAPI

NewMockMetadataAPI creates a new mock instance.

func (*MockMetadataAPI) EXPECT added in v0.2.4 

func (m *MockMetadataAPI) EXPECT() *MockMetadataAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetadataAPI) GetBucketByBucketID added in v0.2.4 

func (m *MockMetadataAPI) GetBucketByBucketID(ctx context.Context, bucketID int64, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketByBucketID mocks base method.

func (*MockMetadataAPI) GetBucketByBucketName added in v0.2.4 

func (m *MockMetadataAPI) GetBucketByBucketName(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketByBucketName mocks base method.

func (*MockMetadataAPI) GetBucketInfoByBucketName added in v1.5.0 

func (m *MockMetadataAPI) GetBucketInfoByBucketName(ctx context.Context, bucketName string, opts ...grpc.DialOption) (*types.Bucket, error)

GetBucketInfoByBucketName mocks base method.

func (*MockMetadataAPI) GetBucketMeta added in v0.2.4 

func (m *MockMetadataAPI) GetBucketMeta(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.VGFInfoBucket, *types0.StreamRecord, error)

GetBucketMeta mocks base method.

func (*MockMetadataAPI) GetBucketReadQuota added in v0.2.4 

func (m *MockMetadataAPI) GetBucketReadQuota(ctx context.Context, bucket *types3.BucketInfo, yearMonth string, opts ...grpc.DialOption) (uint64, uint64, uint64, uint64, uint64, uint64, error)

GetBucketReadQuota mocks base method.

func (*MockMetadataAPI) GetBucketReadQuotaCount added in v1.6.0 

func (m *MockMetadataAPI) GetBucketReadQuotaCount(ctx context.Context, yearMonth string, opts ...grpc.DialOption) (int64, error)

GetBucketReadQuotaCount mocks base method.

func (*MockMetadataAPI) GetBucketSize added in v1.1.0 

func (m *MockMetadataAPI) GetBucketSize(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (string, error)

GetBucketSize mocks base method.

func (*MockMetadataAPI) GetEndpointBySpID added in v0.2.4 

func (m *MockMetadataAPI) GetEndpointBySpID(ctx context.Context, spID uint32, opts ...grpc.DialOption) (string, error)

GetEndpointBySpID mocks base method.

func (*MockMetadataAPI) GetGlobalVirtualGroup added in v0.2.4 

func (m *MockMetadataAPI) GetGlobalVirtualGroup(ctx context.Context, bucketID uint64, lvgID uint32, opts ...grpc.DialOption) (*types4.GlobalVirtualGroup, error)

GetGlobalVirtualGroup mocks base method.

func (*MockMetadataAPI) GetGlobalVirtualGroupByGvgID added in v0.2.4 

func (m *MockMetadataAPI) GetGlobalVirtualGroupByGvgID(ctx context.Context, gvgID uint32, opts ...grpc.DialOption) (*types4.GlobalVirtualGroup, error)

GetGlobalVirtualGroupByGvgID mocks base method.

func (*MockMetadataAPI) GetGroupList added in v0.2.4 

func (m *MockMetadataAPI) GetGroupList(ctx context.Context, name, prefix, sourceType string, limit, offset int64, includeRemoved bool, opts ...grpc.DialOption) ([]*types.Group, int64, error)

GetGroupList mocks base method.

func (*MockMetadataAPI) GetGroupMembers added in v0.2.4 

func (m *MockMetadataAPI) GetGroupMembers(ctx context.Context, groupID uint64, startAfter string, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

GetGroupMembers mocks base method.

func (*MockMetadataAPI) GetLatestBucketReadQuota added in v1.1.0 

func (m *MockMetadataAPI) GetLatestBucketReadQuota(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) (*gfsptask.GfSpBucketQuotaInfo, error)

GetLatestBucketReadQuota mocks base method.

func (*MockMetadataAPI) GetLatestObjectID added in v1.2.0 

func (m *MockMetadataAPI) GetLatestObjectID(ctx context.Context, opts ...grpc.DialOption) (uint64, error)

GetLatestObjectID mocks base method.

func (*MockMetadataAPI) GetObjectByID added in v0.2.4 

func (m *MockMetadataAPI) GetObjectByID(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (*types3.ObjectInfo, error)

GetObjectByID mocks base method.

func (*MockMetadataAPI) GetObjectMeta added in v0.2.4 

func (m *MockMetadataAPI) GetObjectMeta(ctx context.Context, objectName, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Object, error)

GetObjectMeta mocks base method.

func (*MockMetadataAPI) GetPaymentByBucketID added in v0.2.4 

func (m *MockMetadataAPI) GetPaymentByBucketID(ctx context.Context, bucketID int64, includePrivate bool, opts ...grpc.DialOption) (*types0.StreamRecord, error)

GetPaymentByBucketID mocks base method.

func (*MockMetadataAPI) GetPaymentByBucketName added in v0.2.4 

func (m *MockMetadataAPI) GetPaymentByBucketName(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types0.StreamRecord, error)

GetPaymentByBucketName mocks base method.

func (*MockMetadataAPI) GetSPInfo added in v0.2.4 

func (m *MockMetadataAPI) GetSPInfo(ctx context.Context, operatorAddress string, opts ...grpc.DialOption) (*types2.StorageProvider, error)

GetSPInfo mocks base method.

func (*MockMetadataAPI) GetSPMigratingBucketNumber added in v0.2.5 

func (m *MockMetadataAPI) GetSPMigratingBucketNumber(ctx context.Context, spID uint32, opts ...grpc.DialOption) (uint64, error)

GetSPMigratingBucketNumber mocks base method.

func (*MockMetadataAPI) GetStatus added in v0.2.4 

func (m *MockMetadataAPI) GetStatus(ctx context.Context, opts ...grpc.DialOption) (*types.Status, error)

GetStatus mocks base method.

func (*MockMetadataAPI) GetUploadObjectSegment added in v0.2.4 

func (m *MockMetadataAPI) GetUploadObjectSegment(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (uint32, error)

GetUploadObjectSegment mocks base method.

func (*MockMetadataAPI) GetUploadObjectState added in v0.2.4 

func (m *MockMetadataAPI) GetUploadObjectState(ctx context.Context, objectID uint64, opts ...grpc.DialOption) (int32, string, error)

GetUploadObjectState mocks base method.

func (*MockMetadataAPI) GetUserBuckets added in v0.2.4 

func (m *MockMetadataAPI) GetUserBuckets(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) ([]*types.VGFInfoBucket, error)

GetUserBuckets mocks base method.

func (*MockMetadataAPI) GetUserBucketsCount added in v0.2.4 

func (m *MockMetadataAPI) GetUserBucketsCount(ctx context.Context, account string, includeRemoved bool, opts ...grpc.DialOption) (int64, error)

GetUserBucketsCount mocks base method.

func (*MockMetadataAPI) GetUserGroups added in v0.2.4 

func (m *MockMetadataAPI) GetUserGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

GetUserGroups mocks base method.

func (*MockMetadataAPI) GetUserOwnedGroups added in v0.2.4 

func (m *MockMetadataAPI) GetUserOwnedGroups(ctx context.Context, accountID string, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.GroupMember, error)

GetUserOwnedGroups mocks base method.

func (*MockMetadataAPI) GetVirtualGroupFamily added in v0.2.4 

func (m *MockMetadataAPI) GetVirtualGroupFamily(ctx context.Context, vgfID uint32, opts ...grpc.DialOption) (*types4.GlobalVirtualGroupFamily, error)

GetVirtualGroupFamily mocks base method.

func (*MockMetadataAPI) ListBucketReadQuota added in v1.6.0 

func (m *MockMetadataAPI) ListBucketReadQuota(ctx context.Context, yearMonth string, offset, limit uint32, opts ...grpc.DialOption) ([]*types.BucketReadQuotaRecord, error)

ListBucketReadQuota mocks base method.

func (*MockMetadataAPI) ListBucketReadRecord added in v0.2.4 

func (m *MockMetadataAPI) ListBucketReadRecord(ctx context.Context, bucket *types3.BucketInfo, startTimestampUs, endTimestampUs, maxRecordNum int64, opts ...grpc.DialOption) ([]*types.ReadRecord, int64, error)

ListBucketReadRecord mocks base method.

func (*MockMetadataAPI) ListBucketsByIDs added in v0.2.4 

func (m *MockMetadataAPI) ListBucketsByIDs(ctx context.Context, bucketIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Bucket, error)

ListBucketsByIDs mocks base method.

func (*MockMetadataAPI) ListCompleteMigrationBucketEvents added in v1.3.0 

func (m *MockMetadataAPI) ListCompleteMigrationBucketEvents(ctx context.Context, blockID uint64, srcSpID uint32, opts ...grpc.DialOption) ([]*types3.EventCompleteMigrationBucket, error)

ListCompleteMigrationBucketEvents mocks base method.

func (*MockMetadataAPI) ListDeletedObjectsByBlockNumberRange added in v0.2.4 

func (m *MockMetadataAPI) ListDeletedObjectsByBlockNumberRange(ctx context.Context, spOperatorAddress string, startBlockNumber, endBlockNumber uint64, includePrivate bool, opts ...grpc.DialOption) ([]*types.Object, uint64, error)

ListDeletedObjectsByBlockNumberRange mocks base method.

func (*MockMetadataAPI) ListExpiredBucketsBySp added in v0.2.4 

func (m *MockMetadataAPI) ListExpiredBucketsBySp(ctx context.Context, createAt int64, primarySpID uint32, limit int64, opts ...grpc.DialOption) ([]*types.Bucket, error)

ListExpiredBucketsBySp mocks base method.

func (*MockMetadataAPI) ListGlobalVirtualGroupsByBucket added in v0.2.4 

func (m *MockMetadataAPI) ListGlobalVirtualGroupsByBucket(ctx context.Context, bucketID uint64, opts ...grpc.DialOption) ([]*types4.GlobalVirtualGroup, error)

ListGlobalVirtualGroupsByBucket mocks base method.

func (*MockMetadataAPI) ListGlobalVirtualGroupsBySecondarySP added in v0.2.4 

func (m *MockMetadataAPI) ListGlobalVirtualGroupsBySecondarySP(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*types4.GlobalVirtualGroup, error)

ListGlobalVirtualGroupsBySecondarySP mocks base method.

func (*MockMetadataAPI) ListGroupsByIDs added in v0.2.5 

func (m *MockMetadataAPI) ListGroupsByIDs(ctx context.Context, groupIDs []uint64, opts ...grpc.DialOption) (map[uint64]*types.Group, error)

ListGroupsByIDs mocks base method.

func (*MockMetadataAPI) ListMigrateBucketEvents added in v0.2.4 

func (m *MockMetadataAPI) ListMigrateBucketEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListMigrateBucketEvents, error)

ListMigrateBucketEvents mocks base method.

func (*MockMetadataAPI) ListObjectPolicies added in v0.2.5 

func (m *MockMetadataAPI) ListObjectPolicies(ctx context.Context, objectName, bucketName string, startAfter uint64, actionType int32, limit uint32, opts ...grpc.DialOption) ([]*types.Policy, error)

ListObjectPolicies mocks base method.

func (*MockMetadataAPI) ListObjectsByBucketName added in v0.2.4 

func (m *MockMetadataAPI) ListObjectsByBucketName(ctx context.Context, bucketName, accountID string, maxKeys uint64, startAfter, continuationToken, delimiter, prefix string, includeRemoved bool, opts ...grpc.DialOption) ([]*types.Object, uint64, uint64, bool, string, string, string, string, []string, string, error)

ListObjectsByBucketName mocks base method.

func (*MockMetadataAPI) ListObjectsByGVGAndBucketForGC added in v0.2.4 

func (m *MockMetadataAPI) ListObjectsByGVGAndBucketForGC(ctx context.Context, gvgID uint32, bucketID, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

ListObjectsByGVGAndBucketForGC mocks base method.

func (*MockMetadataAPI) ListObjectsByIDs added in v0.2.4 

func (m *MockMetadataAPI) ListObjectsByIDs(ctx context.Context, objectIDs []uint64, includeRemoved bool, opts ...grpc.DialOption) (map[uint64]*types.Object, error)

ListObjectsByIDs mocks base method.

func (*MockMetadataAPI) ListObjectsInGVG added in v0.2.4 

func (m *MockMetadataAPI) ListObjectsInGVG(ctx context.Context, gvgID uint32, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

ListObjectsInGVG mocks base method.

func (*MockMetadataAPI) ListObjectsInGVGAndBucket added in v0.2.4 

func (m *MockMetadataAPI) ListObjectsInGVGAndBucket(ctx context.Context, gvgID uint32, bucketID, startAfter uint64, limit uint32, opts ...grpc.DialOption) ([]*types.ObjectDetails, error)

ListObjectsInGVGAndBucket mocks base method.

func (*MockMetadataAPI) ListPaymentAccountStreams added in v0.2.5 

func (m *MockMetadataAPI) ListPaymentAccountStreams(ctx context.Context, paymentAccount string, opts ...grpc.DialOption) ([]*types.Bucket, error)

ListPaymentAccountStreams mocks base method.

func (*MockMetadataAPI) ListSpExitEvents added in v0.2.4 

func (m *MockMetadataAPI) ListSpExitEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) (*types.ListSpExitEvents, error)

ListSpExitEvents mocks base method.

func (*MockMetadataAPI) ListSwapOutEvents added in v0.2.4 

func (m *MockMetadataAPI) ListSwapOutEvents(ctx context.Context, blockID uint64, spID uint32, opts ...grpc.DialOption) ([]*types.ListSwapOutEvents, error)

ListSwapOutEvents mocks base method.

func (*MockMetadataAPI) ListUserPaymentAccounts added in v0.2.5 

func (m *MockMetadataAPI) ListUserPaymentAccounts(ctx context.Context, accountID string, opts ...grpc.DialOption) ([]*types.PaymentAccountMeta, error)

ListUserPaymentAccounts mocks base method.

func (*MockMetadataAPI) ListVirtualGroupFamiliesSpID added in v0.2.4 

func (m *MockMetadataAPI) ListVirtualGroupFamiliesSpID(ctx context.Context, spID uint32, opts ...grpc.DialOption) ([]*types4.GlobalVirtualGroupFamily, error)

ListVirtualGroupFamiliesSpID mocks base method.

func (*MockMetadataAPI) PrimarySpIncomeDetails added in v1.1.0 

func (m *MockMetadataAPI) PrimarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.PrimarySpIncomeDetail, error)

PrimarySpIncomeDetails mocks base method.

func (*MockMetadataAPI) SecondarySpIncomeDetails added in v1.1.0 

func (m *MockMetadataAPI) SecondarySpIncomeDetails(ctx context.Context, spID uint32, opts ...grpc.DialOption) (int64, []*types.SecondarySpIncomeDetail, error)

SecondarySpIncomeDetails mocks base method.

func (*MockMetadataAPI) VerifyMigrateGVGPermission added in v0.2.6 

func (m *MockMetadataAPI) VerifyMigrateGVGPermission(ctx context.Context, bucketID uint64, gvgID, dstSpID uint32, opts ...grpc.DialOption) (*types1.Effect, error)

VerifyMigrateGVGPermission mocks base method.

func (*MockMetadataAPI) VerifyPermission added in v0.2.4 

func (m *MockMetadataAPI) VerifyPermission(ctx context.Context, Operator, bucketName, objectName string, actionType types1.ActionType, opts ...grpc.DialOption) (*types1.Effect, error)

VerifyPermission mocks base method.

func (*MockMetadataAPI) VerifyPermissionByID added in v0.2.4 

func (m *MockMetadataAPI) VerifyPermissionByID(ctx context.Context, Operator string, resourceType resource.ResourceType, resourceID uint64, actionType types1.ActionType, opts ...grpc.DialOption) (*types1.Effect, error)

VerifyPermissionByID mocks base method.

type MockMetadataAPIMockRecorder added in v0.2.4 

type MockMetadataAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockMetadataAPIMockRecorder is the mock recorder for MockMetadataAPI.

func (*MockMetadataAPIMockRecorder) GetBucketByBucketID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetBucketByBucketID(ctx, bucketID, includePrivate any, opts ...any) *gomock.Call

GetBucketByBucketID indicates an expected call of GetBucketByBucketID.

func (*MockMetadataAPIMockRecorder) GetBucketByBucketName added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetBucketByBucketName(ctx, bucketName, includePrivate any, opts ...any) *gomock.Call

GetBucketByBucketName indicates an expected call of GetBucketByBucketName.

func (*MockMetadataAPIMockRecorder) GetBucketInfoByBucketName added in v1.5.0 

func (mr *MockMetadataAPIMockRecorder) GetBucketInfoByBucketName(ctx, bucketName any, opts ...any) *gomock.Call

GetBucketInfoByBucketName indicates an expected call of GetBucketInfoByBucketName.

func (*MockMetadataAPIMockRecorder) GetBucketMeta added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetBucketMeta(ctx, bucketName, includePrivate any, opts ...any) *gomock.Call

GetBucketMeta indicates an expected call of GetBucketMeta.

func (*MockMetadataAPIMockRecorder) GetBucketReadQuota added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetBucketReadQuota(ctx, bucket, yearMonth any, opts ...any) *gomock.Call

GetBucketReadQuota indicates an expected call of GetBucketReadQuota.

func (*MockMetadataAPIMockRecorder) GetBucketReadQuotaCount added in v1.6.0 

func (mr *MockMetadataAPIMockRecorder) GetBucketReadQuotaCount(ctx, yearMonth any, opts ...any) *gomock.Call

GetBucketReadQuotaCount indicates an expected call of GetBucketReadQuotaCount.

func (*MockMetadataAPIMockRecorder) GetBucketSize added in v1.1.0 

func (mr *MockMetadataAPIMockRecorder) GetBucketSize(ctx, bucketID any, opts ...any) *gomock.Call

GetBucketSize indicates an expected call of GetBucketSize.

func (*MockMetadataAPIMockRecorder) GetEndpointBySpID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetEndpointBySpID(ctx, spID any, opts ...any) *gomock.Call

GetEndpointBySpID indicates an expected call of GetEndpointBySpID.

func (*MockMetadataAPIMockRecorder) GetGlobalVirtualGroup added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetGlobalVirtualGroup(ctx, bucketID, lvgID any, opts ...any) *gomock.Call

GetGlobalVirtualGroup indicates an expected call of GetGlobalVirtualGroup.

func (*MockMetadataAPIMockRecorder) GetGlobalVirtualGroupByGvgID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetGlobalVirtualGroupByGvgID(ctx, gvgID any, opts ...any) *gomock.Call

GetGlobalVirtualGroupByGvgID indicates an expected call of GetGlobalVirtualGroupByGvgID.

func (*MockMetadataAPIMockRecorder) GetGroupList added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetGroupList(ctx, name, prefix, sourceType, limit, offset, includeRemoved any, opts ...any) *gomock.Call

GetGroupList indicates an expected call of GetGroupList.

func (*MockMetadataAPIMockRecorder) GetGroupMembers added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetGroupMembers(ctx, groupID, startAfter, limit any, opts ...any) *gomock.Call

GetGroupMembers indicates an expected call of GetGroupMembers.

func (*MockMetadataAPIMockRecorder) GetLatestBucketReadQuota added in v1.1.0 

func (mr *MockMetadataAPIMockRecorder) GetLatestBucketReadQuota(ctx, bucketID any, opts ...any) *gomock.Call

GetLatestBucketReadQuota indicates an expected call of GetLatestBucketReadQuota.

func (*MockMetadataAPIMockRecorder) GetLatestObjectID added in v1.2.0 

func (mr *MockMetadataAPIMockRecorder) GetLatestObjectID(ctx any, opts ...any) *gomock.Call

GetLatestObjectID indicates an expected call of GetLatestObjectID.

func (*MockMetadataAPIMockRecorder) GetObjectByID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetObjectByID(ctx, objectID any, opts ...any) *gomock.Call

GetObjectByID indicates an expected call of GetObjectByID.

func (*MockMetadataAPIMockRecorder) GetObjectMeta added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetObjectMeta(ctx, objectName, bucketName, includePrivate any, opts ...any) *gomock.Call

GetObjectMeta indicates an expected call of GetObjectMeta.

func (*MockMetadataAPIMockRecorder) GetPaymentByBucketID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetPaymentByBucketID(ctx, bucketID, includePrivate any, opts ...any) *gomock.Call

GetPaymentByBucketID indicates an expected call of GetPaymentByBucketID.

func (*MockMetadataAPIMockRecorder) GetPaymentByBucketName added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetPaymentByBucketName(ctx, bucketName, includePrivate any, opts ...any) *gomock.Call

GetPaymentByBucketName indicates an expected call of GetPaymentByBucketName.

func (*MockMetadataAPIMockRecorder) GetSPInfo added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetSPInfo(ctx, operatorAddress any, opts ...any) *gomock.Call

GetSPInfo indicates an expected call of GetSPInfo.

func (*MockMetadataAPIMockRecorder) GetSPMigratingBucketNumber added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) GetSPMigratingBucketNumber(ctx, spID any, opts ...any) *gomock.Call

GetSPMigratingBucketNumber indicates an expected call of GetSPMigratingBucketNumber.

func (*MockMetadataAPIMockRecorder) GetStatus added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetStatus(ctx any, opts ...any) *gomock.Call

GetStatus indicates an expected call of GetStatus.

func (*MockMetadataAPIMockRecorder) GetUploadObjectSegment added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUploadObjectSegment(ctx, objectID any, opts ...any) *gomock.Call

GetUploadObjectSegment indicates an expected call of GetUploadObjectSegment.

func (*MockMetadataAPIMockRecorder) GetUploadObjectState added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUploadObjectState(ctx, objectID any, opts ...any) *gomock.Call

GetUploadObjectState indicates an expected call of GetUploadObjectState.

func (*MockMetadataAPIMockRecorder) GetUserBuckets added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUserBuckets(ctx, account, includeRemoved any, opts ...any) *gomock.Call

GetUserBuckets indicates an expected call of GetUserBuckets.

func (*MockMetadataAPIMockRecorder) GetUserBucketsCount added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUserBucketsCount(ctx, account, includeRemoved any, opts ...any) *gomock.Call

GetUserBucketsCount indicates an expected call of GetUserBucketsCount.

func (*MockMetadataAPIMockRecorder) GetUserGroups added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUserGroups(ctx, accountID, startAfter, limit any, opts ...any) *gomock.Call

GetUserGroups indicates an expected call of GetUserGroups.

func (*MockMetadataAPIMockRecorder) GetUserOwnedGroups added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUserOwnedGroups(ctx, accountID, startAfter, limit any, opts ...any) *gomock.Call

GetUserOwnedGroups indicates an expected call of GetUserOwnedGroups.

func (*MockMetadataAPIMockRecorder) GetVirtualGroupFamily added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetVirtualGroupFamily(ctx, vgfID any, opts ...any) *gomock.Call

GetVirtualGroupFamily indicates an expected call of GetVirtualGroupFamily.

func (*MockMetadataAPIMockRecorder) ListBucketReadQuota added in v1.6.0 

func (mr *MockMetadataAPIMockRecorder) ListBucketReadQuota(ctx, yearMonth, offset, limit any, opts ...any) *gomock.Call

ListBucketReadQuota indicates an expected call of ListBucketReadQuota.

func (*MockMetadataAPIMockRecorder) ListBucketReadRecord added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListBucketReadRecord(ctx, bucket, startTimestampUs, endTimestampUs, maxRecordNum any, opts ...any) *gomock.Call

ListBucketReadRecord indicates an expected call of ListBucketReadRecord.

func (*MockMetadataAPIMockRecorder) ListBucketsByIDs added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListBucketsByIDs(ctx, bucketIDs, includeRemoved any, opts ...any) *gomock.Call

ListBucketsByIDs indicates an expected call of ListBucketsByIDs.

func (*MockMetadataAPIMockRecorder) ListCompleteMigrationBucketEvents added in v1.3.0 

func (mr *MockMetadataAPIMockRecorder) ListCompleteMigrationBucketEvents(ctx, blockID, srcSpID any, opts ...any) *gomock.Call

ListCompleteMigrationBucketEvents indicates an expected call of ListCompleteMigrationBucketEvents.

func (*MockMetadataAPIMockRecorder) ListDeletedObjectsByBlockNumberRange added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListDeletedObjectsByBlockNumberRange(ctx, spOperatorAddress, startBlockNumber, endBlockNumber, includePrivate any, opts ...any) *gomock.Call

ListDeletedObjectsByBlockNumberRange indicates an expected call of ListDeletedObjectsByBlockNumberRange.

func (*MockMetadataAPIMockRecorder) ListExpiredBucketsBySp added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListExpiredBucketsBySp(ctx, createAt, primarySpID, limit any, opts ...any) *gomock.Call

ListExpiredBucketsBySp indicates an expected call of ListExpiredBucketsBySp.

func (*MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsByBucket added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsByBucket(ctx, bucketID any, opts ...any) *gomock.Call

ListGlobalVirtualGroupsByBucket indicates an expected call of ListGlobalVirtualGroupsByBucket.

func (*MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP(ctx, spID any, opts ...any) *gomock.Call

ListGlobalVirtualGroupsBySecondarySP indicates an expected call of ListGlobalVirtualGroupsBySecondarySP.

func (*MockMetadataAPIMockRecorder) ListGroupsByIDs added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) ListGroupsByIDs(ctx, groupIDs any, opts ...any) *gomock.Call

ListGroupsByIDs indicates an expected call of ListGroupsByIDs.

func (*MockMetadataAPIMockRecorder) ListMigrateBucketEvents added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListMigrateBucketEvents(ctx, blockID, spID any, opts ...any) *gomock.Call

ListMigrateBucketEvents indicates an expected call of ListMigrateBucketEvents.

func (*MockMetadataAPIMockRecorder) ListObjectPolicies added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) ListObjectPolicies(ctx, objectName, bucketName, startAfter, actionType, limit any, opts ...any) *gomock.Call

ListObjectPolicies indicates an expected call of ListObjectPolicies.

func (*MockMetadataAPIMockRecorder) ListObjectsByBucketName added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListObjectsByBucketName(ctx, bucketName, accountID, maxKeys, startAfter, continuationToken, delimiter, prefix, includeRemoved any, opts ...any) *gomock.Call

ListObjectsByBucketName indicates an expected call of ListObjectsByBucketName.

func (*MockMetadataAPIMockRecorder) ListObjectsByGVGAndBucketForGC added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListObjectsByGVGAndBucketForGC(ctx, gvgID, bucketID, startAfter, limit any, opts ...any) *gomock.Call

ListObjectsByGVGAndBucketForGC indicates an expected call of ListObjectsByGVGAndBucketForGC.

func (*MockMetadataAPIMockRecorder) ListObjectsByIDs added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListObjectsByIDs(ctx, objectIDs, includeRemoved any, opts ...any) *gomock.Call

ListObjectsByIDs indicates an expected call of ListObjectsByIDs.

func (*MockMetadataAPIMockRecorder) ListObjectsInGVG added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListObjectsInGVG(ctx, gvgID, startAfter, limit any, opts ...any) *gomock.Call

ListObjectsInGVG indicates an expected call of ListObjectsInGVG.

func (*MockMetadataAPIMockRecorder) ListObjectsInGVGAndBucket added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListObjectsInGVGAndBucket(ctx, gvgID, bucketID, startAfter, limit any, opts ...any) *gomock.Call

ListObjectsInGVGAndBucket indicates an expected call of ListObjectsInGVGAndBucket.

func (*MockMetadataAPIMockRecorder) ListPaymentAccountStreams added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) ListPaymentAccountStreams(ctx, paymentAccount any, opts ...any) *gomock.Call

ListPaymentAccountStreams indicates an expected call of ListPaymentAccountStreams.

func (*MockMetadataAPIMockRecorder) ListSpExitEvents added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListSpExitEvents(ctx, blockID, spID any, opts ...any) *gomock.Call

ListSpExitEvents indicates an expected call of ListSpExitEvents.

func (*MockMetadataAPIMockRecorder) ListSwapOutEvents added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListSwapOutEvents(ctx, blockID, spID any, opts ...any) *gomock.Call

ListSwapOutEvents indicates an expected call of ListSwapOutEvents.

func (*MockMetadataAPIMockRecorder) ListUserPaymentAccounts added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) ListUserPaymentAccounts(ctx, accountID any, opts ...any) *gomock.Call

ListUserPaymentAccounts indicates an expected call of ListUserPaymentAccounts.

func (*MockMetadataAPIMockRecorder) ListVirtualGroupFamiliesSpID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListVirtualGroupFamiliesSpID(ctx, spID any, opts ...any) *gomock.Call

ListVirtualGroupFamiliesSpID indicates an expected call of ListVirtualGroupFamiliesSpID.

func (*MockMetadataAPIMockRecorder) PrimarySpIncomeDetails added in v1.1.0 

func (mr *MockMetadataAPIMockRecorder) PrimarySpIncomeDetails(ctx, spID any, opts ...any) *gomock.Call

PrimarySpIncomeDetails indicates an expected call of PrimarySpIncomeDetails.

func (*MockMetadataAPIMockRecorder) SecondarySpIncomeDetails added in v1.1.0 

func (mr *MockMetadataAPIMockRecorder) SecondarySpIncomeDetails(ctx, spID any, opts ...any) *gomock.Call

SecondarySpIncomeDetails indicates an expected call of SecondarySpIncomeDetails.

func (*MockMetadataAPIMockRecorder) VerifyMigrateGVGPermission added in v0.2.6 

func (mr *MockMetadataAPIMockRecorder) VerifyMigrateGVGPermission(ctx, bucketID, gvgID, dstSpID any, opts ...any) *gomock.Call

VerifyMigrateGVGPermission indicates an expected call of VerifyMigrateGVGPermission.

func (*MockMetadataAPIMockRecorder) VerifyPermission added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) VerifyPermission(ctx, Operator, bucketName, objectName, actionType any, opts ...any) *gomock.Call

VerifyPermission indicates an expected call of VerifyPermission.

func (*MockMetadataAPIMockRecorder) VerifyPermissionByID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) VerifyPermissionByID(ctx, Operator, resourceType, resourceID, actionType any, opts ...any) *gomock.Call

VerifyPermissionByID indicates an expected call of VerifyPermissionByID.

type MockP2PAPI added in v0.2.4 

type MockP2PAPI struct {
	// contains filtered or unexported fields
}

MockP2PAPI is a mock of P2PAPI interface.

func NewMockP2PAPI added in v0.2.4 

func NewMockP2PAPI(ctrl *gomock.Controller) *MockP2PAPI

NewMockP2PAPI creates a new mock instance.

func (*MockP2PAPI) AskSecondaryReplicatePieceApproval added in v0.2.4 

func (m *MockP2PAPI) AskSecondaryReplicatePieceApproval(ctx context.Context, task task.ApprovalReplicatePieceTask, low, high int, timeout int64) ([]*gfsptask.GfSpReplicatePieceApprovalTask, error)

AskSecondaryReplicatePieceApproval mocks base method.

func (*MockP2PAPI) EXPECT added in v0.2.4 

func (m *MockP2PAPI) EXPECT() *MockP2PAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockP2PAPI) QueryP2PBootstrap added in v0.2.4 

func (m *MockP2PAPI) QueryP2PBootstrap(ctx context.Context) ([]string, error)

QueryP2PBootstrap mocks base method.

type MockP2PAPIMockRecorder added in v0.2.4 

type MockP2PAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockP2PAPIMockRecorder is the mock recorder for MockP2PAPI.

func (*MockP2PAPIMockRecorder) AskSecondaryReplicatePieceApproval added in v0.2.4 

func (mr *MockP2PAPIMockRecorder) AskSecondaryReplicatePieceApproval(ctx, task, low, high, timeout any) *gomock.Call

AskSecondaryReplicatePieceApproval indicates an expected call of AskSecondaryReplicatePieceApproval.

func (*MockP2PAPIMockRecorder) QueryP2PBootstrap added in v0.2.4 

func (mr *MockP2PAPIMockRecorder) QueryP2PBootstrap(ctx any) *gomock.Call

QueryP2PBootstrap indicates an expected call of QueryP2PBootstrap.

type MockQueryAPI added in v0.2.4 

type MockQueryAPI struct {
	// contains filtered or unexported fields
}

MockQueryAPI is a mock of QueryAPI interface.

func NewMockQueryAPI added in v0.2.4 

func NewMockQueryAPI(ctrl *gomock.Controller) *MockQueryAPI

NewMockQueryAPI creates a new mock instance.

func (*MockQueryAPI) EXPECT added in v0.2.4 

func (m *MockQueryAPI) EXPECT() *MockQueryAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockQueryAPI) QueryBucketMigrate added in v0.2.4 

func (m *MockQueryAPI) QueryBucketMigrate(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)

QueryBucketMigrate mocks base method.

func (*MockQueryAPI) QuerySPExit added in v0.2.4 

func (m *MockQueryAPI) QuerySPExit(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)

QuerySPExit mocks base method.

func (*MockQueryAPI) QueryTasks added in v0.2.4 

func (m *MockQueryAPI) QueryTasks(ctx context.Context, endpoint, subKey string, opts ...grpc.DialOption) ([]string, error)

QueryTasks mocks base method.

type MockQueryAPIMockRecorder added in v0.2.4 

type MockQueryAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockQueryAPIMockRecorder is the mock recorder for MockQueryAPI.

func (*MockQueryAPIMockRecorder) QueryBucketMigrate added in v0.2.4 

func (mr *MockQueryAPIMockRecorder) QueryBucketMigrate(ctx, endpoint any, opts ...any) *gomock.Call

QueryBucketMigrate indicates an expected call of QueryBucketMigrate.

func (*MockQueryAPIMockRecorder) QuerySPExit added in v0.2.4 

func (mr *MockQueryAPIMockRecorder) QuerySPExit(ctx, endpoint any, opts ...any) *gomock.Call

QuerySPExit indicates an expected call of QuerySPExit.

func (*MockQueryAPIMockRecorder) QueryTasks added in v0.2.4 

func (mr *MockQueryAPIMockRecorder) QueryTasks(ctx, endpoint, subKey any, opts ...any) *gomock.Call

QueryTasks indicates an expected call of QueryTasks.

type MockReceiverAPI added in v0.2.4 

type MockReceiverAPI struct {
	// contains filtered or unexported fields
}

MockReceiverAPI is a mock of ReceiverAPI interface.

func NewMockReceiverAPI added in v0.2.4 

func NewMockReceiverAPI(ctrl *gomock.Controller) *MockReceiverAPI

NewMockReceiverAPI creates a new mock instance.

func (*MockReceiverAPI) DoneReplicatePiece added in v0.2.4 

func (m *MockReceiverAPI) DoneReplicatePiece(ctx context.Context, task task.ReceivePieceTask, opts ...grpc.DialOption) ([]byte, []byte, error)

DoneReplicatePiece mocks base method.

func (*MockReceiverAPI) EXPECT added in v0.2.4 

func (m *MockReceiverAPI) EXPECT() *MockReceiverAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockReceiverAPI) ReplicatePiece added in v0.2.4 

func (m *MockReceiverAPI) ReplicatePiece(ctx context.Context, task task.ReceivePieceTask, data []byte, opts ...grpc.DialOption) error

ReplicatePiece mocks base method.

type MockReceiverAPIMockRecorder added in v0.2.4 

type MockReceiverAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockReceiverAPIMockRecorder is the mock recorder for MockReceiverAPI.

func (*MockReceiverAPIMockRecorder) DoneReplicatePiece added in v0.2.4 

func (mr *MockReceiverAPIMockRecorder) DoneReplicatePiece(ctx, task any, opts ...any) *gomock.Call

DoneReplicatePiece indicates an expected call of DoneReplicatePiece.

func (*MockReceiverAPIMockRecorder) ReplicatePiece added in v0.2.4 

func (mr *MockReceiverAPIMockRecorder) ReplicatePiece(ctx, task, data any, opts ...any) *gomock.Call

ReplicatePiece indicates an expected call of ReplicatePiece.

type MockSignerAPI added in v0.2.4 

type MockSignerAPI struct {
	// contains filtered or unexported fields
}

MockSignerAPI is a mock of SignerAPI interface.

func NewMockSignerAPI added in v0.2.4 

func NewMockSignerAPI(ctrl *gomock.Controller) *MockSignerAPI

NewMockSignerAPI creates a new mock instance.

func (*MockSignerAPI) CompleteMigrateBucket added in v0.2.4 

func (m *MockSignerAPI) CompleteMigrateBucket(ctx context.Context, migrateBucket *types3.MsgCompleteMigrateBucket) (string, error)

CompleteMigrateBucket mocks base method.

func (*MockSignerAPI) CompleteSPExit added in v0.2.4 

func (m *MockSignerAPI) CompleteSPExit(ctx context.Context, completeSPExit *types4.MsgCompleteStorageProviderExit) (string, error)

CompleteSPExit mocks base method.

func (*MockSignerAPI) CompleteSwapIn added in v1.3.0 

func (m *MockSignerAPI) CompleteSwapIn(ctx context.Context, completeSwpIn *types4.MsgCompleteSwapIn) (string, error)

CompleteSwapIn mocks base method.

func (*MockSignerAPI) CompleteSwapOut added in v0.2.4 

func (m *MockSignerAPI) CompleteSwapOut(ctx context.Context, completeSwapOut *types4.MsgCompleteSwapOut) (string, error)

CompleteSwapOut mocks base method.

func (*MockSignerAPI) CreateGlobalVirtualGroup added in v0.2.4 

func (m *MockSignerAPI) CreateGlobalVirtualGroup(ctx context.Context, group *gfspserver.GfSpCreateGlobalVirtualGroup) error

CreateGlobalVirtualGroup mocks base method.

func (*MockSignerAPI) DelegateCreateObject added in v1.6.0 

func (m *MockSignerAPI) DelegateCreateObject(ctx context.Context, object *types3.MsgDelegateCreateObject) (string, error)

DelegateCreateObject mocks base method.

func (*MockSignerAPI) DelegateUpdateObjectContent added in v1.6.0 

func (m *MockSignerAPI) DelegateUpdateObjectContent(ctx context.Context, object *types3.MsgDelegateUpdateObjectContent) (string, error)

DelegateUpdateObjectContent mocks base method.

func (*MockSignerAPI) DeleteGlobalVirtualGroup added in v1.2.0 

func (m *MockSignerAPI) DeleteGlobalVirtualGroup(ctx context.Context, deleteGVG *types4.MsgDeleteGlobalVirtualGroup) (string, error)

DeleteGlobalVirtualGroup mocks base method.

func (*MockSignerAPI) Deposit added in v1.2.0 

func (m *MockSignerAPI) Deposit(ctx context.Context, deposit *types4.MsgDeposit) (string, error)

Deposit mocks base method.

func (*MockSignerAPI) DiscontinueBucket added in v0.2.4 

func (m *MockSignerAPI) DiscontinueBucket(ctx context.Context, bucket *types3.MsgDiscontinueBucket) (string, error)

DiscontinueBucket mocks base method.

func (*MockSignerAPI) EXPECT added in v0.2.4 

func (m *MockSignerAPI) EXPECT() *MockSignerAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSignerAPI) RejectMigrateBucket added in v1.1.0 

func (m *MockSignerAPI) RejectMigrateBucket(ctx context.Context, rejectMigrateBucket *types3.MsgRejectMigrateBucket) (string, error)

RejectMigrateBucket mocks base method.

func (*MockSignerAPI) RejectUnSealObject added in v0.2.4 

func (m *MockSignerAPI) RejectUnSealObject(ctx context.Context, object *types3.MsgRejectSealObject) (string, error)

RejectUnSealObject mocks base method.

func (*MockSignerAPI) ReserveSwapIn added in v1.3.0 

func (m *MockSignerAPI) ReserveSwapIn(ctx context.Context, reserveSwapIn *types4.MsgReserveSwapIn) (string, error)

ReserveSwapIn mocks base method.

func (*MockSignerAPI) SPExit added in v0.2.4 

func (m *MockSignerAPI) SPExit(ctx context.Context, spExit *types4.MsgStorageProviderExit) (string, error)

SPExit mocks base method.

func (*MockSignerAPI) SealObject added in v0.2.4 

func (m *MockSignerAPI) SealObject(ctx context.Context, object *types3.MsgSealObject) (string, error)

SealObject mocks base method.

func (*MockSignerAPI) SealObjectV2 added in v1.6.0 

func (m *MockSignerAPI) SealObjectV2(ctx context.Context, object *types3.MsgSealObjectV2) (string, error)

SealObjectV2 mocks base method.

func (*MockSignerAPI) SignBucketMigrationInfo added in v1.1.0 

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

SignBucketMigrationInfo mocks base method.

func (*MockSignerAPI) SignCreateBucketApproval added in v0.2.4 

func (m *MockSignerAPI) SignCreateBucketApproval(ctx context.Context, bucket *types3.MsgCreateBucket) ([]byte, error)

SignCreateBucketApproval mocks base method.

func (*MockSignerAPI) SignCreateObjectApproval added in v0.2.4 

func (m *MockSignerAPI) SignCreateObjectApproval(ctx context.Context, object *types3.MsgCreateObject) ([]byte, error)

SignCreateObjectApproval mocks base method.

func (*MockSignerAPI) SignMigrateBucketApproval added in v0.2.4 

func (m *MockSignerAPI) SignMigrateBucketApproval(ctx context.Context, bucket *types3.MsgMigrateBucket) ([]byte, error)

SignMigrateBucketApproval mocks base method.

func (*MockSignerAPI) SignMigrateGVG added in v0.2.6 

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

SignMigrateGVG mocks base method.

func (*MockSignerAPI) SignP2PPingMsg added in v0.2.4 

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

SignP2PPingMsg mocks base method.

func (*MockSignerAPI) SignP2PPongMsg added in v0.2.4 

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

SignP2PPongMsg mocks base method.

func (*MockSignerAPI) SignReceiveTask added in v0.2.4 

func (m *MockSignerAPI) SignReceiveTask(ctx context.Context, receiveTask task.ReceivePieceTask) ([]byte, error)

SignReceiveTask mocks base method.

func (*MockSignerAPI) SignRecoveryTask added in v0.2.4 

func (m *MockSignerAPI) SignRecoveryTask(ctx context.Context, recoveryTask task.RecoveryPieceTask) ([]byte, error)

SignRecoveryTask mocks base method.

func (*MockSignerAPI) SignReplicatePieceApproval added in v0.2.4 

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

SignReplicatePieceApproval mocks base method.

func (*MockSignerAPI) SignSecondarySPMigrationBucket added in v0.2.4 

func (m *MockSignerAPI) SignSecondarySPMigrationBucket(ctx context.Context, signDoc *types3.SecondarySpMigrationBucketSignDoc) ([]byte, error)

SignSecondarySPMigrationBucket mocks base method.

func (*MockSignerAPI) SignSecondarySealBls added in v0.2.4 

func (m *MockSignerAPI) SignSecondarySealBls(ctx context.Context, objectID uint64, gvgId uint32, checksums [][]byte) ([]byte, error)

SignSecondarySealBls mocks base method.

func (*MockSignerAPI) SignSwapOut added in v0.2.4 

func (m *MockSignerAPI) SignSwapOut(ctx context.Context, swapOut *types4.MsgSwapOut) ([]byte, error)

SignSwapOut mocks base method.

func (*MockSignerAPI) SwapOut added in v0.2.4 

func (m *MockSignerAPI) SwapOut(ctx context.Context, swapOut *types4.MsgSwapOut) (string, error)

SwapOut mocks base method.

func (*MockSignerAPI) UpdateSPPrice added in v0.2.4 

func (m *MockSignerAPI) UpdateSPPrice(ctx context.Context, price *types2.MsgUpdateSpStoragePrice) (string, error)

UpdateSPPrice mocks base method.

type MockSignerAPIMockRecorder added in v0.2.4 

type MockSignerAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockSignerAPIMockRecorder is the mock recorder for MockSignerAPI.

func (*MockSignerAPIMockRecorder) CompleteMigrateBucket added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) CompleteMigrateBucket(ctx, migrateBucket any) *gomock.Call

CompleteMigrateBucket indicates an expected call of CompleteMigrateBucket.

func (*MockSignerAPIMockRecorder) CompleteSPExit added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) CompleteSPExit(ctx, completeSPExit any) *gomock.Call

CompleteSPExit indicates an expected call of CompleteSPExit.

func (*MockSignerAPIMockRecorder) CompleteSwapIn added in v1.3.0 

func (mr *MockSignerAPIMockRecorder) CompleteSwapIn(ctx, completeSwpIn any) *gomock.Call

CompleteSwapIn indicates an expected call of CompleteSwapIn.

func (*MockSignerAPIMockRecorder) CompleteSwapOut added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) CompleteSwapOut(ctx, completeSwapOut any) *gomock.Call

CompleteSwapOut indicates an expected call of CompleteSwapOut.

func (*MockSignerAPIMockRecorder) CreateGlobalVirtualGroup added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) CreateGlobalVirtualGroup(ctx, group any) *gomock.Call

CreateGlobalVirtualGroup indicates an expected call of CreateGlobalVirtualGroup.

func (*MockSignerAPIMockRecorder) DelegateCreateObject added in v1.6.0 

func (mr *MockSignerAPIMockRecorder) DelegateCreateObject(ctx, object any) *gomock.Call

DelegateCreateObject indicates an expected call of DelegateCreateObject.

func (*MockSignerAPIMockRecorder) DelegateUpdateObjectContent added in v1.6.0 

func (mr *MockSignerAPIMockRecorder) DelegateUpdateObjectContent(ctx, object any) *gomock.Call

DelegateUpdateObjectContent indicates an expected call of DelegateUpdateObjectContent.

func (*MockSignerAPIMockRecorder) DeleteGlobalVirtualGroup added in v1.2.0 

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

DeleteGlobalVirtualGroup indicates an expected call of DeleteGlobalVirtualGroup.

func (*MockSignerAPIMockRecorder) Deposit added in v1.2.0 

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

Deposit indicates an expected call of Deposit.

func (*MockSignerAPIMockRecorder) DiscontinueBucket added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) DiscontinueBucket(ctx, bucket any) *gomock.Call

DiscontinueBucket indicates an expected call of DiscontinueBucket.

func (*MockSignerAPIMockRecorder) RejectMigrateBucket added in v1.1.0 

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

RejectMigrateBucket indicates an expected call of RejectMigrateBucket.

func (*MockSignerAPIMockRecorder) RejectUnSealObject added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) RejectUnSealObject(ctx, object any) *gomock.Call

RejectUnSealObject indicates an expected call of RejectUnSealObject.

func (*MockSignerAPIMockRecorder) ReserveSwapIn added in v1.3.0 

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

ReserveSwapIn indicates an expected call of ReserveSwapIn.

func (*MockSignerAPIMockRecorder) SPExit added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SPExit(ctx, spExit any) *gomock.Call

SPExit indicates an expected call of SPExit.

func (*MockSignerAPIMockRecorder) SealObject added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SealObject(ctx, object any) *gomock.Call

SealObject indicates an expected call of SealObject.

func (*MockSignerAPIMockRecorder) SealObjectV2 added in v1.6.0 

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

SealObjectV2 indicates an expected call of SealObjectV2.

func (*MockSignerAPIMockRecorder) SignBucketMigrationInfo added in v1.1.0 

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

SignBucketMigrationInfo indicates an expected call of SignBucketMigrationInfo.

func (*MockSignerAPIMockRecorder) SignCreateBucketApproval added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignCreateBucketApproval(ctx, bucket any) *gomock.Call

SignCreateBucketApproval indicates an expected call of SignCreateBucketApproval.

func (*MockSignerAPIMockRecorder) SignCreateObjectApproval added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignCreateObjectApproval(ctx, object any) *gomock.Call

SignCreateObjectApproval indicates an expected call of SignCreateObjectApproval.

func (*MockSignerAPIMockRecorder) SignMigrateBucketApproval added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignMigrateBucketApproval(ctx, bucket any) *gomock.Call

SignMigrateBucketApproval indicates an expected call of SignMigrateBucketApproval.

func (*MockSignerAPIMockRecorder) SignMigrateGVG added in v0.2.6 

func (mr *MockSignerAPIMockRecorder) SignMigrateGVG(ctx, task any) *gomock.Call

SignMigrateGVG indicates an expected call of SignMigrateGVG.

func (*MockSignerAPIMockRecorder) SignP2PPingMsg added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignP2PPingMsg(ctx, ping any) *gomock.Call

SignP2PPingMsg indicates an expected call of SignP2PPingMsg.

func (*MockSignerAPIMockRecorder) SignP2PPongMsg added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignP2PPongMsg(ctx, pong any) *gomock.Call

SignP2PPongMsg indicates an expected call of SignP2PPongMsg.

func (*MockSignerAPIMockRecorder) SignReceiveTask added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignReceiveTask(ctx, receiveTask any) *gomock.Call

SignReceiveTask indicates an expected call of SignReceiveTask.

func (*MockSignerAPIMockRecorder) SignRecoveryTask added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignRecoveryTask(ctx, recoveryTask any) *gomock.Call

SignRecoveryTask indicates an expected call of SignRecoveryTask.

func (*MockSignerAPIMockRecorder) SignReplicatePieceApproval added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignReplicatePieceApproval(ctx, task any) *gomock.Call

SignReplicatePieceApproval indicates an expected call of SignReplicatePieceApproval.

func (*MockSignerAPIMockRecorder) SignSecondarySPMigrationBucket added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignSecondarySPMigrationBucket(ctx, signDoc any) *gomock.Call

SignSecondarySPMigrationBucket indicates an expected call of SignSecondarySPMigrationBucket.

func (*MockSignerAPIMockRecorder) SignSecondarySealBls added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignSecondarySealBls(ctx, objectID, gvgId, checksums any) *gomock.Call

SignSecondarySealBls indicates an expected call of SignSecondarySealBls.

func (*MockSignerAPIMockRecorder) SignSwapOut added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignSwapOut(ctx, swapOut any) *gomock.Call

SignSwapOut indicates an expected call of SignSwapOut.

func (*MockSignerAPIMockRecorder) SwapOut added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SwapOut(ctx, swapOut any) *gomock.Call

SwapOut indicates an expected call of SwapOut.

func (*MockSignerAPIMockRecorder) UpdateSPPrice added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) UpdateSPPrice(ctx, price any) *gomock.Call

UpdateSPPrice indicates an expected call of UpdateSPPrice.

type MockUploaderAPI added in v0.2.4 

type MockUploaderAPI struct {
	// contains filtered or unexported fields
}

MockUploaderAPI is a mock of UploaderAPI interface.

func NewMockUploaderAPI added in v0.2.4 

func NewMockUploaderAPI(ctrl *gomock.Controller) *MockUploaderAPI

NewMockUploaderAPI creates a new mock instance.

func (*MockUploaderAPI) EXPECT added in v0.2.4 

func (m *MockUploaderAPI) EXPECT() *MockUploaderAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockUploaderAPI) ResumableUploadObject added in v0.2.4 

func (m *MockUploaderAPI) ResumableUploadObject(ctx context.Context, task task.ResumableUploadObjectTask, stream io.Reader, opts ...grpc.DialOption) error

ResumableUploadObject mocks base method.

func (*MockUploaderAPI) UploadObject added in v0.2.4 

func (m *MockUploaderAPI) UploadObject(ctx context.Context, task task.UploadObjectTask, stream io.Reader, opts ...grpc.DialOption) error

UploadObject mocks base method.

type MockUploaderAPIMockRecorder added in v0.2.4 

type MockUploaderAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockUploaderAPIMockRecorder is the mock recorder for MockUploaderAPI.

func (*MockUploaderAPIMockRecorder) ResumableUploadObject added in v0.2.4 

func (mr *MockUploaderAPIMockRecorder) ResumableUploadObject(ctx, task, stream any, opts ...any) *gomock.Call

ResumableUploadObject indicates an expected call of ResumableUploadObject.

func (*MockUploaderAPIMockRecorder) UploadObject added in v0.2.4 

func (mr *MockUploaderAPIMockRecorder) UploadObject(ctx, task, stream any, opts ...any) *gomock.Call

UploadObject indicates an expected call of UploadObject.

type MockstdLib added in v0.2.5 

type MockstdLib struct {
	// contains filtered or unexported fields
}

MockstdLib is a mock of stdLib interface.

func NewMockstdLib added in v0.2.5 

func NewMockstdLib(ctrl *gomock.Controller) *MockstdLib

NewMockstdLib creates a new mock instance.

func (*MockstdLib) Close added in v0.2.5 

func (m *MockstdLib) Close() error

Close mocks base method.

func (*MockstdLib) EXPECT added in v0.2.5 

func (m *MockstdLib) EXPECT() *MockstdLibMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockstdLib) Read added in v0.2.5 

func (m *MockstdLib) Read(p []byte) (int, error)

Read mocks base method.

type MockstdLibMockRecorder added in v0.2.5 

type MockstdLibMockRecorder struct {
	// contains filtered or unexported fields
}

MockstdLibMockRecorder is the mock recorder for MockstdLib.

func (*MockstdLibMockRecorder) Close added in v0.2.5 

func (mr *MockstdLibMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockstdLibMockRecorder) Read added in v0.2.5 

func (mr *MockstdLibMockRecorder) Read(p any) *gomock.Call

Read indicates an expected call of Read.

type P2PAPI added in v0.2.4 

type P2PAPI interface {
	AskSecondaryReplicatePieceApproval(ctx context.Context, task coretask.ApprovalReplicatePieceTask, low, high int, timeout int64) ([]*gfsptask.GfSpReplicatePieceApprovalTask, error)
	QueryP2PBootstrap(ctx context.Context) ([]string, error)
}

P2PAPI for mock use

type QueryAPI added in v0.2.4 

type QueryAPI interface {
	QueryTasks(ctx context.Context, endpoint string, subKey string, opts ...grpc.DialOption) ([]string, error)
	QueryBucketMigrate(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)
	QuerySPExit(ctx context.Context, endpoint string, opts ...grpc.DialOption) (string, error)
}

QueryAPI for mock use

type ReceiverAPI added in v0.2.4 

type ReceiverAPI interface {
	ReplicatePiece(ctx context.Context, task coretask.ReceivePieceTask, data []byte, opts ...grpc.DialOption) error
	DoneReplicatePiece(ctx context.Context, task coretask.ReceivePieceTask, opts ...grpc.DialOption) ([]byte, []byte, error)
}

ReceiverAPI for mock use

type SignerAPI added in v0.2.4 

type SignerAPI interface {
	SignCreateBucketApproval(ctx context.Context, bucket *storagetypes.MsgCreateBucket) ([]byte, error)
	SignMigrateBucketApproval(ctx context.Context, bucket *storagetypes.MsgMigrateBucket) ([]byte, error)
	SignCreateObjectApproval(ctx context.Context, object *storagetypes.MsgCreateObject) ([]byte, error)
	DelegateCreateObject(ctx context.Context, object *storagetypes.MsgDelegateCreateObject) (string, error)
	DelegateUpdateObjectContent(ctx context.Context, object *storagetypes.MsgDelegateUpdateObjectContent) (string, error)
	SealObject(ctx context.Context, object *storagetypes.MsgSealObject) (string, error)
	SealObjectV2(ctx context.Context, object *storagetypes.MsgSealObjectV2) (string, error)
	UpdateSPPrice(ctx context.Context, price *sptypes.MsgUpdateSpStoragePrice) (string, error)
	CreateGlobalVirtualGroup(ctx context.Context, group *gfspserver.GfSpCreateGlobalVirtualGroup) error
	RejectUnSealObject(ctx context.Context, object *storagetypes.MsgRejectSealObject) (string, error)
	DiscontinueBucket(ctx context.Context, bucket *storagetypes.MsgDiscontinueBucket) (string, error)
	SignReplicatePieceApproval(ctx context.Context, task coretask.ApprovalReplicatePieceTask) ([]byte, error)
	SignSecondarySealBls(ctx context.Context, objectID uint64, gvgId uint32, checksums [][]byte) ([]byte, error)
	SignReceiveTask(ctx context.Context, receiveTask coretask.ReceivePieceTask) ([]byte, error)
	SignRecoveryTask(ctx context.Context, recoveryTask coretask.RecoveryPieceTask) ([]byte, error)
	SignP2PPingMsg(ctx context.Context, ping *gfspp2p.GfSpPing) ([]byte, error)
	SignP2PPongMsg(ctx context.Context, pong *gfspp2p.GfSpPong) ([]byte, error)
	CompleteMigrateBucket(ctx context.Context, migrateBucket *storagetypes.MsgCompleteMigrateBucket) (string, error)
	SignSecondarySPMigrationBucket(ctx context.Context, signDoc *storagetypes.SecondarySpMigrationBucketSignDoc) ([]byte, error)
	SignSwapOut(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) ([]byte, error)
	SwapOut(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) (string, error)
	CompleteSwapOut(ctx context.Context, completeSwapOut *virtualgrouptypes.MsgCompleteSwapOut) (string, error)
	SPExit(ctx context.Context, spExit *virtualgrouptypes.MsgStorageProviderExit) (string, error)
	CompleteSPExit(ctx context.Context, completeSPExit *virtualgrouptypes.MsgCompleteStorageProviderExit) (string, error)
	SignMigrateGVG(ctx context.Context, task *gfsptask.GfSpMigrateGVGTask) ([]byte, error)
	SignBucketMigrationInfo(ctx context.Context, task *gfsptask.GfSpBucketMigrationInfo) ([]byte, error)
	RejectMigrateBucket(ctx context.Context, rejectMigrateBucket *storagetypes.MsgRejectMigrateBucket) (string, error)
	ReserveSwapIn(ctx context.Context, reserveSwapIn *virtualgrouptypes.MsgReserveSwapIn) (string, error)
	CompleteSwapIn(ctx context.Context, completeSwpIn *virtualgrouptypes.MsgCompleteSwapIn) (string, error)
	Deposit(ctx context.Context, deposit *virtualgrouptypes.MsgDeposit) (string, error)
	DeleteGlobalVirtualGroup(ctx context.Context, deleteGVG *virtualgrouptypes.MsgDeleteGlobalVirtualGroup) (string, error)
}

SignerAPI for mock use

type UploaderAPI added in v0.2.4 

type UploaderAPI interface {
	UploadObject(ctx context.Context, task coretask.UploadObjectTask, stream io.Reader, opts ...grpc.DialOption) error
	ResumableUploadObject(ctx context.Context, task coretask.ResumableUploadObjectTask, stream io.Reader, opts ...grpc.DialOption) error
}

UploaderAPI for mock use

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.