message.go 456 B

1234567891011121314151617181920212223
  1. package model
  2. import (
  3. "encoding/json"
  4. )
  5. // BMsg databus binlog message.
  6. type BMsg struct {
  7. Action string `json:"action"`
  8. Table string `json:"table"`
  9. New json.RawMessage `json:"new"`
  10. Old json.RawMessage `json:"old"`
  11. MTS int64
  12. }
  13. // PMsg Push msg
  14. type PMsg struct {
  15. Action string `json:"action"`
  16. Table string `json:"table"`
  17. Data *AsoAccount `json:"data"`
  18. Flag int `json:"flag"`
  19. MTS int64
  20. }