autoscaler

Documentation

Index

• func GetStorageSize(sldb *sldbv1.ServerlessDB, instances []string) (uint64, error)
• func TikvPvcExpand(tc *v1alpha1.TidbCluster, oldTc *v1alpha1.TidbCluster, ...) (bool, error)
• type AutoScalerAPI
  • func NewAutoScalerAPI() AutoScalerAPI
• type AutoScalerManager
  • func NewAutoScalerManager() *AutoScalerManager
  • func (am *AutoScalerManager) CheckLastAutoScalerCompleted(tcArr *utils.TClus, sldb *sldbv1.ServerlessDB, sldbType v1alpha1.MemberType) error
  • func (am *AutoScalerManager) GetStorageSize(sldb *sldbv1.ServerlessDB, instances []string) (uint64, error)
  • func (am *AutoScalerManager) SCalerOutInAPHandler(sldb *sldbv1.ServerlessDB) (bool, error)
  • func (am *AutoScalerManager) SCalerOutInHandler(sldb *sldbv1.ServerlessDB) (bool, error)
  • func (am *AutoScalerManager) ScalerBaseOnMidWareAP(sldb *sldbv1.ServerlessDB) (bool, error)
  • func (am *AutoScalerManager) ScalerBaseOnMidWareTP(sldb *sldbv1.ServerlessDB) (bool, error)
  • func (am *AutoScalerManager) SyncAutoScaling(tcArr *utils.TClus, sldb *sldbv1.ServerlessDB, sldbType v1alpha1.MemberType) error
  • func (am *AutoScalerManager) SyncTiDB(tcArr *utils.TClus, sldb *sldbv1.ServerlessDB) error
  • func (am *AutoScalerManager) SyncTiKV(tc *v1alpha1.TidbCluster, sldb *sldbv1.ServerlessDB) error
  • func (am *AutoScalerManager) SyncTidbClusterReplicas(sldb *sldbv1.ServerlessDB, tcArr *utils.TClus, sldbType v1alpha1.MemberType) error
  • func (am *AutoScalerManager) TiKVSCalerHandler(sldb *sldbv1.ServerlessDB) (bool, error)
  • func (am *AutoScalerManager) UpdateSldbClusterAutoScaler(sldb *sldbv1.ServerlessDB) error

Functions

func GetStorageSize

func GetStorageSize(sldb *sldbv1.ServerlessDB, instances []string) (uint64, error)

func TikvPvcExpand

func TikvPvcExpand(tc *v1alpha1.TidbCluster, oldTc *v1alpha1.TidbCluster, sldbType v1alpha1.MemberType) (bool, error)

Types

type AutoScalerAPI

type AutoScalerAPI interface {
	SCalerOutInHandler(sldb *sldbv1.ServerlessDB) (bool, error)
	SCalerOutInAPHandler(sldb *sldbv1.ServerlessDB) (bool, error)
	TiKVSCalerHandler(sldb *sldbv1.ServerlessDB) (bool, error)
	ScalerBaseOnMidWareTP(sldb *sldbv1.ServerlessDB) (bool, error)
	ScalerBaseOnMidWareAP(sldb *sldbv1.ServerlessDB) (bool, error)
}

func NewAutoScalerAPI

func NewAutoScalerAPI() AutoScalerAPI

type AutoScalerManager

type AutoScalerManager struct {
	Sldbclient *slcluster.SlabInterface
}

func NewAutoScalerManager

func NewAutoScalerManager() *AutoScalerManager

func (*AutoScalerManager) CheckLastAutoScalerCompleted

func (am *AutoScalerManager) CheckLastAutoScalerCompleted(tcArr *utils.TClus, sldb *sldbv1.ServerlessDB, sldbType v1alpha1.MemberType) error

func (*AutoScalerManager) GetStorageSize

func (am *AutoScalerManager) GetStorageSize(sldb *sldbv1.ServerlessDB, instances []string) (uint64, error)

func (*AutoScalerManager) SCalerOutInAPHandler

func (am *AutoScalerManager) SCalerOutInAPHandler(sldb *sldbv1.ServerlessDB) (bool, error)

func (*AutoScalerManager) SCalerOutInHandler

func (am *AutoScalerManager) SCalerOutInHandler(sldb *sldbv1.ServerlessDB) (bool, error)

func (*AutoScalerManager) ScalerBaseOnMidWareAP

func (am *AutoScalerManager) ScalerBaseOnMidWareAP(sldb *sldbv1.ServerlessDB) (bool, error)

func (*AutoScalerManager) ScalerBaseOnMidWareTP

func (am *AutoScalerManager) ScalerBaseOnMidWareTP(sldb *sldbv1.ServerlessDB) (bool, error)

func (*AutoScalerManager) SyncAutoScaling

func (am *AutoScalerManager) SyncAutoScaling(tcArr *utils.TClus, sldb *sldbv1.ServerlessDB, sldbType v1alpha1.MemberType) error

func (*AutoScalerManager) SyncTiDB

func (am *AutoScalerManager) SyncTiDB(tcArr *utils.TClus, sldb *sldbv1.ServerlessDB) error

func (*AutoScalerManager) SyncTiKV

func (am *AutoScalerManager) SyncTiKV(tc *v1alpha1.TidbCluster, sldb *sldbv1.ServerlessDB) error

func (*AutoScalerManager) SyncTidbClusterReplicas

func (am *AutoScalerManager) SyncTidbClusterReplicas(sldb *sldbv1.ServerlessDB, tcArr *utils.TClus, sldbType v1alpha1.MemberType) error

func (*AutoScalerManager) TiKVSCalerHandler

func (am *AutoScalerManager) TiKVSCalerHandler(sldb *sldbv1.ServerlessDB) (bool, error)

func (*AutoScalerManager) UpdateSldbClusterAutoScaler

func (am *AutoScalerManager) UpdateSldbClusterAutoScaler(sldb *sldbv1.ServerlessDB) error