spdb

package
v1.5.1 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2024 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Overview

Package spdb is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BucketFreeQuota added in v0.2.3 

type BucketFreeQuota struct {
	QuotaSize uint64
}

BucketFreeQuota defines free quota of a bucket.

type BucketQuota 

type BucketQuota struct {
	ChargedQuotaSize uint64 // the charged quota of bucket on greenfield chain meta
	FreeQuotaSize    uint64 // the free quota of SP on greenfield chain
}

BucketQuota defines read quota of a bucket.

type BucketTraffic 

type BucketTraffic struct {
	BucketID              uint64
	YearMonth             string
	BucketName            string
	ReadConsumedSize      uint64
	FreeQuotaSize         uint64 // the total free quota size of SP price meta
	FreeQuotaConsumedSize uint64 // the consumed free quota size
	ChargedQuotaSize      uint64 // the total charged quota of bucket
	ModifyTime            int64
}

BucketTraffic is record traffic by year and month.

type ExitRecoverDB added in v1.3.0 

type ExitRecoverDB interface {
	// GetRecoverGVGStats return recover gvg stats
	GetRecoverGVGStats(gvgID uint32) (*RecoverGVGStats, error)
	// BatchGetRecoverGVGStats return recover gvg stats list
	BatchGetRecoverGVGStats(gvgID []uint32) ([]*RecoverGVGStats, error)
	// SetRecoverGVGStats insert a recover gvg stats unit
	SetRecoverGVGStats(stats []*RecoverGVGStats) error
	// UpdateRecoverGVGStats update recover gvg stats
	UpdateRecoverGVGStats(stats *RecoverGVGStats) (err error)
	// DeleteRecoverGVGStats delete recover gvg stats
	DeleteRecoverGVGStats(gvgID uint32) (err error)

	// InsertRecoverFailedObject inserts a new failed object unit.
	InsertRecoverFailedObject(object *RecoverFailedObject) error
	// UpdateRecoverFailedObject update failed object unit
	UpdateRecoverFailedObject(object *RecoverFailedObject) (err error)
	// DeleteRecoverFailedObject delete failed object unit
	DeleteRecoverFailedObject(objectID uint64) (err error)
	// GetRecoverFailedObject return the failed object.
	GetRecoverFailedObject(objectID uint64) (*RecoverFailedObject, error)
	// GetRecoverFailedObjects return the failed object by retry time
	GetRecoverFailedObjects(retry, limit uint32) ([]*RecoverFailedObject, error)
	// GetRecoverFailedObjectsByRetryTime return the failed object by retry time
	GetRecoverFailedObjectsByRetryTime(retry uint32) ([]*RecoverFailedObject, error)
	// CountRecoverFailedObject return the failed object total count
	CountRecoverFailedObject() (int64, error)
}

ExitRecoverDB is used to support sp exit and recover resource.

type GCObjectMeta 

type GCObjectMeta struct {
	TaskKey             string
	StartBlockHeight    uint64
	EndBlockHeight      uint64
	CurrentBlockHeight  uint64
	LastDeletedObjectID uint64
}

GCObjectMeta defines the gc object range progress info.

type GCObjectProgressDB 

type GCObjectProgressDB interface {
	// InsertGCObjectProgress inserts a new gc object progress.
	InsertGCObjectProgress(gcMeta *GCObjectMeta) error
	// DeleteGCObjectProgress deletes the gc object progress.
	DeleteGCObjectProgress(taskKey string) error
	// UpdateGCObjectProgress updates the gc object progress.
	UpdateGCObjectProgress(gcMeta *GCObjectMeta) error
	// GetGCMetasToGC queries the latest gc meta to continue gc.
	// It is only used in startup.
	GetGCMetasToGC(limit int) ([]*GCObjectMeta, error)
}

GCObjectProgressDB interface which records gc object related progress.

type GCPieceMeta added in v1.2.0 

type GCPieceMeta struct {
	ObjectID        uint64
	SegmentIndex    uint32
	RedundancyIndex int32
	PieceChecksum   string
	Version         int64 // the version is used to locate the correct piece in Piece Store.  Default is 0.
}

GCPieceMeta defines the gc piece with segment index and piece checksum.

type IntegrityMeta 

type IntegrityMeta struct {
	ObjectID          uint64
	RedundancyIndex   int32
	IntegrityChecksum []byte
	PieceChecksumList [][]byte
}

IntegrityMeta defines the payload integrity hash and piece checksum with objectID.

type MigrateBucketProgressMeta added in v1.3.0 

type MigrateBucketProgressMeta struct {
	BucketID              uint64 // as primary key
	SubscribedBlockHeight uint64
	MigrateState          int

	TotalGvgNum            uint32 // Total number of GVGs that need to be migrated
	MigratedFinishedGvgNum uint32 // Number of successfully migrated GVGs
	GcFinishedGvgNum       uint32 // Number of successfully gc finished GVGs

	PreDeductedQuota uint64 // Quota pre-deducted by the source sp in the pre-migrate bucket phase
	RecoupQuota      uint64 // In case of migration failure, the dest sp recoup the quota for the source sp

	LastGcObjectID uint64 // After bucket migration is complete, the progress of GC, up to which object is GC performed.
	LastGcGvgID    uint64 // which GVG is GC performed.
}

MigrateBucketProgressMeta is used to record migrate bucket progress meta.

type MigrateDB added in v0.2.3 

type MigrateDB interface {
	// UpdateSPExitSubscribeProgress includes insert and update.
	UpdateSPExitSubscribeProgress(blockHeight uint64) error
	// QuerySPExitSubscribeProgress returns blockHeight which is called at startup.
	QuerySPExitSubscribeProgress() (uint64, error)
	// UpdateSwapOutSubscribeProgress includes insert and update.
	UpdateSwapOutSubscribeProgress(blockHeight uint64) error
	// QuerySwapOutSubscribeProgress returns blockHeight which is called at startup.
	QuerySwapOutSubscribeProgress() (uint64, error)
	// UpdateBucketMigrateSubscribeProgress includes insert and update.
	UpdateBucketMigrateSubscribeProgress(blockHeight uint64) error
	// UpdateBucketMigrateGCSubscribeProgress includes insert and update.
	UpdateBucketMigrateGCSubscribeProgress(blockHeight uint64) error
	// QueryBucketMigrateSubscribeProgress returns blockHeight which is called at startup.
	QueryBucketMigrateSubscribeProgress() (uint64, error)

	// InsertSwapOutUnit is used to insert a swap out unit.
	InsertSwapOutUnit(meta *SwapOutMeta) error
	// UpdateSwapOutUnitCompletedGVGList is used to record dest swap out progress, manager restart can load it.
	UpdateSwapOutUnitCompletedGVGList(swapOutKey string, completedGVGList []uint32) error
	// QuerySwapOutUnitInSrcSP is used to rebuild swap out plan at startup.
	QuerySwapOutUnitInSrcSP(swapOutKey string) (*SwapOutMeta, error)
	// ListDestSPSwapOutUnits is used to rebuild swap out plan at startup.
	ListDestSPSwapOutUnits() ([]*SwapOutMeta, error)

	// InsertMigrateGVGUnit inserts a new gvg migrate unit.
	InsertMigrateGVGUnit(meta *MigrateGVGUnitMeta) error
	// DeleteMigrateGVGUnit deletes the gvg migrate unit.
	DeleteMigrateGVGUnit(meta *MigrateGVGUnitMeta) error
	// UpdateMigrateGVGUnitStatus updates gvg unit status.
	UpdateMigrateGVGUnitStatus(migrateKey string, migrateStatus int) error
	// UpdateMigrateGVGUnitLastMigrateObjectID updates gvg unit LastMigrateObjectID.
	UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey string, lastMigrateObjectID uint64) error
	// UpdateMigrateGVGRetryCount updates gvg unit retry time
	UpdateMigrateGVGRetryCount(migrateKey string, retryTime int) error
	// UpdateMigrateGVGMigratedBytesSize updates gvg unit retry time
	UpdateMigrateGVGMigratedBytesSize(migrateKey string, migratedBytes uint64) error
	// QueryMigrateGVGUnit returns the gvg migrate unit info.
	QueryMigrateGVGUnit(migrateKey string) (*MigrateGVGUnitMeta, error)
	// ListMigrateGVGUnitsByBucketID is used to load at dest sp startup(bucket migrate).
	ListMigrateGVGUnitsByBucketID(bucketID uint64) ([]*MigrateGVGUnitMeta, error)
	// DeleteMigrateGVGUnitsByBucketID is used to delete migrate gvg units at bucket migrate
	DeleteMigrateGVGUnitsByBucketID(bucketID uint64) error

	// UpdateBucketMigrationProgress update MigrateBucketProgress migrate state.
	UpdateBucketMigrationProgress(bucketID uint64, migrateState int) error
	// UpdateBucketMigrationPreDeductedQuota update pre-deducted quota and migration state when src sp receives a preMigrateBucket request.
	UpdateBucketMigrationPreDeductedQuota(bucketID uint64, deductedQuota uint64, state int) error
	// UpdateBucketMigrationRecoupQuota update RecoupQuota and the corresponding state in MigrateBucketProgress.
	UpdateBucketMigrationRecoupQuota(bucketID uint64, recoupQuota uint64, state int) error
	// UpdateBucketMigrationGCProgress update bucket migration gc progress
	UpdateBucketMigrationGCProgress(progressMeta MigrateBucketProgressMeta) error
	// UpdateBucketMigrationMigratingProgress update bucket migration migrating progress
	UpdateBucketMigrationMigratingProgress(bucketID uint64, gvgUnits uint32, gvgUnitsFinished uint32) error
	// QueryMigrateBucketState returns the migrate state.
	QueryMigrateBucketState(bucketID uint64) (int, error)
	// QueryMigrateBucketProgress returns the migration progress.
	QueryMigrateBucketProgress(bucketID uint64) (*MigrateBucketProgressMeta, error)
	// ListBucketMigrationToConfirm returns the migrate bucket id to be confirmed.
	ListBucketMigrationToConfirm(migrationStates []int) ([]*MigrateBucketProgressMeta, error)
	// DeleteMigrateBucket delete the bucket migrate status
	DeleteMigrateBucket(bucketID uint64) error
}

MigrateDB is used to support sp exit and bucket migrate.

type MigrateGVGUnitMeta added in v0.2.3 

type MigrateGVGUnitMeta struct {
	MigrateGVGKey            string // as primary key
	SwapOutKey               string
	GlobalVirtualGroupID     uint32 // is used by sp exit/bucket migrate
	DestGlobalVirtualGroupID uint32 // is used by bucket migrate
	VirtualGroupFamilyID     uint32 // is used by sp exit
	RedundancyIndex          int32  // is used by sp exit
	BucketID                 uint64 // is used by bucket migrate
	SrcSPID                  uint32
	DestSPID                 uint32
	LastMigratedObjectID     uint64
	MigrateStatus            int    // scheduler assign unit status.
	RetryTime                int    //
	MigratedBytesSize        uint64 // migrated bytes
}

MigrateGVGUnitMeta is used to record migrate type/meta/status/progress.

type MockExitRecoverDB added in v1.3.0 

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

MockExitRecoverDB is a mock of ExitRecoverDB interface.

func NewMockExitRecoverDB added in v1.3.0 

func NewMockExitRecoverDB(ctrl *gomock.Controller) *MockExitRecoverDB

NewMockExitRecoverDB creates a new mock instance.

func (*MockExitRecoverDB) BatchGetRecoverGVGStats added in v1.3.0 

func (m *MockExitRecoverDB) BatchGetRecoverGVGStats(gvgID []uint32) ([]*RecoverGVGStats, error)

BatchGetRecoverGVGStats mocks base method.

func (*MockExitRecoverDB) CountRecoverFailedObject added in v1.3.0 

func (m *MockExitRecoverDB) CountRecoverFailedObject() (int64, error)

CountRecoverFailedObject mocks base method.

func (*MockExitRecoverDB) DeleteRecoverFailedObject added in v1.3.0 

func (m *MockExitRecoverDB) DeleteRecoverFailedObject(objectID uint64) error

DeleteRecoverFailedObject mocks base method.

func (*MockExitRecoverDB) DeleteRecoverGVGStats added in v1.3.0 

func (m *MockExitRecoverDB) DeleteRecoverGVGStats(gvgID uint32) error

DeleteRecoverGVGStats mocks base method.

func (*MockExitRecoverDB) EXPECT added in v1.3.0 

func (m *MockExitRecoverDB) EXPECT() *MockExitRecoverDBMockRecorder

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

func (*MockExitRecoverDB) GetRecoverFailedObject added in v1.3.0 

func (m *MockExitRecoverDB) GetRecoverFailedObject(objectID uint64) (*RecoverFailedObject, error)

GetRecoverFailedObject mocks base method.

func (*MockExitRecoverDB) GetRecoverFailedObjects added in v1.3.0 

func (m *MockExitRecoverDB) GetRecoverFailedObjects(retry, limit uint32) ([]*RecoverFailedObject, error)

GetRecoverFailedObjects mocks base method.

func (*MockExitRecoverDB) GetRecoverFailedObjectsByRetryTime added in v1.3.0 

func (m *MockExitRecoverDB) GetRecoverFailedObjectsByRetryTime(retry uint32) ([]*RecoverFailedObject, error)

GetRecoverFailedObjectsByRetryTime mocks base method.

func (*MockExitRecoverDB) GetRecoverGVGStats added in v1.3.0 

func (m *MockExitRecoverDB) GetRecoverGVGStats(gvgID uint32) (*RecoverGVGStats, error)

GetRecoverGVGStats mocks base method.

func (*MockExitRecoverDB) InsertRecoverFailedObject added in v1.3.0 

func (m *MockExitRecoverDB) InsertRecoverFailedObject(object *RecoverFailedObject) error

InsertRecoverFailedObject mocks base method.

func (*MockExitRecoverDB) SetRecoverGVGStats added in v1.3.0 

func (m *MockExitRecoverDB) SetRecoverGVGStats(stats []*RecoverGVGStats) error

SetRecoverGVGStats mocks base method.

func (*MockExitRecoverDB) UpdateRecoverFailedObject added in v1.3.0 

func (m *MockExitRecoverDB) UpdateRecoverFailedObject(object *RecoverFailedObject) error

UpdateRecoverFailedObject mocks base method.

func (*MockExitRecoverDB) UpdateRecoverGVGStats added in v1.3.0 

func (m *MockExitRecoverDB) UpdateRecoverGVGStats(stats *RecoverGVGStats) error

UpdateRecoverGVGStats mocks base method.

type MockExitRecoverDBMockRecorder added in v1.3.0 

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

MockExitRecoverDBMockRecorder is the mock recorder for MockExitRecoverDB.

func (*MockExitRecoverDBMockRecorder) BatchGetRecoverGVGStats added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) BatchGetRecoverGVGStats(gvgID any) *gomock.Call

BatchGetRecoverGVGStats indicates an expected call of BatchGetRecoverGVGStats.

func (*MockExitRecoverDBMockRecorder) CountRecoverFailedObject added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) CountRecoverFailedObject() *gomock.Call

CountRecoverFailedObject indicates an expected call of CountRecoverFailedObject.

func (*MockExitRecoverDBMockRecorder) DeleteRecoverFailedObject added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) DeleteRecoverFailedObject(objectID any) *gomock.Call

DeleteRecoverFailedObject indicates an expected call of DeleteRecoverFailedObject.

func (*MockExitRecoverDBMockRecorder) DeleteRecoverGVGStats added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) DeleteRecoverGVGStats(gvgID any) *gomock.Call

DeleteRecoverGVGStats indicates an expected call of DeleteRecoverGVGStats.

func (*MockExitRecoverDBMockRecorder) GetRecoverFailedObject added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) GetRecoverFailedObject(objectID any) *gomock.Call

GetRecoverFailedObject indicates an expected call of GetRecoverFailedObject.

func (*MockExitRecoverDBMockRecorder) GetRecoverFailedObjects added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) GetRecoverFailedObjects(retry, limit any) *gomock.Call

GetRecoverFailedObjects indicates an expected call of GetRecoverFailedObjects.

