gfspclient

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2023 License: GPL-3.0 Imports: 33 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"
	// 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"
	// 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"
)

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

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

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
}

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, task *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)
}

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

func (s *GfSpClient) GetBucketMeta(ctx context.Context, bucketName string, includePrivate bool,
	opts ...grpc.DialOption) (*types.Bucket, *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, error)

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) 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) 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) 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) 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, gvgID 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.StreamRecordMeta, 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, task *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) 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) QueryBucketMigrate added in v0.2.3 

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

func (*GfSpClient) QueryP2PBootstrap 

func (s *GfSpClient) QueryP2PBootstrap(ctx context.Context) ([]string, 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) 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) 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) 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) 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) SignMigratePiece added in v0.2.3 

func (s *GfSpClient) SignMigratePiece(ctx context.Context, task *gfsptask.GfSpMigratePieceTask) ([]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) SwapOut added in v0.2.3 

func (s *GfSpClient) SwapOut(ctx context.Context, swapOut *virtualgrouptypes.MsgSwapOut) (string, 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) 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) 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
}

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)
	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.Bucket, *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, 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)
	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.StreamRecordMeta, 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)
}

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) 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 interface{}) *gomock.Call

AskCreateBucketApproval indicates an expected call of AskCreateBucketApproval.

func (*MockApproverAPIMockRecorder) AskCreateObjectApproval added in v0.2.4 

func (mr *MockApproverAPIMockRecorder) AskCreateObjectApproval(ctx, t interface{}) *gomock.Call

AskCreateObjectApproval indicates an expected call of AskCreateObjectApproval.

func (*MockApproverAPIMockRecorder) AskMigrateBucketApproval added in v0.2.4 

func (mr *MockApproverAPIMockRecorder) AskMigrateBucketApproval(ctx, t interface{}) *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) 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) 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) 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) 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.

type MockAuthenticatorAPIMockRecorder added in v0.2.4 

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

MockAuthenticatorAPIMockRecorder is the mock recorder for MockAuthenticatorAPI.

func (*MockAuthenticatorAPIMockRecorder) GetAuthNonce added in v0.2.4 

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

GetAuthNonce indicates an expected call of GetAuthNonce.

func (*MockAuthenticatorAPIMockRecorder) UpdateUserPublicKey added in v0.2.4 

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

UpdateUserPublicKey indicates an expected call of UpdateUserPublicKey.

func (*MockAuthenticatorAPIMockRecorder) VerifyAuthentication added in v0.2.4 

func (mr *MockAuthenticatorAPIMockRecorder) VerifyAuthentication(ctx, auth, account, bucket, object interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

VerifyGNFD1EddsaSignature indicates an expected call of VerifyGNFD1EddsaSignature.

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

type MockDownloaderAPIMockRecorder added in v0.2.4 

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

MockDownloaderAPIMockRecorder is the mock recorder for MockDownloaderAPI.

func (*MockDownloaderAPIMockRecorder) GetChallengeInfo added in v0.2.4 

func (mr *MockDownloaderAPIMockRecorder) GetChallengeInfo(ctx, challengePieceTask interface{}, opts ...interface{}) *gomock.Call

GetChallengeInfo indicates an expected call of GetChallengeInfo.

func (*MockDownloaderAPIMockRecorder) GetObject added in v0.2.4 

func (mr *MockDownloaderAPIMockRecorder) GetObject(ctx, downloadObjectTask interface{}, opts ...interface{}) *gomock.Call

GetObject indicates an expected call of GetObject.

func (*MockDownloaderAPIMockRecorder) GetPiece added in v0.2.4 

func (mr *MockDownloaderAPIMockRecorder) GetPiece(ctx, downloadPieceTask interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

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, task *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) 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 interface{}) *gomock.Call

DoneReplicatePieceToSecondary indicates an expected call of DoneReplicatePieceToSecondary.

func (*MockGaterAPIMockRecorder) GetPieceFromECChunks added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) GetPieceFromECChunks(ctx, endpoint, task interface{}) *gomock.Call

GetPieceFromECChunks indicates an expected call of GetPieceFromECChunks.

func (*MockGaterAPIMockRecorder) GetSecondarySPMigrationBucketApproval added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) GetSecondarySPMigrationBucketApproval(ctx, secondarySPEndpoint, signDoc interface{}) *gomock.Call

GetSecondarySPMigrationBucketApproval indicates an expected call of GetSecondarySPMigrationBucketApproval.

func (*MockGaterAPIMockRecorder) GetSwapOutApproval added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) GetSwapOutApproval(ctx, destSPEndpoint, swapOutApproval interface{}) *gomock.Call

GetSwapOutApproval indicates an expected call of GetSwapOutApproval.

func (*MockGaterAPIMockRecorder) MigratePiece added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) MigratePiece(ctx, task interface{}) *gomock.Call

MigratePiece indicates an expected call of MigratePiece.

func (*MockGaterAPIMockRecorder) NotifyDestSPMigrateSwapOut added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) NotifyDestSPMigrateSwapOut(ctx, destEndpoint, swapOut interface{}) *gomock.Call

NotifyDestSPMigrateSwapOut indicates an expected call of NotifyDestSPMigrateSwapOut.

