cdc

package

v0.0.0-...-d89597d Latest Latest Go to latest Published: Feb 10, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tipocket

Documentation ¶

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

operation.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL