egg_mq_consume/consume/md/md_egg_canal_user_consume.go

package md

type CanalUser struct {
	Id        string `json:"id"`
	Level     string `json:"level"`
	ParentUid string `json:"parent_uid"`
}

type CanalUserMessage[T any] struct {
	Data     []T      `json:"data"`
	Database string   `json:"database"`
	ES       int64    `json:"es"`
	ID       int64    `json:"id"`
	IsDdl    bool     `json:"isDdl"`
	Old      []T      `json:"old"`
	PkNames  []string `json:"pkNames"`
	Table    string   `json:"table"`
	TS       int64    `json:"ts"`
	Type     string   `json:"type"`
}