func (*MockGaterAPIMockRecorder) ReplicatePieceToSecondary added in v0.2.4 

func (mr *MockGaterAPIMockRecorder) ReplicatePieceToSecondary(ctx, endpoint, receive, data interface{}) *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) 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) 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) 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) 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) GetBucketMeta added in v0.2.4 

func (m *MockGfSpClientAPI) GetBucketMeta(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, *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, error)

GetBucketReadQuota 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) 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) 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) 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) 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.StreamRecordMeta, 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, task *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) 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) 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) 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) 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

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

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

SignMigratePiece 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) 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) 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 interface{}, opts ...interface{}) *gomock.Call

ApproverConn indicates an expected call of ApproverConn.

func (*MockGfSpClientAPIMockRecorder) AskCreateBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskCreateBucketApproval(ctx, t interface{}) *gomock.Call

AskCreateBucketApproval indicates an expected call of AskCreateBucketApproval.

func (*MockGfSpClientAPIMockRecorder) AskCreateObjectApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskCreateObjectApproval(ctx, t interface{}) *gomock.Call

AskCreateObjectApproval indicates an expected call of AskCreateObjectApproval.

func (*MockGfSpClientAPIMockRecorder) AskMigrateBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskMigrateBucketApproval(ctx, t interface{}) *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 interface{}) *gomock.Call

AskSecondaryReplicatePieceApproval indicates an expected call of AskSecondaryReplicatePieceApproval.

func (*MockGfSpClientAPIMockRecorder) AskTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) AskTask(ctx, limit interface{}) *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 interface{}) *gomock.Call

CompleteMigrateBucket indicates an expected call of CompleteMigrateBucket.

func (*MockGfSpClientAPIMockRecorder) CompleteSPExit added in v0.2.4 

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

CompleteSPExit indicates an expected call of CompleteSPExit.

func (*MockGfSpClientAPIMockRecorder) CompleteSwapOut added in v0.2.4 

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

CompleteSwapOut indicates an expected call of CompleteSwapOut.

func (*MockGfSpClientAPIMockRecorder) Connection added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) Connection(ctx, address interface{}, opts ...interface{}) *gomock.Call

Connection indicates an expected call of Connection.

func (*MockGfSpClientAPIMockRecorder) CreateGlobalVirtualGroup added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CreateGlobalVirtualGroup(ctx, group interface{}) *gomock.Call

CreateGlobalVirtualGroup indicates an expected call of CreateGlobalVirtualGroup.

func (*MockGfSpClientAPIMockRecorder) CreateResumableUploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CreateResumableUploadObject(ctx, task interface{}) *gomock.Call

CreateResumableUploadObject indicates an expected call of CreateResumableUploadObject.

func (*MockGfSpClientAPIMockRecorder) CreateUploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) CreateUploadObject(ctx, task interface{}) *gomock.Call

CreateUploadObject indicates an expected call of CreateUploadObject.

func (*MockGfSpClientAPIMockRecorder) DiscontinueBucket added in v0.2.4 

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

DiscontinueBucket indicates an expected call of DiscontinueBucket.

func (*MockGfSpClientAPIMockRecorder) DoneReplicatePiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) DoneReplicatePiece(ctx, task interface{}, opts ...interface{}) *gomock.Call

DoneReplicatePiece indicates an expected call of DoneReplicatePiece.

func (*MockGfSpClientAPIMockRecorder) DoneReplicatePieceToSecondary added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) DoneReplicatePieceToSecondary(ctx, endpoint, receive interface{}) *gomock.Call

DoneReplicatePieceToSecondary indicates an expected call of DoneReplicatePieceToSecondary.

func (*MockGfSpClientAPIMockRecorder) GetAuthNonce added in v0.2.4 

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

GetAuthNonce indicates an expected call of GetAuthNonce.