func (*MockExitRecoverDBMockRecorder) GetRecoverFailedObjectsByRetryTime added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) GetRecoverFailedObjectsByRetryTime(retry any) *gomock.Call

GetRecoverFailedObjectsByRetryTime indicates an expected call of GetRecoverFailedObjectsByRetryTime.

func (*MockExitRecoverDBMockRecorder) GetRecoverGVGStats added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) GetRecoverGVGStats(gvgID any) *gomock.Call

GetRecoverGVGStats indicates an expected call of GetRecoverGVGStats.

func (*MockExitRecoverDBMockRecorder) InsertRecoverFailedObject added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) InsertRecoverFailedObject(object any) *gomock.Call

InsertRecoverFailedObject indicates an expected call of InsertRecoverFailedObject.

func (*MockExitRecoverDBMockRecorder) SetRecoverGVGStats added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) SetRecoverGVGStats(stats any) *gomock.Call

SetRecoverGVGStats indicates an expected call of SetRecoverGVGStats.

func (*MockExitRecoverDBMockRecorder) UpdateRecoverFailedObject added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) UpdateRecoverFailedObject(object any) *gomock.Call

UpdateRecoverFailedObject indicates an expected call of UpdateRecoverFailedObject.

func (*MockExitRecoverDBMockRecorder) UpdateRecoverGVGStats added in v1.3.0 

func (mr *MockExitRecoverDBMockRecorder) UpdateRecoverGVGStats(stats any) *gomock.Call

UpdateRecoverGVGStats indicates an expected call of UpdateRecoverGVGStats.

type MockGCObjectProgressDB 

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

MockGCObjectProgressDB is a mock of GCObjectProgressDB interface.

func NewMockGCObjectProgressDB 

func NewMockGCObjectProgressDB(ctrl *gomock.Controller) *MockGCObjectProgressDB

NewMockGCObjectProgressDB creates a new mock instance.

func (*MockGCObjectProgressDB) DeleteGCObjectProgress 

func (m *MockGCObjectProgressDB) DeleteGCObjectProgress(taskKey string) error

DeleteGCObjectProgress mocks base method.

func (*MockGCObjectProgressDB) EXPECT 

func (m *MockGCObjectProgressDB) EXPECT() *MockGCObjectProgressDBMockRecorder

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

func (*MockGCObjectProgressDB) GetGCMetasToGC added in v0.2.3 

func (m *MockGCObjectProgressDB) GetGCMetasToGC(limit int) ([]*GCObjectMeta, error)

GetGCMetasToGC mocks base method.

func (*MockGCObjectProgressDB) InsertGCObjectProgress added in v0.2.3 

func (m *MockGCObjectProgressDB) InsertGCObjectProgress(gcMeta *GCObjectMeta) error

InsertGCObjectProgress mocks base method.

func (*MockGCObjectProgressDB) UpdateGCObjectProgress added in v0.2.3 

func (m *MockGCObjectProgressDB) UpdateGCObjectProgress(gcMeta *GCObjectMeta) error

UpdateGCObjectProgress mocks base method.

type MockGCObjectProgressDBMockRecorder 

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

MockGCObjectProgressDBMockRecorder is the mock recorder for MockGCObjectProgressDB.

func (*MockGCObjectProgressDBMockRecorder) DeleteGCObjectProgress 

func (mr *MockGCObjectProgressDBMockRecorder) DeleteGCObjectProgress(taskKey any) *gomock.Call

DeleteGCObjectProgress indicates an expected call of DeleteGCObjectProgress.

func (*MockGCObjectProgressDBMockRecorder) GetGCMetasToGC added in v0.2.3 

func (mr *MockGCObjectProgressDBMockRecorder) GetGCMetasToGC(limit any) *gomock.Call

GetGCMetasToGC indicates an expected call of GetGCMetasToGC.

func (*MockGCObjectProgressDBMockRecorder) InsertGCObjectProgress added in v0.2.3 

func (mr *MockGCObjectProgressDBMockRecorder) InsertGCObjectProgress(gcMeta any) *gomock.Call

InsertGCObjectProgress indicates an expected call of InsertGCObjectProgress.

func (*MockGCObjectProgressDBMockRecorder) UpdateGCObjectProgress added in v0.2.3 

func (mr *MockGCObjectProgressDBMockRecorder) UpdateGCObjectProgress(gcMeta any) *gomock.Call

UpdateGCObjectProgress indicates an expected call of UpdateGCObjectProgress.

type MockMigrateDB added in v0.2.3 

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

MockMigrateDB is a mock of MigrateDB interface.

func NewMockMigrateDB added in v0.2.3 

func NewMockMigrateDB(ctrl *gomock.Controller) *MockMigrateDB

NewMockMigrateDB creates a new mock instance.

func (*MockMigrateDB) DeleteMigrateBucket added in v1.3.0 

func (m *MockMigrateDB) DeleteMigrateBucket(bucketID uint64) error

DeleteMigrateBucket mocks base method.

func (*MockMigrateDB) DeleteMigrateGVGUnit added in v0.2.3 

func (m *MockMigrateDB) DeleteMigrateGVGUnit(meta *MigrateGVGUnitMeta) error

DeleteMigrateGVGUnit mocks base method.

func (*MockMigrateDB) DeleteMigrateGVGUnitsByBucketID added in v0.2.4 

func (m *MockMigrateDB) DeleteMigrateGVGUnitsByBucketID(bucketID uint64) error

DeleteMigrateGVGUnitsByBucketID mocks base method.

func (*MockMigrateDB) EXPECT added in v0.2.3 

func (m *MockMigrateDB) EXPECT() *MockMigrateDBMockRecorder

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

func (*MockMigrateDB) InsertMigrateGVGUnit added in v0.2.3 

func (m *MockMigrateDB) InsertMigrateGVGUnit(meta *MigrateGVGUnitMeta) error

InsertMigrateGVGUnit mocks base method.

func (*MockMigrateDB) InsertSwapOutUnit added in v0.2.3 

func (m *MockMigrateDB) InsertSwapOutUnit(meta *SwapOutMeta) error

InsertSwapOutUnit mocks base method.

func (*MockMigrateDB) ListBucketMigrationToConfirm added in v1.3.0 

func (m *MockMigrateDB) ListBucketMigrationToConfirm(migrationStates []int) ([]*MigrateBucketProgressMeta, error)

ListBucketMigrationToConfirm mocks base method.

func (*MockMigrateDB) ListDestSPSwapOutUnits added in v0.2.3 

func (m *MockMigrateDB) ListDestSPSwapOutUnits() ([]*SwapOutMeta, error)

ListDestSPSwapOutUnits mocks base method.

func (*MockMigrateDB) ListMigrateGVGUnitsByBucketID added in v0.2.3 

func (m *MockMigrateDB) ListMigrateGVGUnitsByBucketID(bucketID uint64) ([]*MigrateGVGUnitMeta, error)

ListMigrateGVGUnitsByBucketID mocks base method.

func (*MockMigrateDB) QueryBucketMigrateSubscribeProgress added in v0.2.3 

func (m *MockMigrateDB) QueryBucketMigrateSubscribeProgress() (uint64, error)

QueryBucketMigrateSubscribeProgress mocks base method.

func (*MockMigrateDB) QueryMigrateBucketProgress added in v1.3.0 

func (m *MockMigrateDB) QueryMigrateBucketProgress(bucketID uint64) (*MigrateBucketProgressMeta, error)

QueryMigrateBucketProgress mocks base method.

func (*MockMigrateDB) QueryMigrateBucketState added in v1.3.0 

func (m *MockMigrateDB) QueryMigrateBucketState(bucketID uint64) (int, error)

QueryMigrateBucketState mocks base method.

func (*MockMigrateDB) QueryMigrateGVGUnit added in v0.2.3 

func (m *MockMigrateDB) QueryMigrateGVGUnit(migrateKey string) (*MigrateGVGUnitMeta, error)

QueryMigrateGVGUnit mocks base method.

func (*MockMigrateDB) QuerySPExitSubscribeProgress added in v0.2.3 

func (m *MockMigrateDB) QuerySPExitSubscribeProgress() (uint64, error)

QuerySPExitSubscribeProgress mocks base method.

func (*MockMigrateDB) QuerySwapOutSubscribeProgress added in v0.2.3 

func (m *MockMigrateDB) QuerySwapOutSubscribeProgress() (uint64, error)

QuerySwapOutSubscribeProgress mocks base method.

func (*MockMigrateDB) QuerySwapOutUnitInSrcSP added in v0.2.3 

func (m *MockMigrateDB) QuerySwapOutUnitInSrcSP(swapOutKey string) (*SwapOutMeta, error)

QuerySwapOutUnitInSrcSP mocks base method.

func (*MockMigrateDB) UpdateBucketMigrateGCSubscribeProgress added in v1.3.0 

func (m *MockMigrateDB) UpdateBucketMigrateGCSubscribeProgress(blockHeight uint64) error

UpdateBucketMigrateGCSubscribeProgress mocks base method.

func (*MockMigrateDB) UpdateBucketMigrateSubscribeProgress added in v0.2.3 

func (m *MockMigrateDB) UpdateBucketMigrateSubscribeProgress(blockHeight uint64) error

UpdateBucketMigrateSubscribeProgress mocks base method.

func (*MockMigrateDB) UpdateBucketMigrationGCProgress added in v1.3.0 

func (m *MockMigrateDB) UpdateBucketMigrationGCProgress(progressMeta MigrateBucketProgressMeta) error

UpdateBucketMigrationGCProgress mocks base method.

func (*MockMigrateDB) UpdateBucketMigrationMigratingProgress added in v1.3.0 

func (m *MockMigrateDB) UpdateBucketMigrationMigratingProgress(bucketID uint64, gvgUnits, gvgUnitsFinished uint32) error

UpdateBucketMigrationMigratingProgress mocks base method.

func (*MockMigrateDB) UpdateBucketMigrationPreDeductedQuota added in v1.3.0 

func (m *MockMigrateDB) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota uint64, state int) error

UpdateBucketMigrationPreDeductedQuota mocks base method.

func (*MockMigrateDB) UpdateBucketMigrationProgress added in v1.3.0 

func (m *MockMigrateDB) UpdateBucketMigrationProgress(bucketID uint64, migrateState int) error

UpdateBucketMigrationProgress mocks base method.

func (*MockMigrateDB) UpdateBucketMigrationRecoupQuota added in v1.3.0 

func (m *MockMigrateDB) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota uint64, state int) error

UpdateBucketMigrationRecoupQuota mocks base method.

func (*MockMigrateDB) UpdateMigrateGVGMigratedBytesSize added in v1.3.0 

func (m *MockMigrateDB) UpdateMigrateGVGMigratedBytesSize(migrateKey string, migratedBytes uint64) error

UpdateMigrateGVGMigratedBytesSize mocks base method.

func (*MockMigrateDB) UpdateMigrateGVGRetryCount added in v1.1.0 

func (m *MockMigrateDB) UpdateMigrateGVGRetryCount(migrateKey string, retryTime int) error

UpdateMigrateGVGRetryCount mocks base method.

func (*MockMigrateDB) UpdateMigrateGVGUnitLastMigrateObjectID added in v0.2.3 

func (m *MockMigrateDB) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey string, lastMigrateObjectID uint64) error

UpdateMigrateGVGUnitLastMigrateObjectID mocks base method.

func (*MockMigrateDB) UpdateMigrateGVGUnitStatus added in v0.2.3 

func (m *MockMigrateDB) UpdateMigrateGVGUnitStatus(migrateKey string, migrateStatus int) error

UpdateMigrateGVGUnitStatus mocks base method.

func (*MockMigrateDB) UpdateSPExitSubscribeProgress added in v0.2.3 

func (m *MockMigrateDB) UpdateSPExitSubscribeProgress(blockHeight uint64) error

UpdateSPExitSubscribeProgress mocks base method.

func (*MockMigrateDB) UpdateSwapOutSubscribeProgress added in v0.2.3 

func (m *MockMigrateDB) UpdateSwapOutSubscribeProgress(blockHeight uint64) error

UpdateSwapOutSubscribeProgress mocks base method.

func (*MockMigrateDB) UpdateSwapOutUnitCompletedGVGList added in v0.2.3 

func (m *MockMigrateDB) UpdateSwapOutUnitCompletedGVGList(swapOutKey string, completedGVGList []uint32) error

UpdateSwapOutUnitCompletedGVGList mocks base method.

type MockMigrateDBMockRecorder added in v0.2.3 

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

MockMigrateDBMockRecorder is the mock recorder for MockMigrateDB.

func (*MockMigrateDBMockRecorder) DeleteMigrateBucket added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) DeleteMigrateBucket(bucketID any) *gomock.Call

DeleteMigrateBucket indicates an expected call of DeleteMigrateBucket.

func (*MockMigrateDBMockRecorder) DeleteMigrateGVGUnit added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) DeleteMigrateGVGUnit(meta any) *gomock.Call

DeleteMigrateGVGUnit indicates an expected call of DeleteMigrateGVGUnit.

func (*MockMigrateDBMockRecorder) DeleteMigrateGVGUnitsByBucketID added in v0.2.4 

func (mr *MockMigrateDBMockRecorder) DeleteMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call

DeleteMigrateGVGUnitsByBucketID indicates an expected call of DeleteMigrateGVGUnitsByBucketID.

func (*MockMigrateDBMockRecorder) InsertMigrateGVGUnit added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) InsertMigrateGVGUnit(meta any) *gomock.Call

InsertMigrateGVGUnit indicates an expected call of InsertMigrateGVGUnit.

func (*MockMigrateDBMockRecorder) InsertSwapOutUnit added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) InsertSwapOutUnit(meta any) *gomock.Call

InsertSwapOutUnit indicates an expected call of InsertSwapOutUnit.

func (*MockMigrateDBMockRecorder) ListBucketMigrationToConfirm added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) ListBucketMigrationToConfirm(migrationStates any) *gomock.Call

ListBucketMigrationToConfirm indicates an expected call of ListBucketMigrationToConfirm.

func (*MockMigrateDBMockRecorder) ListDestSPSwapOutUnits added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) ListDestSPSwapOutUnits() *gomock.Call

ListDestSPSwapOutUnits indicates an expected call of ListDestSPSwapOutUnits.

func (*MockMigrateDBMockRecorder) ListMigrateGVGUnitsByBucketID added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) ListMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call

ListMigrateGVGUnitsByBucketID indicates an expected call of ListMigrateGVGUnitsByBucketID.

func (*MockMigrateDBMockRecorder) QueryBucketMigrateSubscribeProgress added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) QueryBucketMigrateSubscribeProgress() *gomock.Call

QueryBucketMigrateSubscribeProgress indicates an expected call of QueryBucketMigrateSubscribeProgress.

func (*MockMigrateDBMockRecorder) QueryMigrateBucketProgress added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) QueryMigrateBucketProgress(bucketID any) *gomock.Call

QueryMigrateBucketProgress indicates an expected call of QueryMigrateBucketProgress.

func (*MockMigrateDBMockRecorder) QueryMigrateBucketState added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) QueryMigrateBucketState(bucketID any) *gomock.Call

QueryMigrateBucketState indicates an expected call of QueryMigrateBucketState.

func (*MockMigrateDBMockRecorder) QueryMigrateGVGUnit added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) QueryMigrateGVGUnit(migrateKey any) *gomock.Call

QueryMigrateGVGUnit indicates an expected call of QueryMigrateGVGUnit.

func (*MockMigrateDBMockRecorder) QuerySPExitSubscribeProgress added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) QuerySPExitSubscribeProgress() *gomock.Call

QuerySPExitSubscribeProgress indicates an expected call of QuerySPExitSubscribeProgress.

func (*MockMigrateDBMockRecorder) QuerySwapOutSubscribeProgress added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) QuerySwapOutSubscribeProgress() *gomock.Call

QuerySwapOutSubscribeProgress indicates an expected call of QuerySwapOutSubscribeProgress.

func (*MockMigrateDBMockRecorder) QuerySwapOutUnitInSrcSP added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) QuerySwapOutUnitInSrcSP(swapOutKey any) *gomock.Call

QuerySwapOutUnitInSrcSP indicates an expected call of QuerySwapOutUnitInSrcSP.

