gc

Documentation

Index

• type SafePointManager
  • func NewSafePointManager(store endpoint.GCSafePointStorage, cfg config.PDServerConfig) *SafePointManager
  • func (manager *SafePointManager) LoadGCSafePoint() (uint64, error)
  • func (manager *SafePointManager) UpdateGCSafePoint(newSafePoint uint64) (oldSafePoint uint64, err error)
  • func (manager *SafePointManager) UpdateServiceGCSafePoint(serviceID string, newSafePoint uint64, ttl int64, now time.Time) (minServiceSafePoint *endpoint.ServiceSafePoint, updated bool, err error)
• type SafePointV2Manager
  • func NewSafePointManagerV2(ctx context.Context, keyspaceStore endpoint.KeyspaceStorage, ...) *SafePointV2Manager
  • func (manager *SafePointV2Manager) LoadGCSafePoint(keyspaceID uint32) (*endpoint.GCSafePointV2, error)
  • func (manager *SafePointV2Manager) RemoveServiceSafePoint(keyspaceID uint32, serviceID string, now time.Time) (*endpoint.ServiceSafePointV2, error)
  • func (manager *SafePointV2Manager) UpdateGCSafePoint(gcSafePoint *endpoint.GCSafePointV2) (oldGCSafePoint *endpoint.GCSafePointV2, err error)
  • func (manager *SafePointV2Manager) UpdateServiceSafePoint(serviceSafePoint *endpoint.ServiceSafePointV2, now time.Time) (*endpoint.ServiceSafePointV2, error)

Types

type SafePointManager

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

SafePointManager is the manager for safePoint of GC and services.

func NewSafePointManager

func NewSafePointManager(store endpoint.GCSafePointStorage, cfg config.PDServerConfig) *SafePointManager

NewSafePointManager creates a SafePointManager of GC and services.

func (*SafePointManager) LoadGCSafePoint

func (manager *SafePointManager) LoadGCSafePoint() (uint64, error)

LoadGCSafePoint loads current GC safe point from storage.

func (*SafePointManager) UpdateGCSafePoint

func (manager *SafePointManager) UpdateGCSafePoint(newSafePoint uint64) (oldSafePoint uint64, err error)

UpdateGCSafePoint updates the safepoint if it is greater than the previous one it returns the old safepoint in the storage.

func (*SafePointManager) UpdateServiceGCSafePoint

func (manager *SafePointManager) UpdateServiceGCSafePoint(serviceID string, newSafePoint uint64, ttl int64, now time.Time) (minServiceSafePoint *endpoint.ServiceSafePoint, updated bool, err error)

UpdateServiceGCSafePoint update the safepoint for a specific service.

type SafePointV2Manager

type SafePointV2Manager struct {
	*syncutil.LockGroup
	// contains filtered or unexported fields
}

SafePointV2Manager is the manager for GCSafePointV2 and ServiceSafePointV2.

func NewSafePointManagerV2

func NewSafePointManagerV2(
	ctx context.Context,
	keyspaceStore endpoint.KeyspaceStorage,
	v2Storage endpoint.SafePointV2Storage,
	v1Storage endpoint.GCSafePointStorage,
) *SafePointV2Manager

NewSafePointManagerV2 returns a new SafePointV2Manager.

func (*SafePointV2Manager) LoadGCSafePoint

func (manager *SafePointV2Manager) LoadGCSafePoint(keyspaceID uint32) (*endpoint.GCSafePointV2, error)

LoadGCSafePoint returns GCSafePointV2 of keyspaceID.

func (*SafePointV2Manager) RemoveServiceSafePoint

func (manager *SafePointV2Manager) RemoveServiceSafePoint(keyspaceID uint32, serviceID string, now time.Time) (*endpoint.ServiceSafePointV2, error)

RemoveServiceSafePoint remove keyspace service safe point with the given keyspaceID and serviceID.

func (*SafePointV2Manager) UpdateGCSafePoint

func (manager *SafePointV2Manager) UpdateGCSafePoint(gcSafePoint *endpoint.GCSafePointV2) (oldGCSafePoint *endpoint.GCSafePointV2, err error)

UpdateGCSafePoint is used to update gc safe point for given keyspace.

func (*SafePointV2Manager) UpdateServiceSafePoint

func (manager *SafePointV2Manager) UpdateServiceSafePoint(serviceSafePoint *endpoint.ServiceSafePointV2, now time.Time) (*endpoint.ServiceSafePointV2, error)

UpdateServiceSafePoint update keyspace service safe point with the given serviceSafePoint.