pipeline

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

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

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

type PipelineState struct {
	Gtid      string `json:"gtid"`
	Name      string `json:"name"`
	Timestamp int64  `json:"timestamp"`
}

type StateTracker struct {
	State  *PipelineState
	Config *config.StateTracking
	// contains filtered or unexported fields
}