func (*MockMigrateDBMockRecorder) UpdateBucketMigrateGCSubscribeProgress added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrateGCSubscribeProgress(blockHeight any) *gomock.Call

UpdateBucketMigrateGCSubscribeProgress indicates an expected call of UpdateBucketMigrateGCSubscribeProgress.

func (*MockMigrateDBMockRecorder) UpdateBucketMigrateSubscribeProgress added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrateSubscribeProgress(blockHeight any) *gomock.Call

UpdateBucketMigrateSubscribeProgress indicates an expected call of UpdateBucketMigrateSubscribeProgress.

func (*MockMigrateDBMockRecorder) UpdateBucketMigrationGCProgress added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationGCProgress(progressMeta any) *gomock.Call

UpdateBucketMigrationGCProgress indicates an expected call of UpdateBucketMigrationGCProgress.

func (*MockMigrateDBMockRecorder) UpdateBucketMigrationMigratingProgress added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationMigratingProgress(bucketID, gvgUnits, gvgUnitsFinished any) *gomock.Call

UpdateBucketMigrationMigratingProgress indicates an expected call of UpdateBucketMigrationMigratingProgress.

func (*MockMigrateDBMockRecorder) UpdateBucketMigrationPreDeductedQuota added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota, state any) *gomock.Call

UpdateBucketMigrationPreDeductedQuota indicates an expected call of UpdateBucketMigrationPreDeductedQuota.

func (*MockMigrateDBMockRecorder) UpdateBucketMigrationProgress added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationProgress(bucketID, migrateState any) *gomock.Call

UpdateBucketMigrationProgress indicates an expected call of UpdateBucketMigrationProgress.

func (*MockMigrateDBMockRecorder) UpdateBucketMigrationRecoupQuota added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota, state any) *gomock.Call

UpdateBucketMigrationRecoupQuota indicates an expected call of UpdateBucketMigrationRecoupQuota.

func (*MockMigrateDBMockRecorder) UpdateMigrateGVGMigratedBytesSize added in v1.3.0 

func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGMigratedBytesSize(migrateKey, migratedBytes any) *gomock.Call

UpdateMigrateGVGMigratedBytesSize indicates an expected call of UpdateMigrateGVGMigratedBytesSize.

func (*MockMigrateDBMockRecorder) UpdateMigrateGVGRetryCount added in v1.1.0 

func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGRetryCount(migrateKey, retryTime any) *gomock.Call

UpdateMigrateGVGRetryCount indicates an expected call of UpdateMigrateGVGRetryCount.

func (*MockMigrateDBMockRecorder) UpdateMigrateGVGUnitLastMigrateObjectID added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey, lastMigrateObjectID any) *gomock.Call

UpdateMigrateGVGUnitLastMigrateObjectID indicates an expected call of UpdateMigrateGVGUnitLastMigrateObjectID.

func (*MockMigrateDBMockRecorder) UpdateMigrateGVGUnitStatus added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGUnitStatus(migrateKey, migrateStatus any) *gomock.Call

UpdateMigrateGVGUnitStatus indicates an expected call of UpdateMigrateGVGUnitStatus.

func (*MockMigrateDBMockRecorder) UpdateSPExitSubscribeProgress added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) UpdateSPExitSubscribeProgress(blockHeight any) *gomock.Call

UpdateSPExitSubscribeProgress indicates an expected call of UpdateSPExitSubscribeProgress.

func (*MockMigrateDBMockRecorder) UpdateSwapOutSubscribeProgress added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) UpdateSwapOutSubscribeProgress(blockHeight any) *gomock.Call

UpdateSwapOutSubscribeProgress indicates an expected call of UpdateSwapOutSubscribeProgress.

func (*MockMigrateDBMockRecorder) UpdateSwapOutUnitCompletedGVGList added in v0.2.3 

func (mr *MockMigrateDBMockRecorder) UpdateSwapOutUnitCompletedGVGList(swapOutKey, completedGVGList any) *gomock.Call

UpdateSwapOutUnitCompletedGVGList indicates an expected call of UpdateSwapOutUnitCompletedGVGList.

type MockOffChainAuthKeyDB 

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

MockOffChainAuthKeyDB is a mock of OffChainAuthKeyDB interface.

func NewMockOffChainAuthKeyDB 

func NewMockOffChainAuthKeyDB(ctrl *gomock.Controller) *MockOffChainAuthKeyDB

NewMockOffChainAuthKeyDB creates a new mock instance.

func (*MockOffChainAuthKeyDB) EXPECT 

func (m *MockOffChainAuthKeyDB) EXPECT() *MockOffChainAuthKeyDBMockRecorder

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

func (*MockOffChainAuthKeyDB) GetAuthKey 

func (m *MockOffChainAuthKeyDB) GetAuthKey(userAddress, domain string) (*OffChainAuthKey, error)

GetAuthKey mocks base method.

func (*MockOffChainAuthKeyDB) InsertAuthKey 

func (m *MockOffChainAuthKeyDB) InsertAuthKey(newRecord *OffChainAuthKey) error

InsertAuthKey mocks base method.

func (*MockOffChainAuthKeyDB) UpdateAuthKey 

func (m *MockOffChainAuthKeyDB) UpdateAuthKey(userAddress, domain string, oldNonce, newNonce int32, newPublicKey string, newExpiryDate time.Time) error

UpdateAuthKey mocks base method.

type MockOffChainAuthKeyDBMockRecorder 

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

MockOffChainAuthKeyDBMockRecorder is the mock recorder for MockOffChainAuthKeyDB.

func (*MockOffChainAuthKeyDBMockRecorder) GetAuthKey 

func (mr *MockOffChainAuthKeyDBMockRecorder) GetAuthKey(userAddress, domain any) *gomock.Call

GetAuthKey indicates an expected call of GetAuthKey.

func (*MockOffChainAuthKeyDBMockRecorder) InsertAuthKey 

func (mr *MockOffChainAuthKeyDBMockRecorder) InsertAuthKey(newRecord any) *gomock.Call

InsertAuthKey indicates an expected call of InsertAuthKey.

func (*MockOffChainAuthKeyDBMockRecorder) UpdateAuthKey 

func (mr *MockOffChainAuthKeyDBMockRecorder) UpdateAuthKey(userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate any) *gomock.Call

UpdateAuthKey indicates an expected call of UpdateAuthKey.

type MockSPDB 

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

MockSPDB is a mock of SPDB interface.

func NewMockSPDB 

func NewMockSPDB(ctrl *gomock.Controller) *MockSPDB

NewMockSPDB creates a new mock instance.

func (*MockSPDB) BatchGetRecoverGVGStats added in v1.3.0 

func (m *MockSPDB) BatchGetRecoverGVGStats(gvgID []uint32) ([]*RecoverGVGStats, error)

BatchGetRecoverGVGStats mocks base method.

func (*MockSPDB) CheckQuotaAndAddReadRecord 

func (m *MockSPDB) CheckQuotaAndAddReadRecord(record *ReadRecord, quota *BucketQuota) error

CheckQuotaAndAddReadRecord mocks base method.

func (*MockSPDB) CountRecoverFailedObject added in v1.3.0 

func (m *MockSPDB) CountRecoverFailedObject() (int64, error)

CountRecoverFailedObject mocks base method.

func (*MockSPDB) DeleteAllReplicatePieceChecksum 

func (m *MockSPDB) DeleteAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) error

DeleteAllReplicatePieceChecksum mocks base method.

func (*MockSPDB) DeleteAllReplicatePieceChecksumOptimized added in v0.2.5 

func (m *MockSPDB) DeleteAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32) error

DeleteAllReplicatePieceChecksumOptimized mocks base method.

func (*MockSPDB) DeleteExpiredBucketTraffic added in v1.2.0 

func (m *MockSPDB) DeleteExpiredBucketTraffic(yearMonth string) error

DeleteExpiredBucketTraffic mocks base method.

func (*MockSPDB) DeleteExpiredReadRecord added in v1.2.0 

func (m *MockSPDB) DeleteExpiredReadRecord(ts, limit uint64) error

DeleteExpiredReadRecord mocks base method.

func (*MockSPDB) DeleteGCObjectProgress 

func (m *MockSPDB) DeleteGCObjectProgress(taskKey string) error

DeleteGCObjectProgress mocks base method.

func (*MockSPDB) DeleteMigrateBucket added in v1.3.0 

func (m *MockSPDB) DeleteMigrateBucket(bucketID uint64) error

DeleteMigrateBucket mocks base method.

func (*MockSPDB) DeleteMigrateGVGUnit added in v0.2.3 

func (m *MockSPDB) DeleteMigrateGVGUnit(meta *MigrateGVGUnitMeta) error

DeleteMigrateGVGUnit mocks base method.

func (*MockSPDB) DeleteMigrateGVGUnitsByBucketID added in v0.2.4 

func (m *MockSPDB) DeleteMigrateGVGUnitsByBucketID(bucketID uint64) error

DeleteMigrateGVGUnitsByBucketID mocks base method.

func (*MockSPDB) DeleteObjectIntegrity 

func (m *MockSPDB) DeleteObjectIntegrity(objectID uint64, redundancyIndex int32) error

DeleteObjectIntegrity mocks base method.

func (*MockSPDB) DeleteRecoverFailedObject added in v1.3.0 

func (m *MockSPDB) DeleteRecoverFailedObject(objectID uint64) error

DeleteRecoverFailedObject mocks base method.

func (*MockSPDB) DeleteRecoverGVGStats added in v1.3.0 

func (m *MockSPDB) DeleteRecoverGVGStats(gvgID uint32) error

DeleteRecoverGVGStats mocks base method.

func (*MockSPDB) DeleteReplicatePieceChecksum 

func (m *MockSPDB) DeleteReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) error

DeleteReplicatePieceChecksum mocks base method.

func (*MockSPDB) DeleteShadowObjectIntegrity added in v1.5.0 

func (m *MockSPDB) DeleteShadowObjectIntegrity(objectID uint64, redundancyIndex int32) error

DeleteShadowObjectIntegrity mocks base method.

func (*MockSPDB) DeleteUploadProgress added in v0.2.3 

func (m *MockSPDB) DeleteUploadProgress(objectID uint64) error

DeleteUploadProgress mocks base method.

func (*MockSPDB) EXPECT 

func (m *MockSPDB) EXPECT() *MockSPDBMockRecorder

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

func (*MockSPDB) FetchAllSp 

func (m *MockSPDB) FetchAllSp(status ...types0.Status) ([]*types0.StorageProvider, error)

FetchAllSp mocks base method.

func (*MockSPDB) FetchAllSpWithoutOwnSp 

func (m *MockSPDB) FetchAllSpWithoutOwnSp(status ...types0.Status) ([]*types0.StorageProvider, error)

FetchAllSpWithoutOwnSp mocks base method.

func (*MockSPDB) GetAllReplicatePieceChecksum 

func (m *MockSPDB) GetAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error)

GetAllReplicatePieceChecksum mocks base method.

func (*MockSPDB) GetAllReplicatePieceChecksumOptimized added in v0.2.5 

func (m *MockSPDB) GetAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error)

GetAllReplicatePieceChecksumOptimized mocks base method.

func (*MockSPDB) GetAuthKey 

func (m *MockSPDB) GetAuthKey(userAddress, domain string) (*OffChainAuthKey, error)

GetAuthKey mocks base method.

func (*MockSPDB) GetBucketReadRecord 

func (m *MockSPDB) GetBucketReadRecord(bucketID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetBucketReadRecord mocks base method.

func (*MockSPDB) GetBucketTraffic 

func (m *MockSPDB) GetBucketTraffic(bucketID uint64, yearMonth string) (*BucketTraffic, error)

GetBucketTraffic mocks base method.

func (*MockSPDB) GetGCMetasToGC added in v0.2.3 

func (m *MockSPDB) GetGCMetasToGC(limit int) ([]*GCObjectMeta, error)

GetGCMetasToGC mocks base method.

func (*MockSPDB) GetLatestBucketTraffic added in v1.1.0 

func (m *MockSPDB) GetLatestBucketTraffic(bucketID uint64) (*BucketTraffic, error)

GetLatestBucketTraffic mocks base method.

func (*MockSPDB) GetObjectIntegrity 

func (m *MockSPDB) GetObjectIntegrity(objectID uint64, redundancyIndex int32) (*IntegrityMeta, error)

GetObjectIntegrity mocks base method.

func (*MockSPDB) GetObjectReadRecord 

func (m *MockSPDB) GetObjectReadRecord(objectID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetObjectReadRecord mocks base method.

func (*MockSPDB) GetOwnSpInfo 

func (m *MockSPDB) GetOwnSpInfo() (*types0.StorageProvider, error)

GetOwnSpInfo mocks base method.

func (*MockSPDB) GetReadRecord 

func (m *MockSPDB) GetReadRecord(timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetReadRecord mocks base method.

func (*MockSPDB) GetRecoverFailedObject added in v1.3.0 

func (m *MockSPDB) GetRecoverFailedObject(objectID uint64) (*RecoverFailedObject, error)

GetRecoverFailedObject mocks base method.

func (*MockSPDB) GetRecoverFailedObjects added in v1.3.0 

func (m *MockSPDB) GetRecoverFailedObjects(retry, limit uint32) ([]*RecoverFailedObject, error)

GetRecoverFailedObjects mocks base method.

func (*MockSPDB) GetRecoverFailedObjectsByRetryTime added in v1.3.0 

func (m *MockSPDB) GetRecoverFailedObjectsByRetryTime(retry uint32) ([]*RecoverFailedObject, error)

GetRecoverFailedObjectsByRetryTime mocks base method.

func (*MockSPDB) GetRecoverGVGStats added in v1.3.0 

func (m *MockSPDB) GetRecoverGVGStats(gvgID uint32) (*RecoverGVGStats, error)

GetRecoverGVGStats mocks base method.

func (*MockSPDB) GetReplicatePieceChecksum 

func (m *MockSPDB) GetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) ([]byte, error)

GetReplicatePieceChecksum mocks base method.

func (*MockSPDB) GetShadowObjectIntegrity added in v1.5.0 

func (m *MockSPDB) GetShadowObjectIntegrity(objectID uint64, redundancyIndex int32) (*ShadowIntegrityMeta, error)

GetShadowObjectIntegrity mocks base method.

func (*MockSPDB) GetSpByAddress 

func (m *MockSPDB) GetSpByAddress(address string, addressType SpAddressType) (*types0.StorageProvider, error)

GetSpByAddress mocks base method.

func (*MockSPDB) GetSpByEndpoint 

func (m *MockSPDB) GetSpByEndpoint(endpoint string) (*types0.StorageProvider, error)

GetSpByEndpoint mocks base method.

func (*MockSPDB) GetSpByID added in v0.2.4 

func (m *MockSPDB) GetSpByID(id uint32) (*types0.StorageProvider, error)

GetSpByID mocks base method.

func (*MockSPDB) GetUploadMetasToRejectUnsealByRangeTS added in v1.2.0 

func (m *MockSPDB) GetUploadMetasToRejectUnsealByRangeTS(limit int, startTimeStamp, endTimeStamp int64) ([]*UploadObjectMeta, error)

GetUploadMetasToRejectUnsealByRangeTS mocks base method.

func (*MockSPDB) GetUploadMetasToReplicate added in v0.2.3 

func (m *MockSPDB) GetUploadMetasToReplicate(limit int, timeout int64) ([]*UploadObjectMeta, error)

GetUploadMetasToReplicate mocks base method.

func (*MockSPDB) GetUploadMetasToReplicateByStartTS added in v1.2.0 

func (m *MockSPDB) GetUploadMetasToReplicateByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error)

GetUploadMetasToReplicateByStartTS mocks base method.

func (*MockSPDB) GetUploadMetasToSeal added in v0.2.3 

func (m *MockSPDB) GetUploadMetasToSeal(limit int, timeout int64) ([]*UploadObjectMeta, error)

GetUploadMetasToSeal mocks base method.

func (*MockSPDB) GetUploadMetasToSealByStartTS added in v1.2.0 

func (m *MockSPDB) GetUploadMetasToSealByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error)

