cdc_event

type CDCEvent struct {
	Schema string                   `json:"schema"`
	Table  string                   `json:"table"`
	Action string                   `json:"action"`
	Before []map[string]interface{} `json:"before"`
	After  []map[string]interface{} `json:"after"`
	Meta   CDCEventMeta             `json:"meta"`
	Kafka  KafkaMeta                `json:"kafka"`
	// contains filtered or unexported fields
}

type CDCEventMeta struct {
	Timestamp int64  `json:"timestamp"`
	Pipeline  string `json:"pipeline"`
}

type KafkaMeta struct {
	Topic string `json:"topic"`
	Key   string `json:"key"`
}