spdb

package
v1.3.1 Latest Latest
Warning

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

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

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: ./spdb.go

Generated by this command: 

mockgen -source=./spdb.go -destination=./spdb_mock.go -package=spdb

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
}

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

SetReplicatePieceChecksum 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) 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) 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) 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) 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) 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 any) *gomock.Call

SetReplicatePieceChecksum indicates an expected call of SetReplicatePieceChecksum.

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

SetReplicatePieceChecksum mocks base method.

func (*MockSignatureDB) UpdateIntegrityChecksum added in v0.2.3 

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

UpdateIntegrityChecksum 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.

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) 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) 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) 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 any) *gomock.Call

SetReplicatePieceChecksum indicates an expected call of SetReplicatePieceChecksum.

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) UpdatePieceChecksum added in v0.2.3 

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

UpdatePieceChecksum indicates an expected call of UpdatePieceChecksum.

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 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
	// 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) error
	// GetReplicatePieceChecksum gets all piece hashes.
	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)
}

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.