GetUploadMetasToSealByStartTS mocks base method.

func (*MockSPDB) GetUploadState added in v0.2.3 

func (m *MockSPDB) GetUploadState(objectID uint64) (types.TaskState, string, error)

GetUploadState mocks base method.

func (*MockSPDB) GetUserReadRecord 

func (m *MockSPDB) GetUserReadRecord(userAddress string, timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetUserReadRecord mocks base method.

func (*MockSPDB) InitBucketTraffic added in v0.2.3 

func (m *MockSPDB) InitBucketTraffic(record *ReadRecord, quota *BucketQuota) error

InitBucketTraffic mocks base method.

func (*MockSPDB) InsertAuthKey 

func (m *MockSPDB) InsertAuthKey(newRecord *OffChainAuthKey) error

InsertAuthKey mocks base method.

func (*MockSPDB) InsertGCObjectProgress added in v0.2.3 

func (m *MockSPDB) InsertGCObjectProgress(gcMeta *GCObjectMeta) error

InsertGCObjectProgress mocks base method.

func (*MockSPDB) InsertMigrateGVGUnit added in v0.2.3 

func (m *MockSPDB) InsertMigrateGVGUnit(meta *MigrateGVGUnitMeta) error

InsertMigrateGVGUnit mocks base method.

func (*MockSPDB) InsertPutEvent added in v0.2.3 

func (m *MockSPDB) InsertPutEvent(task task.Task) error

InsertPutEvent mocks base method.

func (*MockSPDB) InsertRecoverFailedObject added in v1.3.0 

func (m *MockSPDB) InsertRecoverFailedObject(object *RecoverFailedObject) error

InsertRecoverFailedObject mocks base method.

func (*MockSPDB) InsertSwapOutUnit added in v0.2.3 

func (m *MockSPDB) InsertSwapOutUnit(meta *SwapOutMeta) error

InsertSwapOutUnit mocks base method.

func (*MockSPDB) InsertUploadProgress added in v0.2.3 

func (m *MockSPDB) InsertUploadProgress(objectID uint64) error

InsertUploadProgress mocks base method.

func (*MockSPDB) ListBucketMigrationToConfirm added in v1.3.0 

func (m *MockSPDB) ListBucketMigrationToConfirm(migrationStates []int) ([]*MigrateBucketProgressMeta, error)

ListBucketMigrationToConfirm mocks base method.

func (*MockSPDB) ListDestSPSwapOutUnits added in v0.2.3 

func (m *MockSPDB) ListDestSPSwapOutUnits() ([]*SwapOutMeta, error)

ListDestSPSwapOutUnits mocks base method.

func (*MockSPDB) ListIntegrityMetaByObjectIDRange added in v1.2.0 

func (m *MockSPDB) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID int64, includePrivate bool) ([]*IntegrityMeta, error)

ListIntegrityMetaByObjectIDRange mocks base method.

func (*MockSPDB) ListMigrateGVGUnitsByBucketID added in v0.2.3 

func (m *MockSPDB) ListMigrateGVGUnitsByBucketID(bucketID uint64) ([]*MigrateGVGUnitMeta, error)

ListMigrateGVGUnitsByBucketID mocks base method.

func (*MockSPDB) ListReplicatePieceChecksumByObjectIDRange added in v1.2.0 

func (m *MockSPDB) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID int64) ([]*GCPieceMeta, error)

ListReplicatePieceChecksumByObjectIDRange mocks base method.

func (*MockSPDB) ListShadowIntegrityMeta added in v1.5.0 

func (m *MockSPDB) ListShadowIntegrityMeta() ([]*ShadowIntegrityMeta, error)

ListShadowIntegrityMeta mocks base method.

func (*MockSPDB) QueryBucketMigrateSubscribeProgress added in v0.2.3 

func (m *MockSPDB) QueryBucketMigrateSubscribeProgress() (uint64, error)

QueryBucketMigrateSubscribeProgress mocks base method.

func (*MockSPDB) QueryMigrateBucketProgress added in v1.3.0 

func (m *MockSPDB) QueryMigrateBucketProgress(bucketID uint64) (*MigrateBucketProgressMeta, error)

QueryMigrateBucketProgress mocks base method.

func (*MockSPDB) QueryMigrateBucketState added in v1.3.0 

func (m *MockSPDB) QueryMigrateBucketState(bucketID uint64) (int, error)

QueryMigrateBucketState mocks base method.

func (*MockSPDB) QueryMigrateGVGUnit added in v0.2.3 

func (m *MockSPDB) QueryMigrateGVGUnit(migrateKey string) (*MigrateGVGUnitMeta, error)

QueryMigrateGVGUnit mocks base method.

func (*MockSPDB) QuerySPExitSubscribeProgress added in v0.2.3 

func (m *MockSPDB) QuerySPExitSubscribeProgress() (uint64, error)

QuerySPExitSubscribeProgress mocks base method.

func (*MockSPDB) QuerySwapOutSubscribeProgress added in v0.2.3 

func (m *MockSPDB) QuerySwapOutSubscribeProgress() (uint64, error)

QuerySwapOutSubscribeProgress mocks base method.

func (*MockSPDB) QuerySwapOutUnitInSrcSP added in v0.2.3 

func (m *MockSPDB) QuerySwapOutUnitInSrcSP(swapOutKey string) (*SwapOutMeta, error)

QuerySwapOutUnitInSrcSP mocks base method.

func (*MockSPDB) SetObjectIntegrity 

func (m *MockSPDB) SetObjectIntegrity(integrity *IntegrityMeta) error

SetObjectIntegrity mocks base method.

func (*MockSPDB) SetOwnSpInfo 

func (m *MockSPDB) SetOwnSpInfo(sp *types0.StorageProvider) error

SetOwnSpInfo mocks base method.

func (*MockSPDB) SetRecoverGVGStats added in v1.3.0 

func (m *MockSPDB) SetRecoverGVGStats(stats []*RecoverGVGStats) error

SetRecoverGVGStats mocks base method.

func (*MockSPDB) SetReplicatePieceChecksum 

func (m *MockSPDB) SetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32, checksum []byte, version int64) error

SetReplicatePieceChecksum mocks base method.

func (*MockSPDB) SetShadowObjectIntegrity added in v1.5.0 

func (m *MockSPDB) SetShadowObjectIntegrity(integrity *ShadowIntegrityMeta) error

SetShadowObjectIntegrity mocks base method.

func (*MockSPDB) UpdateAllSp 

func (m *MockSPDB) UpdateAllSp(spList []*types0.StorageProvider) error

UpdateAllSp mocks base method.

func (*MockSPDB) UpdateAuthKey 

func (m *MockSPDB) UpdateAuthKey(userAddress, domain string, oldNonce, newNonce int32, newPublicKey string, newExpiryDate time.Time) error

UpdateAuthKey mocks base method.

func (*MockSPDB) UpdateBucketMigrateGCSubscribeProgress added in v1.3.0 

func (m *MockSPDB) UpdateBucketMigrateGCSubscribeProgress(blockHeight uint64) error

UpdateBucketMigrateGCSubscribeProgress mocks base method.

func (*MockSPDB) UpdateBucketMigrateSubscribeProgress added in v0.2.3 

func (m *MockSPDB) UpdateBucketMigrateSubscribeProgress(blockHeight uint64) error

UpdateBucketMigrateSubscribeProgress mocks base method.

func (*MockSPDB) UpdateBucketMigrationGCProgress added in v1.3.0 

func (m *MockSPDB) UpdateBucketMigrationGCProgress(progressMeta MigrateBucketProgressMeta) error

UpdateBucketMigrationGCProgress mocks base method.

func (*MockSPDB) UpdateBucketMigrationMigratingProgress added in v1.3.0 

func (m *MockSPDB) UpdateBucketMigrationMigratingProgress(bucketID uint64, gvgUnits, gvgUnitsFinished uint32) error

UpdateBucketMigrationMigratingProgress mocks base method.

func (*MockSPDB) UpdateBucketMigrationPreDeductedQuota added in v1.3.0 

func (m *MockSPDB) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota uint64, state int) error

UpdateBucketMigrationPreDeductedQuota mocks base method.

func (*MockSPDB) UpdateBucketMigrationProgress added in v1.3.0 

func (m *MockSPDB) UpdateBucketMigrationProgress(bucketID uint64, migrateState int) error

UpdateBucketMigrationProgress mocks base method.

func (*MockSPDB) UpdateBucketMigrationRecoupQuota added in v1.3.0 

func (m *MockSPDB) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota uint64, state int) error

UpdateBucketMigrationRecoupQuota mocks base method.

func (*MockSPDB) UpdateBucketTraffic added in v1.1.0 

func (m *MockSPDB) UpdateBucketTraffic(bucketID uint64, update *BucketTraffic) error

UpdateBucketTraffic mocks base method.

func (*MockSPDB) UpdateExtraQuota added in v0.2.5 

func (m *MockSPDB) UpdateExtraQuota(bucketID, extraQuota uint64, yearMonth string) error

UpdateExtraQuota mocks base method.

func (*MockSPDB) UpdateGCObjectProgress added in v0.2.3 

func (m *MockSPDB) UpdateGCObjectProgress(gcMeta *GCObjectMeta) error

UpdateGCObjectProgress mocks base method.

func (*MockSPDB) UpdateIntegrityChecksum added in v0.2.3 

func (m *MockSPDB) UpdateIntegrityChecksum(integrity *IntegrityMeta) error

UpdateIntegrityChecksum mocks base method.

func (*MockSPDB) UpdateIntegrityMeta added in v1.5.0 

func (m *MockSPDB) UpdateIntegrityMeta(integrity *IntegrityMeta) error

UpdateIntegrityMeta mocks base method.

func (*MockSPDB) UpdateMigrateGVGMigratedBytesSize added in v1.3.0 

func (m *MockSPDB) UpdateMigrateGVGMigratedBytesSize(migrateKey string, migratedBytes uint64) error

UpdateMigrateGVGMigratedBytesSize mocks base method.

func (*MockSPDB) UpdateMigrateGVGRetryCount added in v1.1.0 

func (m *MockSPDB) UpdateMigrateGVGRetryCount(migrateKey string, retryTime int) error

UpdateMigrateGVGRetryCount mocks base method.

func (*MockSPDB) UpdateMigrateGVGUnitLastMigrateObjectID added in v0.2.3 

func (m *MockSPDB) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey string, lastMigrateObjectID uint64) error

UpdateMigrateGVGUnitLastMigrateObjectID mocks base method.

func (*MockSPDB) UpdateMigrateGVGUnitStatus added in v0.2.3 

func (m *MockSPDB) UpdateMigrateGVGUnitStatus(migrateKey string, migrateStatus int) error

UpdateMigrateGVGUnitStatus mocks base method.

func (*MockSPDB) UpdatePieceChecksum added in v0.2.3 

func (m *MockSPDB) UpdatePieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte) error

UpdatePieceChecksum mocks base method.

func (*MockSPDB) UpdateRecoverFailedObject added in v1.3.0 

func (m *MockSPDB) UpdateRecoverFailedObject(object *RecoverFailedObject) error

UpdateRecoverFailedObject mocks base method.

func (*MockSPDB) UpdateRecoverGVGStats added in v1.3.0 

func (m *MockSPDB) UpdateRecoverGVGStats(stats *RecoverGVGStats) error

UpdateRecoverGVGStats mocks base method.

func (*MockSPDB) UpdateSPExitSubscribeProgress added in v0.2.3 

func (m *MockSPDB) UpdateSPExitSubscribeProgress(blockHeight uint64) error

UpdateSPExitSubscribeProgress mocks base method.

func (*MockSPDB) UpdateShadowIntegrityChecksum added in v1.5.0 

func (m *MockSPDB) UpdateShadowIntegrityChecksum(integrity *ShadowIntegrityMeta) error

UpdateShadowIntegrityChecksum mocks base method.

func (*MockSPDB) UpdateShadowPieceChecksum added in v1.5.0 

func (m *MockSPDB) UpdateShadowPieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte, version int64) error

UpdateShadowPieceChecksum mocks base method.

func (*MockSPDB) UpdateSwapOutSubscribeProgress added in v0.2.3 

func (m *MockSPDB) UpdateSwapOutSubscribeProgress(blockHeight uint64) error

UpdateSwapOutSubscribeProgress mocks base method.

func (*MockSPDB) UpdateSwapOutUnitCompletedGVGList added in v0.2.3 

func (m *MockSPDB) UpdateSwapOutUnitCompletedGVGList(swapOutKey string, completedGVGList []uint32) error

UpdateSwapOutUnitCompletedGVGList mocks base method.

func (*MockSPDB) UpdateUploadProgress 

func (m *MockSPDB) UpdateUploadProgress(uploadMeta *UploadObjectMeta) error

UpdateUploadProgress mocks base method.

type MockSPDBMockRecorder 

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

MockSPDBMockRecorder is the mock recorder for MockSPDB.

func (*MockSPDBMockRecorder) BatchGetRecoverGVGStats added in v1.3.0 

func (mr *MockSPDBMockRecorder) BatchGetRecoverGVGStats(gvgID any) *gomock.Call

BatchGetRecoverGVGStats indicates an expected call of BatchGetRecoverGVGStats.

func (*MockSPDBMockRecorder) CheckQuotaAndAddReadRecord 

func (mr *MockSPDBMockRecorder) CheckQuotaAndAddReadRecord(record, quota any) *gomock.Call

CheckQuotaAndAddReadRecord indicates an expected call of CheckQuotaAndAddReadRecord.

func (*MockSPDBMockRecorder) CountRecoverFailedObject added in v1.3.0 

func (mr *MockSPDBMockRecorder) CountRecoverFailedObject() *gomock.Call

CountRecoverFailedObject indicates an expected call of CountRecoverFailedObject.

func (*MockSPDBMockRecorder) DeleteAllReplicatePieceChecksum 

func (mr *MockSPDBMockRecorder) DeleteAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call

DeleteAllReplicatePieceChecksum indicates an expected call of DeleteAllReplicatePieceChecksum.

func (*MockSPDBMockRecorder) DeleteAllReplicatePieceChecksumOptimized added in v0.2.5 

func (mr *MockSPDBMockRecorder) DeleteAllReplicatePieceChecksumOptimized(objectID, redundancyIdx any) *gomock.Call

DeleteAllReplicatePieceChecksumOptimized indicates an expected call of DeleteAllReplicatePieceChecksumOptimized.

func (*MockSPDBMockRecorder) DeleteExpiredBucketTraffic added in v1.2.0 

func (mr *MockSPDBMockRecorder) DeleteExpiredBucketTraffic(yearMonth any) *gomock.Call

DeleteExpiredBucketTraffic indicates an expected call of DeleteExpiredBucketTraffic.

func (*MockSPDBMockRecorder) DeleteExpiredReadRecord added in v1.2.0 

func (mr *MockSPDBMockRecorder) DeleteExpiredReadRecord(ts, limit any) *gomock.Call

DeleteExpiredReadRecord indicates an expected call of DeleteExpiredReadRecord.

func (*MockSPDBMockRecorder) DeleteGCObjectProgress 

func (mr *MockSPDBMockRecorder) DeleteGCObjectProgress(taskKey any) *gomock.Call

DeleteGCObjectProgress indicates an expected call of DeleteGCObjectProgress.

func (*MockSPDBMockRecorder) DeleteMigrateBucket added in v1.3.0 

func (mr *MockSPDBMockRecorder) DeleteMigrateBucket(bucketID any) *gomock.Call

DeleteMigrateBucket indicates an expected call of DeleteMigrateBucket.

func (*MockSPDBMockRecorder) DeleteMigrateGVGUnit added in v0.2.3 

func (mr *MockSPDBMockRecorder) DeleteMigrateGVGUnit(meta any) *gomock.Call

DeleteMigrateGVGUnit indicates an expected call of DeleteMigrateGVGUnit.

func (*MockSPDBMockRecorder) DeleteMigrateGVGUnitsByBucketID added in v0.2.4 

func (mr *MockSPDBMockRecorder) DeleteMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call

DeleteMigrateGVGUnitsByBucketID indicates an expected call of DeleteMigrateGVGUnitsByBucketID.

