member

Documentation

Index

• Constants
• func IsTiDBAllComponentsHealthy(tc *pcv1alpha1.TidbCluster) bool
• func IsTiDBAvailable(tc *pcv1alpha1.TidbCluster) bool
• func NewProxyMemberManager(dependencies *controller.Dependencies) manager.Manager
• func NewSldbFinalizerMemberManager(dependencies *controller.Dependencies) manager.Manager
• func NewSldbFreezeMemberManager(dependencies *controller.Dependencies) manager.Manager
• func NewSldbPhaseMemberManager(dependencies *controller.Dependencies) manager.Manager
• func NewTCMemberManager(dependencies *controller.Dependencies) manager.Manager
• type FakeTcMemberManager
  • func NewFakeTcMemberManager() *FakeTcMemberManager
  • func (m *FakeTcMemberManager) SetSyncError(err error)
  • func (m *FakeTcMemberManager) Sync(_ *v1alpha1.ServerlessDB) error
• type StatusUpdater

Constants

const ComponentProxy = "proxy"

const (
	RoleInstanceLabelKey string = "bcrds.cmss.com/role"
)

Functions

func IsTiDBAllComponentsHealthy

func IsTiDBAllComponentsHealthy(tc *pcv1alpha1.TidbCluster) bool

This judgment method is more strict and is used to judge whether the creation and restart are completed

func IsTiDBAvailable

func IsTiDBAvailable(tc *pcv1alpha1.TidbCluster) bool

The minimum number of replicas of each component of tidb that meet the health requirements

func NewProxyMemberManager

func NewProxyMemberManager(dependencies *controller.Dependencies) manager.Manager

NewProxyMemberManager returns a *proxyMemberManager

func NewSldbFinalizerMemberManager

func NewSldbFinalizerMemberManager(dependencies *controller.Dependencies) manager.Manager

NewTCMemberManager returns a *tcMemberManager

func NewSldbFreezeMemberManager

func NewSldbFreezeMemberManager(dependencies *controller.Dependencies) manager.Manager

func NewSldbPhaseMemberManager

func NewSldbPhaseMemberManager(dependencies *controller.Dependencies) manager.Manager

NewTCMemberManager returns a *tcMemberManager

func NewTCMemberManager

func NewTCMemberManager(dependencies *controller.Dependencies) manager.Manager

NewTCMemberManager returns a *tcMemberManager

Types

type FakeTcMemberManager

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

func NewFakeTcMemberManager

func NewFakeTcMemberManager() *FakeTcMemberManager

func (*FakeTcMemberManager) SetSyncError

func (m *FakeTcMemberManager) SetSyncError(err error)

func (*FakeTcMemberManager) Sync

func (m *FakeTcMemberManager) Sync(_ *v1alpha1.ServerlessDB) error

type StatusUpdater

type StatusUpdater interface {
	// Upgrade upgrade the cluster
	StatusUpdate(*v1alpha1.ServerlessDB) (*v1alpha1.ServerlessDBStatus, error)
}

StatusUpdater implements the logic for StatusUpdater the serverlessdb.