event

type Event struct {
	ID         string                 `json:"id"`
	Schema     string                 `json:"schema"`
	Table      string                 `json:"table"`
	Action     string                 `json:"action"`
	Data       map[string]interface{} `json:"data"`
	CommitTime time.Time              `json:"commit_time"`
}

type Publisher interface {
	Publish(subject string, evt *Event) error
	Close() error
}