func (*MockSPDBMockRecorder) DeleteObjectIntegrity 

func (mr *MockSPDBMockRecorder) DeleteObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

DeleteObjectIntegrity indicates an expected call of DeleteObjectIntegrity.

func (*MockSPDBMockRecorder) DeleteRecoverFailedObject added in v1.3.0 

func (mr *MockSPDBMockRecorder) DeleteRecoverFailedObject(objectID any) *gomock.Call

DeleteRecoverFailedObject indicates an expected call of DeleteRecoverFailedObject.

func (*MockSPDBMockRecorder) DeleteRecoverGVGStats added in v1.3.0 

func (mr *MockSPDBMockRecorder) DeleteRecoverGVGStats(gvgID any) *gomock.Call

DeleteRecoverGVGStats indicates an expected call of DeleteRecoverGVGStats.

func (*MockSPDBMockRecorder) DeleteReplicatePieceChecksum 

func (mr *MockSPDBMockRecorder) DeleteReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call

DeleteReplicatePieceChecksum indicates an expected call of DeleteReplicatePieceChecksum.

func (*MockSPDBMockRecorder) DeleteShadowObjectIntegrity added in v1.5.0 

func (mr *MockSPDBMockRecorder) DeleteShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

DeleteShadowObjectIntegrity indicates an expected call of DeleteShadowObjectIntegrity.

func (*MockSPDBMockRecorder) DeleteUploadProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) DeleteUploadProgress(objectID any) *gomock.Call

DeleteUploadProgress indicates an expected call of DeleteUploadProgress.

func (*MockSPDBMockRecorder) FetchAllSp 

func (mr *MockSPDBMockRecorder) FetchAllSp(status ...any) *gomock.Call

FetchAllSp indicates an expected call of FetchAllSp.

func (*MockSPDBMockRecorder) FetchAllSpWithoutOwnSp 

func (mr *MockSPDBMockRecorder) FetchAllSpWithoutOwnSp(status ...any) *gomock.Call

FetchAllSpWithoutOwnSp indicates an expected call of FetchAllSpWithoutOwnSp.

func (*MockSPDBMockRecorder) GetAllReplicatePieceChecksum 

func (mr *MockSPDBMockRecorder) GetAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call

GetAllReplicatePieceChecksum indicates an expected call of GetAllReplicatePieceChecksum.

func (*MockSPDBMockRecorder) GetAllReplicatePieceChecksumOptimized added in v0.2.5 

func (mr *MockSPDBMockRecorder) GetAllReplicatePieceChecksumOptimized(objectID, redundancyIdx, pieceCount any) *gomock.Call

GetAllReplicatePieceChecksumOptimized indicates an expected call of GetAllReplicatePieceChecksumOptimized.

func (*MockSPDBMockRecorder) GetAuthKey 

func (mr *MockSPDBMockRecorder) GetAuthKey(userAddress, domain any) *gomock.Call

GetAuthKey indicates an expected call of GetAuthKey.

func (*MockSPDBMockRecorder) GetBucketReadRecord 

func (mr *MockSPDBMockRecorder) GetBucketReadRecord(bucketID, timeRange any) *gomock.Call

GetBucketReadRecord indicates an expected call of GetBucketReadRecord.

func (*MockSPDBMockRecorder) GetBucketTraffic 

func (mr *MockSPDBMockRecorder) GetBucketTraffic(bucketID, yearMonth any) *gomock.Call

GetBucketTraffic indicates an expected call of GetBucketTraffic.

func (*MockSPDBMockRecorder) GetGCMetasToGC added in v0.2.3 

func (mr *MockSPDBMockRecorder) GetGCMetasToGC(limit any) *gomock.Call

GetGCMetasToGC indicates an expected call of GetGCMetasToGC.

func (*MockSPDBMockRecorder) GetLatestBucketTraffic added in v1.1.0 

func (mr *MockSPDBMockRecorder) GetLatestBucketTraffic(bucketID any) *gomock.Call

GetLatestBucketTraffic indicates an expected call of GetLatestBucketTraffic.

func (*MockSPDBMockRecorder) GetObjectIntegrity 

func (mr *MockSPDBMockRecorder) GetObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

GetObjectIntegrity indicates an expected call of GetObjectIntegrity.

func (*MockSPDBMockRecorder) GetObjectReadRecord 

func (mr *MockSPDBMockRecorder) GetObjectReadRecord(objectID, timeRange any) *gomock.Call

GetObjectReadRecord indicates an expected call of GetObjectReadRecord.

func (*MockSPDBMockRecorder) GetOwnSpInfo 

func (mr *MockSPDBMockRecorder) GetOwnSpInfo() *gomock.Call

GetOwnSpInfo indicates an expected call of GetOwnSpInfo.

func (*MockSPDBMockRecorder) GetReadRecord 

func (mr *MockSPDBMockRecorder) GetReadRecord(timeRange any) *gomock.Call

GetReadRecord indicates an expected call of GetReadRecord.

func (*MockSPDBMockRecorder) GetRecoverFailedObject added in v1.3.0 

func (mr *MockSPDBMockRecorder) GetRecoverFailedObject(objectID any) *gomock.Call

GetRecoverFailedObject indicates an expected call of GetRecoverFailedObject.

func (*MockSPDBMockRecorder) GetRecoverFailedObjects added in v1.3.0 

func (mr *MockSPDBMockRecorder) GetRecoverFailedObjects(retry, limit any) *gomock.Call

GetRecoverFailedObjects indicates an expected call of GetRecoverFailedObjects.

func (*MockSPDBMockRecorder) GetRecoverFailedObjectsByRetryTime added in v1.3.0 

func (mr *MockSPDBMockRecorder) GetRecoverFailedObjectsByRetryTime(retry any) *gomock.Call

GetRecoverFailedObjectsByRetryTime indicates an expected call of GetRecoverFailedObjectsByRetryTime.

func (*MockSPDBMockRecorder) GetRecoverGVGStats added in v1.3.0 

func (mr *MockSPDBMockRecorder) GetRecoverGVGStats(gvgID any) *gomock.Call

GetRecoverGVGStats indicates an expected call of GetRecoverGVGStats.

func (*MockSPDBMockRecorder) GetReplicatePieceChecksum 

func (mr *MockSPDBMockRecorder) GetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call

GetReplicatePieceChecksum indicates an expected call of GetReplicatePieceChecksum.

func (*MockSPDBMockRecorder) GetShadowObjectIntegrity added in v1.5.0 

func (mr *MockSPDBMockRecorder) GetShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

GetShadowObjectIntegrity indicates an expected call of GetShadowObjectIntegrity.

func (*MockSPDBMockRecorder) GetSpByAddress 

func (mr *MockSPDBMockRecorder) GetSpByAddress(address, addressType any) *gomock.Call

GetSpByAddress indicates an expected call of GetSpByAddress.

func (*MockSPDBMockRecorder) GetSpByEndpoint 

func (mr *MockSPDBMockRecorder) GetSpByEndpoint(endpoint any) *gomock.Call

GetSpByEndpoint indicates an expected call of GetSpByEndpoint.

func (*MockSPDBMockRecorder) GetSpByID added in v0.2.4 

func (mr *MockSPDBMockRecorder) GetSpByID(id any) *gomock.Call

GetSpByID indicates an expected call of GetSpByID.

func (*MockSPDBMockRecorder) GetUploadMetasToRejectUnsealByRangeTS added in v1.2.0 

func (mr *MockSPDBMockRecorder) GetUploadMetasToRejectUnsealByRangeTS(limit, startTimeStamp, endTimeStamp any) *gomock.Call

GetUploadMetasToRejectUnsealByRangeTS indicates an expected call of GetUploadMetasToRejectUnsealByRangeTS.

func (*MockSPDBMockRecorder) GetUploadMetasToReplicate added in v0.2.3 

func (mr *MockSPDBMockRecorder) GetUploadMetasToReplicate(limit, timeout any) *gomock.Call

GetUploadMetasToReplicate indicates an expected call of GetUploadMetasToReplicate.

func (*MockSPDBMockRecorder) GetUploadMetasToReplicateByStartTS added in v1.2.0 

func (mr *MockSPDBMockRecorder) GetUploadMetasToReplicateByStartTS(limit, startTimeStamp any) *gomock.Call

GetUploadMetasToReplicateByStartTS indicates an expected call of GetUploadMetasToReplicateByStartTS.

func (*MockSPDBMockRecorder) GetUploadMetasToSeal added in v0.2.3 

func (mr *MockSPDBMockRecorder) GetUploadMetasToSeal(limit, timeout any) *gomock.Call

GetUploadMetasToSeal indicates an expected call of GetUploadMetasToSeal.

func (*MockSPDBMockRecorder) GetUploadMetasToSealByStartTS added in v1.2.0 

func (mr *MockSPDBMockRecorder) GetUploadMetasToSealByStartTS(limit, startTimeStamp any) *gomock.Call

GetUploadMetasToSealByStartTS indicates an expected call of GetUploadMetasToSealByStartTS.

func (*MockSPDBMockRecorder) GetUploadState added in v0.2.3 

func (mr *MockSPDBMockRecorder) GetUploadState(objectID any) *gomock.Call

GetUploadState indicates an expected call of GetUploadState.

func (*MockSPDBMockRecorder) GetUserReadRecord 

func (mr *MockSPDBMockRecorder) GetUserReadRecord(userAddress, timeRange any) *gomock.Call

GetUserReadRecord indicates an expected call of GetUserReadRecord.

func (*MockSPDBMockRecorder) InitBucketTraffic added in v0.2.3 

func (mr *MockSPDBMockRecorder) InitBucketTraffic(record, quota any) *gomock.Call

InitBucketTraffic indicates an expected call of InitBucketTraffic.

func (*MockSPDBMockRecorder) InsertAuthKey 

func (mr *MockSPDBMockRecorder) InsertAuthKey(newRecord any) *gomock.Call

InsertAuthKey indicates an expected call of InsertAuthKey.

func (*MockSPDBMockRecorder) InsertGCObjectProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) InsertGCObjectProgress(gcMeta any) *gomock.Call

InsertGCObjectProgress indicates an expected call of InsertGCObjectProgress.

func (*MockSPDBMockRecorder) InsertMigrateGVGUnit added in v0.2.3 

func (mr *MockSPDBMockRecorder) InsertMigrateGVGUnit(meta any) *gomock.Call

InsertMigrateGVGUnit indicates an expected call of InsertMigrateGVGUnit.

func (*MockSPDBMockRecorder) InsertPutEvent added in v0.2.3 

func (mr *MockSPDBMockRecorder) InsertPutEvent(task any) *gomock.Call

InsertPutEvent indicates an expected call of InsertPutEvent.

func (*MockSPDBMockRecorder) InsertRecoverFailedObject added in v1.3.0 

func (mr *MockSPDBMockRecorder) InsertRecoverFailedObject(object any) *gomock.Call

InsertRecoverFailedObject indicates an expected call of InsertRecoverFailedObject.

func (*MockSPDBMockRecorder) InsertSwapOutUnit added in v0.2.3 

func (mr *MockSPDBMockRecorder) InsertSwapOutUnit(meta any) *gomock.Call

InsertSwapOutUnit indicates an expected call of InsertSwapOutUnit.

func (*MockSPDBMockRecorder) InsertUploadProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) InsertUploadProgress(objectID any) *gomock.Call

InsertUploadProgress indicates an expected call of InsertUploadProgress.

func (*MockSPDBMockRecorder) ListBucketMigrationToConfirm added in v1.3.0 

func (mr *MockSPDBMockRecorder) ListBucketMigrationToConfirm(migrationStates any) *gomock.Call

ListBucketMigrationToConfirm indicates an expected call of ListBucketMigrationToConfirm.

func (*MockSPDBMockRecorder) ListDestSPSwapOutUnits added in v0.2.3 

func (mr *MockSPDBMockRecorder) ListDestSPSwapOutUnits() *gomock.Call

ListDestSPSwapOutUnits indicates an expected call of ListDestSPSwapOutUnits.

func (*MockSPDBMockRecorder) ListIntegrityMetaByObjectIDRange added in v1.2.0 

func (mr *MockSPDBMockRecorder) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID, includePrivate any) *gomock.Call

ListIntegrityMetaByObjectIDRange indicates an expected call of ListIntegrityMetaByObjectIDRange.

func (*MockSPDBMockRecorder) ListMigrateGVGUnitsByBucketID added in v0.2.3 

func (mr *MockSPDBMockRecorder) ListMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call

ListMigrateGVGUnitsByBucketID indicates an expected call of ListMigrateGVGUnitsByBucketID.

func (*MockSPDBMockRecorder) ListReplicatePieceChecksumByObjectIDRange added in v1.2.0 

func (mr *MockSPDBMockRecorder) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID any) *gomock.Call

ListReplicatePieceChecksumByObjectIDRange indicates an expected call of ListReplicatePieceChecksumByObjectIDRange.

func (*MockSPDBMockRecorder) ListShadowIntegrityMeta added in v1.5.0 

func (mr *MockSPDBMockRecorder) ListShadowIntegrityMeta() *gomock.Call

ListShadowIntegrityMeta indicates an expected call of ListShadowIntegrityMeta.

func (*MockSPDBMockRecorder) QueryBucketMigrateSubscribeProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) QueryBucketMigrateSubscribeProgress() *gomock.Call

QueryBucketMigrateSubscribeProgress indicates an expected call of QueryBucketMigrateSubscribeProgress.

func (*MockSPDBMockRecorder) QueryMigrateBucketProgress added in v1.3.0 

func (mr *MockSPDBMockRecorder) QueryMigrateBucketProgress(bucketID any) *gomock.Call

QueryMigrateBucketProgress indicates an expected call of QueryMigrateBucketProgress.

func (*MockSPDBMockRecorder) QueryMigrateBucketState added in v1.3.0 

func (mr *MockSPDBMockRecorder) QueryMigrateBucketState(bucketID any) *gomock.Call

QueryMigrateBucketState indicates an expected call of QueryMigrateBucketState.

func (*MockSPDBMockRecorder) QueryMigrateGVGUnit added in v0.2.3 

func (mr *MockSPDBMockRecorder) QueryMigrateGVGUnit(migrateKey any) *gomock.Call

QueryMigrateGVGUnit indicates an expected call of QueryMigrateGVGUnit.

func (*MockSPDBMockRecorder) QuerySPExitSubscribeProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) QuerySPExitSubscribeProgress() *gomock.Call

QuerySPExitSubscribeProgress indicates an expected call of QuerySPExitSubscribeProgress.

func (*MockSPDBMockRecorder) QuerySwapOutSubscribeProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) QuerySwapOutSubscribeProgress() *gomock.Call

QuerySwapOutSubscribeProgress indicates an expected call of QuerySwapOutSubscribeProgress.

func (*MockSPDBMockRecorder) QuerySwapOutUnitInSrcSP added in v0.2.3 

func (mr *MockSPDBMockRecorder) QuerySwapOutUnitInSrcSP(swapOutKey any) *gomock.Call

QuerySwapOutUnitInSrcSP indicates an expected call of QuerySwapOutUnitInSrcSP.

func (*MockSPDBMockRecorder) SetObjectIntegrity 

func (mr *MockSPDBMockRecorder) SetObjectIntegrity(integrity any) *gomock.Call

SetObjectIntegrity indicates an expected call of SetObjectIntegrity.

func (*MockSPDBMockRecorder) SetOwnSpInfo 

func (mr *MockSPDBMockRecorder) SetOwnSpInfo(sp any) *gomock.Call

SetOwnSpInfo indicates an expected call of SetOwnSpInfo.

func (*MockSPDBMockRecorder) SetRecoverGVGStats added in v1.3.0 

func (mr *MockSPDBMockRecorder) SetRecoverGVGStats(stats any) *gomock.Call

SetRecoverGVGStats indicates an expected call of SetRecoverGVGStats.

func (*MockSPDBMockRecorder) SetReplicatePieceChecksum 

func (mr *MockSPDBMockRecorder) SetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx, checksum, version any) *gomock.Call

SetReplicatePieceChecksum indicates an expected call of SetReplicatePieceChecksum.

