cdc

Documentation

Index

• Constants
• type CDC
• type CDCJob
• type CDCSpec
• type CdcOps
  • func New(cli client.Client) *CdcOps
  • func (c *CdcOps) ApplyCDC(spec *CDCSpec) (*CDC, error)
  • func (c *CdcOps) DeleteCDC(cc *CDC) error
  • func (c *CdcOps) StartJob(job *CDCJob, spec *CDCSpec) error
  • func (c *CdcOps) StopJob(job *CDCJob) error

Constants

const (
	// EtcdKeyBase is the common prefix of the keys in CDC
	EtcdKeyBase = "/tidb/cdc"
)

Types

type CDC

type CDC struct {
	Sts    *appsv1.StatefulSet
	Source *v1alpha1.TidbCluster
}

type CDCJob

type CDCJob struct {
	*CDC
	SinkURI  string
	StartTs  uint64
	TargetTs uint64
}

type CDCSpec

type CDCSpec struct {
	Namespace string
	Name      string
	Source    *v1alpha1.TidbCluster
	Replicas  int32
	Image     string
	Resources v1alpha1.Resources
}

type CdcOps

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

CdcOps knows how to operate TiDB CDC on k8s

func New

func New(cli client.Client) *CdcOps

func (*CdcOps) ApplyCDC

func (c *CdcOps) ApplyCDC(spec *CDCSpec) (*CDC, error)

func (*CdcOps) DeleteCDC

func (c *CdcOps) DeleteCDC(cc *CDC) error

func (*CdcOps) StartJob

func (c *CdcOps) StartJob(job *CDCJob, spec *CDCSpec) error

func (*CdcOps) StopJob

func (c *CdcOps) StopJob(job *CDCJob) error