cdc

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 15, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CDCConnector 

type CDCConnector struct {
	SinkURI *url.URL
	// contains filtered or unexported fields
}

func NewCDCConnector 

func NewCDCConnector(
	cdcHost string, cdcPort int, tables []string, startTSO uint64, storageUri *url.URL,
	flushInterval time.Duration, fileSize int, binaryEncodingMethod string,
) (*CDCConnector, error)

func (*CDCConnector) CreateChangefeed 

func (c *CDCConnector) CreateChangefeed() error

type ChangefeedConfig 

type ChangefeedConfig struct {
	ReplicaConfig *apiv2.ReplicaConfig `json:"replica_config"`
	SinkURI       string               `json:"sink_uri"`
	StartTs       uint64               `json:"start_ts"`
}

type SinkURIConfig 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.