func (*MockSPDBMockRecorder) SetShadowObjectIntegrity added in v1.5.0 

func (mr *MockSPDBMockRecorder) SetShadowObjectIntegrity(integrity any) *gomock.Call

SetShadowObjectIntegrity indicates an expected call of SetShadowObjectIntegrity.

func (*MockSPDBMockRecorder) UpdateAllSp 

func (mr *MockSPDBMockRecorder) UpdateAllSp(spList any) *gomock.Call

UpdateAllSp indicates an expected call of UpdateAllSp.

func (*MockSPDBMockRecorder) UpdateAuthKey 

func (mr *MockSPDBMockRecorder) UpdateAuthKey(userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate any) *gomock.Call

UpdateAuthKey indicates an expected call of UpdateAuthKey.

func (*MockSPDBMockRecorder) UpdateBucketMigrateGCSubscribeProgress added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateBucketMigrateGCSubscribeProgress(blockHeight any) *gomock.Call

UpdateBucketMigrateGCSubscribeProgress indicates an expected call of UpdateBucketMigrateGCSubscribeProgress.

func (*MockSPDBMockRecorder) UpdateBucketMigrateSubscribeProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateBucketMigrateSubscribeProgress(blockHeight any) *gomock.Call

UpdateBucketMigrateSubscribeProgress indicates an expected call of UpdateBucketMigrateSubscribeProgress.

func (*MockSPDBMockRecorder) UpdateBucketMigrationGCProgress added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateBucketMigrationGCProgress(progressMeta any) *gomock.Call

UpdateBucketMigrationGCProgress indicates an expected call of UpdateBucketMigrationGCProgress.

func (*MockSPDBMockRecorder) UpdateBucketMigrationMigratingProgress added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateBucketMigrationMigratingProgress(bucketID, gvgUnits, gvgUnitsFinished any) *gomock.Call

UpdateBucketMigrationMigratingProgress indicates an expected call of UpdateBucketMigrationMigratingProgress.

func (*MockSPDBMockRecorder) UpdateBucketMigrationPreDeductedQuota added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota, state any) *gomock.Call

UpdateBucketMigrationPreDeductedQuota indicates an expected call of UpdateBucketMigrationPreDeductedQuota.

func (*MockSPDBMockRecorder) UpdateBucketMigrationProgress added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateBucketMigrationProgress(bucketID, migrateState any) *gomock.Call

UpdateBucketMigrationProgress indicates an expected call of UpdateBucketMigrationProgress.

func (*MockSPDBMockRecorder) UpdateBucketMigrationRecoupQuota added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota, state any) *gomock.Call

UpdateBucketMigrationRecoupQuota indicates an expected call of UpdateBucketMigrationRecoupQuota.

func (*MockSPDBMockRecorder) UpdateBucketTraffic added in v1.1.0 

func (mr *MockSPDBMockRecorder) UpdateBucketTraffic(bucketID, update any) *gomock.Call

UpdateBucketTraffic indicates an expected call of UpdateBucketTraffic.

func (*MockSPDBMockRecorder) UpdateExtraQuota added in v0.2.5 

func (mr *MockSPDBMockRecorder) UpdateExtraQuota(bucketID, extraQuota, yearMonth any) *gomock.Call

UpdateExtraQuota indicates an expected call of UpdateExtraQuota.

func (*MockSPDBMockRecorder) UpdateGCObjectProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateGCObjectProgress(gcMeta any) *gomock.Call

UpdateGCObjectProgress indicates an expected call of UpdateGCObjectProgress.

func (*MockSPDBMockRecorder) UpdateIntegrityChecksum added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateIntegrityChecksum(integrity any) *gomock.Call

UpdateIntegrityChecksum indicates an expected call of UpdateIntegrityChecksum.

func (*MockSPDBMockRecorder) UpdateIntegrityMeta added in v1.5.0 

func (mr *MockSPDBMockRecorder) UpdateIntegrityMeta(integrity any) *gomock.Call

UpdateIntegrityMeta indicates an expected call of UpdateIntegrityMeta.

func (*MockSPDBMockRecorder) UpdateMigrateGVGMigratedBytesSize added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateMigrateGVGMigratedBytesSize(migrateKey, migratedBytes any) *gomock.Call

UpdateMigrateGVGMigratedBytesSize indicates an expected call of UpdateMigrateGVGMigratedBytesSize.

func (*MockSPDBMockRecorder) UpdateMigrateGVGRetryCount added in v1.1.0 

func (mr *MockSPDBMockRecorder) UpdateMigrateGVGRetryCount(migrateKey, retryTime any) *gomock.Call

UpdateMigrateGVGRetryCount indicates an expected call of UpdateMigrateGVGRetryCount.

func (*MockSPDBMockRecorder) UpdateMigrateGVGUnitLastMigrateObjectID added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey, lastMigrateObjectID any) *gomock.Call

UpdateMigrateGVGUnitLastMigrateObjectID indicates an expected call of UpdateMigrateGVGUnitLastMigrateObjectID.

func (*MockSPDBMockRecorder) UpdateMigrateGVGUnitStatus added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateMigrateGVGUnitStatus(migrateKey, migrateStatus any) *gomock.Call

UpdateMigrateGVGUnitStatus indicates an expected call of UpdateMigrateGVGUnitStatus.

func (*MockSPDBMockRecorder) UpdatePieceChecksum added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdatePieceChecksum(objectID, redundancyIndex, checksum any) *gomock.Call

UpdatePieceChecksum indicates an expected call of UpdatePieceChecksum.

func (*MockSPDBMockRecorder) UpdateRecoverFailedObject added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateRecoverFailedObject(object any) *gomock.Call

UpdateRecoverFailedObject indicates an expected call of UpdateRecoverFailedObject.

func (*MockSPDBMockRecorder) UpdateRecoverGVGStats added in v1.3.0 

func (mr *MockSPDBMockRecorder) UpdateRecoverGVGStats(stats any) *gomock.Call

UpdateRecoverGVGStats indicates an expected call of UpdateRecoverGVGStats.

func (*MockSPDBMockRecorder) UpdateSPExitSubscribeProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateSPExitSubscribeProgress(blockHeight any) *gomock.Call

UpdateSPExitSubscribeProgress indicates an expected call of UpdateSPExitSubscribeProgress.

func (*MockSPDBMockRecorder) UpdateShadowIntegrityChecksum added in v1.5.0 

func (mr *MockSPDBMockRecorder) UpdateShadowIntegrityChecksum(integrity any) *gomock.Call

UpdateShadowIntegrityChecksum indicates an expected call of UpdateShadowIntegrityChecksum.

func (*MockSPDBMockRecorder) UpdateShadowPieceChecksum added in v1.5.0 

func (mr *MockSPDBMockRecorder) UpdateShadowPieceChecksum(objectID, redundancyIndex, checksum, version any) *gomock.Call

UpdateShadowPieceChecksum indicates an expected call of UpdateShadowPieceChecksum.

func (*MockSPDBMockRecorder) UpdateSwapOutSubscribeProgress added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateSwapOutSubscribeProgress(blockHeight any) *gomock.Call

UpdateSwapOutSubscribeProgress indicates an expected call of UpdateSwapOutSubscribeProgress.

func (*MockSPDBMockRecorder) UpdateSwapOutUnitCompletedGVGList added in v0.2.3 

func (mr *MockSPDBMockRecorder) UpdateSwapOutUnitCompletedGVGList(swapOutKey, completedGVGList any) *gomock.Call

UpdateSwapOutUnitCompletedGVGList indicates an expected call of UpdateSwapOutUnitCompletedGVGList.

func (*MockSPDBMockRecorder) UpdateUploadProgress 

func (mr *MockSPDBMockRecorder) UpdateUploadProgress(uploadMeta any) *gomock.Call

UpdateUploadProgress indicates an expected call of UpdateUploadProgress.

type MockSPInfoDB 

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

MockSPInfoDB is a mock of SPInfoDB interface.

func NewMockSPInfoDB 

func NewMockSPInfoDB(ctrl *gomock.Controller) *MockSPInfoDB

NewMockSPInfoDB creates a new mock instance.

func (*MockSPInfoDB) EXPECT 

func (m *MockSPInfoDB) EXPECT() *MockSPInfoDBMockRecorder

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

func (*MockSPInfoDB) FetchAllSp 

func (m *MockSPInfoDB) FetchAllSp(status ...types0.Status) ([]*types0.StorageProvider, error)

FetchAllSp mocks base method.

func (*MockSPInfoDB) FetchAllSpWithoutOwnSp 

func (m *MockSPInfoDB) FetchAllSpWithoutOwnSp(status ...types0.Status) ([]*types0.StorageProvider, error)

FetchAllSpWithoutOwnSp mocks base method.

func (*MockSPInfoDB) GetOwnSpInfo 

func (m *MockSPInfoDB) GetOwnSpInfo() (*types0.StorageProvider, error)

GetOwnSpInfo mocks base method.

func (*MockSPInfoDB) GetSpByAddress 

func (m *MockSPInfoDB) GetSpByAddress(address string, addressType SpAddressType) (*types0.StorageProvider, error)

GetSpByAddress mocks base method.

func (*MockSPInfoDB) GetSpByEndpoint 

func (m *MockSPInfoDB) GetSpByEndpoint(endpoint string) (*types0.StorageProvider, error)

GetSpByEndpoint mocks base method.

func (*MockSPInfoDB) GetSpByID added in v0.2.4 

func (m *MockSPInfoDB) GetSpByID(id uint32) (*types0.StorageProvider, error)

GetSpByID mocks base method.

func (*MockSPInfoDB) SetOwnSpInfo 

func (m *MockSPInfoDB) SetOwnSpInfo(sp *types0.StorageProvider) error

SetOwnSpInfo mocks base method.

func (*MockSPInfoDB) UpdateAllSp 

func (m *MockSPInfoDB) UpdateAllSp(spList []*types0.StorageProvider) error

UpdateAllSp mocks base method.

type MockSPInfoDBMockRecorder 

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

MockSPInfoDBMockRecorder is the mock recorder for MockSPInfoDB.

func (*MockSPInfoDBMockRecorder) FetchAllSp 

func (mr *MockSPInfoDBMockRecorder) FetchAllSp(status ...any) *gomock.Call

FetchAllSp indicates an expected call of FetchAllSp.

func (*MockSPInfoDBMockRecorder) FetchAllSpWithoutOwnSp 

func (mr *MockSPInfoDBMockRecorder) FetchAllSpWithoutOwnSp(status ...any) *gomock.Call

FetchAllSpWithoutOwnSp indicates an expected call of FetchAllSpWithoutOwnSp.

func (*MockSPInfoDBMockRecorder) GetOwnSpInfo 

func (mr *MockSPInfoDBMockRecorder) GetOwnSpInfo() *gomock.Call

GetOwnSpInfo indicates an expected call of GetOwnSpInfo.

func (*MockSPInfoDBMockRecorder) GetSpByAddress 

func (mr *MockSPInfoDBMockRecorder) GetSpByAddress(address, addressType any) *gomock.Call

GetSpByAddress indicates an expected call of GetSpByAddress.

func (*MockSPInfoDBMockRecorder) GetSpByEndpoint 

func (mr *MockSPInfoDBMockRecorder) GetSpByEndpoint(endpoint any) *gomock.Call

GetSpByEndpoint indicates an expected call of GetSpByEndpoint.

func (*MockSPInfoDBMockRecorder) GetSpByID added in v0.2.4 

func (mr *MockSPInfoDBMockRecorder) GetSpByID(id any) *gomock.Call

GetSpByID indicates an expected call of GetSpByID.

func (*MockSPInfoDBMockRecorder) SetOwnSpInfo 

func (mr *MockSPInfoDBMockRecorder) SetOwnSpInfo(sp any) *gomock.Call

SetOwnSpInfo indicates an expected call of SetOwnSpInfo.

func (*MockSPInfoDBMockRecorder) UpdateAllSp 

func (mr *MockSPInfoDBMockRecorder) UpdateAllSp(spList any) *gomock.Call

UpdateAllSp indicates an expected call of UpdateAllSp.

type MockSignatureDB added in v0.2.3 

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

MockSignatureDB is a mock of SignatureDB interface.

func NewMockSignatureDB added in v0.2.3 

func NewMockSignatureDB(ctrl *gomock.Controller) *MockSignatureDB

NewMockSignatureDB creates a new mock instance.

func (*MockSignatureDB) DeleteAllReplicatePieceChecksum added in v0.2.3 

func (m *MockSignatureDB) DeleteAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) error

DeleteAllReplicatePieceChecksum mocks base method.

func (*MockSignatureDB) DeleteAllReplicatePieceChecksumOptimized added in v0.2.5 

func (m *MockSignatureDB) DeleteAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32) error

DeleteAllReplicatePieceChecksumOptimized mocks base method.

func (*MockSignatureDB) DeleteObjectIntegrity added in v0.2.3 

func (m *MockSignatureDB) DeleteObjectIntegrity(objectID uint64, redundancyIndex int32) error

DeleteObjectIntegrity mocks base method.

func (*MockSignatureDB) DeleteReplicatePieceChecksum added in v1.2.0 

func (m *MockSignatureDB) DeleteReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) error

DeleteReplicatePieceChecksum mocks base method.

func (*MockSignatureDB) DeleteShadowObjectIntegrity added in v1.5.0 

func (m *MockSignatureDB) DeleteShadowObjectIntegrity(objectID uint64, redundancyIndex int32) error

DeleteShadowObjectIntegrity mocks base method.

func (*MockSignatureDB) EXPECT added in v0.2.3 

func (m *MockSignatureDB) EXPECT() *MockSignatureDBMockRecorder

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

func (*MockSignatureDB) GetAllReplicatePieceChecksum added in v0.2.3 

func (m *MockSignatureDB) GetAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error)

GetAllReplicatePieceChecksum mocks base method.

func (*MockSignatureDB) GetAllReplicatePieceChecksumOptimized added in v0.2.5 

func (m *MockSignatureDB) GetAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error)

GetAllReplicatePieceChecksumOptimized mocks base method.

func (*MockSignatureDB) GetObjectIntegrity added in v0.2.3 

func (m *MockSignatureDB) GetObjectIntegrity(objectID uint64, redundancyIndex int32) (*IntegrityMeta, error)

GetObjectIntegrity mocks base method.

func (*MockSignatureDB) GetReplicatePieceChecksum added in v1.3.0 

func (m *MockSignatureDB) GetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) ([]byte, error)

GetReplicatePieceChecksum mocks base method.

func (*MockSignatureDB) GetShadowObjectIntegrity added in v1.5.0 

func (m *MockSignatureDB) GetShadowObjectIntegrity(objectID uint64, redundancyIndex int32) (*ShadowIntegrityMeta, error)

GetShadowObjectIntegrity mocks base method.

func (*MockSignatureDB) ListIntegrityMetaByObjectIDRange added in v1.2.0 

func (m *MockSignatureDB) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID int64, includePrivate bool) ([]*IntegrityMeta, error)

ListIntegrityMetaByObjectIDRange mocks base method.

func (*MockSignatureDB) ListReplicatePieceChecksumByObjectIDRange added in v1.2.0 

func (m *MockSignatureDB) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID int64) ([]*GCPieceMeta, error)

ListReplicatePieceChecksumByObjectIDRange mocks base method.

func (*MockSignatureDB) ListShadowIntegrityMeta added in v1.5.0 

func (m *MockSignatureDB) ListShadowIntegrityMeta() ([]*ShadowIntegrityMeta, error)

ListShadowIntegrityMeta mocks base method.

func (*MockSignatureDB) SetObjectIntegrity added in v0.2.3 

func (m *MockSignatureDB) SetObjectIntegrity(integrity *IntegrityMeta) error

SetObjectIntegrity mocks base method.

func (*MockSignatureDB) SetReplicatePieceChecksum added in v0.2.3 

func (m *MockSignatureDB) SetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32, checksum []byte, version int64) error

SetReplicatePieceChecksum mocks base method.

func (*MockSignatureDB) SetShadowObjectIntegrity added in v1.5.0 

