cdc

package

v0.0.0-...-1b33b2a Latest Latest Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 54 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/tikv/migration

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func RecordGoRuntimeSettings()
type ChangefeedResp
- func (c ChangefeedResp) MarshalJSON() ([]byte, error)
type Server
- func NewServer(pdEndpoints []string) (*Server, error)
- func (s *Server) Close()
- func (s *Server) Run(ctx context.Context) error

Constants ¶

View Source

const (
	// APIOpVarAdminJob is the key of admin job in HTTP API
	APIOpVarAdminJob = "admin-job"
	// APIOpVarChangefeedID is the key of changefeed ID in HTTP API
	APIOpVarChangefeedID = "cf-id"
	// APIOpVarTargetCaptureID is the key of to-capture ID in HTTP API
	APIOpVarTargetCaptureID = "target-cp-id"
	// APIOpVarKeySpanID is the key of keyspan ID in HTTP API
	APIOpVarKeySpanID = "keyspan-id"
	// APIOpForceRemoveChangefeed is used when remove a changefeed
	APIOpForceRemoveChangefeed = "force-remove"
)

Variables ¶

This section is empty.

Functions ¶

func RecordGoRuntimeSettings ¶

func RecordGoRuntimeSettings()

RecordGoRuntimeSettings records GOGC settings.

Types ¶

type ChangefeedResp ¶

type ChangefeedResp struct {
	FeedState    string              `json:"state"`
	TSO          uint64              `json:"tso"`
	Checkpoint   string              `json:"checkpoint"`
	RunningError *model.RunningError `json:"error"`
}

ChangefeedResp holds the most common usage information for a changefeed

func (ChangefeedResp) MarshalJSON ¶

func (c ChangefeedResp) MarshalJSON() ([]byte, error)

MarshalJSON use to marshal ChangefeedResp

type Server ¶

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

Server is the capture server TODO: we need to make Server more unit testable and add more test cases. Especially we need to decouple the HTTPServer out of Server.

func NewServer ¶

func NewServer(pdEndpoints []string) (*Server, error)

NewServer creates a Server instance.

func (*Server) Close ¶

func (s *Server) Close()

Close closes the server.

func (*Server) Run ¶

func (s *Server) Run(ctx context.Context) error

Run runs the server.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
capture
kv
model
owner
processor Package processor implements the processor logic based on ETCD worker(pkg/orchestrator).	Package processor implements the processor logic based on ETCD worker(pkg/orchestrator).
pipeline
puller
frontier
scheduler
util
sink
codec
common
producer
producer/kafka
sorter
encoding
memory Package memory is an in-memory EventSorter implementation.	Package memory is an in-memory EventSorter implementation.
unified

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