func (*MockGfSpClientAPIMockRecorder) GetBucketByBucketID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketByBucketID(ctx, bucketID, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetBucketByBucketID indicates an expected call of GetBucketByBucketID.

func (*MockGfSpClientAPIMockRecorder) GetBucketByBucketName added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketByBucketName(ctx, bucketName, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetBucketByBucketName indicates an expected call of GetBucketByBucketName.

func (*MockGfSpClientAPIMockRecorder) GetBucketMeta added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketMeta(ctx, bucketName, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetBucketMeta indicates an expected call of GetBucketMeta.

func (*MockGfSpClientAPIMockRecorder) GetBucketReadQuota added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetBucketReadQuota(ctx, bucket, yearMonth interface{}, opts ...interface{}) *gomock.Call

GetBucketReadQuota indicates an expected call of GetBucketReadQuota.

func (*MockGfSpClientAPIMockRecorder) GetChallengeInfo added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetChallengeInfo(ctx, challengePieceTask interface{}, opts ...interface{}) *gomock.Call

GetChallengeInfo indicates an expected call of GetChallengeInfo.

func (*MockGfSpClientAPIMockRecorder) GetEndpointBySpID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetEndpointBySpID(ctx, spID interface{}, opts ...interface{}) *gomock.Call

GetEndpointBySpID indicates an expected call of GetEndpointBySpID.

func (*MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroup added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroup(ctx, bucketID, lvgID interface{}, opts ...interface{}) *gomock.Call

GetGlobalVirtualGroup indicates an expected call of GetGlobalVirtualGroup.

func (*MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroupByGvgID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetGlobalVirtualGroupByGvgID(ctx, gvgID interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

GetGroupMembers indicates an expected call of GetGroupMembers.

func (*MockGfSpClientAPIMockRecorder) GetObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetObject(ctx, downloadObjectTask interface{}, opts ...interface{}) *gomock.Call

GetObject indicates an expected call of GetObject.

func (*MockGfSpClientAPIMockRecorder) GetObjectByID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetObjectByID(ctx, objectID interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

GetObjectMeta indicates an expected call of GetObjectMeta.

func (*MockGfSpClientAPIMockRecorder) GetPaymentByBucketID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPaymentByBucketID(ctx, bucketID, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetPaymentByBucketID indicates an expected call of GetPaymentByBucketID.

func (*MockGfSpClientAPIMockRecorder) GetPaymentByBucketName added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPaymentByBucketName(ctx, bucketName, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetPaymentByBucketName indicates an expected call of GetPaymentByBucketName.

func (*MockGfSpClientAPIMockRecorder) GetPiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPiece(ctx, downloadPieceTask interface{}, opts ...interface{}) *gomock.Call

GetPiece indicates an expected call of GetPiece.

func (*MockGfSpClientAPIMockRecorder) GetPieceFromECChunks added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetPieceFromECChunks(ctx, endpoint, task interface{}) *gomock.Call

GetPieceFromECChunks indicates an expected call of GetPieceFromECChunks.

func (*MockGfSpClientAPIMockRecorder) GetSPInfo added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetSPInfo(ctx, operatorAddress interface{}, opts ...interface{}) *gomock.Call

GetSPInfo indicates an expected call of GetSPInfo.

func (*MockGfSpClientAPIMockRecorder) GetSPMigratingBucketNumber added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) GetSPMigratingBucketNumber(ctx, spID interface{}, opts ...interface{}) *gomock.Call

GetSPMigratingBucketNumber indicates an expected call of GetSPMigratingBucketNumber.

func (*MockGfSpClientAPIMockRecorder) GetSecondarySPMigrationBucketApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetSecondarySPMigrationBucketApproval(ctx, secondarySPEndpoint, signDoc interface{}) *gomock.Call

GetSecondarySPMigrationBucketApproval indicates an expected call of GetSecondarySPMigrationBucketApproval.

func (*MockGfSpClientAPIMockRecorder) GetStatus added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetStatus(ctx interface{}, opts ...interface{}) *gomock.Call

GetStatus indicates an expected call of GetStatus.

func (*MockGfSpClientAPIMockRecorder) GetSwapOutApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetSwapOutApproval(ctx, destSPEndpoint, swapOutApproval interface{}) *gomock.Call

GetSwapOutApproval indicates an expected call of GetSwapOutApproval.

func (*MockGfSpClientAPIMockRecorder) GetUploadObjectSegment added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUploadObjectSegment(ctx, objectID interface{}, opts ...interface{}) *gomock.Call

GetUploadObjectSegment indicates an expected call of GetUploadObjectSegment.

func (*MockGfSpClientAPIMockRecorder) GetUploadObjectState added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUploadObjectState(ctx, objectID interface{}, opts ...interface{}) *gomock.Call

GetUploadObjectState indicates an expected call of GetUploadObjectState.

func (*MockGfSpClientAPIMockRecorder) GetUserBuckets added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUserBuckets(ctx, account, includeRemoved interface{}, opts ...interface{}) *gomock.Call

GetUserBuckets indicates an expected call of GetUserBuckets.

func (*MockGfSpClientAPIMockRecorder) GetUserBucketsCount added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetUserBucketsCount(ctx, account, includeRemoved interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

GetUserOwnedGroups indicates an expected call of GetUserOwnedGroups.

func (*MockGfSpClientAPIMockRecorder) GetVirtualGroupFamily added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) GetVirtualGroupFamily(ctx, vgfID interface{}, opts ...interface{}) *gomock.Call

GetVirtualGroupFamily indicates an expected call of GetVirtualGroupFamily.

func (*MockGfSpClientAPIMockRecorder) HTTPClient added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) HTTPClient(ctx interface{}) *gomock.Call

HTTPClient indicates an expected call of HTTPClient.

func (*MockGfSpClientAPIMockRecorder) ListBucketReadRecord added in v0.2.4 

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

ListBucketReadRecord indicates an expected call of ListBucketReadRecord.

func (*MockGfSpClientAPIMockRecorder) ListBucketsByIDs added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListBucketsByIDs(ctx, bucketIDs, includeRemoved interface{}, opts ...interface{}) *gomock.Call

ListBucketsByIDs indicates an expected call of ListBucketsByIDs.

func (*MockGfSpClientAPIMockRecorder) ListDeletedObjectsByBlockNumberRange added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListDeletedObjectsByBlockNumberRange(ctx, spOperatorAddress, startBlockNumber, endBlockNumber, includePrivate interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

ListExpiredBucketsBySp indicates an expected call of ListExpiredBucketsBySp.

func (*MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsByBucket added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsByBucket(ctx, bucketID interface{}, opts ...interface{}) *gomock.Call

ListGlobalVirtualGroupsByBucket indicates an expected call of ListGlobalVirtualGroupsByBucket.

func (*MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP(ctx, spID interface{}, opts ...interface{}) *gomock.Call

ListGlobalVirtualGroupsBySecondarySP indicates an expected call of ListGlobalVirtualGroupsBySecondarySP.

func (*MockGfSpClientAPIMockRecorder) ListGroupsByIDs added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) ListGroupsByIDs(ctx, groupIDs interface{}, opts ...interface{}) *gomock.Call

ListGroupsByIDs indicates an expected call of ListGroupsByIDs.

func (*MockGfSpClientAPIMockRecorder) ListMigrateBucketEvents added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListMigrateBucketEvents(ctx, blockID, spID interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

ListObjectsByGVGAndBucketForGC indicates an expected call of ListObjectsByGVGAndBucketForGC.

func (*MockGfSpClientAPIMockRecorder) ListObjectsByIDs added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListObjectsByIDs(ctx, objectIDs, includeRemoved interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

ListObjectsInGVGAndBucket indicates an expected call of ListObjectsInGVGAndBucket.

func (*MockGfSpClientAPIMockRecorder) ListPaymentAccountStreams added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) ListPaymentAccountStreams(ctx, paymentAccount interface{}, opts ...interface{}) *gomock.Call

ListPaymentAccountStreams indicates an expected call of ListPaymentAccountStreams.

func (*MockGfSpClientAPIMockRecorder) ListSpExitEvents added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListSpExitEvents(ctx, blockID, spID interface{}, opts ...interface{}) *gomock.Call

ListSpExitEvents indicates an expected call of ListSpExitEvents.

func (*MockGfSpClientAPIMockRecorder) ListSwapOutEvents added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListSwapOutEvents(ctx, blockID, spID interface{}, opts ...interface{}) *gomock.Call

ListSwapOutEvents indicates an expected call of ListSwapOutEvents.

func (*MockGfSpClientAPIMockRecorder) ListUserPaymentAccounts added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) ListUserPaymentAccounts(ctx, accountID interface{}, opts ...interface{}) *gomock.Call

ListUserPaymentAccounts indicates an expected call of ListUserPaymentAccounts.

func (*MockGfSpClientAPIMockRecorder) ListVirtualGroupFamiliesSpID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ListVirtualGroupFamiliesSpID(ctx, spID interface{}, opts ...interface{}) *gomock.Call

ListVirtualGroupFamiliesSpID indicates an expected call of ListVirtualGroupFamiliesSpID.

func (*MockGfSpClientAPIMockRecorder) ManagerConn added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ManagerConn(ctx interface{}, opts ...interface{}) *gomock.Call

ManagerConn indicates an expected call of ManagerConn.

func (*MockGfSpClientAPIMockRecorder) MigratePiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) MigratePiece(ctx, task interface{}) *gomock.Call

MigratePiece indicates an expected call of MigratePiece.

func (*MockGfSpClientAPIMockRecorder) NotifyDestSPMigrateSwapOut added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) NotifyDestSPMigrateSwapOut(ctx, destEndpoint, swapOut interface{}) *gomock.Call

NotifyDestSPMigrateSwapOut indicates an expected call of NotifyDestSPMigrateSwapOut.

func (*MockGfSpClientAPIMockRecorder) NotifyMigrateSwapOut added in v0.2.4 

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

NotifyMigrateSwapOut indicates an expected call of NotifyMigrateSwapOut.

func (*MockGfSpClientAPIMockRecorder) P2PConn added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) P2PConn(ctx interface{}, opts ...interface{}) *gomock.Call

P2PConn indicates an expected call of P2PConn.

func (*MockGfSpClientAPIMockRecorder) PickVirtualGroupFamilyID added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) PickVirtualGroupFamilyID(ctx, task interface{}) *gomock.Call

PickVirtualGroupFamilyID indicates an expected call of PickVirtualGroupFamilyID.

func (*MockGfSpClientAPIMockRecorder) QueryBucketMigrate added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QueryBucketMigrate(ctx, endpoint interface{}, opts ...interface{}) *gomock.Call

QueryBucketMigrate indicates an expected call of QueryBucketMigrate.

func (*MockGfSpClientAPIMockRecorder) QueryP2PBootstrap added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QueryP2PBootstrap(ctx interface{}) *gomock.Call

QueryP2PBootstrap indicates an expected call of QueryP2PBootstrap.

func (*MockGfSpClientAPIMockRecorder) QuerySPExit added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QuerySPExit(ctx, endpoint interface{}, opts ...interface{}) *gomock.Call

QuerySPExit indicates an expected call of QuerySPExit.

func (*MockGfSpClientAPIMockRecorder) QueryTasks added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) QueryTasks(ctx, endpoint, subKey interface{}, opts ...interface{}) *gomock.Call

QueryTasks indicates an expected call of QueryTasks.

func (*MockGfSpClientAPIMockRecorder) RecoupQuota added in v0.2.5 

func (mr *MockGfSpClientAPIMockRecorder) RecoupQuota(ctx context.Context, bucketID, extraQuota, yearMonth interface{}, opts ...interface{}) *gomock.Call

func (*MockGfSpClientAPIMockRecorder) RejectUnSealObject added in v0.2.4 

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

RejectUnSealObject indicates an expected call of RejectUnSealObject.

func (*MockGfSpClientAPIMockRecorder) ReplicatePiece added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ReplicatePiece(ctx, task, data interface{}, opts ...interface{}) *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 interface{}) *gomock.Call

ReplicatePieceToSecondary indicates an expected call of ReplicatePieceToSecondary.

func (*MockGfSpClientAPIMockRecorder) ReportTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ReportTask(ctx, report interface{}) *gomock.Call

ReportTask indicates an expected call of ReportTask.

func (*MockGfSpClientAPIMockRecorder) ResumableUploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) ResumableUploadObject(ctx, task, stream interface{}, opts ...interface{}) *gomock.Call

ResumableUploadObject indicates an expected call of ResumableUploadObject.

func (*MockGfSpClientAPIMockRecorder) SPExit added in v0.2.4 

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

SPExit indicates an expected call of SPExit.

func (*MockGfSpClientAPIMockRecorder) SealObject added in v0.2.4 

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

SealObject indicates an expected call of SealObject.

func (*MockGfSpClientAPIMockRecorder) SignCreateBucketApproval added in v0.2.4 

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

SignCreateBucketApproval indicates an expected call of SignCreateBucketApproval.

func (*MockGfSpClientAPIMockRecorder) SignCreateObjectApproval added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignCreateObjectApproval(ctx, object interface{}) *gomock.Call

SignCreateObjectApproval indicates an expected call of SignCreateObjectApproval.

func (*MockGfSpClientAPIMockRecorder) SignMigrateBucketApproval added in v0.2.4 

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

SignMigrateBucketApproval indicates an expected call of SignMigrateBucketApproval.

func (*MockGfSpClientAPIMockRecorder) SignMigratePiece added in v0.2.4 

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

SignMigratePiece indicates an expected call of SignMigratePiece.

func (*MockGfSpClientAPIMockRecorder) SignP2PPingMsg added in v0.2.4 

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

SignP2PPingMsg indicates an expected call of SignP2PPingMsg.

func (*MockGfSpClientAPIMockRecorder) SignP2PPongMsg added in v0.2.4 

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

SignP2PPongMsg indicates an expected call of SignP2PPongMsg.

func (*MockGfSpClientAPIMockRecorder) SignReceiveTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignReceiveTask(ctx, receiveTask interface{}) *gomock.Call

SignReceiveTask indicates an expected call of SignReceiveTask.

func (*MockGfSpClientAPIMockRecorder) SignRecoveryTask added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignRecoveryTask(ctx, recoveryTask interface{}) *gomock.Call

SignRecoveryTask indicates an expected call of SignRecoveryTask.

func (*MockGfSpClientAPIMockRecorder) SignReplicatePieceApproval added in v0.2.4 

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

SignReplicatePieceApproval indicates an expected call of SignReplicatePieceApproval.

func (*MockGfSpClientAPIMockRecorder) SignSecondarySPMigrationBucket added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignSecondarySPMigrationBucket(ctx, signDoc interface{}) *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 interface{}) *gomock.Call

SignSecondarySealBls indicates an expected call of SignSecondarySealBls.

func (*MockGfSpClientAPIMockRecorder) SignSwapOut added in v0.2.4 

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

SignSwapOut indicates an expected call of SignSwapOut.

func (*MockGfSpClientAPIMockRecorder) SignerConn added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) SignerConn(ctx interface{}, opts ...interface{}) *gomock.Call