func (m *MockSignatureDB) SetShadowObjectIntegrity(integrity *ShadowIntegrityMeta) error

SetShadowObjectIntegrity mocks base method.

func (*MockSignatureDB) UpdateIntegrityChecksum added in v0.2.3 

func (m *MockSignatureDB) UpdateIntegrityChecksum(integrity *IntegrityMeta) error

UpdateIntegrityChecksum mocks base method.

func (*MockSignatureDB) UpdateIntegrityMeta added in v1.5.0 

func (m *MockSignatureDB) UpdateIntegrityMeta(integrity *IntegrityMeta) error

UpdateIntegrityMeta mocks base method.

func (*MockSignatureDB) UpdatePieceChecksum added in v0.2.3 

func (m *MockSignatureDB) UpdatePieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte) error

UpdatePieceChecksum mocks base method.

func (*MockSignatureDB) UpdateShadowIntegrityChecksum added in v1.5.0 

func (m *MockSignatureDB) UpdateShadowIntegrityChecksum(integrity *ShadowIntegrityMeta) error

UpdateShadowIntegrityChecksum mocks base method.

func (*MockSignatureDB) UpdateShadowPieceChecksum added in v1.5.0 

func (m *MockSignatureDB) UpdateShadowPieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte, version int64) error

UpdateShadowPieceChecksum mocks base method.

type MockSignatureDBMockRecorder added in v0.2.3 

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

MockSignatureDBMockRecorder is the mock recorder for MockSignatureDB.

func (*MockSignatureDBMockRecorder) DeleteAllReplicatePieceChecksum added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) DeleteAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call

DeleteAllReplicatePieceChecksum indicates an expected call of DeleteAllReplicatePieceChecksum.

func (*MockSignatureDBMockRecorder) DeleteAllReplicatePieceChecksumOptimized added in v0.2.5 

func (mr *MockSignatureDBMockRecorder) DeleteAllReplicatePieceChecksumOptimized(objectID, redundancyIdx any) *gomock.Call

DeleteAllReplicatePieceChecksumOptimized indicates an expected call of DeleteAllReplicatePieceChecksumOptimized.

func (*MockSignatureDBMockRecorder) DeleteObjectIntegrity added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) DeleteObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

DeleteObjectIntegrity indicates an expected call of DeleteObjectIntegrity.

func (*MockSignatureDBMockRecorder) DeleteReplicatePieceChecksum added in v1.2.0 

func (mr *MockSignatureDBMockRecorder) DeleteReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call

DeleteReplicatePieceChecksum indicates an expected call of DeleteReplicatePieceChecksum.

func (*MockSignatureDBMockRecorder) DeleteShadowObjectIntegrity added in v1.5.0 

func (mr *MockSignatureDBMockRecorder) DeleteShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

DeleteShadowObjectIntegrity indicates an expected call of DeleteShadowObjectIntegrity.

func (*MockSignatureDBMockRecorder) GetAllReplicatePieceChecksum added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) GetAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call

GetAllReplicatePieceChecksum indicates an expected call of GetAllReplicatePieceChecksum.

func (*MockSignatureDBMockRecorder) GetAllReplicatePieceChecksumOptimized added in v0.2.5 

func (mr *MockSignatureDBMockRecorder) GetAllReplicatePieceChecksumOptimized(objectID, redundancyIdx, pieceCount any) *gomock.Call

GetAllReplicatePieceChecksumOptimized indicates an expected call of GetAllReplicatePieceChecksumOptimized.

func (*MockSignatureDBMockRecorder) GetObjectIntegrity added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) GetObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

GetObjectIntegrity indicates an expected call of GetObjectIntegrity.

func (*MockSignatureDBMockRecorder) GetReplicatePieceChecksum added in v1.3.0 

func (mr *MockSignatureDBMockRecorder) GetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call

GetReplicatePieceChecksum indicates an expected call of GetReplicatePieceChecksum.

func (*MockSignatureDBMockRecorder) GetShadowObjectIntegrity added in v1.5.0 

func (mr *MockSignatureDBMockRecorder) GetShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call

GetShadowObjectIntegrity indicates an expected call of GetShadowObjectIntegrity.

func (*MockSignatureDBMockRecorder) ListIntegrityMetaByObjectIDRange added in v1.2.0 

func (mr *MockSignatureDBMockRecorder) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID, includePrivate any) *gomock.Call

ListIntegrityMetaByObjectIDRange indicates an expected call of ListIntegrityMetaByObjectIDRange.

func (*MockSignatureDBMockRecorder) ListReplicatePieceChecksumByObjectIDRange added in v1.2.0 

func (mr *MockSignatureDBMockRecorder) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID any) *gomock.Call

ListReplicatePieceChecksumByObjectIDRange indicates an expected call of ListReplicatePieceChecksumByObjectIDRange.

func (*MockSignatureDBMockRecorder) ListShadowIntegrityMeta added in v1.5.0 

func (mr *MockSignatureDBMockRecorder) ListShadowIntegrityMeta() *gomock.Call

ListShadowIntegrityMeta indicates an expected call of ListShadowIntegrityMeta.

func (*MockSignatureDBMockRecorder) SetObjectIntegrity added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) SetObjectIntegrity(integrity any) *gomock.Call

SetObjectIntegrity indicates an expected call of SetObjectIntegrity.

func (*MockSignatureDBMockRecorder) SetReplicatePieceChecksum added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) SetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx, checksum, version any) *gomock.Call

SetReplicatePieceChecksum indicates an expected call of SetReplicatePieceChecksum.

func (*MockSignatureDBMockRecorder) SetShadowObjectIntegrity added in v1.5.0 

func (mr *MockSignatureDBMockRecorder) SetShadowObjectIntegrity(integrity any) *gomock.Call

SetShadowObjectIntegrity indicates an expected call of SetShadowObjectIntegrity.

func (*MockSignatureDBMockRecorder) UpdateIntegrityChecksum added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) UpdateIntegrityChecksum(integrity any) *gomock.Call

UpdateIntegrityChecksum indicates an expected call of UpdateIntegrityChecksum.

func (*MockSignatureDBMockRecorder) UpdateIntegrityMeta added in v1.5.0 

func (mr *MockSignatureDBMockRecorder) UpdateIntegrityMeta(integrity any) *gomock.Call

UpdateIntegrityMeta indicates an expected call of UpdateIntegrityMeta.

func (*MockSignatureDBMockRecorder) UpdatePieceChecksum added in v0.2.3 

func (mr *MockSignatureDBMockRecorder) UpdatePieceChecksum(objectID, redundancyIndex, checksum any) *gomock.Call

UpdatePieceChecksum indicates an expected call of UpdatePieceChecksum.

func (*MockSignatureDBMockRecorder) UpdateShadowIntegrityChecksum added in v1.5.0 

func (mr *MockSignatureDBMockRecorder) UpdateShadowIntegrityChecksum(integrity any) *gomock.Call

UpdateShadowIntegrityChecksum indicates an expected call of UpdateShadowIntegrityChecksum.

func (*MockSignatureDBMockRecorder) UpdateShadowPieceChecksum added in v1.5.0 

func (mr *MockSignatureDBMockRecorder) UpdateShadowPieceChecksum(objectID, redundancyIndex, checksum, version any) *gomock.Call

UpdateShadowPieceChecksum indicates an expected call of UpdateShadowPieceChecksum.

type MockTrafficDB 

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

MockTrafficDB is a mock of TrafficDB interface.

func NewMockTrafficDB 

func NewMockTrafficDB(ctrl *gomock.Controller) *MockTrafficDB

NewMockTrafficDB creates a new mock instance.

func (*MockTrafficDB) CheckQuotaAndAddReadRecord 

func (m *MockTrafficDB) CheckQuotaAndAddReadRecord(record *ReadRecord, quota *BucketQuota) error

CheckQuotaAndAddReadRecord mocks base method.

func (*MockTrafficDB) DeleteExpiredBucketTraffic added in v1.2.0 

func (m *MockTrafficDB) DeleteExpiredBucketTraffic(yearMonth string) error

DeleteExpiredBucketTraffic mocks base method.

func (*MockTrafficDB) DeleteExpiredReadRecord added in v1.2.0 

func (m *MockTrafficDB) DeleteExpiredReadRecord(ts, limit uint64) error

DeleteExpiredReadRecord mocks base method.

func (*MockTrafficDB) EXPECT 

func (m *MockTrafficDB) EXPECT() *MockTrafficDBMockRecorder

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

func (*MockTrafficDB) GetBucketReadRecord 

