tidbcluster

Documentation

Index

• type ControlInterface
  • func NewDefaultTidbClusterControl(tcControl controller.TidbClusterControlInterface, ...) ControlInterface
• type Controller
  • func NewController(deps *controller.Dependencies) *Controller
  • func (c *Controller) Run(workers int, stopCh <-chan struct{})
• type FakeTidbClusterControlInterface
  • func NewFakeTidbClusterControlInterface() *FakeTidbClusterControlInterface
  • func (c *FakeTidbClusterControlInterface) SetUpdateTCError(err error)
  • func (c *FakeTidbClusterControlInterface) UpdateTidbCluster(_ *v1alpha1.TidbCluster) error
• type PodController
  • func NewPodController(deps *controller.Dependencies) *PodController
  • func (c *PodController) Run(workers int, stopCh <-chan struct{})
• type TidbClusterConditionUpdater

Types

type ControlInterface

type ControlInterface interface {
	// UpdateTidbCluster implements the control logic for StatefulSet creation, update, and deletion
	UpdateTidbCluster(*v1alpha1.TidbCluster) error
}

ControlInterface implements the control logic for updating TidbClusters and their children StatefulSets. It is implemented as an interface to allow for extensions that provide different semantics. Currently, there is only one implementation.

func NewDefaultTidbClusterControl

func NewDefaultTidbClusterControl(
	tcControl controller.TidbClusterControlInterface,
	pdMemberManager manager.Manager,
	tikvMemberManager manager.Manager,
	tidbMemberManager manager.Manager,
	tiproxyMemberManager manager.Manager,
	reclaimPolicyManager manager.Manager,
	metaManager manager.Manager,
	orphanPodsCleaner member.OrphanPodsCleaner,
	pvcCleaner member.PVCCleanerInterface,

	pvcModifier volumes.PVCModifierInterface,
	pumpMemberManager manager.Manager,
	tiflashMemberManager manager.Manager,
	ticdcMemberManager manager.Manager,
	discoveryManager member.TidbDiscoveryManager,
	tidbClusterStatusManager manager.Manager,
	conditionUpdater TidbClusterConditionUpdater,
	recorder record.EventRecorder) ControlInterface

NewDefaultTidbClusterControl returns a new instance of the default implementation TidbClusterControlInterface that implements the documented semantics for TidbClusters.

type Controller

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

Controller controls tidbclusters.

func NewController

func NewController(deps *controller.Dependencies) *Controller

NewController creates a tidbcluster controller.

func (*Controller) Run

func (c *Controller) Run(workers int, stopCh <-chan struct{})

Run runs the tidbcluster controller.

type FakeTidbClusterControlInterface

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

func NewFakeTidbClusterControlInterface

func NewFakeTidbClusterControlInterface() *FakeTidbClusterControlInterface

func (*FakeTidbClusterControlInterface) SetUpdateTCError

func (c *FakeTidbClusterControlInterface) SetUpdateTCError(err error)

func (*FakeTidbClusterControlInterface) UpdateTidbCluster

func (c *FakeTidbClusterControlInterface) UpdateTidbCluster(_ *v1alpha1.TidbCluster) error

type PodController

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

PodController control pods of tidb cluster. see docs/design-proposals/2021-11-24-graceful-reschedule-tikv-pod.md

func NewPodController

func NewPodController(deps *controller.Dependencies) *PodController

NewPodController create a PodController.

func (*PodController) Run

func (c *PodController) Run(workers int, stopCh <-chan struct{})

Run the controller.

type TidbClusterConditionUpdater

type TidbClusterConditionUpdater interface {
	Update(*v1alpha1.TidbCluster) error
}

TidbClusterConditionUpdater interface that translates cluster state into into tidb cluster status conditions.