SignerConn indicates an expected call of SignerConn.

func (*MockGfSpClientAPIMockRecorder) SwapOut added in v0.2.4 

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

SwapOut indicates an expected call of SwapOut.

func (*MockGfSpClientAPIMockRecorder) UpdateSPPrice added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) UpdateSPPrice(ctx, price interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

UpdateUserPublicKey indicates an expected call of UpdateUserPublicKey.

func (*MockGfSpClientAPIMockRecorder) UploadObject added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) UploadObject(ctx, task, stream interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

VerifyGNFD1EddsaSignature indicates an expected call of VerifyGNFD1EddsaSignature.

func (*MockGfSpClientAPIMockRecorder) VerifyPermission added in v0.2.4 

func (mr *MockGfSpClientAPIMockRecorder) VerifyPermission(ctx, Operator, bucketName, objectName, actionType interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

Connection indicates an expected call of Connection.

func (*MockGfSpConnAPIMockRecorder) HTTPClient added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) HTTPClient(ctx interface{}) *gomock.Call

HTTPClient indicates an expected call of HTTPClient.

func (*MockGfSpConnAPIMockRecorder) ManagerConn added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) ManagerConn(ctx interface{}, opts ...interface{}) *gomock.Call

ManagerConn indicates an expected call of ManagerConn.