func (m *MockTrafficDB) GetBucketReadRecord(bucketID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetBucketReadRecord mocks base method.

func (*MockTrafficDB) GetBucketTraffic 

func (m *MockTrafficDB) GetBucketTraffic(bucketID uint64, yearMonth string) (*BucketTraffic, error)

GetBucketTraffic mocks base method.

func (*MockTrafficDB) GetLatestBucketTraffic added in v1.1.0 

func (m *MockTrafficDB) GetLatestBucketTraffic(bucketID uint64) (*BucketTraffic, error)

GetLatestBucketTraffic mocks base method.

func (*MockTrafficDB) GetObjectReadRecord 

func (m *MockTrafficDB) GetObjectReadRecord(objectID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetObjectReadRecord mocks base method.

func (*MockTrafficDB) GetReadRecord 

func (m *MockTrafficDB) GetReadRecord(timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetReadRecord mocks base method.

func (*MockTrafficDB) GetUserReadRecord 

func (m *MockTrafficDB) GetUserReadRecord(userAddress string, timeRange *TrafficTimeRange) ([]*ReadRecord, error)

GetUserReadRecord mocks base method.

func (*MockTrafficDB) InitBucketTraffic added in v0.2.3 

func (m *MockTrafficDB) InitBucketTraffic(record *ReadRecord, quota *BucketQuota) error

InitBucketTraffic mocks base method.

func (*MockTrafficDB) UpdateBucketTraffic added in v1.1.0 

func (m *MockTrafficDB) UpdateBucketTraffic(bucketID uint64, update *BucketTraffic) error

UpdateBucketTraffic mocks base method.

func (*MockTrafficDB) UpdateExtraQuota added in v0.2.5 

func (m *MockTrafficDB) UpdateExtraQuota(bucketID, extraQuota uint64, yearMonth string) error

UpdateExtraQuota mocks base method.

type MockTrafficDBMockRecorder 

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

MockTrafficDBMockRecorder is the mock recorder for MockTrafficDB.

func (*MockTrafficDBMockRecorder) CheckQuotaAndAddReadRecord 

func (mr *MockTrafficDBMockRecorder) CheckQuotaAndAddReadRecord(record, quota any) *gomock.Call

CheckQuotaAndAddReadRecord indicates an expected call of CheckQuotaAndAddReadRecord.

func (*MockTrafficDBMockRecorder) DeleteExpiredBucketTraffic added in v1.2.0 

func (mr *MockTrafficDBMockRecorder) DeleteExpiredBucketTraffic(yearMonth any) *gomock.Call

DeleteExpiredBucketTraffic indicates an expected call of DeleteExpiredBucketTraffic.

func (*MockTrafficDBMockRecorder) DeleteExpiredReadRecord added in v1.2.0 

func (mr *MockTrafficDBMockRecorder) DeleteExpiredReadRecord(ts, limit any) *gomock.Call

DeleteExpiredReadRecord indicates an expected call of DeleteExpiredReadRecord.

func (*MockTrafficDBMockRecorder) GetBucketReadRecord 

func (mr *MockTrafficDBMockRecorder) GetBucketReadRecord(bucketID, timeRange any) *gomock.Call

GetBucketReadRecord indicates an expected call of GetBucketReadRecord.

func (*MockTrafficDBMockRecorder) GetBucketTraffic 

func (mr *MockTrafficDBMockRecorder) GetBucketTraffic(bucketID, yearMonth any) *gomock.Call

GetBucketTraffic indicates an expected call of GetBucketTraffic.

func (*MockTrafficDBMockRecorder) GetLatestBucketTraffic added in v1.1.0 

func (mr *MockTrafficDBMockRecorder) GetLatestBucketTraffic(bucketID any) *gomock.Call

GetLatestBucketTraffic indicates an expected call of GetLatestBucketTraffic.

func (*MockTrafficDBMockRecorder) GetObjectReadRecord 

func (mr *MockTrafficDBMockRecorder) GetObjectReadRecord(objectID, timeRange any) *gomock.Call

GetObjectReadRecord indicates an expected call of GetObjectReadRecord.

func (*MockTrafficDBMockRecorder) GetReadRecord 

func (mr *MockTrafficDBMockRecorder) GetReadRecord(timeRange any) *gomock.Call

GetReadRecord indicates an expected call of GetReadRecord.

func (*MockTrafficDBMockRecorder) GetUserReadRecord 

func (mr *MockTrafficDBMockRecorder) GetUserReadRecord(userAddress, timeRange any) *gomock.Call

GetUserReadRecord indicates an expected call of GetUserReadRecord.

func (*MockTrafficDBMockRecorder) InitBucketTraffic added in v0.2.3 

func (mr *MockTrafficDBMockRecorder) InitBucketTraffic(record, quota any) *gomock.Call

InitBucketTraffic indicates an expected call of InitBucketTraffic.

func (*MockTrafficDBMockRecorder) UpdateBucketTraffic added in v1.1.0 

func (mr *MockTrafficDBMockRecorder) UpdateBucketTraffic(bucketID, update any) *gomock.Call

UpdateBucketTraffic indicates an expected call of UpdateBucketTraffic.

func (*MockTrafficDBMockRecorder) UpdateExtraQuota added in v1.1.0 

func (mr *MockTrafficDBMockRecorder) UpdateExtraQuota(bucketID, extraQuota, yearMonth any) *gomock.Call

UpdateExtraQuota indicates an expected call of UpdateExtraQuota.

type MockUploadObjectProgressDB 

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

MockUploadObjectProgressDB is a mock of UploadObjectProgressDB interface.

func NewMockUploadObjectProgressDB 

func NewMockUploadObjectProgressDB(ctrl *gomock.Controller) *MockUploadObjectProgressDB

NewMockUploadObjectProgressDB creates a new mock instance.

func (*MockUploadObjectProgressDB) DeleteUploadProgress added in v0.2.3 

func (m *MockUploadObjectProgressDB) DeleteUploadProgress(objectID uint64) error

DeleteUploadProgress mocks base method.

func (*MockUploadObjectProgressDB) EXPECT 

func (m *MockUploadObjectProgressDB) EXPECT() *MockUploadObjectProgressDBMockRecorder

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

func (*MockUploadObjectProgressDB) GetUploadMetasToRejectUnsealByRangeTS added in v1.2.0 

func (m *MockUploadObjectProgressDB) GetUploadMetasToRejectUnsealByRangeTS(limit int, startTimeStamp, endTimeStamp int64) ([]*UploadObjectMeta, error)

GetUploadMetasToRejectUnsealByRangeTS mocks base method.

func (*MockUploadObjectProgressDB) GetUploadMetasToReplicate added in v0.2.3 

func (m *MockUploadObjectProgressDB) GetUploadMetasToReplicate(limit int, timeout int64) ([]*UploadObjectMeta, error)

GetUploadMetasToReplicate mocks base method.

func (*MockUploadObjectProgressDB) GetUploadMetasToReplicateByStartTS added in v1.2.0 

func (m *MockUploadObjectProgressDB) GetUploadMetasToReplicateByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error)

GetUploadMetasToReplicateByStartTS mocks base method.

func (*MockUploadObjectProgressDB) GetUploadMetasToSeal added in v0.2.3 

func (m *MockUploadObjectProgressDB) GetUploadMetasToSeal(limit int, timeout int64) ([]*UploadObjectMeta, error)

GetUploadMetasToSeal mocks base method.

func (*MockUploadObjectProgressDB) GetUploadMetasToSealByStartTS added in v1.2.0 

func (m *MockUploadObjectProgressDB) GetUploadMetasToSealByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error)

GetUploadMetasToSealByStartTS mocks base method.

func (*MockUploadObjectProgressDB) GetUploadState added in v0.2.3 

func (m *MockUploadObjectProgressDB) GetUploadState(objectID uint64) (types.TaskState, string, error)

GetUploadState mocks base method.

func (*MockUploadObjectProgressDB) InsertPutEvent added in v0.2.3 

func (m *MockUploadObjectProgressDB) InsertPutEvent(task task.Task) error

InsertPutEvent mocks base method.

func (*MockUploadObjectProgressDB) InsertUploadProgress added in v0.2.3 

func (m *MockUploadObjectProgressDB) InsertUploadProgress(objectID uint64) error

InsertUploadProgress mocks base method.

func (*MockUploadObjectProgressDB) UpdateUploadProgress 

func (m *MockUploadObjectProgressDB) UpdateUploadProgress(uploadMeta *UploadObjectMeta) error

UpdateUploadProgress mocks base method.

type MockUploadObjectProgressDBMockRecorder 

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

MockUploadObjectProgressDBMockRecorder is the mock recorder for MockUploadObjectProgressDB.

func (*MockUploadObjectProgressDBMockRecorder) DeleteUploadProgress added in v0.2.3 

func (mr *MockUploadObjectProgressDBMockRecorder) DeleteUploadProgress(objectID any) *gomock.Call

DeleteUploadProgress indicates an expected call of DeleteUploadProgress.

func (*MockUploadObjectProgressDBMockRecorder) GetUploadMetasToRejectUnsealByRangeTS added in v1.2.0 

func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToRejectUnsealByRangeTS(limit, startTimeStamp, endTimeStamp any) *gomock.Call

GetUploadMetasToRejectUnsealByRangeTS indicates an expected call of GetUploadMetasToRejectUnsealByRangeTS.

func (*MockUploadObjectProgressDBMockRecorder) GetUploadMetasToReplicate added in v0.2.3 

func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToReplicate(limit, timeout any) *gomock.Call

GetUploadMetasToReplicate indicates an expected call of GetUploadMetasToReplicate.

func (*MockUploadObjectProgressDBMockRecorder) GetUploadMetasToReplicateByStartTS added in v1.2.0 

func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToReplicateByStartTS(limit, startTimeStamp any) *gomock.Call

GetUploadMetasToReplicateByStartTS indicates an expected call of GetUploadMetasToReplicateByStartTS.

func (*MockUploadObjectProgressDBMockRecorder) GetUploadMetasToSeal added in v0.2.3 

func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToSeal(limit, timeout any) *gomock.Call

GetUploadMetasToSeal indicates an expected call of GetUploadMetasToSeal.

func (*MockUploadObjectProgressDBMockRecorder) GetUploadMetasToSealByStartTS added in v1.2.0 

func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToSealByStartTS(limit, startTimeStamp any) *gomock.Call

GetUploadMetasToSealByStartTS indicates an expected call of GetUploadMetasToSealByStartTS.

func (*MockUploadObjectProgressDBMockRecorder) GetUploadState added in v0.2.3 

func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadState(objectID any) *gomock.Call

GetUploadState indicates an expected call of GetUploadState.

func (*MockUploadObjectProgressDBMockRecorder) InsertPutEvent added in v0.2.3 

func (mr *MockUploadObjectProgressDBMockRecorder) InsertPutEvent(task any) *gomock.Call

InsertPutEvent indicates an expected call of InsertPutEvent.

func (*MockUploadObjectProgressDBMockRecorder) InsertUploadProgress added in v0.2.3 

func (mr *MockUploadObjectProgressDBMockRecorder) InsertUploadProgress(objectID any) *gomock.Call

InsertUploadProgress indicates an expected call of InsertUploadProgress.

func (*MockUploadObjectProgressDBMockRecorder) UpdateUploadProgress 

func (mr *MockUploadObjectProgressDBMockRecorder) UpdateUploadProgress(uploadMeta any) *gomock.Call

UpdateUploadProgress indicates an expected call of UpdateUploadProgress.

type OffChainAuthKey 

type OffChainAuthKey struct {
	UserAddress string
	Domain      string

	CurrentNonce     int32
	CurrentPublicKey string
	NextNonce        int32
	ExpiryDate       time.Time

	CreatedTime  time.Time
	ModifiedTime time.Time
}

type OffChainAuthKeyDB 

type OffChainAuthKeyDB interface {
	GetAuthKey(userAddress string, domain string) (*OffChainAuthKey, error)
	UpdateAuthKey(userAddress string, domain string, oldNonce int32, newNonce int32, newPublicKey string, newExpiryDate time.Time) error
	InsertAuthKey(newRecord *OffChainAuthKey) error
}

OffChainAuthKeyDB interface.

type ReadRecord 

type ReadRecord struct {
	BucketID        uint64
	ObjectID        uint64
	UserAddress     string
	BucketName      string
	ObjectName      string
	ReadSize        uint64
	ReadTimestampUs int64
}

ReadRecord defines a read request record, will decrease the bucket read quota.

type RecoverFailedObject added in v1.3.0 

type RecoverFailedObject struct {
	ObjectID        uint64
	VirtualGroupID  uint32
	RedundancyIndex int32
	RetryTime       int
}

type RecoverGVGStats added in v1.3.0 

type RecoverGVGStats struct {
	VirtualGroupID       uint32
	VirtualGroupFamilyID uint32
	RedundancyIndex      int32
	StartAfter           uint64
	NextStartAfter       uint64
	Limit                uint64
	Status               RecoverStatus
	ObjectCount          uint64
}

type RecoverStatus added in v1.3.0 

type RecoverStatus int
const (
	Processing RecoverStatus = 0
	Processed  RecoverStatus = 1
	Completed  RecoverStatus = 2
)

type SPDB 

type SPDB interface {
	UploadObjectProgressDB
	GCObjectProgressDB
	SignatureDB
	TrafficDB
	SPInfoDB
	OffChainAuthKeyDB
	MigrateDB
	ExitRecoverDB
}

SPDB contains all sp db operations

type SPInfoDB 

type SPInfoDB interface {
	// UpdateAllSp update all sp info, delete old sp info.
	UpdateAllSp(spList []*sptypes.StorageProvider) error
	// FetchAllSp if status is nil return all sp info; otherwise return sp info by status.
	FetchAllSp(status ...sptypes.Status) ([]*sptypes.StorageProvider, error)
	// FetchAllSpWithoutOwnSp if status is nil return all sp info without own sp;
	// otherwise return sp info by status without own sp.
	FetchAllSpWithoutOwnSp(status ...sptypes.Status) ([]*sptypes.StorageProvider, error)
	// GetSpByAddress return sp info by address and addressType.
	GetSpByAddress(address string, addressType SpAddressType) (*sptypes.StorageProvider, error)
	// GetSpByEndpoint return sp info by endpoint.
	GetSpByEndpoint(endpoint string) (*sptypes.StorageProvider, error)
	// GetSpByID return sp info by id.
	GetSpByID(id uint32) (*sptypes.StorageProvider, error)
	// GetOwnSpInfo return own sp info.
	GetOwnSpInfo() (*sptypes.StorageProvider, error)
	// SetOwnSpInfo set(maybe overwrite) own sp info.
	SetOwnSpInfo(sp *sptypes.StorageProvider) error
}

SPInfoDB defines a series of sp interfaces.

type ShadowIntegrityMeta added in v1.5.0 

type ShadowIntegrityMeta struct {
	ObjectID          uint64
	RedundancyIndex   int32
	IntegrityChecksum []byte
	PieceChecksumList [][]byte
	Version           int64
}

ShadowIntegrityMeta defines the payload integrity hash and piece checksum with objectID. It is used for storing user's updated object meta. When the SP seals the object successful, this temporary record will be persisted to IntegrityMeta and removed from ShadowIntegrityMeta.

type SignatureDB 

type SignatureDB interface {
	/*
		Object Signature is used to get challenge info.
	*/
	// GetObjectIntegrity gets integrity meta info by object id and redundancy index.
	GetObjectIntegrity(objectID uint64, redundancyIndex int32) (*IntegrityMeta, error)
	// SetObjectIntegrity sets(maybe overwrite) integrity hash info to db.
	SetObjectIntegrity(integrity *IntegrityMeta) error
	// DeleteObjectIntegrity deletes the integrity hash.
	DeleteObjectIntegrity(objectID uint64, redundancyIndex int32) error
	// UpdateIntegrityChecksum update IntegrityMetaTable's integrity checksum
	UpdateIntegrityChecksum(integrity *IntegrityMeta) error
	// UpdatePieceChecksum if the IntegrityMetaTable already exists, it will be appended to the existing PieceChecksumList.
	UpdatePieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte) error
	// UpdateIntegrityMeta update both piece checksum and integrity
	UpdateIntegrityMeta(integrity *IntegrityMeta) error
	// ListIntegrityMetaByObjectIDRange list integrity meta in range
	ListIntegrityMetaByObjectIDRange(startObjectID int64, endObjectID int64, includePrivate bool) ([]*IntegrityMeta, error)

	/*
		Piece Signature is used to help replicate object's piece data to secondary sps, which is temporary.
	*/
	// SetReplicatePieceChecksum sets(maybe overwrite) the piece hash.
	SetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32, checksum []byte, version int64) error
	// GetReplicatePieceChecksum gets a piece hash.
	GetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) ([]byte, error)
	// GetAllReplicatePieceChecksum gets all piece hashes.
	GetAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error)
	// GetAllReplicatePieceChecksumOptimized gets all piece hashes.
	GetAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error)
	// DeleteReplicatePieceChecksum deletes piece hashes.
	DeleteReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) (err error)
	// DeleteAllReplicatePieceChecksum deletes all piece hashes.
	DeleteAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) error
	// DeleteAllReplicatePieceChecksumOptimized deletes all piece hashes.
	DeleteAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32) error
	// ListReplicatePieceChecksumByObjectIDRange list replicate piece checksum in range
	ListReplicatePieceChecksumByObjectIDRange(startObjectID int64, endObjectID int64) ([]*GCPieceMeta, error)

	/*
	  Used for Object Update, the ShadowObjectIntegrity is used for temporally storing used updated object meta;
	  it will be clean when the object is re-sealed
	*/
	// GetShadowObjectIntegrity gets the shadow object integrity meta info by object id and redundancy index.
	GetShadowObjectIntegrity(objectID uint64, redundancyIndex int32) (*ShadowIntegrityMeta, error)
	// SetShadowObjectIntegrity sets(maybe overwrite) shadow integrity hash info to db.
	SetShadowObjectIntegrity(integrity *ShadowIntegrityMeta) error
	// DeleteShadowObjectIntegrity deletes the shadow integrity hash.
	DeleteShadowObjectIntegrity(objectID uint64, redundancyIndex int32) error
	// UpdateShadowIntegrityChecksum update ShadowIntegrityMetaTable's integrity checksum
	UpdateShadowIntegrityChecksum(integrity *ShadowIntegrityMeta) error
	// UpdateShadowPieceChecksum if the IntegrityMetaTable already exists, it will be appended to the existing PieceChecksumList.
	UpdateShadowPieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte, version int64) error
	// ListShadowIntegrityMeta list Shadow IntegrityMeta records with default limit
	ListShadowIntegrityMeta() ([]*ShadowIntegrityMeta, error)
}

SignatureDB abstract object integrity interface.

type SpAddressType 

type SpAddressType int32

SpAddressType identify address type of SP. 

const (
	OperatorAddressType SpAddressType = iota + 1
	FundingAddressType
	SealAddressType
	ApprovalAddressType
)

type SwapOutMeta added in v0.2.3 

type SwapOutMeta struct {
	SwapOutKey    string // as primary key
	IsDestSP      bool
	SwapOutMsg    *virtualgrouptypes.MsgSwapOut
	CompletedGVGs []uint32
}

SwapOutMeta is used to record swap out meta.

type TrafficDB 

type TrafficDB interface {
	// CheckQuotaAndAddReadRecord get the traffic info from db, update the quota meta and check
	// whether the added traffic record exceeds the quota, if it exceeds the quota,
	// it will return error, Otherwise, add a record and return nil.
	CheckQuotaAndAddReadRecord(record *ReadRecord, quota *BucketQuota) error
	// InitBucketTraffic init the traffic info
	InitBucketTraffic(record *ReadRecord, quota *BucketQuota) error
	// GetBucketTraffic return bucket traffic info,
	// notice maybe return (nil, nil) while there is no bucket traffic.
	GetBucketTraffic(bucketID uint64, yearMonth string) (*BucketTraffic, error)
	// UpdateExtraQuota update the read consumed quota and free consumed quota in traffic db with the extra quota
	UpdateExtraQuota(bucketID, extraQuota uint64, yearMonth string) error
	// GetLatestBucketTraffic return latest bucket traffic info
	GetLatestBucketTraffic(bucketID uint64) (*BucketTraffic, error)
	// UpdateBucketTraffic update bucket traffic info
	UpdateBucketTraffic(bucketID uint64, update *BucketTraffic) (err error)
	// GetReadRecord return record list by time range.
	GetReadRecord(timeRange *TrafficTimeRange) ([]*ReadRecord, error)
	// GetBucketReadRecord return bucket record list by time range.
	GetBucketReadRecord(bucketID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error)
	// GetObjectReadRecord return object record list by time range.
	GetObjectReadRecord(objectID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error)
	// GetUserReadRecord return user record list by time range.
	GetUserReadRecord(userAddress string, timeRange *TrafficTimeRange) ([]*ReadRecord, error)

	// DeleteExpiredReadRecord delete all read record before ts with limit
	DeleteExpiredReadRecord(ts, limit uint64) (err error)
	// DeleteExpiredBucketTraffic delete all bucket traffic before yearMonth, when large dataset
	DeleteExpiredBucketTraffic(yearMonth string) (err error)
}

TrafficDB defines a series of traffic interfaces.

type TrafficTimeRange 

type TrafficTimeRange struct {
	StartTimestampUs int64
	EndTimestampUs   int64
	LimitNum         int // is unlimited if LimitNum <= 0.
}

TrafficTimeRange is used by query, return records in [StartTimestampUs, EndTimestampUs).

type UploadObjectMeta 

type UploadObjectMeta struct {
	ObjectID              uint64
	TaskState             storetypes.TaskState
	GlobalVirtualGroupID  uint32
	SecondaryEndpoints    []string
	SecondarySignatures   [][]byte
	ErrorDescription      string
	CreateTimeStampSecond int64
}

UploadObjectMeta defines the upload object state and related seal info, etc.

type UploadObjectProgressDB 

type UploadObjectProgressDB interface {
	// InsertUploadProgress inserts a new upload object progress.
	InsertUploadProgress(objectID uint64) error
	// DeleteUploadProgress deletes the upload object progress.
	DeleteUploadProgress(objectID uint64) error
	// UpdateUploadProgress updates the upload object progress state.
	UpdateUploadProgress(uploadMeta *UploadObjectMeta) error
	// GetUploadState queries the task state by object id.
	GetUploadState(objectID uint64) (storetypes.TaskState, string, error)
	// GetUploadMetasToReplicate queries the latest upload_done/replicate_doing object to continue replicate.
	// It is only used in startup.
	GetUploadMetasToReplicate(limit int, timeout int64) ([]*UploadObjectMeta, error)
	// GetUploadMetasToSeal queries the latest replicate_done/seal_doing object to continue seal.
	// It is only used in startup.
	GetUploadMetasToSeal(limit int, timeout int64) ([]*UploadObjectMeta, error)
	// GetUploadMetasToReplicateByStartTS queries the upload_done/replicate_doing object to continue replicate.
	// It is used in task retry scheduler.
	GetUploadMetasToReplicateByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error)
	// GetUploadMetasToSealByStartTS queries the replicate_done/seal_doing object to continue seal.
	// It is used in task retry scheduler.
	GetUploadMetasToSealByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error)
	// GetUploadMetasToRejectUnsealByRangeTS queries the upload_done/replicate_doing object to reject.
	// It is used in task retry scheduler.
	GetUploadMetasToRejectUnsealByRangeTS(limit int, startTimeStamp int64, endTimeStamp int64) ([]*UploadObjectMeta, error)
	// InsertPutEvent inserts a new upload event progress.
	InsertPutEvent(task coretask.Task) error
}

UploadObjectProgressDB interface which records upload object related progress(includes foreground and background) and state.

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.