dmcluster

Documentation

Index

• type ControlInterface
  • func NewDefaultDMClusterControl(dcControl controller.DMClusterControlInterface, ...) ControlInterface
• type Controller
  • func NewController(deps *controller.Dependencies) *Controller
  • func (c *Controller) Name() string
  • func (c *Controller) Run(workers int, stopCh <-chan struct{})
• type DMClusterConditionUpdater
• type FakeDMClusterControlInterface
  • func NewFakeDMClusterControlInterface() *FakeDMClusterControlInterface
  • func (ftcc *FakeDMClusterControlInterface) SetUpdateDCError(err error)
  • func (ftcc *FakeDMClusterControlInterface) UpdateDMCluster(_ *v1alpha1.DMCluster) error

Types

type ControlInterface

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

ControlInterface implements the control logic for updating DMClusters 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 NewDefaultDMClusterControl

func NewDefaultDMClusterControl(
	dcControl controller.DMClusterControlInterface,
	masterMemberManager manager.DMManager,
	workerMemberManager manager.DMManager,
	reclaimPolicyManager manager.DMManager,
	orphanPodsCleaner member.OrphanPodsCleaner,
	pvcCleaner member.PVCCleanerInterface,
	pvcResizer member.PVCResizerInterface,
	discoveryManager member.TidbDiscoveryManager,
	conditionUpdater DMClusterConditionUpdater,
	recorder record.EventRecorder) ControlInterface

NewDefaultDMClusterControl returns a new instance of the default implementation DMClusterControlInterface that implements the documented semantics for DMClusters.

type Controller

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

Controller controls dmclusters.

func NewController

func NewController(deps *controller.Dependencies) *Controller

NewController creates a dmcluster controller.

func (*Controller) Name

func (c *Controller) Name() string

Name returns the dmcluster controller name

func (*Controller) Run

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

Run runs the dmcluster controller.

type DMClusterConditionUpdater

type DMClusterConditionUpdater interface {
	Update(*v1alpha1.DMCluster) error
}

DMClusterConditionUpdater interface that translates cluster state into into dm cluster status conditions.

type FakeDMClusterControlInterface

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

func NewFakeDMClusterControlInterface

func NewFakeDMClusterControlInterface() *FakeDMClusterControlInterface

func (*FakeDMClusterControlInterface) SetUpdateDCError

func (ftcc *FakeDMClusterControlInterface) SetUpdateDCError(err error)

func (*FakeDMClusterControlInterface) UpdateDMCluster

func (ftcc *FakeDMClusterControlInterface) UpdateDMCluster(_ *v1alpha1.DMCluster) error