cdc

Documentation

Index

• type CDCConnector
  • func NewCDCConnector(cdcHost string, cdcPort int, tables []string, startTSO uint64, ...) (*CDCConnector, error)
  • func (c *CDCConnector) CreateChangefeed() error
• type ChangefeedConfig
• type SinkURIConfig

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
}