func (*MockGfSpConnAPIMockRecorder) P2PConn added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) P2PConn(ctx interface{}, opts ...interface{}) *gomock.Call

P2PConn indicates an expected call of P2PConn.

func (*MockGfSpConnAPIMockRecorder) SignerConn added in v0.2.4 

func (mr *MockGfSpConnAPIMockRecorder) SignerConn(ctx interface{}, opts ...interface{}) *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) NotifyMigrateSwapOut added in v0.2.4 

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

NotifyMigrateSwapOut 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 interface{}) *gomock.Call

AskTask indicates an expected call of AskTask.

func (*MockManagerAPIMockRecorder) CreateResumableUploadObject added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) CreateResumableUploadObject(ctx, task interface{}) *gomock.Call

CreateResumableUploadObject indicates an expected call of CreateResumableUploadObject.

func (*MockManagerAPIMockRecorder) CreateUploadObject added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) CreateUploadObject(ctx, task interface{}) *gomock.Call

CreateUploadObject indicates an expected call of CreateUploadObject.

func (*MockManagerAPIMockRecorder) NotifyMigrateSwapOut added in v0.2.4 

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

NotifyMigrateSwapOut indicates an expected call of NotifyMigrateSwapOut.

func (*MockManagerAPIMockRecorder) PickVirtualGroupFamilyID added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) PickVirtualGroupFamilyID(ctx, task interface{}) *gomock.Call

