gfspvgmgr

Documentation

Index

• Constants
• Variables
• func NewIDSetFromList(list []uint32) vgmgr.IDSet
• func NewVirtualGroupManager(selfOperatorAddress string, chainClient consensus.Consensus, ...) (vgmgr.VirtualGroupManager, error)
• type FreeStorageSizeWeightPicker
• type FreezeSPPool
  • func NewFreezeSPPool() *FreezeSPPool
  • func (s *FreezeSPPool) FreezeSPAndGVGs(spID uint32, joinedGVGs []*virtual_types.GlobalVirtualGroup)
  • func (s *FreezeSPPool) GetFreezeGVGsInFamily(familyID uint32) vgmgr.IDSet
  • func (s *FreezeSPPool) GetFreezeSPIDs() vgmgr.IDSet
  • func (s *FreezeSPPool) ReleaseAllSP()
  • func (s *FreezeSPPool) ReleaseSP()
• type HealthChecker
  • func NewHealthChecker(chainClient consensus.Consensus) *HealthChecker
  • func (checker *HealthChecker) Start()
• type SPStats

Constants

const (
	DefaultFreezingPeriodForSP = 5 * time.Minute
	ReleaseSPJobInterval       = 1 * time.Minute
)

const (
	VirtualGroupManagerSpace            = "VirtualGroupManager"
	RefreshMetaInterval                 = 5 * time.Second
	MaxStorageUsageRatio                = 0.95
	DefaultInitialGVGStakingStorageSize = uint64(2) * 1024 * 1024 * 1024 * 1024 // 2TB per GVG, chain side DefaultMaxStoreSizePerFamily is 64 TB

)

Variables

var (
	ErrFailedPickVGF = gfsperrors.Register(VirtualGroupManagerSpace, http.StatusInternalServerError, 540001,
		"failed to pick virtual group family, need to create global virtual group")
	ErrFailedPickGVG = gfsperrors.Register(VirtualGroupManagerSpace, http.StatusInternalServerError, 540002,
		"failed to pick global virtual group, need to stake more storage size")
	ErrStaledMetadata = gfsperrors.Register(VirtualGroupManagerSpace, http.StatusInternalServerError, 540003,
		"metadata is staled, need to force refresh metadata")
	ErrFailedPickDestSP = gfsperrors.Register(VirtualGroupManagerSpace, http.StatusInternalServerError, 540004,
		"failed to pick dest sp")
)

Functions

func NewIDSetFromList

func NewIDSetFromList(list []uint32) vgmgr.IDSet

func NewVirtualGroupManager

func NewVirtualGroupManager(selfOperatorAddress string, chainClient consensus.Consensus, gfspClient gfspclient.GfSpClientAPI, enableHealthyChecker bool) (vgmgr.VirtualGroupManager, error)

NewVirtualGroupManager returns a virtual group manager interface.

Types

type FreeStorageSizeWeightPicker

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

FreeStorageSizeWeightPicker is used to pick index by storage usage, The more free storage usage, the greater the probability of being picked.

type FreezeSPPool

type FreezeSPPool struct {
	sync.Map
}

func NewFreezeSPPool

func NewFreezeSPPool() *FreezeSPPool

func (*FreezeSPPool) FreezeSPAndGVGs

func (s *FreezeSPPool) FreezeSPAndGVGs(spID uint32, joinedGVGs []*virtual_types.GlobalVirtualGroup)

FreezeSPAndGVGs puts a Secondary SP and its joined Global virtual groups into the Freeze Pool.

func (*FreezeSPPool) GetFreezeGVGsInFamily

func (s *FreezeSPPool) GetFreezeGVGsInFamily(familyID uint32) vgmgr.IDSet

func (*FreezeSPPool) GetFreezeSPIDs

func (s *FreezeSPPool) GetFreezeSPIDs() vgmgr.IDSet

func (*FreezeSPPool) ReleaseAllSP

func (s *FreezeSPPool) ReleaseAllSP()

func (*FreezeSPPool) ReleaseSP

func (s *FreezeSPPool) ReleaseSP()

type HealthChecker

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

func NewHealthChecker

func NewHealthChecker(chainClient consensus.Consensus) *HealthChecker

func (*HealthChecker) Start

func (checker *HealthChecker) Start()

type SPStats

type SPStats struct {
	JoinedGVGs  []*virtual_types.GlobalVirtualGroup
	FreezeUntil int64
}