PickVirtualGroupFamilyID indicates an expected call of PickVirtualGroupFamilyID.

func (*MockManagerAPIMockRecorder) ReportTask added in v0.2.4 

func (mr *MockManagerAPIMockRecorder) ReportTask(ctx, report interface{}) *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) GetBucketMeta added in v0.2.4 

func (m *MockMetadataAPI) GetBucketMeta(ctx context.Context, bucketName string, includePrivate bool, opts ...grpc.DialOption) (*types.Bucket, *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, error)

GetBucketReadQuota 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) 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) 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) 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.StreamRecordMeta, 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) 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 interface{}, opts ...interface{}) *gomock.Call

GetBucketByBucketID indicates an expected call of GetBucketByBucketID.

func (*MockMetadataAPIMockRecorder) GetBucketByBucketName added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetBucketByBucketName(ctx, bucketName, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetBucketByBucketName indicates an expected call of GetBucketByBucketName.

func (*MockMetadataAPIMockRecorder) GetBucketMeta added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetBucketMeta(ctx, bucketName, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetBucketMeta indicates an expected call of GetBucketMeta.

func (*MockMetadataAPIMockRecorder) GetBucketReadQuota added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetBucketReadQuota(ctx, bucket, yearMonth interface{}, opts ...interface{}) *gomock.Call

GetBucketReadQuota indicates an expected call of GetBucketReadQuota.

func (*MockMetadataAPIMockRecorder) GetEndpointBySpID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetEndpointBySpID(ctx, spID interface{}, opts ...interface{}) *gomock.Call

GetEndpointBySpID indicates an expected call of GetEndpointBySpID.

func (*MockMetadataAPIMockRecorder) GetGlobalVirtualGroup added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetGlobalVirtualGroup(ctx, bucketID, lvgID interface{}, opts ...interface{}) *gomock.Call

GetGlobalVirtualGroup indicates an expected call of GetGlobalVirtualGroup.

func (*MockMetadataAPIMockRecorder) GetGlobalVirtualGroupByGvgID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetGlobalVirtualGroupByGvgID(ctx, gvgID interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

GetGroupMembers indicates an expected call of GetGroupMembers.

func (*MockMetadataAPIMockRecorder) GetObjectByID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetObjectByID(ctx, objectID interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

GetObjectMeta indicates an expected call of GetObjectMeta.

func (*MockMetadataAPIMockRecorder) GetPaymentByBucketID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetPaymentByBucketID(ctx, bucketID, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetPaymentByBucketID indicates an expected call of GetPaymentByBucketID.

func (*MockMetadataAPIMockRecorder) GetPaymentByBucketName added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetPaymentByBucketName(ctx, bucketName, includePrivate interface{}, opts ...interface{}) *gomock.Call

GetPaymentByBucketName indicates an expected call of GetPaymentByBucketName.

func (*MockMetadataAPIMockRecorder) GetSPInfo added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetSPInfo(ctx, operatorAddress interface{}, opts ...interface{}) *gomock.Call

GetSPInfo indicates an expected call of GetSPInfo.

func (*MockMetadataAPIMockRecorder) GetSPMigratingBucketNumber added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) GetSPMigratingBucketNumber(ctx, spID interface{}, opts ...interface{}) *gomock.Call

GetSPMigratingBucketNumber indicates an expected call of GetSPMigratingBucketNumber.

func (*MockMetadataAPIMockRecorder) GetStatus added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetStatus(ctx interface{}, opts ...interface{}) *gomock.Call

GetStatus indicates an expected call of GetStatus.

func (*MockMetadataAPIMockRecorder) GetUploadObjectSegment added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUploadObjectSegment(ctx, objectID interface{}, opts ...interface{}) *gomock.Call

GetUploadObjectSegment indicates an expected call of GetUploadObjectSegment.

func (*MockMetadataAPIMockRecorder) GetUploadObjectState added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUploadObjectState(ctx, objectID interface{}, opts ...interface{}) *gomock.Call

GetUploadObjectState indicates an expected call of GetUploadObjectState.

func (*MockMetadataAPIMockRecorder) GetUserBuckets added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUserBuckets(ctx, account, includeRemoved interface{}, opts ...interface{}) *gomock.Call

GetUserBuckets indicates an expected call of GetUserBuckets.

func (*MockMetadataAPIMockRecorder) GetUserBucketsCount added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetUserBucketsCount(ctx, account, includeRemoved interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

GetUserOwnedGroups indicates an expected call of GetUserOwnedGroups.

func (*MockMetadataAPIMockRecorder) GetVirtualGroupFamily added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) GetVirtualGroupFamily(ctx, vgfID interface{}, opts ...interface{}) *gomock.Call

GetVirtualGroupFamily indicates an expected call of GetVirtualGroupFamily.

func (*MockMetadataAPIMockRecorder) ListBucketReadRecord added in v0.2.4 

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

ListBucketReadRecord indicates an expected call of ListBucketReadRecord.

func (*MockMetadataAPIMockRecorder) ListBucketsByIDs added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListBucketsByIDs(ctx, bucketIDs, includeRemoved interface{}, opts ...interface{}) *gomock.Call

ListBucketsByIDs indicates an expected call of ListBucketsByIDs.

func (*MockMetadataAPIMockRecorder) ListDeletedObjectsByBlockNumberRange added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListDeletedObjectsByBlockNumberRange(ctx, spOperatorAddress, startBlockNumber, endBlockNumber, includePrivate interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

ListExpiredBucketsBySp indicates an expected call of ListExpiredBucketsBySp.

func (*MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsByBucket added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsByBucket(ctx, bucketID interface{}, opts ...interface{}) *gomock.Call

ListGlobalVirtualGroupsByBucket indicates an expected call of ListGlobalVirtualGroupsByBucket.

func (*MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListGlobalVirtualGroupsBySecondarySP(ctx, spID interface{}, opts ...interface{}) *gomock.Call

ListGlobalVirtualGroupsBySecondarySP indicates an expected call of ListGlobalVirtualGroupsBySecondarySP.

func (*MockMetadataAPIMockRecorder) ListGroupsByIDs added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) ListGroupsByIDs(ctx, groupIDs interface{}, opts ...interface{}) *gomock.Call

ListGroupsByIDs indicates an expected call of ListGroupsByIDs.

func (*MockMetadataAPIMockRecorder) ListMigrateBucketEvents added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListMigrateBucketEvents(ctx, blockID, spID interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

ListObjectsByGVGAndBucketForGC indicates an expected call of ListObjectsByGVGAndBucketForGC.

func (*MockMetadataAPIMockRecorder) ListObjectsByIDs added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListObjectsByIDs(ctx, objectIDs, includeRemoved interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

ListObjectsInGVGAndBucket indicates an expected call of ListObjectsInGVGAndBucket.

func (*MockMetadataAPIMockRecorder) ListPaymentAccountStreams added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) ListPaymentAccountStreams(ctx, paymentAccount interface{}, opts ...interface{}) *gomock.Call

ListPaymentAccountStreams indicates an expected call of ListPaymentAccountStreams.

func (*MockMetadataAPIMockRecorder) ListSpExitEvents added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListSpExitEvents(ctx, blockID, spID interface{}, opts ...interface{}) *gomock.Call

ListSpExitEvents indicates an expected call of ListSpExitEvents.

func (*MockMetadataAPIMockRecorder) ListSwapOutEvents added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListSwapOutEvents(ctx, blockID, spID interface{}, opts ...interface{}) *gomock.Call

ListSwapOutEvents indicates an expected call of ListSwapOutEvents.

func (*MockMetadataAPIMockRecorder) ListUserPaymentAccounts added in v0.2.5 

func (mr *MockMetadataAPIMockRecorder) ListUserPaymentAccounts(ctx, accountID interface{}, opts ...interface{}) *gomock.Call

ListUserPaymentAccounts indicates an expected call of ListUserPaymentAccounts.

func (*MockMetadataAPIMockRecorder) ListVirtualGroupFamiliesSpID added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) ListVirtualGroupFamiliesSpID(ctx, spID interface{}, opts ...interface{}) *gomock.Call

ListVirtualGroupFamiliesSpID indicates an expected call of ListVirtualGroupFamiliesSpID.

func (*MockMetadataAPIMockRecorder) VerifyPermission added in v0.2.4 

func (mr *MockMetadataAPIMockRecorder) VerifyPermission(ctx, Operator, bucketName, objectName, actionType interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *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 interface{}) *gomock.Call

AskSecondaryReplicatePieceApproval indicates an expected call of AskSecondaryReplicatePieceApproval.

func (*MockP2PAPIMockRecorder) QueryP2PBootstrap added in v0.2.4 

func (mr *MockP2PAPIMockRecorder) QueryP2PBootstrap(ctx interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

QueryBucketMigrate indicates an expected call of QueryBucketMigrate.

func (*MockQueryAPIMockRecorder) QuerySPExit added in v0.2.4 

func (mr *MockQueryAPIMockRecorder) QuerySPExit(ctx, endpoint interface{}, opts ...interface{}) *gomock.Call

QuerySPExit indicates an expected call of QuerySPExit.

func (*MockQueryAPIMockRecorder) QueryTasks added in v0.2.4 

func (mr *MockQueryAPIMockRecorder) QueryTasks(ctx, endpoint, subKey interface{}, opts ...interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

DoneReplicatePiece indicates an expected call of DoneReplicatePiece.

func (*MockReceiverAPIMockRecorder) ReplicatePiece added in v0.2.4 

func (mr *MockReceiverAPIMockRecorder) ReplicatePiece(ctx, task, data interface{}, opts ...interface{}) *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) 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) 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) RejectUnSealObject added in v0.2.4 

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

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

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

SignMigratePiece 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 interface{}) *gomock.Call

CompleteMigrateBucket indicates an expected call of CompleteMigrateBucket.

func (*MockSignerAPIMockRecorder) CompleteSPExit added in v0.2.4 

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

CompleteSPExit indicates an expected call of CompleteSPExit.

func (*MockSignerAPIMockRecorder) CompleteSwapOut added in v0.2.4 

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

CompleteSwapOut indicates an expected call of CompleteSwapOut.

func (*MockSignerAPIMockRecorder) CreateGlobalVirtualGroup added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) CreateGlobalVirtualGroup(ctx, group interface{}) *gomock.Call

CreateGlobalVirtualGroup indicates an expected call of CreateGlobalVirtualGroup.

func (*MockSignerAPIMockRecorder) DiscontinueBucket added in v0.2.4 

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

DiscontinueBucket indicates an expected call of DiscontinueBucket.

func (*MockSignerAPIMockRecorder) RejectUnSealObject added in v0.2.4 

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

RejectUnSealObject indicates an expected call of RejectUnSealObject.

func (*MockSignerAPIMockRecorder) SPExit added in v0.2.4 

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

SPExit indicates an expected call of SPExit.

func (*MockSignerAPIMockRecorder) SealObject added in v0.2.4 

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

SealObject indicates an expected call of SealObject.

func (*MockSignerAPIMockRecorder) SignCreateBucketApproval added in v0.2.4 

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

SignCreateBucketApproval indicates an expected call of SignCreateBucketApproval.

func (*MockSignerAPIMockRecorder) SignCreateObjectApproval added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignCreateObjectApproval(ctx, object interface{}) *gomock.Call

SignCreateObjectApproval indicates an expected call of SignCreateObjectApproval.

func (*MockSignerAPIMockRecorder) SignMigrateBucketApproval added in v0.2.4 

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

SignMigrateBucketApproval indicates an expected call of SignMigrateBucketApproval.

func (*MockSignerAPIMockRecorder) SignMigratePiece added in v0.2.4 

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

SignMigratePiece indicates an expected call of SignMigratePiece.

func (*MockSignerAPIMockRecorder) SignP2PPingMsg added in v0.2.4 

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

SignP2PPingMsg indicates an expected call of SignP2PPingMsg.

func (*MockSignerAPIMockRecorder) SignP2PPongMsg added in v0.2.4 

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

SignP2PPongMsg indicates an expected call of SignP2PPongMsg.

func (*MockSignerAPIMockRecorder) SignReceiveTask added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignReceiveTask(ctx, receiveTask interface{}) *gomock.Call

SignReceiveTask indicates an expected call of SignReceiveTask.

func (*MockSignerAPIMockRecorder) SignRecoveryTask added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignRecoveryTask(ctx, recoveryTask interface{}) *gomock.Call

SignRecoveryTask indicates an expected call of SignRecoveryTask.

func (*MockSignerAPIMockRecorder) SignReplicatePieceApproval added in v0.2.4 

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

SignReplicatePieceApproval indicates an expected call of SignReplicatePieceApproval.

func (*MockSignerAPIMockRecorder) SignSecondarySPMigrationBucket added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) SignSecondarySPMigrationBucket(ctx, signDoc interface{}) *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 interface{}) *gomock.Call

SignSecondarySealBls indicates an expected call of SignSecondarySealBls.

func (*MockSignerAPIMockRecorder) SignSwapOut added in v0.2.4 

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

SignSwapOut indicates an expected call of SignSwapOut.

func (*MockSignerAPIMockRecorder) SwapOut added in v0.2.4 

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

SwapOut indicates an expected call of SwapOut.

func (*MockSignerAPIMockRecorder) UpdateSPPrice added in v0.2.4 

func (mr *MockSignerAPIMockRecorder) UpdateSPPrice(ctx, price interface{}) *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 interface{}, opts ...interface{}) *gomock.Call

ResumableUploadObject indicates an expected call of ResumableUploadObject.

func (*MockUploaderAPIMockRecorder) UploadObject added in v0.2.4 

func (mr *MockUploaderAPIMockRecorder) UploadObject(ctx, task, stream interface{}, opts ...interface{}) *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 interface{}) *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)
	SealObject(ctx context.Context, object *storagetypes.MsgSealObject) (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)
	SignMigratePiece(ctx context.Context, task *gfsptask.GfSpMigratePieceTask) ([]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)
}

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.